Home
last modified time | relevance | path

Searched refs:client_ (Results 1 – 25 of 45) sorted by relevance

12

/third_party/nghttp2/src/
Dh2load_http1_session.cc166 client_(client), in Http1Session()
175 void Http1Session::on_connect() { client_->signal_write(); } in on_connect()
178 auto config = client_->worker->config; in submit_request()
179 const auto &req = config->h1reqs[client_->reqidx]; in submit_request()
180 client_->reqidx++; in submit_request()
182 if (client_->reqidx == config->h1reqs.size()) { in submit_request()
183 client_->reqidx = 0; in submit_request()
186 client_->on_request(stream_req_counter_); in submit_request()
188 auto req_stat = client_->get_req_stat(stream_req_counter_); in submit_request()
190 client_->record_request_time(req_stat); in submit_request()
[all …]
Dh2load_http2_session.cc40 : client_(client), session_(nullptr) {} in Http2Session()
227 auto config = client_->worker->config; in on_connect()
234 nghttp2_session_client_new2(&session_, callbacks, client_, opt); in on_connect()
259 client_->signal_write(); in on_connect()
267 auto config = client_->worker->config; in submit_request()
268 auto &nva = config->nva[client_->reqidx++]; in submit_request()
270 if (client_->reqidx == config->nva.size()) { in submit_request()
271 client_->reqidx = 0; in submit_request()
283 client_->on_request(stream_id); in submit_request()
297 nghttp2_session_want_write(session_) == 0 && client_->wb.rleft() == 0) { in on_read()
[all …]
/third_party/node/src/
Dinspector_agent.cc333 : session_id_(session_id), client_(client) {} in SameThreadInspectorSession()
339 std::weak_ptr<NodeInspectorClient> client_; member in node::inspector::__anon3f0d7d490111::SameThreadInspectorSession
378 client_ = V8Inspector::create(env->isolate(), this); in NodeInspectorClient()
433 client_->contextCreated(v8info); in contextCreated()
437 client_->contextDestroyed(context); in contextDestroyed()
452 client_, in connectFrontend()
510 client_->exceptionThrown( in ReportUncaughtException()
518 client_->createStackTrace(stack_trace), in ReportUncaughtException()
540 client_->asyncTaskScheduled(task_name, task, recurring); in AsyncTaskScheduled()
544 client_->asyncTaskCanceled(task); in AsyncTaskCanceled()
[all …]
/third_party/skia/third_party/externals/spirv-tools/test/
Dbinary_parse_test.cpp217 spvBinaryParse(ScopedContext().context, &client_, in Parse()
223 MockParseClient client_; member in spvtools::__anon912fb7380111::BinaryParseTest
230 client_, \
241 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
250 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
253 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
261 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
264 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
278 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
280 spvBinaryParse(ctx.CContext(), &client_, words.data(), words.size(), in TEST_F()
[all …]
/third_party/spirv-tools/test/
Dbinary_parse_test.cpp217 spvBinaryParse(ScopedContext().context, &client_, in Parse()
223 MockParseClient client_; member in spvtools::__anonb4c518230111::BinaryParseTest
230 client_, \
241 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
250 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
253 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
261 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
264 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
278 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
280 spvBinaryParse(ctx.CContext(), &client_, words.data(), words.size(), in TEST_F()
[all …]
/third_party/flutter/skia/third_party/externals/spirv-tools/test/
Dbinary_parse_test.cpp212 spvBinaryParse(ScopedContext().context, &client_, in Parse()
218 MockParseClient client_; member in __anon7f158d6d0111::BinaryParseTest
225 client_, \
236 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
245 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
248 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
256 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
259 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
273 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
275 spvBinaryParse(ctx, &client_, words.data(), words.size(), in TEST_F()
[all …]
/third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/test/
Dbinary_parse_test.cpp217 spvBinaryParse(ScopedContext().context, &client_, in Parse()
223 MockParseClient client_; member in spvtools::__anon17539ba40111::BinaryParseTest
230 client_, \
241 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
250 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
253 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
261 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
264 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
278 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
280 spvBinaryParse(ctx.CContext(), &client_, words.data(), words.size(), in TEST_F()
[all …]
/third_party/grpc/test/cpp/qps/
Dclient_callback.cc257 : client_(client), ctx_(std::move(ctx)), messages_issued_(0) {} in CallbackStreamingPingPongReactor()
262 StartWrite(client_->request()); in StartNewRpc()
271 if ((!ok || client_->ThreadCompleted()) && in OnWriteDone()
279 client_->AddHistogramEntry(write_time_, ok, thread_ptr_); in OnReadDone()
281 if (client_->ThreadCompleted() || !ok || in OnReadDone()
282 (client_->messages_per_stream() != 0 && in OnReadDone()
283 ++messages_issued_ >= client_->messages_per_stream())) { in OnReadDone()
292 if (!client_->IsClosedLoop()) { in OnReadDone()
293 gpr_timespec next_issue_time = client_->NextRPCIssueTime(); in OnReadDone()
298 StartWrite(client_->request()); in OnReadDone()
[all …]
Dclient.h257 : client_(client), idx_(idx), impl_(&Thread::ThreadFunc, this) {} in Thread()
281 if (client_->GetLatencyCollectionIntervalInSeconds() > 0) { in UpdateHistogram()
285 client_->GetLatencyCollectionIntervalInSeconds()) { in UpdateHistogram()
307 &client_->start_requests_, in ThreadFunc()
315 client_->ThreadFunc(idx_, this); in ThreadFunc()
316 client_->CompleteThread(); in ThreadFunc()
322 Client* client_; variable
/third_party/mindspore/tests/ut/cpp/ps/core/
Dtcp_pb_server_test.cc29 TestTcpServer() : client_(nullptr), server_(nullptr) {} in TestTcpServer()
52 client_->Stop(); in TearDown()
57 std::unique_ptr<TcpClient> client_; member in mindspore::ps::core::TestTcpServer
63 client_ = std::make_unique<TcpClient>("127.0.0.1", server_->BoundPort(), config.get()); in TEST_F()
67 …client_->SetMessageCallback([&](std::shared_ptr<MessageMeta> meta, const Protos &, const void *dat… in TEST_F()
73 client_->Init(); in TEST_F()
84 …client_->SendMessage(message_meta, Protos::RAW, kv_message.SerializeAsString().data(), kv_message.… in TEST_F()
86 client_->Start(); in TEST_F()
/third_party/flutter/engine/flutter/runtime/
Dace_runtime_controller.cc39 : client_(p_client), in RuntimeController()
57 client_, // in Clone()
146 return client_.DefaultRouteName(); in DefaultRouteName()
150 client_.ScheduleFrame(); in ScheduleFrame()
154 client_.Render(scene->takeLayerTree()); in Render()
159 client_.HandlePlatformMessage(std::move(message)); in HandlePlatformMessage()
163 return client_.GetFontCollection(); in GetFontCollection()
167 client_.SetNeedsReportTimings(value); in SetNeedsReportTimings()
Druntime_controller.cc57 : client_(p_client), in RuntimeController()
134 client_, // in Clone()
299 return client_.DefaultRouteName(); in DefaultRouteName()
303 client_.ScheduleFrame(); in ScheduleFrame()
307 client_.Render(scene->takeLayerTree()); in Render()
312 client_.UpdateSemantics(update->takeNodes(), update->takeActions()); in UpdateSemantics()
318 client_.HandlePlatformMessage(std::move(message)); in HandlePlatformMessage()
322 return client_.GetFontCollection(); in GetFontCollection()
327 client_.UpdateIsolateDescription(isolate_name, isolate_port); in UpdateIsolateDescription()
331 client_.SetNeedsReportTimings(value); in SetNeedsReportTimings()
/third_party/mindspore/mindspore/lite/src/delegate/npu/
Dnpu_executor.cc25 client_.reset(); in ~NPUExecutor()
38 this->client_ = npu_manager_->GetClient(model_name_); in Prepare()
39 if (this->client_ == nullptr) { in Prepare()
87 if (this->client_ == nullptr) { in Run()
92 …int ret = this->client_->Process(context, this->npu_input_tensors_, this->npu_output_tensors_, 100… in Run()
120 if (this->client_ == nullptr) { in GetIOTensorVec()
124 auto ret = this->client_->GetModelIOTensorDim(model_name_, input_dimension, output_dimension); in GetIOTensorVec()
Dnpu_manager.cc74 model->client_.reset(); in Reset()
233 return models_[model_name]->client_; in GetClient()
247 it->second->client_ = client; in LoadModel()
/third_party/node/test/parallel/
Dtest-tcp-wrap-connect.js20 req.oncomplete = function(status, client_, req_, readable, writable) { argument
22 assert.strictEqual(client_, client);
31 shutdownReq.oncomplete = function(status, client_, error) { argument
33 assert.strictEqual(client_, client);
Dtest-tcp-wrap-listen.js62 function done(status, client_, req_) { argument
67 assert.strictEqual(client_, client);
/third_party/cef/libcef/renderer/
Drender_urlrequest_impl.cc92 client_(client), in Context()
222 client_->OnRequestComplete(url_request_.get()); in OnComplete()
256 client_->OnDownloadProgress(url_request_.get(), download_data_received_, in OnBodyReadable()
260 client_->OnDownloadData(url_request_.get(), buffer, read_bytes); in OnBodyReadable()
288 client_->OnDownloadProgress(url_request_.get(), download_data_received_, in OnDownloadProgress()
294 client_->OnDownloadData(url_request_.get(), data, dataLength); in OnDownloadData()
301 client_->OnUploadProgress(url_request_.get(), current, total); in OnUploadProgress()
305 CefRefPtr<CefURLRequestClient> client() const { return client_; } in client()
330 CefRefPtr<CefURLRequestClient> client_; member in CefRenderURLRequest::Context
/third_party/grpc/test/cpp/end2end/
Dserver_crash_test.cc102 client_.reset(new SubProcess({g_root + "/server_crash_test_client", in CreateServerAndClient()
104 GPR_ASSERT(client_); in CreateServerAndClient()
112 void KillClient() { client_.reset(); } in KillClient()
119 std::unique_ptr<SubProcess> client_; member in grpc::testing::__anon11d024890111::CrashTest
/third_party/cef/libcef/browser/net_service/
Dbrowser_urlrequest_impl.cc131 client_(client), in Context()
184 CefRefPtr<CefURLRequestClient> client() const { return client_; } in client()
325 g_manager.Get().Add(request_id, url_request_, client_); in ContinueOnOriginatingThread()
469 client_->OnUploadProgress(url_request_.get(), position, total); in OnUploadProgress()
484 client_->OnDownloadProgress(url_request_.get(), current, in OnDownloadProgress()
493 client_->OnUploadProgress(url_request_.get(), upload_data_size_, in NotifyUploadProgressIfNecessary()
505 client_->OnDownloadData(url_request_.get(), string_piece.data(), in OnDataReceived()
534 client_->OnRequestComplete(url_request_.get()); in OnComplete()
553 client_ = nullptr; in Cleanup()
582 CefRefPtr<CefURLRequestClient> client_; member in CefBrowserURLRequest::Context
Dstream_reader_url_loader.cc473 client_(std::move(client)), in StreamReaderURLLoader()
483 client_.set_disconnect_handler( in StreamReaderURLLoader()
682 DCHECK(client_.is_bound()); in ContinueWithResponseHeaders()
692 client_->OnReceiveRedirect( in ContinueWithResponseHeaders()
700 client_->OnReceiveResponse(std::move(pending_response), in ContinueWithResponseHeaders()
731 client_->OnStartLoadingResponseBody(std::move(consumer_handle)); in SendBody()
801 client_->OnTransferSizeUpdated(bytes_read); in OnReaderReadCompleted()
819 client_->OnComplete(status); in RequestComplete()
/third_party/cef/libcef/browser/
Dbrowser_host_create.cc24 client_(client), in CreateBrowserHelper()
31 CefBrowserHost::CreateBrowserSync(window_info_, client_, url_, settings_, in Run()
36 CefRefPtr<CefClient> client_; member in __anon7eaefff00111::CreateBrowserHelper
/third_party/flutter/engine/flutter/shell/platform/darwin/ios/framework/Source/
Dvsync_waiter_ios.mm44 client_([[VSyncClient alloc] initWithTaskRunner:task_runners_.GetUITaskRunner()
53 [client_.get() invalidate];
57 [client_.get() await];
62 return [client_.get() displayRefreshRate];
/third_party/cef/libcef/browser/alloy/
Dalloy_browser_host_impl.cc71 client_(client), in ShowDevToolsHelper()
77 CefRefPtr<CefClient> client_; member in __anon91aebe5e0111::ShowDevToolsHelper
83 helper->browser_->ShowDevTools(helper->window_info_, helper->client_, in ShowDevToolsWithHelper()
867 if (client_) { in FindReply()
868 if (auto handler = client_->GetFindHandler()) { in FindReply()
1150 if (client_.get() && (IsWindowless() || !window_destroyed_)) { in CloseContents()
1151 CefRefPtr<CefLifeSpanHandler> handler = client_->GetLifeSpanHandler(); in CloseContents()
1213 if (client_.get()) { in TakeFocus()
1214 CefRefPtr<CefFocusHandler> handler = client_->GetFocusHandler(); in TakeFocus()
1259 if (client_) in CanDragEnter()
[all …]
/third_party/flutter/engine/flutter/lib/ui/window/
Dwindow.h40 WindowClient* client() const { return client_; } in client()
60 WindowClient* client_;
/third_party/boost/boost/iostreams/
Dchain.hpp276 void register_client(client_type* client) { pimpl_->client_ = client; } in register_client()
277 void notify() { if (pimpl_->client_) pimpl_->client_->notify(); } in notify()
314 : client_(0), device_buffer_size_(default_device_buffer_size), in chain_impl()
376 client_type* client_; member

12