Home
last modified time | relevance | path

Searched defs:recv (Results 1 – 25 of 159) sorted by relevance

1234567

/external/cronet/third_party/protobuf/ruby/src/main/java/com/google/protobuf/jruby/
DRubyEnum.java49 public static IRubyObject lookup(ThreadContext context, IRubyObject recv, IRubyObject number) { in lookup()
62 public static IRubyObject resolve(ThreadContext context, IRubyObject recv, IRubyObject name) { in resolve()
75 public static IRubyObject getDescriptor(ThreadContext context, IRubyObject recv) { in getDescriptor()
DRubyMessage.java547 public static IRubyObject getDescriptor(ThreadContext context, IRubyObject recv) { in getDescriptor()
561 public static IRubyObject encode(ThreadContext context, IRubyObject recv, IRubyObject[] args) { in encode()
590 public static IRubyObject decode(ThreadContext context, IRubyObject recv, IRubyObject[] args) { in decode()
639 …public static IRubyObject encodeJson(ThreadContext context, IRubyObject recv, IRubyObject[] args) { in encodeJson()
692 …public static IRubyObject decodeJson(ThreadContext context, IRubyObject recv, IRubyObject[] args) { in decodeJson()
/external/protobuf/ruby/src/main/java/com/google/protobuf/jruby/
DRubyEnum.java49 public static IRubyObject lookup(ThreadContext context, IRubyObject recv, IRubyObject number) { in lookup()
62 public static IRubyObject resolve(ThreadContext context, IRubyObject recv, IRubyObject name) { in resolve()
75 public static IRubyObject getDescriptor(ThreadContext context, IRubyObject recv) { in getDescriptor()
DRubyMessage.java576 public static IRubyObject getDescriptor(ThreadContext context, IRubyObject recv) { in getDescriptor()
590 public static IRubyObject encode(ThreadContext context, IRubyObject recv, IRubyObject[] args) { in encode()
621 public static IRubyObject decode(ThreadContext context, IRubyObject recv, IRubyObject[] args) { in decode()
683 ThreadContext context, IRubyObject recv, IRubyObject[] args) { in encodeJson()
739 ThreadContext context, IRubyObject recv, IRubyObject[] args) { in decodeJson()
/external/rust/crates/tokio/src/signal/
Dwindows.rs90 pub async fn recv(&mut self) -> Option<()> { in recv() method
162 pub async fn recv(&mut self) -> Option<()> { in recv() method
288 pub async fn recv(&mut self) -> Option<()> { in recv() method
385 pub async fn recv(&mut self) -> Option<()> { in recv() method
482 pub async fn recv(&mut self) -> Option<()> { in recv() method
Dmod.rs86 async fn recv(&mut self) -> Option<()> { in recv() method
/external/webrtc/pc/
Drtp_media_utils_unittest.cc37 bool recv = RtpTransceiverDirectionHasRecv(direction); in TEST_P() local
47 bool recv = RtpTransceiverDirectionHasRecv(direction); in TEST_P() local
83 bool recv = std::get<1>(GetParam()); in TEST_P() local
Drtp_media_utils.cc18 bool recv) { in RtpTransceiverDirectionFromSendRecv()
66 bool recv) { in RtpTransceiverDirectionWithRecvSet()
/external/scapy/scapy/
Dsupersocket.py46 def recv(self, x=MTU): member in SuperSocket
83 def recv(self, x=MTU): member in L3RawSocket
136 def recv(self, x=MTU): member in StreamSocket
160 def recv(self, x=65535): member in SSLStreamSocket
217 def recv(self, x=MTU): member in L2ListenTcpdump
271 def recv(self, x=MTU): member in TunTapInterface
/external/rust/crates/tokio/tests/support/
Dmpsc_stream.rs9 recv: UnboundedReceiver<T>, field
27 recv: Receiver<T>, field
/external/scapy/scapy/arch/
Dpcapdnet.py208 def recv(self, x=MTU): member in L2pcapListenSocket
284 def recv(self,x=MTU): member in L2pcapSocket
327 def recv(self, x = MTU): member in L3pcapSocket
466 def recv(self, x=MTU): member in L2pcapListenSocket
633 def recv(self,x=MTU): member in L3dnetSocket
705 def recv(self,x=MTU): member in L2dnetSocket
Dlinux.py435 def recv(self, x=MTU): member in L3PacketSocket
529 def recv(self, x=MTU): member in L2Socket
593 def recv(self, x=MTU): member in L2ListenSocket
/external/openthread/tools/harness-simulation/posix/sniffer_sim/
Dsniffer_transport.py74 def recv(self, bufsize): member in SnifferTransport
148 def recv(self, bufsize): member in SnifferSocketTransport
/external/musl/src/network/
Drecv.c3 ssize_t recv(int fd, void *buf, size_t len, int flags) in recv() function
/external/openthread/tests/scripts/thread-cert/
Dsniffer_transport.py75 def recv(self, bufsize): member in SnifferTransport
153 def recv(self, bufsize): member in SnifferSocketTransport
/external/rust/crates/tokio-util/tests/
Dudp.rs33 let recv = b.next().map(|e| e.unwrap()); in send_framed_byte_codec() localVariable
53 let recv = b.next().map(|e| e.unwrap()); in send_framed_byte_codec() localVariable
/external/rust/crates/quiche/src/
Dstream.rs647 pub recv: RecvBuf, field
1673 let mut recv = RecvBuf::new(u64::MAX, DEFAULT_STREAM_WINDOW); in empty_read() localVariable
1683 let mut recv = RecvBuf::new(15, DEFAULT_STREAM_WINDOW); in empty_stream_frame() localVariable
1739 let mut recv = RecvBuf::new(u64::MAX, DEFAULT_STREAM_WINDOW); in ordered_read() localVariable
1776 let mut recv = RecvBuf::new(u64::MAX, DEFAULT_STREAM_WINDOW); in split_read() localVariable
1816 let mut recv = RecvBuf::new(u64::MAX, DEFAULT_STREAM_WINDOW); in incomplete_read() localVariable
1844 let mut recv = RecvBuf::new(u64::MAX, DEFAULT_STREAM_WINDOW); in zero_len_read() localVariable
1872 let mut recv = RecvBuf::new(u64::MAX, DEFAULT_STREAM_WINDOW); in past_read() localVariable
1911 let mut recv = RecvBuf::new(u64::MAX, DEFAULT_STREAM_WINDOW); in fully_overlapping_read() localVariable
1942 let mut recv = RecvBuf::new(u64::MAX, DEFAULT_STREAM_WINDOW); in fully_overlapping_read2() localVariable
[all …]
/external/scapy/scapy/arch/bpf/
Dsupersocket.py201 def recv(self, x=BPF_BUFFER_LENGTH): member in _L2bpfSocket
267 def recv(self, x=BPF_BUFFER_LENGTH): member in L2bpfListenSocket
/external/rust/crates/tokio/src/runtime/tests/
Dloom_oneshot.rs39 pub(crate) fn recv(self) -> T { in recv() method
/external/autotest/server/cros/network/rf_switch/
Drf_mocks.py38 def recv(self, size): member in SocketMock
/external/rust/crates/tokio/src/sync/tests/
Dloom_notify.rs116 let mut recv = Box::pin(rx1.notified()); in notify_drop() localVariable
/external/rust/crates/tokio/tests/
Dsync_mpsc.rs302 let mut recv = tokio_test::task::spawn(rx.recv()); in recv_close_gets_none_reserved() localVariable
514 let mut recv = tokio_test::task::spawn(rx.recv()); in ready_close_cancel_bounded() localVariable
Dsync_broadcast.rs99 let mut recv = task::spawn(rx.recv()); in send_recv_bounded() localVariable
153 let mut recv = Box::pin(rx.recv()); in change_tasks() localVariable
/external/mesa3d/src/vulkan/overlay-layer/
Dmesa-overlay-control.py36 def recv(self, timeout): member in Connection
/external/python/python-api-core/google/api_core/
Dbidi.py325 def recv(self): member in BidiRpc
560 def recv(self): member in ResumableBidiRpc

1234567