Home
last modified time | relevance | path

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

12

/aosp_15_r20/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 …]
/aosp_15_r20/external/grpc-grpc/src/core/lib/channel/
H A 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 …]
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/http/
H A Dquic_send_control_stream.cc50 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in MaybeSendSettingsFrame() local
90 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in WritePriorityUpdate() local
109 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in SendGoAway() local
H A Dweb_transport_http3.cc109 QuicConnection::ScopedPacketFlusher flusher( in CloseSession() local
339 QuicConnection::ScopedPacketFlusher flusher(session_->connection()); in WritePreamble() local
H A Dquic_spdy_stream.cc281 QuicConnection::ScopedPacketFlusher flusher(spdy_session_->connection()); in WriteHeaders() local
337 QuicConnection::ScopedPacketFlusher flusher(spdy_session_->connection()); in WriteOrBufferBody() local
439 QuicConnection::ScopedPacketFlusher flusher(spdy_session_->connection()); in WriteBodySlices() local
H A Dquic_spdy_client_stream.cc161 QuicConnection::ScopedPacketFlusher flusher(session_->connection()); in SendRequest() local
H A Dquic_spdy_session.cc864 QuicConnection::ScopedPacketFlusher flusher(connection()); in SendInitialData() local
H A Dend_to_end_test.cc5155 QuicConnection::ScopedPacketFlusher flusher(client_session->connection()); in TEST_P() local
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/
H A Dquic_connection.cc99 QuicConnection::ScopedPacketFlusher flusher(connection_); in OnAlarm() local
150 QuicConnection::ScopedPacketFlusher flusher(connection_); in OnAlarm() local
2438 ScopedPacketFlusher flusher(this); in SendCryptoData() local
2473 ScopedPacketFlusher flusher(this); in SendStreamData() local
2489 ScopedPacketFlusher flusher(this); in SendControlFrame() local
2519 ScopedPacketFlusher flusher(this); in OnStreamReset() local
2728 ScopedPacketFlusher flusher(this); in ProcessUdpPacket() local
2788 ScopedPacketFlusher flusher(this); in OnCanWrite() local
4328 ScopedPacketFlusher flusher(this); in SetDefaultEncryptionLevel() local
4591 ScopedPacketFlusher flusher(this); in SendConnectionClosePacket() local
[all …]
H A Dquic_connection_test.cc246 ScopedPacketFlusher flusher(this); in SendPacket() local
275 ScopedPacketFlusher flusher(this); in SaveAndSendStreamData() local
288 ScopedPacketFlusher flusher(this); in SendStreamDataWithString() local
307 ScopedPacketFlusher flusher(this); in SendApplicationDataAtLevel() local
1068 QuicConnection::ScopedPacketFlusher flusher(&connection_); in SendAckPacketToPeer() local
2253 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
3810 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
3837 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
3866 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
3889 QuicConnection::ScopedPacketFlusher flusher(&connection_); in TEST_P() local
[all …]
H A Dtls_server_handshaker_test.cc685 QuicConnection::ScopedPacketFlusher flusher(server_connection_); in TEST_P() local
845 QuicConnection::ScopedPacketFlusher flusher(server_connection_); in TEST_P() local
H A Dquic_session.cc676 QuicConnection::ScopedPacketFlusher flusher(connection_); in OnCanWrite() local
953 QuicConnection::ScopedPacketFlusher flusher(connection()); in ResetStream() local
H A Dquic_stream.cc602 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in ResetWithError() local
H A Dtls_server_handshaker.cc466 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in AdvanceHandshakeFromCallback() local
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/qpack/
H A Dqpack_send_stream.cc31 QuicConnection::ScopedPacketFlusher flusher(session()->connection()); in WriteStreamData() local
/aosp_15_r20/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
H A DWriteQueueTest.java153 Thread flusher = new Thread(new Runnable() { in concurrentWriteAndFlush() local
/aosp_15_r20/external/linux-kselftest/tools/testing/selftests/bpf/progs/
H A Dcgroup_hierarchical_stats.c83 int BPF_PROG(flusher, struct cgroup *cgrp, struct cgroup *parent, int cpu) in BPF_PROG() argument
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/simulator/
H A Dquic_endpoint.cc226 QuicConnection::ScopedPacketFlusher flusher(connection_.get()); in WriteStreamData() local
/aosp_15_r20/external/liburing/test/
H A Dsubmit-reuse.c26 static void *flusher(void *__data) in flusher() function
/aosp_15_r20/tools/tradefederation/core/src/com/android/tradefed/device/metric/
DJavaCodeCoverageCollector.java113 void setCoverageFlusher(JavaCodeCoverageFlusher flusher) { in setCoverageFlusher()
/aosp_15_r20/external/igt-gpu-tools/tools/
H A Dintel_guc_logger.c183 static void *flusher(void *arg) in flusher() function
/aosp_15_r20/external/lzma/CPP/7zip/Compress/
H A DDeflateDecoder.cpp384 CCoderReleaser flusher(this); in CodeReal() local
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/
H A Dquic_test_client.cc396 QuicConnection::ScopedPacketFlusher flusher(session->connection()); in SendRequestAndRstTogether() local
H A Dcrypto_test_utils.cc140 QuicConnection::ScopedPacketFlusher flusher(&dest_conn); in MovePackets() local
/aosp_15_r20/external/perfetto/src/shared_lib/test/
H A Dapi_integrationtest.cc896 struct PerfettoDsAsyncFlusher* flusher; in TEST_F() local

12