// Copyright 2019 Google LLC
//
// 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
//
//     https://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.

#include "dap/dap.h"

#include "gmock/gmock.h"
#include "gtest/gtest.h"

#include <condition_variable>
#include <mutex>
#include <thread>
#include <vector>

int main(int argc, char** argv) {
  ::testing::InitGoogleTest(&argc, argv);
  return RUN_ALL_TESTS();
}

TEST(DAP, PairedInitializeTerminate) {
  dap::initialize();
  dap::terminate();
}

TEST(DAP, NestedInitializeTerminate) {
  dap::initialize();
  dap::initialize();
  dap::initialize();
  dap::terminate();
  dap::terminate();
  dap::terminate();
}

TEST(DAP, MultiThreadedInitializeTerminate) {
  const size_t numThreads = 64;

  std::mutex mutex;
  std::condition_variable cv;
  size_t numInits = 0;

  std::vector<std::thread> threads;
  threads.reserve(numThreads);
  for (size_t i = 0; i < numThreads; i++) {
    threads.emplace_back([&] {
      dap::initialize();
      {
        std::unique_lock<std::mutex> lock(mutex);
        numInits++;
        if (numInits == numThreads) {
          cv.notify_all();
        } else {
          cv.wait(lock, [&] { return numInits == numThreads; });
        }
      }
      dap::terminate();
    });
  }

  for (auto& thread : threads) {
    thread.join();
  }
}