Function test_clone_thread

tests/system_test/clone_test.cpp:172–262

}

void test_clone_thread(void* /*arg*/) {
  klog::Info("=== Clone Thread Test ===");

  bool passed = true;
  g_thread_done = 0;
  g_threads_may_exit = false;
  g_leader_pid = 0;
  g_thread1_pid = 0;
  g_thread1_tgid = 0;
  g_thread2_pid = 0;
  g_thread2_tgid = 0;

  auto leader_ptr = kstd::make_unique<TaskControlBlock>("CloneThreadLeader", 10,
                                                        leader_work, nullptr);
  TaskManagerSingleton::instance().AddTask(std::move(leader_ptr));

  for (int i = 0; i < 100 && g_leader_pid.load() == 0; ++i) {
    (void)sys_sleep(10);
  }

  Pid leader_pid = g_leader_pid.load();
  if (leader_pid == 0) {
    klog::Err("Leader did not start");
    g_tests_failed++;
    g_tests_completed++;
    sys_exit(1);
  }

  auto* leader = TaskManagerSingleton::instance().FindTask(leader_pid);
  if (!leader) {
    klog::Err("Leader not found in task table");
    g_tests_failed++;
    g_tests_completed++;
    sys_exit(1);
  }

  uint64_t flags = clone_flag::kThread | clone_flag::kVm | clone_flag::kFiles |
                   clone_flag::kSighand;

  auto thread1 = kstd::make_unique<TaskControlBlock>(
      "CloneThread1", 10, child_thread_work, reinterpret_cast<void*>(1));
  thread1->aux->parent_pid = leader_pid;
  thread1->aux->tgid = leader_pid;
  thread1->aux->clone_flags = static_cast<CloneFlags>(flags);
  thread1->JoinThreadGroup(leader);
  TaskManagerSingleton::instance().AddTask(std::move(thread1));

  auto thread2 = kstd::make_unique<TaskControlBlock>(
      "CloneThread2", 10, child_thread_work, reinterpret_cast<void*>(2));
  thread2->aux->parent_pid = leader_pid;
  thread2->aux->tgid = leader_pid;
  thread2->aux->clone_flags = static_cast<CloneFlags>(flags);
  thread2->JoinThreadGroup(leader);
  TaskManagerSingleton::instance().AddTask(std::move(thread2));

  for (int i = 0; i < 100 && g_thread_done.load() < 2; ++i) {
    (void)sys_sleep(10);
  }