DXR is a code search and navigation tool aimed at making sense of large projects. It supports full-text and regex searches as well as structural queries.

Mercurial (b6d82b1a6b02)

VCS Links

Line Code
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105
/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*-
 * vim: set ts=8 sts=2 et sw=2 tw=80:
 */
/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

#include "mozilla/Atomics.h"
#include "mozilla/IntegerRange.h"
#include "mozilla/Move.h"
#include "mozilla/Vector.h"

#include "js/AllocPolicy.h"
#include "jsapi-tests/tests.h"
#include "threading/Thread.h"

BEGIN_TEST(testThreadingThreadJoin) {
  bool flag = false;
  js::Thread thread;
  CHECK(thread.init([](bool* flagp) { *flagp = true; }, &flag));
  CHECK(thread.joinable());
  thread.join();
  CHECK(flag);
  CHECK(!thread.joinable());
  return true;
}
END_TEST(testThreadingThreadJoin)

BEGIN_TEST(testThreadingThreadDetach) {
  // We are going to detach this thread. Unlike join, we can't have it pointing
  // at the stack because it might do the write after we have returned and
  // pushed a new frame.
  bool* flag = js_new<bool>(false);
  js::Thread thread;
  CHECK(thread.init(
      [](bool* flag) {
        *flag = true;
        js_delete(flag);
      },
      std::move(flag)));
  CHECK(thread.joinable());
  thread.detach();
  CHECK(!thread.joinable());

  return true;
}
END_TEST(testThreadingThreadDetach)

BEGIN_TEST(testThreadingThreadSetName) {
  js::Thread thread;
  CHECK(thread.init([]() { js::ThisThread::SetName("JSAPI Test Thread"); }));
  thread.detach();
  return true;
}
END_TEST(testThreadingThreadSetName)

BEGIN_TEST(testThreadingThreadId) {
  CHECK(js::Thread::Id() == js::Thread::Id());
  js::Thread::Id fromOther;
  js::Thread thread;
  CHECK(thread.init([](js::Thread::Id* idp) { *idp = js::ThisThread::GetId(); },
                    &fromOther));
  js::Thread::Id fromMain = thread.get_id();
  thread.join();
  CHECK(fromOther == fromMain);
  return true;
}
END_TEST(testThreadingThreadId)

BEGIN_TEST(testThreadingThreadVectorMoveConstruct) {
  const static size_t N = 10;
  mozilla::Atomic<int> count(0);
  mozilla::Vector<js::Thread, 0, js::SystemAllocPolicy> v;
  for (auto i : mozilla::IntegerRange(N)) {
    CHECK(v.emplaceBack());
    CHECK(v.back().init([](mozilla::Atomic<int>* countp) { (*countp)++; },
                        &count));
    CHECK(v.length() == i + 1);
  }
  for (auto& th : v) {
    th.join();
  }
  CHECK(count == 10);
  return true;
}
END_TEST(testThreadingThreadVectorMoveConstruct)

// This test is checking that args are using "decay" copy, per spec. If we do
// not use decay copy properly, the rvalue reference |bool&& b| in the
// constructor will automatically become an lvalue reference |bool& b| in the
// trampoline, causing us to read through the reference when passing |bool bb|
// from the trampoline. If the parent runs before the child, the bool may have
// already become false, causing the trampoline to read the changed value, thus
// causing the child's assertion to fail.
BEGIN_TEST(testThreadingThreadArgCopy) {
  for (size_t i = 0; i < 10000; ++i) {
    bool b = true;
    js::Thread thread;
    CHECK(thread.init([](bool bb) { MOZ_RELEASE_ASSERT(bb); }, b));
    b = false;
    thread.join();
  }
  return true;
}
END_TEST(testThreadingThreadArgCopy)