| /aosp_15_r20/external/rust/android-crates-io/crates/h2/src/proto/streams/ |
| D | recv.rs | 14 pub(super) struct Recv { struct
16 init_window_sz: WindowSize,
19 flow: FlowControl,
22 in_flight_data: WindowSize,
25 next_stream_id: Result<StreamId, StreamIdOverflow>,
28 last_processed_id: StreamId,
37 max_stream_id: StreamId,
40 pending_window_updates: store::Queue<stream::NextWindowUpdate>,
43 pending_accept: store::Queue<stream::NextAccept>,
46 pending_reset_expired: store::Queue<stream::NextResetExpire>,
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/opencensus-proto/gen-go/agent/trace/v1/ |
| D | trace_service_grpc.pb.go | 48 Recv() (*UpdatedLibraryConfig, error) methodSpec
60 func (x *traceServiceConfigClient) Recv() (*UpdatedLibraryConfig, error) { func
79 Recv() (*ExportTraceServiceResponse, error) methodSpec
91 func (x *traceServiceExportClient) Recv() (*ExportTraceServiceResponse, error) { func
135 Recv() (*CurrentLibraryConfig, error) methodSpec
147 func (x *traceServiceConfigServer) Recv() (*CurrentLibraryConfig, error) { func
161 Recv() (*ExportTraceServiceRequest, error) methodSpec
173 func (x *traceServiceExportServer) Recv() (*ExportTraceServiceRequest, error) { func
|
| /aosp_15_r20/external/flatbuffers/tests/MyGame/Example/ |
| H A D | MonsterStorage_grpc.go | 62 Recv() (*Monster, error) methodSpec
70 func (x *monsterStorageRetrieveClient) Recv() (*Monster, error) { func
125 Recv() (*Stat, error) methodSpec
137 func (x *monsterStorageGetMinMaxHitPointsClient) Recv() (*Stat, error) { func
228 Recv() (*Monster, error) methodSpec
237 func (x *monsterStorageGetMaxHitPointServer) Recv() (*Monster, error) { func
255 Recv() (*Monster, error) methodSpec
267 func (x *monsterStorageGetMinMaxHitPointsServer) Recv() (*Monster, error) { func
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/ |
| D | broadcast.rs | 393 struct Recv<'a, T> { struct
401 unsafe impl<'a, T: Send> Send for Recv<'a, T> {} argument
402 unsafe impl<'a, T: Send> Sync for Recv<'a, T> {} implementation
1366 impl<'a, T> Recv<'a, T> { implementation
1392 impl<'a, T> Future for Recv<'a, T> implementation
1414 impl<'a, T> Drop for Recv<'a, T> { implementation
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/opencensus-proto/gen-go/agent/metrics/v1/ |
| D | metrics_service_grpc.pb.go | 44 Recv() (*ExportMetricsServiceResponse, error) methodSpec
56 func (x *metricsServiceExportClient) Recv() (*ExportMetricsServiceResponse, error) { func
93 Recv() (*ExportMetricsServiceRequest, error) methodSpec
105 func (x *metricsServiceExportServer) Recv() (*ExportMetricsServiceRequest, error) { func
|
| /aosp_15_r20/prebuilts/go/linux-x86/test/ |
| D | closedchan.go | 21 Recv() (int) methodSpec
46 func (c XChan) Recv() int { func
102 func (c SChan) Recv() int { func
169 func (c SSChan) Recv() int { func
|
| /aosp_15_r20/external/tensorflow/tensorflow/compiler/mlir/tensorflow/ir/ |
| H A D | tf_side_effects.h | 75 struct Recv : public ::mlir::SideEffects::Resource::Base<Recv> { struct
76 StringRef getName() final { return "Recv"; } in getName() argument
|
| /aosp_15_r20/external/tensorflow/tensorflow/core/framework/ |
| H A D | rendezvous.cc | 119 Status RendezvousInterface::Recv(const ParsedKey& key, const Args& recv_args, in Recv() function in tensorflow::RendezvousInterface
146 Status RendezvousInterface::Recv(const ParsedKey& key, const Args& args, in Recv() function in tensorflow::RendezvousInterface
|
| /aosp_15_r20/external/flatbuffers/grpc/examples/go/greeter/models/ |
| H A D | Greeter_grpc.go | 58 Recv() (*HelloReply, error) methodSpec
66 func (x *greeterSayManyHellosClient) Recv() (*HelloReply, error) { func
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/xds/go/udpa/service/orca/v1/ |
| D | orca.pb.go | 232 Recv() (*v1.OrcaLoadReport, error) methodSpec
240 func (x *openRcaServiceStreamCoreMetricsClient) Recv() (*v1.OrcaLoadReport, error) { func
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/xds/go/xds/service/orca/v3/ |
| D | orca.pb.go | 232 Recv() (*v3.OrcaLoadReport, error) methodSpec
240 func (x *openRcaServiceStreamCoreMetricsClient) Recv() (*v3.OrcaLoadReport, error) { func
|
| /aosp_15_r20/prebuilts/go/linux-x86/test/typeparam/ |
| D | append.go | 9 type Recv <-chan int type
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/net/rpc/ |
| D | client_test.go | 49 func (s *S) Recv(nul *struct{}, reply *R) error { func
|
| /aosp_15_r20/external/tensorflow/tensorflow/core/kernels/ |
| H A D | sendrecv_ops_test.cc | 51 static Graph* Recv() { in Recv() function
|
| /aosp_15_r20/tools/acloud/internal/lib/ |
| H A D | emulator_console.py | 125 def Recv(self, expected_substring, buffer_size=128): member in RemoteEmulatorConsole
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/cmd/compile/internal/types2/ |
| D | selection.go | 84 func (s *Selection) Recv() Type { return s.recv } func
|
| D | signature.go | 71 func (s *Signature) Recv() *Var { return s.recv } func
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/go/types/ |
| D | selection.go | 87 func (s *Selection) Recv() Type { return s.recv } func
|
| D | signature.go | 82 func (s *Signature) Recv() *Var { return s.recv } func
|
| /aosp_15_r20/packages/modules/Bluetooth/tools/rootcanal/net/posix/ |
| D | posix_async_socket.cc | 67 ssize_t PosixAsyncSocket::Recv(uint8_t* buffer, uint64_t bufferSize) { in Recv() function in android::net::PosixAsyncSocket
|
| /aosp_15_r20/external/webrtc/rtc_base/ |
| H A D | async_socket.cc | 54 int AsyncSocketAdapter::Recv(void* pv, size_t cb, int64_t* timestamp) { in Recv() function in rtc::AsyncSocketAdapter
|
| /aosp_15_r20/device/google/cuttlefish/common/libs/utils/ |
| D | tcp_socket.cpp | 51 Message ClientSocket::Recv(std::size_t length) { in Recv() function in cuttlefish::ClientSocket
|
| /aosp_15_r20/external/crosvm/base/src/ |
| H A D | tube.rs | 136 Recv(io::Error), enumerator
|
| /aosp_15_r20/packages/modules/Bluetooth/system/gd/hal/ |
| D | syscall_wrapper_impl.cc | 52 ssize_t SyscallWrapperImpl::Recv(int fd, void* buf, size_t n, int flags) { in Recv() function in bluetooth::hal::SyscallWrapperImpl
|
| /aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/g3doc/ |
| H A D | operation_semantics.md | 1913 ## Recv section in Operation Semantics
|