| /third_party/nghttp2/src/ |
| D | h2load_http3_session.cc | 36 : client_(client), conn_(nullptr), npending_request_(0), reqidx_(0) {} in Http3Session()
48 auto config = client_->worker->config; in submit_request()
49 reqidx_ = client_->reqidx; in submit_request()
51 if (++client_->reqidx == config->nva.size()) { in submit_request()
52 client_->reqidx = 0; in submit_request()
83 auto config = client_->worker->config; in read_data()
94 auto config = client_->worker->config; in submit_request_internal()
97 rv = ngtcp2_conn_open_bidi_stream(client_->quic.conn, &stream_id, nullptr); in submit_request_internal()
112 client_->on_request(stream_id); in submit_request_internal()
113 auto req_stat = client_->get_req_stat(stream_id); in submit_request_internal()
[all …]
|
| D | h2load_http1_session.cc | 179 client_(client), in Http1Session()
188 void Http1Session::on_connect() { client_->signal_write(); } in on_connect()
191 auto config = client_->worker->config; in submit_request()
192 const auto &req = config->h1reqs[client_->reqidx]; in submit_request()
193 client_->reqidx++; in submit_request()
195 if (client_->reqidx == config->h1reqs.size()) { in submit_request()
196 client_->reqidx = 0; in submit_request()
199 client_->on_request(stream_req_counter_); in submit_request()
201 auto req_stat = client_->get_req_stat(stream_req_counter_); in submit_request()
203 client_->record_request_time(req_stat); in submit_request()
[all …]
|
| D | h2load_http2_session.cc | 40 : client_(client), session_(nullptr) {} in Http2Session()
207 auto config = client_->worker->config; in on_connect()
214 nghttp2_session_client_new2(&session_, callbacks, client_, opt); in on_connect()
244 client_->signal_write(); in on_connect()
252 auto config = client_->worker->config; in submit_request()
253 auto &nva = config->nva[client_->reqidx++]; in submit_request()
255 if (client_->reqidx == config->nva.size()) { in submit_request()
256 client_->reqidx = 0; in submit_request()
268 client_->on_request(stream_id); in submit_request()
282 nghttp2_session_want_write(session_) == 0 && client_->wb.rleft() == 0) { in on_read()
[all …]
|
| D | h2load_http2_session.h | 48 Client *client_;
|
| D | h2load_http1_session.h | 53 Client *client_;
|
| D | h2load_http3_session.h | 75 Client *client_;
|
| /third_party/node/src/ |
| D | inspector_agent.cc | 344 : session_id_(session_id), client_(client) {} in SameThreadInspectorSession()
350 std::weak_ptr<NodeInspectorClient> client_; member in node::inspector::__anon248506280111::SameThreadInspectorSession
399 client_ = V8Inspector::create(env->isolate(), this); in NodeInspectorClient()
454 client_->contextCreated(v8info); in contextCreated()
458 client_->contextDestroyed(context); in contextDestroyed()
473 client_, in connectFrontend()
531 client_->exceptionThrown( in ReportUncaughtException()
539 client_->createStackTrace(stack_trace), in ReportUncaughtException()
561 client_->asyncTaskScheduled(task_name, task, recurring); in AsyncTaskScheduled()
565 client_->asyncTaskCanceled(task); in AsyncTaskCanceled()
[all …]
|
| D | inspector_agent.h | 124 std::shared_ptr<NodeInspectorClient> client_; variable
|
| /third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/test/ |
| D | binary_parse_test.cpp | 217 spvBinaryParse(ScopedContext().context, &client_, in Parse()
223 MockParseClient client_; member in spvtools::__anon045ed8c30111::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/skia/third_party/externals/spirv-tools/test/ |
| D | binary_parse_test.cpp | 217 spvBinaryParse(ScopedContext().context, &client_, in Parse()
223 MockParseClient client_; member in spvtools::__anonacb8e7570111::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/ |
| D | binary_parse_test.cpp | 208 spvBinaryParse(ScopedContext().context, &client_, in Parse()
214 MockParseClient client_; member in spvtools::__anoncf75f7a20111::BinaryParseTest
221 client_, \
232 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
241 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
244 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
252 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
255 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
269 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
271 spvBinaryParse(ctx.CContext(), &client_, words.data(), words.size(), in TEST_F()
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-tcp-wrap-connect.js | 20 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);
|
| D | test-tcp-wrap-listen.js | 64 function done(status, client_, req_) { argument
69 assert.strictEqual(client_, client);
|
| /third_party/cef/libcef/renderer/ |
| D | render_urlrequest_impl.cc | 92 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/cef/libcef/browser/net_service/ |
| D | browser_urlrequest_impl.cc | 131 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
|
| D | stream_reader_url_loader.cc | 473 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()
|
| D | stream_reader_url_loader.h | 175 mojo::Remote<network::mojom::URLLoaderClient> client_; variable
|
| /third_party/cef/libcef/browser/alloy/ |
| D | alloy_browser_host_impl.cc | 71 client_(client), in ShowDevToolsHelper()
77 CefRefPtr<CefClient> client_; member in __anone16e943d0111::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/cef/libcef/browser/ |
| D | browser_host_create.cc | 24 client_(client), in CreateBrowserHelper()
31 CefBrowserHost::CreateBrowserSync(window_info_, client_, url_, settings_, in Run()
36 CefRefPtr<CefClient> client_; member in __anon55ed230f0111::CreateBrowserHelper
|
| D | browser_host_base.cc | 145 client_(client), in CefBrowserHostBase()
186 return client_; in GetClient()
789 if (client_) { in OnAfterCreated()
790 if (auto handler = client_->GetLifeSpanHandler()) { in OnAfterCreated()
798 if (client_) { in OnBeforeClose()
799 if (auto handler = client_->GetLifeSpanHandler()) { in OnBeforeClose()
|
| D | browser_host_base.h | 246 CefRefPtr<CefClient> client() const { return client_; } in client()
288 CefRefPtr<CefClient> client_; variable
|
| /third_party/vk-gl-cts/external/amber/src/src/vulkan/ |
| D | engine_vulkan_debugger.cc | 543 client_(session, [this](const std::string& err) { OnError(err); }) { in Thread()
584 client_.Send(request); in StepOver()
592 client_.Send(request); in StepIn()
600 client_.Send(request); in StepOut()
608 client_.Send(request); in Continue()
617 if (!client_.TopStackFrame(thread_id_, &frame)) { in ExpectLocation()
623 if (!client_.FrameLocation(virtual_files_, frame, &got_location, in ExpectLocation()
651 if (!client_.Callstack(thread_id_, &got_stack)) { in ExpectCallstack()
722 if (!client_.TopStackFrame(thread_id_, &frame)) { in ExpectLocalT()
727 if (!client_.GetLocals(frame, &locals)) { in ExpectLocalT()
[all …]
|
| /third_party/cef/patch/patches/ |
| D | webkit_plugin_info_2015.patch | 40 agent_->client_->DebuggerTaskFinished();
|
| /third_party/gstreamer/gstplugins_bad/sys/mediafoundation/ |
| D | gstmftransform.cpp | 163 client = (GstObject *) g_weak_ref_get (&client_); in Invoke()
190 g_weak_ref_init (&client_, NULL); in GstMFTransformAsyncCallback()
195 g_weak_ref_clear (&client_); in ~GstMFTransformAsyncCallback()
208 g_weak_ref_set (&client_, client); in Initialize()
217 GWeakRef client_; member in GstMFTransformAsyncCallback
|
| /third_party/cef/libcef/browser/chrome/ |
| D | chrome_browser_host_impl.cc | 491 settings_, client_, web_contents, platform_delegate_.get(), in Attach()
|