| /third_party/cef/libcef/browser/net_service/ |
| D | proxy_url_loader_factory.cc | 335 network::ResourceRequest request_; member in net_service::InterceptedRequest
367 : response_(std::move(response)), request_(request) {} in InterceptDelegate()
376 request_->InputStreamFailed(false /* restart_needed */); in OnInputStreamOpenFailed()
394 base::WeakPtr<InterceptedRequest> request_; member in net_service::InterceptDelegate
409 request_(request), in InterceptedRequest()
451 if (request_.request_initiator && in Restart()
452 network::cors::ShouldCheckCors(request_.url, request_.request_initiator, in Restart()
453 request_.mode)) { in Restart()
454 if (scheme::IsCorsEnabledScheme(request_.url.scheme())) { in Restart()
456 request_.headers.SetHeaderIfMissing( in Restart()
[all …]
|
| D | browser_urlrequest_impl.cc | 130 request_(static_cast<CefRequestImpl*>(request.get())), in Context()
137 request_->SetReadOnly(true); in Context()
145 const GURL& url = GURL(request_->GetURL().ToString()); in Start()
183 CefRefPtr<CefRequest> request() const { return request_.get(); } in request()
268 const int request_flags = request_->GetFlags(); in ContinueOnOriginatingThread()
274 static_cast<CefRequestImpl*>(request_.get()) in ContinueOnOriginatingThread()
282 const GURL& url = GURL(request_->GetURL().ToString()); in ContinueOnOriginatingThread()
311 request_->SetReadOnly(false); in ContinueOnOriginatingThread()
312 request_->SetMethod(method); in ContinueOnOriginatingThread()
313 request_->SetReadOnly(true); in ContinueOnOriginatingThread()
[all …]
|
| D | resource_handler_wrapper.cc | 411 request_ = new CefRequestImpl(); in OpenInputStream()
412 request_->Set(&request, request_id); in OpenInputStream()
413 request_->SetReadOnly(true); in OpenInputStream()
420 handler->Open(request_.get(), handle_request, callbackWrapper.get()); in OpenInputStream()
438 request_, callbackWrapper)); in OpenInputStream()
505 CefRefPtr<CefRequestImpl> request_; member in net_service::__anon069365070111::ResourceResponseWrapper
|
| /third_party/boost/libs/beast/example/http/server/small/ |
| D | http_server_small.cpp | 72 http::request<http::dynamic_body> request_; member in http_connection
90 request_, in read_request()
104 response_.version(request_.version()); in process_request()
107 switch(request_.method()) in process_request()
122 << std::string(request_.method_string()) in process_request()
134 if(request_.target() == "/count") in create_response()
148 else if(request_.target() == "/time") in create_response()
|
| /third_party/grpc/test/cpp/end2end/ |
| D | client_callback_end2end_test.cc | 304 request_.set_message(test_str); in SendGenericEchoAsBidi()
305 send_buf_ = SerializeToByteBuffer(&request_); in SendGenericEchoAsBidi()
325 EXPECT_EQ(request_.message(), response.message()); in SendGenericEchoAsBidi()
338 EchoRequest request_; in SendGenericEchoAsBidi() member in grpc::testing::__anon3934da2c0111::ClientCallbackEnd2endTest::SendGenericEchoAsBidi::Client
661 request_.set_message(msg);
719 StartWrite(&request_); in MaybeWrite()
721 StartWriteLast(&request_, WriteOptions()); in MaybeWrite()
724 EchoRequest request_; member in grpc::testing::__anon3934da2c0111::WriteClient
798 request_.mutable_param()->set_echo_metadata_initially(true); in TEST_P()
799 request_.set_message("Hello metadata"); in TEST_P()
[all …]
|
| D | test_service_impl.cc | 379 StartRead(&request_); in RequestStream()
390 response_->mutable_message()->append(request_.message()); in RequestStream()
392 StartRead(&request_); in RequestStream()
419 EchoRequest request_; in RequestStream() member in grpc::testing::CallbackTestServiceImpl::RequestStream::Reactor
454 : ctx_(ctx), request_(request), server_try_cancel_(server_try_cancel) { in ResponseStream()
500 response_.set_message(request_->message() + in ResponseStream()
522 const EchoRequest* const request_; in ResponseStream() member in grpc::testing::CallbackTestServiceImpl::ResponseStream::Reactor
560 StartRead(&request_); in BidiStream()
581 response_.set_message(request_.message()); in BidiStream()
605 StartRead(&request_); in BidiStream()
[all …]
|
| /third_party/grpc/test/cpp/qps/ |
| D | server_callback.cc | 51 Reactor() { StartRead(&request_); } in StreamingCall()
58 auto s = SetResponse(&request_, &response_); in StreamingCall()
71 StartRead(&request_); in StreamingCall()
77 SimpleRequest request_; in StreamingCall() member in grpc::testing::BenchmarkCallbackServiceImpl::StreamingCall::Reactor
|
| /third_party/cef/libcef/renderer/ |
| D | render_urlrequest_impl.cc | 91 request_(request), in Context()
102 static_cast<CefRequestImpl*>(request_.get())->SetReadOnly(true); in Context()
106 GURL url = GURL(request_->GetURL().ToString()); in Start()
110 url_client_.reset(new CefWebURLLoaderClient(this, request_->GetFlags())); in Start()
114 static_cast<CefRequestImpl*>(request_.get()) in Start()
130 if (request_->GetFlags() & UR_FLAG_ALLOW_STORED_CREDENTIALS) { in Start()
259 if (!(request_->GetFlags() & UR_FLAG_NO_DOWNLOAD_DATA)) { in OnBodyReadable()
304 CefRefPtr<CefRequest> request() const { return request_; } in request()
329 CefRefPtr<CefRequest> request_; member in CefRenderURLRequest::Context
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | message_allocator.h | 48 RequestT* request() { return request_; } in request()
52 void set_request(RequestT* request) { request_ = request; } in set_request()
57 RequestT* request_;
|
| D | server_interface.h | 283 request_(request) { in PayloadAsyncRequest()
299 payload_.bbuf_ptr(), request_) in FinalizeResult()
310 request_); in FinalizeResult()
318 interceptor_methods_.SetRecvMessage(request_, nullptr); in FinalizeResult()
324 Message* const request_; variable
|
| /third_party/cef/tests/ceftests/ |
| D | test_request.cc | 78 request_ = request->GetRequest(); in OnRequestComplete()
79 DCHECK(request_->IsReadOnly()); in OnRequestComplete()
137 DCHECK(config.request_); in Send()
142 config.frame_->CreateURLRequest(config.request_, client.get()); in Send()
144 CefURLRequest::Create(config.request_, client.get(), in Send()
|
| /third_party/boost/libs/asio/example/cpp11/ssl/ |
| D | client.cpp | 95 std::cin.getline(request_, max_length); in send_request()
96 size_t request_length = std::strlen(request_); in send_request()
99 boost::asio::buffer(request_, request_length), in send_request()
133 char request_[max_length]; member in client
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/ssl/ |
| D | client.cpp | 95 std::cin.getline(request_, max_length); in send_request()
96 size_t request_length = std::strlen(request_); in send_request()
99 boost::asio::buffer(request_, request_length), in send_request()
133 char request_[max_length]; member in client
|
| /third_party/protobuf/conformance/ |
| D | conformance_test.cc | 92 request_.set_protobuf_payload(input); in ConformanceRequestSetting()
97 request_.set_json_payload(input); in ConformanceRequestSetting()
102 request_.set_jspb_payload(input); in ConformanceRequestSetting()
107 request_.set_text_payload(input); in ConformanceRequestSetting()
115 request_.set_test_category(test_category); in ConformanceRequestSetting()
117 request_.set_message_type(prototype_message.GetDescriptor()->full_name()); in ConformanceRequestSetting()
118 request_.set_requested_output_format(output_format); in ConformanceRequestSetting()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server4/ |
| D | server.cpp | 71 request_.reset(new request); in operator ()()
83 = request_parser_.parse(*request_, in operator ()()
96 request_handler_(*request_, *reply_); in operator ()()
|
| /third_party/boost/libs/asio/example/cpp03/http/server4/ |
| D | server.cpp | 71 request_.reset(new request); in operator ()()
83 = request_parser_.parse(*request_, in operator ()()
96 request_handler_(*request_, *reply_); in operator ()()
|
| /third_party/boost/libs/asio/example/cpp03/ssl/ |
| D | client.cpp | 75 std::cin.getline(request_, max_length); in handle_handshake()
76 size_t request_length = strlen(request_); in handle_handshake()
79 boost::asio::buffer(request_, request_length), in handle_handshake()
124 char request_[max_length]; member in client
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/ssl/ |
| D | client.cpp | 75 std::cin.getline(request_, max_length); in handle_handshake()
76 size_t request_length = strlen(request_); in handle_handshake()
79 boost::asio::buffer(request_, request_length), in handle_handshake()
124 char request_[max_length]; member in client
|
| /third_party/grpc/examples/cpp/helloworld/ |
| D | greeter_async_server.cc | 95 service_->RequestSayHello(&ctx_, &request_, &responder_, cq_, cq_, in Proceed()
105 reply_.set_message(prefix + request_.name()); in Proceed()
131 HelloRequest request_; member in ServerImpl::CallData
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | callback_test_service.cc | 73 StartRead(&request_); in BidiStream()
99 StartRead(&request_); in BidiStream()
103 EchoRequest request_; in BidiStream() member in grpc::testing::CallbackStreamingTestService::BidiStream::Reactor
|
| D | callback_streaming_ping_pong.h | 46 request_{request},
102 StartWrite(request_); in MaybeWrite()
111 EchoRequest* request_; variable
|
| /third_party/nghttp2/src/ |
| D | asio_server_stream.cc | 37 request_.impl().stream(this); in stream()
44 return request_; in request()
|
| D | asio_client_stream.cc | 36 request_.impl().stream(this); in stream()
44 return request_; in request()
|
| /third_party/cef/patch/patches/ |
| D | net_cookie_flags.patch | 20 - if (cookie_store && request_->allow_credentials()) {
21 + if (cookie_store && request_->allow_credentials() &&
24 request_->force_ignore_site_for_cookies();
|
| /third_party/grpc/src/cpp/server/ |
| D | server_cc.cc | 319 ~UnimplementedAsyncResponse() override { delete request_; } in ~UnimplementedAsyncResponse()
334 UnimplementedAsyncRequest* const request_; member in grpc::Server::UnimplementedAsyncResponse
426 request_(nullptr), in CallData()
465 request_ = handler->Deserialize(call_.call(), request_payload_, in Run()
471 interceptor_methods_.SetRecvMessage(request_, nullptr); in Run()
490 &call_, &ctx_, request_, request_status_, nullptr, nullptr)); in ContinueRunAfterInterception()
491 request_ = nullptr; in ContinueRunAfterInterception()
511 void* request_; member in grpc::Server::SyncRequest::CallData
674 req_->request_ = req_->method_->handler()->Deserialize( in Run()
680 req_->interceptor_methods_.SetRecvMessage(req_->request_, nullptr); in Run()
[all …]
|