/*
 * Copyright (C) 2017 The Android Open Source Project
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package art;

import java.util.Arrays;
import java.lang.reflect.Executable;
import java.lang.reflect.Method;
import java.util.concurrent.Semaphore;

public class Test1941 {
  public static final boolean PRINT_CNT = false;
  public static long CNT = 0;
  public static final long MAX_ITERS = 100_000;

  // Method with multiple paths we can break on.
  public static long fib(long f) {
    if (f < 0) {
      throw new IllegalArgumentException("Bad argument f < 0: f = " + f);
    } else if (f == 0) {
      return 0;
    } else if (f == 1) {
      return 1;
    } else {
      return fib(f - 1) + fib(f - 2);
    }
  }

  public static void notifySingleStep(Thread thr, Executable e, long loc) {
    // Don't bother actually doing anything.
  }

  public static void LoopAllocFreeEnv(Semaphore sem, Semaphore delay) {
    sem.release();
    try {
      delay.acquire();
    } catch (Exception e) {
      throw new Error("exception occurred!", e);
    }
    while (!Thread.interrupted() && CNT < MAX_ITERS) {
      CNT++;
      long env = AllocEnv();
      FreeEnv(env);
      Thread.yield();
    }
  }

  public static native long AllocEnv();
  public static native void FreeEnv(long env);

  public static native void setTracingOn(Thread thr, boolean enable);

  public static void run() throws Exception {
    final Semaphore sem = new Semaphore(0);
    final Semaphore delay = new Semaphore(0);
    Thread thr = new Thread(() -> { LoopAllocFreeEnv(sem, delay); }, "LoopNative");
    thr.start();
    // Make sure the other thread is actually started.
    sem.acquire();
    Trace.enableSingleStepTracing(Test1941.class,
        Test1941.class.getDeclaredMethod(
            "notifySingleStep", Thread.class, Executable.class, Long.TYPE),
        thr);
    setTracingOn(Thread.currentThread(), true);
    // Don't let the other thread start actually running until we've started
    // tracing this thread too in order to ensure that the (formerly) racy
    // behavior can happen.
    delay.release();

    System.out.println("fib(20) is " + fib(20));

    thr.interrupt();
    thr.join();
    setTracingOn(Thread.currentThread(), false);
    Trace.disableTracing(null);
    if (PRINT_CNT) {
      System.out.println("Number of envs created/destroyed: " + CNT);
    }
  }
}