Home
last modified time | relevance | path

Searched refs:close_f (Results 1 – 5 of 5) sorted by relevance

/external/rust/crates/grpcio/src/call/
Dmod.rs446 close_f: BatchFuture, field
452 fn new(call: Call, close_f: BatchFuture) -> ShareCall { in new()
455 close_f, in new()
465 let res = match Pin::new(&mut self.close_f).poll(cx) { in poll_finish()
489 task::check_alive(&self.close_f) in check_alive()
513 close_f: Option<BatchFuture>, field
519 fn new(close_f: Option<BatchFuture>) -> StreamingBase { in new()
521 close_f, in new()
535 if let Some(close_f) = &mut self.close_f { in poll()
536 if Pin::new(close_f).poll(cx)?.is_ready() { in poll()
[all …]
Dclient.rs319 close_f: Option<BatchFuture>, field
328 close_f: None, in new()
358 if self.close_f.is_none() { in drop()
395 if t.close_f.is_none() { in poll_close()
398 let close_f = call.call.start_send_close_client()?; in poll_close() localVariable
399 t.close_f = Some(close_f); in poll_close()
402 if Pin::new(t.close_f.as_mut().unwrap()).poll(cx)?.is_pending() { in poll_close()
Dserver.rs702 let close_f = accept_call!(call); in execute_unary() localVariable
714 let sink = UnarySink::new(ShareCall::new(call, close_f), ser); in execute_unary()
728 let close_f = accept_call!(call); in execute_client_streaming() localVariable
729 let call = Arc::new(Mutex::new(ShareCall::new(call, close_f))); in execute_client_streaming()
747 let close_f = accept_call!(call); in execute_server_streaming() localVariable
761 let sink = ServerStreamingSink::new(ShareCall::new(call, close_f), ser); in execute_server_streaming()
775 let close_f = accept_call!(call); in execute_duplex_streaming() localVariable
776 let call = Arc::new(Mutex::new(ShareCall::new(call, close_f))); in execute_duplex_streaming()
/external/libabigail/tests/data/test-annotate/
Dtest15-pr18892.so.abi12035 <!-- typedef int (int)* close_f -->
12036 …<typedef-decl name='close_f' type-id='type-id-775' filepath='../../.././libsanitizer/tsan/tsan_int…
24571 <!-- close_f __interception::real_close -->
/external/libabigail/tests/data/test-read-dwarf/
Dtest15-pr18892.so.abi7435 …<typedef-decl name='close_f' type-id='type-id-775' filepath='../../.././libsanitizer/tsan/tsan_int…