Searched refs:send_deadline (Results 1 – 10 of 10) sorted by relevance
| /external/grpc-grpc/src/core/lib/surface/ |
| D | call.cc | 182 grpc_millis send_deadline; member
344 grpc_millis send_deadline = args->send_deadline; in grpc_call_create() local
358 send_deadline = GPR_MIN(send_deadline, args->parent->send_deadline); in grpc_call_create()
386 call->send_deadline = send_deadline; in grpc_call_create()
395 send_deadline, in grpc_call_create()
524 grpc_error_get_status(status_error, c->send_deadline, in destroy_call()
704 grpc_error_get_status(error, call->send_deadline, in set_final_status()
1403 call->send_deadline = md->deadline; in receiving_initial_metadata_ready()
1579 call->metadata_batch[0][0].deadline = call->send_deadline; in call_start_batch()
|
| D | call.h | 50 grpc_millis send_deadline; member
|
| D | channel.cc | 321 args.send_deadline = deadline; in grpc_channel_create_call_internal()
|
| D | server.cc | 801 args.send_deadline = GRPC_MILLIS_INF_FUTURE; in accept_stream()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | call.cc | 221 grpc_millis send_deadline; member
388 grpc_millis send_deadline = args->send_deadline; in grpc_call_create() local
400 send_deadline = GPR_MIN(send_deadline, args->parent->send_deadline); in grpc_call_create()
427 call->send_deadline = send_deadline; in grpc_call_create()
434 send_deadline, in grpc_call_create()
564 grpc_error_get_status(status_error, c->send_deadline, in destroy_call()
750 grpc_error_get_status(error, call->send_deadline, in set_final_status()
1483 call->send_deadline = md->deadline; in receiving_initial_metadata_ready()
1669 call->metadata_batch[0][0].deadline = call->send_deadline; in call_start_batch()
|
| D | call.h | 52 grpc_millis send_deadline; member
|
| D | channel.cc | 371 args.send_deadline = deadline; in grpc_channel_create_call_internal()
|
| D | server.cc | 1127 args.send_deadline = GRPC_MILLIS_INF_FUTURE; in AcceptStream()
|
| /external/rust/crates/crossbeam-channel/ |
| D | CHANGELOG.md | 5 - Add `Sender::send_deadline()` and `Receiver::recv_deadline()` methods.
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | channel.rs | 476 self.send_deadline(msg, Instant::now() + timeout) in send_timeout()
518 pub fn send_deadline(&self, msg: T, deadline: Instant) -> Result<(), SendTimeoutError<T>> { in send_deadline() method
|