| /third_party/node/deps/undici/src/lib/ |
| H A D | client.js | 40 kRunning,
331 get [kRunning] () {
466 } else if (client[kRunning] > 0) {
476 assert(client[kRunning] === 0)
884 assert(client[kRunning] === 1)
890 assert(client[kRunning] === 1)
1016 assert.strictEqual(client[kRunning], 0)
1023 } else if (socket[kReset] && client[kRunning] === 0) {
1046 if (!socket[kWriting] || socket.writableNeedDrain || client[kRunning] > 1) {
1055 assert(client[kRunning]
[all...] |
| /third_party/node/deps/v8/src/tasks/ |
| H A D | cancelable-task.h | 115 // |kRunning|: The task is currently running and cannot be canceled anymore.
116 enum Status { kWaiting, kCanceled, kRunning }; enumerator
119 return CompareExchangeStatus(kWaiting, kRunning, previous); in TryRun()
|
| H A D | cancelable-task.cc | 18 if (TryRun(&previous) || previous == kRunning) { in ~Cancelable()
|
| /third_party/node/deps/v8/src/compiler-dispatcher/ |
| H A D | lazy-compile-dispatcher.h | 124 kRunning, member in v8::internal::LazyCompileDispatcher::Job::State
147 return state == State::kRunning || state == State::kAbortRequested; in is_running_on_background()
|
| H A D | lazy-compile-dispatcher.cc | 420 job->state = Job::State::kRunning; in DoBackgroundWork()
436 if (job->state == Job::State::kRunning) { in DoBackgroundWork()
567 case Job::State::kRunning: in VerifyBackgroundTaskCount()
|
| /third_party/node/deps/undici/src/lib/core/ |
| H A D | symbols.js | 24 kRunning: Symbol('running'),
|
| /third_party/node/deps/v8/src/numbers/ |
| H A D | conversions.cc | 284 enum class State { kRunning, kError, kJunk, kEmpty, kZero, kDone };
370 State state_ = State::kRunning;
379 if (state_ != State::kRunning) return; in ParseInt()
384 if (state_ != State::kRunning) return; in ParseInt()
503 case State::kRunning: in GetResult()
968 case State::kRunning: in GetResult()
|
| /third_party/node/src/ |
| H A D | inspector_socket_server.cc | 314 if (was_attached && state_ == ServerState::kRunning in SessionTerminated()
441 state_ = ServerState::kRunning; in Start()
454 CHECK_EQ(state_, ServerState::kRunning); in Stop()
|
| H A D | inspector_socket_server.h | 92 enum class ServerState {kNew, kRunning, kStopped}; member in node::inspector::InspectorSocketServer::ServerState
|
| /third_party/node/deps/undici/ |
| H A D | undici.js | 35 kRunning: Symbol("running"),
6941 var { kFree, kConnected, kPending, kQueued, kRunning, kSize } = require_symbols();
6963 return this[kPool][kRunning];
6979 var { kConnected, kSize, kRunning, kPending, kQueued, kBusy, kFree, kUrl, kClose, kDestroy, kDispatch } = require_symbols();
7050 get [kRunning]() {
7052 for (const { [kRunning]: running } of this[kClients]) {
8342 kRunning,
8578 get [kRunning]() {
8680 } else if (client[kRunning] > 0) {
8686 assert(client[kRunning]
[all...] |
| /third_party/protobuf/src/google/protobuf/ |
| H A D | generated_message_util.h | 192 kRunning = 1, enumerator
|
| H A D | generated_message_util.cc | 767 scc->visit_status.store(SCCInfoBase::kRunning, std::memory_order_relaxed); in InitSCC_DFS()
812 SCCInfoBase::kRunning); in InitSCCImpl()
|
| /third_party/node/deps/v8/src/d8/ |
| H A D | d8.h | 221 kRunning, member in v8::Worker::State
|
| H A D | d8.cc | 4122 bool Worker::is_running() const { return state_.load() == State::kRunning; } in is_running()
4213 auto expected = State::kRunning; in Terminate()
4274 CHECK(state_.compare_exchange_strong(expected, State::kRunning)); in ExecuteInThread()
|