| /system/core/libcutils/tests/ |
| D | sockets_test.cpp | 47 EXPECT_EQ(3, recv(server, buffer, sizeof(buffer), 0)); in TestConnectedSockets()
58 EXPECT_EQ(3, recv(client, buffer, sizeof(buffer), 0)); in TestConnectedSockets()
67 EXPECT_EQ(11, recv(server, buffer, sizeof(buffer), 0)); in TestConnectedSockets()
83 EXPECT_EQ(-1, recv(sock, buffer, sizeof(buffer), 0)); in TestReceiveTimeout()
89 EXPECT_EQ(-1, recv(sock, buffer, sizeof(buffer), 0)); in TestReceiveTimeout()
|
| /system/core/logd/tests/ |
| D | logd_test.cpp | 322 user_logger_content = recv(fd, msg.buf, sizeof(msg), 0) > 0; in TEST()
574 content_wrap = recv(fd, msg_wrap.buf, sizeof(msg_wrap), 0) > 0; in timeout_negative()
578 content_timeout = recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0) > 0; in timeout_negative()
580 content_timeout = recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0) > 0; in timeout_negative()
658 content_wrap = recv(fd, msg_wrap.buf, sizeof(msg_wrap), 0) > 0; in TEST()
662 content_timeout = recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0) > 0; in TEST()
664 content_timeout = recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0) > 0; in TEST()
743 bool read_one = recv(fd, msg.buf, sizeof(msg), 0) > 0; in TEST()
756 recv_ret = recv(fd, msg.buf, sizeof(msg), 0); in TEST()
|
| /system/extras/tests/net_test/ |
| D | tcp_nuke_addr_test.py | 73 _ = connection.recv(buffer_size)
134 read = self.sock.recv(4096)
|
| D | ping6_test.py | 419 self.assertRaisesErrno(errno.EAGAIN, s4.recv, 32768)
541 self.assertEquals("\xf9\x76", s.recv(32768)[4:6])
546 self.assertEquals("\x0a\xce", s.recv(32768)[4:6])
601 self.assertRaisesErrno(errno.EHOSTUNREACH, s.recv, 32768) # No response.
610 self.assertRaisesErrno(errno.EHOSTUNREACH, s.recv, 32768) # No response.
|
| D | netlink.py | 148 data = self.sock.recv(self.BUFSIZE)
|
| D | neighbour_test.py | 107 msg = self.sock.recv(4096)
|
| /system/netd/client/ |
| D | FwmarkClient.cpp | 100 if (TEMP_FAILURE_RETRY(recv(mChannel, &error, sizeof(error), 0)) == -1) { in send()
|
| /system/connectivity/shill/shims/ |
| D | nfqueue-seccomp-mips.policy | 37 recv: 1
|
| D | nfqueue-seccomp-arm.policy | 17 recv: 1
|
| D | netfilter_queue_processor.cc | 164 int receive_count = recv(file_handle, buffer, sizeof(buffer), 0); in Run()
|
| /system/sepolicy/ |
| D | access_vectors | 491 recv
525 recv
|
| /system/bt/btif/src/ |
| D | btif_sock_util.c | 83 OSI_NO_INTR(ret = recv(sock_fd, buf, r, MSG_WAITALL)); in sock_recv_all()
|
| /system/netd/server/ |
| D | SockDiag.cpp | 55 ssize_t bytesread = recv(fd, &ack, sizeof(ack), MSG_DONTWAIT | MSG_PEEK); in checkError()
61 recv(fd, &ack, sizeof(ack), 0); in checkError()
|
| /system/extras/alloc-stress/ |
| D | alloc-stress.cpp | 84 template <typename T> void recv(T& v) { in recv() function in Pipe
|
| /system/core/adb/ |
| D | jdwp_service.cpp | 268 int len = recv( socket, p, size, 0 ); in jdwp_process_event()
308 int len = recv(socket, buf, sizeof(buf), 0); in jdwp_process_event()
|
| /system/bt/udrv/ulinux/ |
| D | uipc.c | 337 OSI_NO_INTR(recv(uipc_main.signal_fds[0], &sig_recv, sizeof(sig_recv), in uipc_check_interrupt_locked()
778 OSI_NO_INTR(n = recv(fd, p_buf+n_read, len-n_read, 0)); in UIPC_Read()
|
| /system/bt/osi/src/ |
| D | socket.c | 134 OSI_NO_INTR(ret = recv(socket->fd, buf, count, MSG_DONTWAIT)); in socket_read()
|
| /system/extras/multinetwork/ |
| D | httpurl.cpp | 198 rval = recv(fd, buf, sizeof(buf), 0); in doHttpQuery()
|
| /system/core/fastboot/ |
| D | socket.cpp | 235 return TEMP_FAILURE_RETRY(recv(sock_, reinterpret_cast<char*>(data), length, 0)); in Receive()
|
| /system/bt/service/ipc/ |
| D | linux_ipc_host.cpp | 254 OSI_NO_INTR(size = recv(pfds_[kFdIpc].fd, &ipc_msg[0], 0, in OnMessage()
|
| /system/bt/stack/smp/ |
| D | smp_act.c | 108 static void smp_update_key_mask (tSMP_CB *p_cb, UINT8 key_type, BOOLEAN recv) in smp_update_key_mask() argument
111 __func__, p_cb->role, recv, p_cb->local_i_key, p_cb->local_r_key); in smp_update_key_mask()
125 if (recv) in smp_update_key_mask()
132 if (recv) in smp_update_key_mask()
|
| /system/core/init/ |
| D | property_service.cpp | 271 r = TEMP_FAILURE_RETRY(recv(s, &msg, sizeof(msg), MSG_DONTWAIT)); in handle_property_set_fd()
|
| /system/core/liblog/ |
| D | logd_reader.c | 621 ret = recv(ret, log_msg, LOGGER_ENTRY_MAX_LEN, 0); in logdRead()
|
| /system/bt/audio_a2dp_hw/ |
| D | audio_a2dp_hw.c | 266 OSI_NO_INTR(read = recv(fd, p, len, MSG_NOSIGNAL)); in skt_read()
339 OSI_NO_INTR(ret = recv(common->ctrl_fd, buffer, length, MSG_NOSIGNAL)); in a2dp_ctrl_receive()
|
| /system/core/libnetutils/ |
| D | ifc_utils.c | 351 len = recv(s, buf, sizeof(buf), 0); in ifc_act_on_address()
|