| /third_party/nghttp2/src/ |
| D | asio_server_connection.h | 81 deadline_(GET_IO_SERVICE(socket_)), in connection()
104 deadline_.expires_from_now(tls_handshake_timeout_); in start_tls_handshake_deadline()
105 deadline_.async_wait( in start_tls_handshake_deadline()
110 deadline_.expires_from_now(read_timeout_); in start_read_deadline()
111 deadline_.async_wait( in start_read_deadline()
120 if (deadline_.expires_at() <= in handle_deadline()
123 deadline_.expires_at(boost::posix_time::pos_infin); in handle_deadline()
127 deadline_.async_wait( in handle_deadline()
134 deadline_.expires_from_now(read_timeout_); in do_read()
195 deadline_.expires_from_now(read_timeout_); in do_write()
[all …]
|
| D | asio_client_session_impl.cc | 47 deadline_(io_service), in session_impl()
71 deadline_.expires_from_now(connect_timeout_); in start_resolve()
86 deadline_.async_wait(std::bind(&session_impl::handle_deadline, self)); in start_resolve()
94 if (deadline_.expires_at() <= in handle_deadline()
98 deadline_.expires_at(boost::posix_time::pos_infin); in handle_deadline()
102 deadline_.async_wait( in handle_deadline()
625 deadline_.expires_from_now(read_timeout_); in do_read()
722 deadline_.expires_from_now(read_timeout_); in do_write()
746 deadline_.cancel(); in stop()
|
| D | asio_client_session_impl.h | 123 boost::asio::deadline_timer deadline_; variable
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/timeouts/ |
| D | async_tcp_client.cpp | 90 deadline_(io_context), in client()
106 deadline_.async_wait(boost::bind(&client::check_deadline, this)); in start()
117 deadline_.cancel(); in stop()
129 deadline_.expires_after(boost::asio::chrono::seconds(60)); in start_connect()
189 deadline_.expires_after(boost::asio::chrono::seconds(30)); in start_read()
262 if (deadline_.expiry() <= steady_timer::clock_type::now()) in check_deadline()
271 deadline_.expires_at(steady_timer::time_point::max()); in check_deadline()
275 deadline_.async_wait(boost::bind(&client::check_deadline, this)); in check_deadline()
283 steady_timer deadline_; member in client
|
| /third_party/boost/libs/asio/example/cpp03/timeouts/ |
| D | async_tcp_client.cpp | 90 deadline_(io_context), in client()
106 deadline_.async_wait(boost::bind(&client::check_deadline, this)); in start()
117 deadline_.cancel(); in stop()
129 deadline_.expires_after(boost::asio::chrono::seconds(60)); in start_connect()
189 deadline_.expires_after(boost::asio::chrono::seconds(30)); in start_read()
262 if (deadline_.expiry() <= steady_timer::clock_type::now()) in check_deadline()
271 deadline_.expires_at(steady_timer::time_point::max()); in check_deadline()
275 deadline_.async_wait(boost::bind(&client::check_deadline, this)); in check_deadline()
283 steady_timer deadline_; member in client
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/timeouts/ |
| D | async_tcp_client.cpp | 91 deadline_(io_context), in client()
107 deadline_.async_wait(std::bind(&client::check_deadline, this)); in start()
118 deadline_.cancel(); in stop()
130 deadline_.expires_after(std::chrono::seconds(60)); in start_connect()
190 deadline_.expires_after(std::chrono::seconds(30)); in start_read()
262 if (deadline_.expiry() <= steady_timer::clock_type::now()) in check_deadline()
271 deadline_.expires_at(steady_timer::time_point::max()); in check_deadline()
275 deadline_.async_wait(std::bind(&client::check_deadline, this)); in check_deadline()
283 steady_timer deadline_; member in client
|
| /third_party/boost/libs/asio/example/cpp11/timeouts/ |
| D | async_tcp_client.cpp | 91 deadline_(io_context), in client()
107 deadline_.async_wait(std::bind(&client::check_deadline, this)); in start()
118 deadline_.cancel(); in stop()
130 deadline_.expires_after(std::chrono::seconds(60)); in start_connect()
190 deadline_.expires_after(std::chrono::seconds(30)); in start_read()
262 if (deadline_.expiry() <= steady_timer::clock_type::now()) in check_deadline()
271 deadline_.expires_at(steady_timer::time_point::max()); in check_deadline()
275 deadline_.async_wait(std::bind(&client::check_deadline, this)); in check_deadline()
283 steady_timer deadline_; member in client
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_error.cc | 160 grpc_millis deadline() const { return deadline_; } in deadline()
164 const grpc_millis deadline_ = GRPC_MILLIS_INF_FUTURE; member in ErrorNone
169 grpc_millis deadline() const { return deadline_; } in deadline()
173 const grpc_millis deadline_ = GRPC_MILLIS_INF_FUTURE; member in ErrorCancelled
178 grpc_millis deadline() const { return deadline_; } in deadline()
182 const grpc_millis deadline_ = GRPC_MILLIS_INF_FUTURE; member in SimpleError
188 grpc_millis deadline() const { return deadline_; } in deadline()
192 const grpc_millis deadline_ = GRPC_MILLIS_INF_FUTURE; member in ErrorWithGrpcStatus
200 grpc_millis deadline() const { return deadline_; } in deadline()
204 const grpc_millis deadline_ = GRPC_MILLIS_INF_FUTURE; member in ErrorWithHttpError
[all …]
|
| D | bm_call_create.cc | 475 const gpr_timespec deadline_ = gpr_inf_future(GPR_CLOCK_MONOTONIC); member in SendEmptyMetadata
|
| /third_party/boost/libs/beast/example/http/server/small/ |
| D | http_server_small.cpp | 78 net::steady_timer deadline_{ member in http_connection
184 self->deadline_.cancel(); in write_response()
194 deadline_.async_wait( in check_deadline()
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | client_context.h | 268 deadline_ = deadline_tp.raw_time(); in set_deadline()
299 return grpc::Timespec2Timepoint(deadline_); in deadline()
303 gpr_timespec raw_deadline() const { return deadline_; } in raw_deadline()
504 gpr_timespec deadline_; variable
|
| D | client_context_impl.h | 260 deadline_ = deadline_tp.raw_time(); in set_deadline()
291 return grpc::Timespec2Timepoint(deadline_); in deadline()
295 gpr_timespec raw_deadline() const { return deadline_; } in raw_deadline()
496 gpr_timespec deadline_; variable
|
| D | server_context_impl.h | 129 return ::grpc::Timespec2Timepoint(deadline_); in deadline()
133 gpr_timespec raw_deadline() const { return deadline_; } in raw_deadline()
427 gpr_timespec deadline_; variable
|
| D | server_context.h | 137 return ::grpc::Timespec2Timepoint(deadline_); in deadline()
141 gpr_timespec raw_deadline() const { return deadline_; } in raw_deadline()
454 gpr_timespec deadline_; variable
|
| /third_party/grpc/src/cpp/server/ |
| D | server_context.cc | 236 : deadline_(gpr_inf_future(GPR_CLOCK_REALTIME)) {} in ServerContextBase()
240 : deadline_(deadline) { in ServerContextBase()
246 deadline_ = deadline; in BindDeadlineAndMetadata()
|
| D | server_cc.cc | 217 &context_->deadline_, context_->client_metadata_.arr(), in IssueRequest()
251 context_->deadline_ = call_details_.deadline; in FinalizeResult()
371 server, method_tag_, &call_, &deadline_, &request_metadata_, in Request()
408 deadline_ = call_details_->deadline; in FinalizeResult()
422 ctx_(mrd->deadline_, &mrd->request_metadata_), in CallData()
528 gpr_timespec deadline_; member in grpc::Server::SyncRequest
560 data->deadline = &deadline_; in CallbackRequest()
646 req_->ctx_->BindDeadlineAndMetadata(req_->deadline_, in Run()
725 gpr_timespec deadline_; member in grpc::Server::CallbackRequest
745 deadline_ = call_details_->deadline; in FinalizeResult()
|
| /third_party/grpc/src/core/ext/transport/chttp2/server/ |
| D | chttp2_server.cc | 149 grpc_millis deadline_; member in grpc_core::__anonb188a9f60111::Chttp2ServerListener::ConnectionState
203 deadline_(GetConnectionDeadline(args)), in ConnectionState()
208 handshake_mgr_->DoHandshake(endpoint, args, deadline_, acceptor_, in ConnectionState()
304 grpc_timer_init(&self->timer_, self->deadline_, &self->on_timeout_); in OnHandshakeDone()
|
| /third_party/grpc/src/cpp/client/ |
| D | client_context.cc | 60 deadline_(gpr_inf_future(GPR_CLOCK_REALTIME)), in ClientContext()
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 501 grpc_millis deadline_; member in grpc_core::__anonee6b702a0111::CallData
835 grpc_millis deadline_; member in grpc_core::__anonee6b702a0111::RetryingCall
1006 grpc_millis deadline_; member in grpc_core::__anonee6b702a0111::LoadBalancedCall
1169 calld->call_start_time_, calld->deadline_, in SetPollent()
1204 deadline_(args.deadline), in DynamicTerminationFilterCallData()
1214 grpc_millis deadline_; member in grpc_core::__anonee6b702a0111::DynamicTerminationFilterCallData
2646 deadline_(args.deadline), in CallData()
3009 if (per_method_deadline < deadline_) { in ApplyServiceConfigToCallLocked()
3010 deadline_ = per_method_deadline; in ApplyServiceConfigToCallLocked()
3011 grpc_deadline_state_reset(elem, deadline_); in ApplyServiceConfigToCallLocked()
[all …]
|
| D | subchannel.h | 161 grpc_millis deadline_; variable
|
| D | subchannel.cc | 144 deadline_(args.deadline) { in SubchannelCall()
275 GetCallStatus(&status, call->deadline_, call->recv_trailing_metadata_, in RecvTrailingMetadataReady()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | server.h | 290 grpc_millis deadline_ = GRPC_MILLIS_INF_FUTURE; variable
|
| D | server.cc | 1261 grpc_millis_to_timespec(deadline_, GPR_CLOCK_MONOTONIC); in Publish()
1266 grpc_millis_to_timespec(deadline_, GPR_CLOCK_MONOTONIC); in Publish()
1401 calld->deadline_ = op_deadline; in RecvInitialMetadataReady()
|