Searched refs:cq_f (Results 1 – 5 of 5) sorted by relevance
| /external/rust/crates/grpcio/src/call/ |
| D | client.rs | 114 let cq_f = check_run(BatchType::CheckRead, |ctx, tag| unsafe { in unary_async() localVariable
127 Ok(ClientUnaryReceiver::new(call, cq_f, method.resp_de())) in unary_async()
136 let cq_f = check_run(BatchType::CheckRead, |ctx, tag| unsafe { in client_streaming() localVariable
148 let share_call = Arc::new(Mutex::new(ShareCall::new(call, cq_f))); in client_streaming()
167 let cq_f = check_run(BatchType::Finish, |ctx, tag| unsafe { in server_streaming() localVariable
186 Ok(ClientSStreamReceiver::new(call, cq_f, method.resp_de())) in server_streaming()
195 let cq_f = check_run(BatchType::Finish, |ctx, tag| unsafe { in duplex_streaming() localVariable
212 let share_call = Arc::new(Mutex::new(ShareCall::new(call, cq_f))); in duplex_streaming()
|
| D | server.rs | 314 cq_f: Option<BatchFuture>,
326 if self.cq_f.is_some() {
327 ready!(Pin::new(self.cq_f.as_mut().unwrap()).poll(cx)?);
328 self.cq_f.take();
373 let (cq_f, err) = match res {
380 cq_f,
|
| D | mod.rs | 263 let (cq_f, tag) = CallTag::batch_pair(bt); in check_run()
272 cq_f in check_run()
|
| /external/rust/crates/grpcio/src/ |
| D | server.rs | 528 cq_f: CqFuture<bool>, field
535 match ready!(Pin::new(&mut self.cq_f).poll(cx)) { in poll()
558 let (cq_f, prom) = CallTag::action_pair(); in shutdown()
571 ShutdownFuture { cq_f } in shutdown()
|
| D | channel.rs | 610 let (cq_f, prom) = CallTag::action_pair(); in wait_for_state_change()
628 async move { should_wait && cq_f.await.unwrap() } in wait_for_state_change()
|