Searched refs:CallTag (Results 1 – 8 of 8) sorted by relevance
| /external/rust/crates/grpcio/src/task/ |
| D | mod.rs | 111 pub enum CallTag { enum
120 impl CallTag { impl
122 pub fn batch_pair(ty: BatchType) -> (BatchFuture, CallTag) { in batch_pair() argument
125 (CqFuture::new(inner), CallTag::Batch(batch)) in batch_pair()
130 pub fn request(ctx: RequestCallContext) -> CallTag { in request() argument
131 CallTag::Request(RequestCallback::new(ctx)) in request()
136 pub fn action_pair() -> (CqFuture<bool>, CallTag) { in action_pair()
139 (CqFuture::new(inner), CallTag::Action(action)) in action_pair()
143 pub fn abort(call: Call) -> CallTag { in abort() argument
144 CallTag::Abort(Abort::new(call)) in abort()
[all …]
|
| D | executor.rs | 18 use super::CallTag;
41 pub fn kick(&self, tag: Box<CallTag>) -> Result<()> { in kick()
157 match task.kicker.kick(Box::new(CallTag::Spawn(w))) { in wake_by_ref()
|
| /external/llvm-project/clang/lib/StaticAnalyzer/Checkers/ |
| D | ReturnValueChecker.cpp | 101 const NoteTag *CallTag = C.getNoteTag( in checkPostCall() local
114 C.addTransition(State, CallTag); in checkPostCall()
148 const NoteTag *CallTag = C.getNoteTag( in checkEndFunction() local
161 C.addTransition(State, CallTag); in checkEndFunction()
|
| /external/rust/crates/grpcio/src/ |
| D | env.rs | 11 use crate::task::CallTag;
28 let tag: Box<CallTag> = unsafe { Box::from_raw(e.tag as _) }; in poll_queue()
|
| D | server.rs | 23 use crate::task::{CallTag, CqFuture};
507 let prom = CallTag::request(ctx); in request_call()
558 let (cq_f, prom) = CallTag::action_pair(); in shutdown()
|
| D | channel.rs | 22 use crate::task::CallTag;
610 let (cq_f, prom) = CallTag::action_pair(); in wait_for_state_change()
|
| /external/rust/crates/grpcio/src/call/ |
| D | mod.rs | 23 use crate::task::{self, BatchFuture, BatchType, CallTag};
250 fn box_batch_tag(tag: CallTag) -> (*mut grpcwrap_batch_context, *mut c_void) { in box_batch_tag()
263 let (cq_f, tag) = CallTag::batch_pair(bt); in check_run()
389 let tag = CallTag::abort(self); in abort()
|
| D | server.rs | 31 use crate::task::{BatchFuture, CallTag, Executor, Kicker};
121 let tag = Box::new(CallTag::unary_request(self, rc)); in handle_unary_req()
|