Home
last modified time | relevance | path

Searched defs:recv_message (Results 1 – 25 of 26) sorted by relevance

12

/external/rust/crates/grpcio-sys/grpc/src/cpp/common/
Dchannel_filter.h159 absl::optional<grpc_core::SliceBuffer>* recv_message() const { in recv_message() function
163 void set_recv_message(absl::optional<grpc_core::SliceBuffer>* recv_message) { in set_recv_message()
/external/grpc-grpc/src/cpp/ext/otel/
Dotel_server_call_tracer.h84 const grpc_core::SliceBuffer& recv_message) override { in RecordReceivedMessage()
Dotel_client_call_tracer.cc133 RecordReceivedMessage(const grpc_core::SliceBuffer& recv_message) { in RecordReceivedMessage()
/external/grpc-grpc/src/core/lib/transport/
Dtransport.h296 bool recv_message : 1; member
377 absl::optional<grpc_core::SliceBuffer>* recv_message = nullptr; member
383 } recv_message; member
/external/grpc-grpc/src/core/lib/channel/
Dcall_tracer.cc112 void RecordReceivedMessage(const SliceBuffer& recv_message) override { in RecordReceivedMessage()
246 void RecordReceivedMessage(const SliceBuffer& recv_message) override { in RecordReceivedMessage()
/external/rust/crates/grpcio-sys/grpc/src/cpp/ext/filters/census/
Dserver_call_tracer.cc139 const grpc_core::SliceBuffer& recv_message) override { in RecordReceivedMessage()
Dclient_filter.cc178 const grpc_core::SliceBuffer& recv_message) { in RecordReceivedMessage()
/external/grpc-grpc/src/python/grpcio_observability/grpc_observability/
Dserver_call_tracer.cc131 const grpc_core::SliceBuffer& recv_message) override { in RecordReceivedMessage()
/external/grpc-grpc/src/cpp/ext/filters/census/
Dserver_call_tracer.cc138 const grpc_core::SliceBuffer& recv_message) override { in RecordReceivedMessage()
Dclient_filter.cc177 const grpc_core::SliceBuffer& recv_message) { in RecordReceivedMessage()
/external/grpc-grpc/test/core/transport/binder/
Dbinder_transport_test.cc568 MakeRecvMessage recv_message(&op); in TEST_F() local
611 MakeRecvMessage recv_message(&op); in TEST_F() local
675 MakeRecvMessage recv_message(&op, /* call_before = */ &on_complete); in TEST_F() local
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/binder/transport/
Dbinder_stream.h107 absl::optional<grpc_core::SliceBuffer>* recv_message; member
/external/grpc-grpc/src/core/ext/transport/binder/transport/
Dbinder_stream.h107 absl::optional<grpc_core::SliceBuffer>* recv_message; member
/external/crosvm/third_party/vmm_vhost/src/
Dconnection.rs196 pub fn recv_message<T: AsBytes + FromBytes + VhostUserMsgValidator>( in recv_message() method
/external/grpc-grpc/include/grpc/impl/
Dgrpc_types.h364 struct grpc_byte_buffer** recv_message; member
365 } recv_message; member
/external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/impl/
Dgrpc_types.h722 struct grpc_byte_buffer** recv_message; member
723 } recv_message; member
/external/rust/crates/grpcio-sys/grpc/include/grpc/impl/
Dgrpc_types.h722 struct grpc_byte_buffer** recv_message; member
723 } recv_message; member
/external/grpc-grpc/src/ruby/ext/grpc/
Drb_call.c618 grpc_byte_buffer* recv_message; member
/external/rust/crates/grpcio-sys/
Dgrpc_wrap.cc86 grpc_byte_buffer* recv_message; member
/external/rust/crates/grpcio/src/call/
Dmod.rs325 pub fn recv_message(&mut self) -> Option<MessageReader> { in recv_message() method
/external/linux-kselftest/tools/testing/selftests/bpf/
Dtest_progs.c1037 static int recv_message(int sock, struct msg *msg) in recv_message() function
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dinternal.h529 absl::optional<grpc_core::SliceBuffer>* recv_message = nullptr; member
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dinternal.h585 absl::optional<grpc_core::SliceBuffer>* recv_message = nullptr; member
/external/rust/crates/grpcio-sys/android/
Dgrpc-bindings.rs973 pub recv_message: *mut *mut grpc_byte_buffer, field
2835 pub recv_message: *mut grpc_byte_buffer, field
/external/rust/crates/grpcio-sys/bindings/
Dbindings.rs1219 pub recv_message: *mut *mut grpc_byte_buffer, field
3889 pub recv_message: *mut grpc_byte_buffer, field

12