Searched refs:close_f (Results 1 – 5 of 5) sorted by relevance
/external/rust/crates/grpcio/src/call/ |
D | mod.rs | 446 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 …]
|
D | client.rs | 319 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()
|
D | server.rs | 702 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/ |
D | test15-pr18892.so.abi | 12035 <!-- 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/ |
D | test15-pr18892.so.abi | 7435 …<typedef-decl name='close_f' type-id='type-id-775' filepath='../../.././libsanitizer/tsan/tsan_int…
|