Home
last modified time | relevance | path

Searched defs:flusher (Results 1 – 25 of 40) sorted by relevance

12

/external/grpc-grpc/src/core/lib/channel/
Dpromise_based_filter.cc416 Flusher flusher(base_); in OnComplete() local
447 Flusher* flusher) { in Done()
489 void BaseCallData::SendMessage::WakeInsideCombiner(Flusher* flusher, in WakeInsideCombiner()
735 Flusher flusher(base_); in OnComplete() local
741 Flusher* flusher) { in Done()
799 void BaseCallData::ReceiveMessage::WakeInsideCombiner(Flusher* flusher, in WakeInsideCombiner()
1015 explicit PollContext(ClientCallData* self, Flusher* flusher) in PollContext()
1264 Flusher flusher(next_poll->call_data); in ~PollContext() local
1393 Flusher flusher(this); in StartBatch() local
1519 void ClientCallData::Cancel(grpc_error_handle error, Flusher* flusher) { in Cancel()
[all …]
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/channel/
Dpromise_based_filter.cc414 Flusher flusher(base_); in OnComplete() local
445 Flusher* flusher) { in Done()
487 void BaseCallData::SendMessage::WakeInsideCombiner(Flusher* flusher, in WakeInsideCombiner()
733 Flusher flusher(base_); in OnComplete() local
739 Flusher* flusher) { in Done()
795 void BaseCallData::ReceiveMessage::WakeInsideCombiner(Flusher* flusher, in WakeInsideCombiner()
1011 explicit PollContext(ClientCallData* self, Flusher* flusher) in PollContext()
1260 Flusher flusher(next_poll->call_data); in ~PollContext() local
1386 Flusher flusher(this); in StartBatch() local
1512 void ClientCallData::Cancel(grpc_error_handle error, Flusher* flusher) { in Cancel()
[all …]
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/http/
Dquic_send_control_stream.cc52 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in MaybeSendSettingsFrame() local
106 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in WritePriorityUpdate() local
125 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in SendGoAway() local
Dquic_spdy_client_stream.cc163 QuicConnection::ScopedPacketFlusher flusher(session_->connection()); in SendRequest() local
Dweb_transport_http3.cc112 QuicConnection::ScopedPacketFlusher flusher( in CloseSession() local
343 QuicConnection::ScopedPacketFlusher flusher(session_->connection()); in WritePreamble() local
Dquic_spdy_stream.cc288 QuicConnection::ScopedPacketFlusher flusher(spdy_session_->connection()); in WriteHeaders() local
344 QuicConnection::ScopedPacketFlusher flusher(spdy_session_->connection()); in WriteOrBufferBody() local
446 QuicConnection::ScopedPacketFlusher flusher(spdy_session_->connection()); in WriteBodySlices() local
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/http/
Dquic_send_control_stream.cc52 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in MaybeSendSettingsFrame() local
106 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in WritePriorityUpdate() local
125 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in SendGoAway() local
Dquic_spdy_client_stream.cc163 QuicConnection::ScopedPacketFlusher flusher(session_->connection()); in SendRequest() local
Dweb_transport_http3.cc112 QuicConnection::ScopedPacketFlusher flusher( in CloseSession() local
343 QuicConnection::ScopedPacketFlusher flusher(session_->connection()); in WritePreamble() local
Dquic_spdy_stream.cc288 QuicConnection::ScopedPacketFlusher flusher(spdy_session_->connection()); in WriteHeaders() local
344 QuicConnection::ScopedPacketFlusher flusher(spdy_session_->connection()); in WriteOrBufferBody() local
446 QuicConnection::ScopedPacketFlusher flusher(spdy_session_->connection()); in WriteBodySlices() local
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/qpack/
Dqpack_send_stream.cc31 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in WriteStreamData() local
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/qpack/
Dqpack_send_stream.cc31 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in WriteStreamData() local
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DWriteQueueTest.java153 Thread flusher = new Thread(new Runnable() { in concurrentWriteAndFlush() local
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/
Dquic_connection.cc2430 ScopedPacketFlusher flusher(this); in SendCryptoData() local
2465 ScopedPacketFlusher flusher(this); in SendStreamData() local
2481 ScopedPacketFlusher flusher(this); in SendControlFrame() local
2511 ScopedPacketFlusher flusher(this); in OnStreamReset() local
2720 ScopedPacketFlusher flusher(this); in ProcessUdpPacket() local
2780 ScopedPacketFlusher flusher(this); in OnCanWrite() local
4104 QuicConnection::ScopedPacketFlusher flusher(this); in OnAckAlarm() local
4340 ScopedPacketFlusher flusher(this); in SetDefaultEncryptionLevel() local
4454 ScopedPacketFlusher flusher(this); in OnProcessUndecryptablePacketsAlarm() local
4621 ScopedPacketFlusher flusher(this); in SendConnectionClosePacket() local
[all …]
Dquic_connection_test.cc251 ScopedPacketFlusher flusher(this); in SendPacket() local
280 ScopedPacketFlusher flusher(this); in SaveAndSendStreamData() local
293 ScopedPacketFlusher flusher(this); in SendStreamDataWithString() local
312 ScopedPacketFlusher flusher(this); in SendApplicationDataAtLevel() local
1078 QuicConnection::ScopedPacketFlusher flusher(&connection_); in SendAckPacketToPeer() local
2305 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
3871 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
3898 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
3927 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
3950 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
[all …]
Dtls_server_handshaker_test.cc690 QuicConnection::ScopedPacketFlusher flusher(server_connection_); in TEST_P() local
849 QuicConnection::ScopedPacketFlusher flusher(server_connection_); in TEST_P() local
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/
Dquic_connection.cc2430 ScopedPacketFlusher flusher(this); in SendCryptoData() local
2465 ScopedPacketFlusher flusher(this); in SendStreamData() local
2481 ScopedPacketFlusher flusher(this); in SendControlFrame() local
2511 ScopedPacketFlusher flusher(this); in OnStreamReset() local
2720 ScopedPacketFlusher flusher(this); in ProcessUdpPacket() local
2780 ScopedPacketFlusher flusher(this); in OnCanWrite() local
4104 QuicConnection::ScopedPacketFlusher flusher(this); in OnAckAlarm() local
4340 ScopedPacketFlusher flusher(this); in SetDefaultEncryptionLevel() local
4454 ScopedPacketFlusher flusher(this); in OnProcessUndecryptablePacketsAlarm() local
4621 ScopedPacketFlusher flusher(this); in SendConnectionClosePacket() local
[all …]
Dquic_connection_test.cc251 ScopedPacketFlusher flusher(this); in SendPacket() local
280 ScopedPacketFlusher flusher(this); in SaveAndSendStreamData() local
293 ScopedPacketFlusher flusher(this); in SendStreamDataWithString() local
312 ScopedPacketFlusher flusher(this); in SendApplicationDataAtLevel() local
1078 QuicConnection::ScopedPacketFlusher flusher(&connection_); in SendAckPacketToPeer() local
2305 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
3871 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
3898 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
3927 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
3950 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
[all …]
Dtls_server_handshaker_test.cc690 QuicConnection::ScopedPacketFlusher flusher(server_connection_); in TEST_P() local
849 QuicConnection::ScopedPacketFlusher flusher(server_connection_); in TEST_P() local
/external/linux-kselftest/tools/testing/selftests/bpf/progs/
Dcgroup_hierarchical_stats.c83 int BPF_PROG(flusher, struct cgroup *cgrp, struct cgroup *parent, int cpu) in BPF_PROG() argument
/external/liburing/test/
Dsubmit-reuse.c26 static void *flusher(void *__data) in flusher() function
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/test_tools/simulator/
Dquic_endpoint.cc228 QuicConnection::ScopedPacketFlusher flusher(connection_.get()); in WriteStreamData() local
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/test_tools/simulator/
Dquic_endpoint.cc228 QuicConnection::ScopedPacketFlusher flusher(connection_.get()); in WriteStreamData() local
/external/igt-gpu-tools/tools/
Dintel_guc_logger.c183 static void *flusher(void *arg) in flusher() function
/external/lzma/CPP/7zip/Compress/
DDeflateDecoder.cpp384 CCoderReleaser flusher(this); in CodeReal() local

12