/*

 * Copyright (c) 2007, 2018, Oracle and/or its affiliates. All rights reserved.

 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.

 *

 * This code is free software; you can redistribute it and/or modify it

 * under the terms of the GNU General Public License version 2 only, as

 * published by the Free Software Foundation.

 *

 * This code is distributed in the hope that it will be useful, but WITHOUT

 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or

 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License

 * version 2 for more details (a copy is included in the LICENSE file that

 * accompanied this code).

 *

 * You should have received a copy of the GNU General Public License version

 * 2 along with this work; if not, write to the Free Software Foundation,

 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.

 *

 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA

 * or visit www.oracle.com if you need additional information or have any

 * questions.

 */

/*

 * @test

 *

 * @summary converted from VM Testbase nsk/jvmti/scenarios/hotswap/HS103/hs103t002.

 * VM Testbase keywords: [quick, jpda, jvmti, noras, redefine, feature_hotswap]

 * VM Testbase readme:

 *  Periodically hotswap class(es) with a changed version in

 *  asynchronous manner from specified number of JVMTI agents. The VM

 *  works in default mode.

 *

 * @library /vmTestbase

 *          /test/lib

 * @run driver jdk.test.lib.FileInstaller . .

 * @build nsk.jvmti.scenarios.hotswap.HS103.hs103t002.hs103t002

 *

 * @comment compile newclassXX to bin/newclassXX

 * @run driver nsk.share.ExtraClassesBuilder

 *      newclass00

 *

 * @build ExecDriver

 * @run main/othervm/native PropertyResolvingWrapper ExecDriver --java

 *      "-agentlib:hs103t002=pathToNewByteCode=./bin -waittime=5 package=nsk samples=100 mode=compiled"

 *      nsk.jvmti.scenarios.hotswap.HS103.hs103t002.hs103t002

 */

package nsk.jvmti.scenarios.hotswap.HS103.hs103t002;

/*

   Periodically hotswap class(es) with a changed version in

   asynchronous manner from specified number of JVMTI agents. The VM

   works in default mode.

*/

import java.util.concurrent.atomic.AtomicInteger;

import nsk.share.jvmti.RedefineAgent;

public class hs103t002 extends RedefineAgent {

    private static final int size = 10;

    private MyThread[] threads;

    private static volatile boolean isRedefineFinished = false;

    private static volatile boolean isRedefineFailed = false;

    public hs103t002(String[] arg) {

        super(arg);

        threads = new MyThread[size];

        for(int i = 0; i < size; i++) {

            threads[i] = new MyThread(" Name.."+i);

        }

    }

    public static void main(String[] arg) {

        arg = nsk.share.jvmti.JVMTITest.commonInit(arg);

        hs103t002 hsCase = new hs103t002(arg);

        System.exit(hsCase.runAgent());

    }

    public static void setRedefinitionDone(){

        System.out.println("redefines finished");

        isRedefineFinished = true;

    }

    public static void setRedefinitionFailed(){

        System.out.println("redefines failed");

        isRedefineFailed = true;

    }

    public boolean  agentMethod() {

        try {

            boolean passed = false;

            startAgentThread();

            waitForRedefine();

            doMyTasks();

            if ((getResult() == 0) &&

                (redefineAttempted() && isRedefined() ) && !isRedefineFailed ) {

                System.out.println("all redefines ok");

                passed = true;

            }

            else {

                System.out.println("some of redefines failed");

            }

            return passed;

        } catch(Exception ex) {

            ex.printStackTrace();

            return false;

        }

    }

    public void doMyTasks() throws InterruptedException {

        System.out.println("running tasks");

        for(MyThread thread : threads)  {

            thread.start();

        }

        for(MyThread thread : threads)  {

            thread.join();

        }

        System.out.println("tasks done");

    }

    private void waitForRedefine() {

        while(!isRedefineFinished) {

            try {

                Thread.sleep(10);

            } catch (InterruptedException e) {

                System.out.println("interrupted while waiting for the redefines");

            }

        }

    }

    public int getResult() {

        while(MyThread.ai.get() != MyThread.size) {

            try {

                Thread.sleep(10);

            } catch (InterruptedException e) {

                System.out.println("interrupted while waiting for the threads");

            }

        }

        int result = 0;

        for(MyThread thread : threads) {

            int state = thread.getThreadState();

            if (state != MyThread.size * 10) {

                System.out.println("Error: thread.getThreadState() returned " + state + ", expected " +  MyThread.size * 10);

                result = 1;

                break;

            }

        }

        return result;

    }

    public native boolean startAgentThread();

}