| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | async_stream_impl.h | 212 GPR_CODEGEN_ASSERT(!started_); in StartCall()
213 started_ = true; in StartCall()
226 GPR_CODEGEN_ASSERT(started_); in ReadInitialMetadata()
235 GPR_CODEGEN_ASSERT(started_); in Read()
250 GPR_CODEGEN_ASSERT(started_); in Finish()
265 : context_(context), call_(call), started_(start) { in ClientAsyncReader()
285 bool started_; variable
361 GPR_CODEGEN_ASSERT(!started_); in StartCall()
362 started_ = true; in StartCall()
374 GPR_CODEGEN_ASSERT(started_); in ReadInitialMetadata()
[all …]
|
| D | async_stream.h | 212 GPR_CODEGEN_ASSERT(!started_); in StartCall()
213 started_ = true; in StartCall()
226 GPR_CODEGEN_ASSERT(started_); in ReadInitialMetadata()
235 GPR_CODEGEN_ASSERT(started_); in Read()
250 GPR_CODEGEN_ASSERT(started_); in Finish()
264 : context_(context), call_(call), started_(start) { in ClientAsyncReader()
284 bool started_; variable
360 GPR_CODEGEN_ASSERT(!started_); in StartCall()
361 started_ = true; in StartCall()
373 GPR_CODEGEN_ASSERT(started_); in ReadInitialMetadata()
[all …]
|
| D | async_unary_call_impl.h | 110 GPR_CODEGEN_ASSERT(!started_); in StartCall()
111 started_ = true; in StartCall()
122 GPR_CODEGEN_ASSERT(started_); in ReadInitialMetadata()
137 GPR_CODEGEN_ASSERT(started_); in Finish()
158 bool started_; variable
165 : context_(context), call_(call), started_(start) { in ClientAsyncResponseReader()
|
| D | client_callback.h | 504 started_.store(true, std::memory_order_release); in StartCall()
515 if (GPR_UNLIKELY(!started_.load(std::memory_order_acquire))) { in Read()
517 if (GPR_LIKELY(!started_.load(std::memory_order_relaxed))) { in Read()
539 if (GPR_UNLIKELY(!started_.load(std::memory_order_acquire))) { in Write()
541 if (GPR_LIKELY(!started_.load(std::memory_order_relaxed))) { in Write()
564 if (GPR_UNLIKELY(!started_.load(std::memory_order_acquire))) { in WritesDone()
566 if (GPR_LIKELY(!started_.load(std::memory_order_relaxed))) { in WritesDone()
693 std::atomic_bool started_{false};
764 started_.store(true, std::memory_order_release); in StartCall()
779 if (GPR_UNLIKELY(!started_.load(std::memory_order_acquire))) { in Read()
[all …]
|
| D | client_callback_impl.h | 499 started_.store(true, std::memory_order_release); in StartCall()
510 if (GPR_UNLIKELY(!started_.load(std::memory_order_acquire))) { in Read()
512 if (GPR_LIKELY(!started_.load(std::memory_order_relaxed))) { in Read()
534 if (GPR_UNLIKELY(!started_.load(std::memory_order_acquire))) { in Write()
536 if (GPR_LIKELY(!started_.load(std::memory_order_relaxed))) { in Write()
558 if (GPR_UNLIKELY(!started_.load(std::memory_order_acquire))) { in WritesDone()
560 if (GPR_LIKELY(!started_.load(std::memory_order_relaxed))) { in WritesDone()
684 std::atomic_bool started_{false};
753 started_.store(true, std::memory_order_release); in StartCall()
768 if (GPR_UNLIKELY(!started_.load(std::memory_order_acquire))) { in Read()
[all …]
|
| D | async_unary_call.h | 235 GPR_CODEGEN_DEBUG_ASSERT(!started_); in StartCall()
236 started_ = true; in StartCall()
247 GPR_CODEGEN_DEBUG_ASSERT(started_); in ReadInitialMetadata()
259 GPR_CODEGEN_DEBUG_ASSERT(started_); in Finish()
268 bool started_ = false; variable
|
| /third_party/ninja/src/ |
| D | metrics.h | 69 Stopwatch() : started_(0) {} in Stopwatch()
73 return 1e-6 * static_cast<double>(Now() - started_); in Elapsed()
76 void Restart() { started_ = Now(); } in Restart()
79 uint64_t started_;
|
| /third_party/grpc/src/cpp/server/ |
| D | external_connection_acceptor_impl.cc | 65 if (shutdown_ || !started_) { in HandleNewConnection()
70 p->fd, started_, shutdown_); in HandleNewConnection()
85 GPR_ASSERT(!started_); in Start()
88 started_ = true; in Start()
|
| D | external_connection_acceptor_impl.h | 64 bool started_ = false; variable
|
| D | server_cc.cc | 906 started_(false), in Server()
967 if (started_ && !shutdown_) { in ~Server()
970 } else if (!started_) { in ~Server()
1116 GPR_ASSERT(!started_); in AddListeningPort()
1148 GPR_ASSERT(!started_); in Start()
1150 started_ = true; in Start()
1305 while (started_ && !shutdown_notified_) { in Wait()
|
| /third_party/grpc/src/core/lib/gprpp/ |
| D | thd_windows.cc | 59 : started_(false) { in ThreadInternalsWindows()
103 started_ = true; in Start()
118 while (!g_thd_info->thread->started_) { in thread_body()
146 bool started_; member in __anona234cc0a0111::ThreadInternalsWindows
|
| D | thd_posix.cc | 76 : started_(false) { in ThreadInternalsPosix()
130 while (!arg.thread->started_) { in ThreadInternalsPosix()
166 started_ = true; in Start()
176 bool started_; member in grpc_core::__anon6b884cf20111::ThreadInternalsPosix
|
| /third_party/node/src/tracing/ |
| D | agent.cc | 18 CHECK(agent_->started_); in ScopedSuspendTracing()
87 if (started_) in Start()
101 started_ = true; in Start()
142 if (!started_) in StopTracing()
148 started_ = false; in StopTracing()
|
| D | agent.h | 136 bool started_ = false; variable
|
| /third_party/benchmark/src/ |
| D | benchmark.cc | 143 started_(false), in State()
184 BM_CHECK(started_ && !finished_ && !error_occurred_); in PauseTiming()
198 BM_CHECK(started_ && !finished_ && !error_occurred_); in ResumeTiming()
229 BM_CHECK(!started_ && !finished_); in StartKeepRunning()
230 started_ = true; in StartKeepRunning()
237 BM_CHECK(started_ && (!finished_ || error_occurred_)); in FinishKeepRunning()
|
| /third_party/json/benchmarks/thirdparty/benchmark/src/ |
| D | benchmark.cc | 299 started_(false), in State()
335 CHECK(started_ && !finished_ && !error_occurred_); in PauseTiming()
340 CHECK(started_ && !finished_ && !error_occurred_); in ResumeTiming()
368 CHECK(!started_ && !finished_); in StartKeepRunning()
369 started_ = true; in StartKeepRunning()
376 CHECK(started_ && (!finished_ || error_occurred_)); in FinishKeepRunning()
|
| /third_party/grpc/src/core/ext/filters/client_channel/resolver/fake/ |
| D | fake_resolver.cc | 84 bool started_ = false; member in grpc_core::FakeResolver
113 started_ = true; in StartLocked()
142 if (!started_ || shutdown_) return; in MaybeSendResultLocked()
|
| /third_party/grpc/test/cpp/end2end/ |
| D | service_config_end2end_test.cc | 302 bool started_ = false; member
310 started_ = true; in Start()
337 if (!started_) return; in Shutdown()
340 started_ = false; in Shutdown()
|
| D | test_service_impl.cc | 142 started_ = true; in Echo()
176 EXPECT_TRUE(started_); in Echo()
315 bool started_ = false; in Echo() member in grpc::testing::CallbackTestServiceImpl::Echo::Reactor
|
| /third_party/boost/libs/beast/test/bench/parser/ |
| D | nodejs_parser.hpp | 536 bool started_ = false; member in boost::beast::http::nodejs_parser
550 return started_; in started()
559 started_ = true; in on_start()
|
| /third_party/node/src/ |
| D | tls_wrap.h | 201 bool started_ = false; variable
|
| /third_party/cef/tests/ceftests/ |
| D | os_rendering_unittest.cc | 189 started_(false), in OSRTestHandler()
1484 bool started() { return started_; } in started()
1493 if (started_) in StartTest()
1495 started_ = true; in StartTest()
1504 bool started_; member in __anon4ecb97c50111::OSRTestHandler
|
| /third_party/json/benchmarks/thirdparty/benchmark/include/benchmark/ |
| D | benchmark.h | 578 if (BENCHMARK_BUILTIN_EXPECT(!started_, false)) { in iterations()
599 bool started_;
657 if (!started_) { in KeepRunningInternal()
|
| /third_party/grpc/include/grpcpp/ |
| D | server.h | 337 bool started_; variable
|
| D | server_impl.h | 333 bool started_; variable
|