/haiku/src/add-ons/kernel/drivers/disk/virtual/nbd/ |
H A D | nbd-server.py | 40 def recv(self, nbytes): member in class:buffsock 43 more = self.sock.recv(nbytes - len(rv)) 54 def recv(self, nbytes): member in class:debugsock 55 print "recv(%d) =" % nbytes, 56 rv = self.sock.recv(nbytes) 88 header = conn.recv(struct.calcsize(template)) 93 self.data = conn.recv(self.len)
|
/haiku/build/scripts/ |
H A D | bootstrap_client.py | 62 data = stdioConnection.recv(bufferSize) 69 data = stderrConnection.recv(bufferSize) 76 data = controlConnection.recv(bufferSize)
|
H A D | bootstrap_daemon.py | 15 dataReceived = connection.recv(size)
|
/haiku/src/tests/system/network/multicast/ |
H A D | multicast.cpp | 36 int len = recv(sock, buf, sizeof(buf), 0);
|
/haiku/src/tests/system/network/ |
H A D | unix_recv_test.c | 33 printf("recv %i\n", ok); 34 ret = recv(fds[0], &buf[0], bufLen, MSG_DONTWAIT); 38 perror("recv");
|
H A D | tcp_client.c | 64 if ((numBytes = recv(sockfd, buffer, sizeof(buffer) - 1, 0)) == -1) { 65 perror("recv");
|
H A D | ipv46_server.cpp | 19 int ret = recv(fd, buffer, sizeof(buffer) - 1, 0); 21 perror("recv");
|
H A D | udp_connect.cpp | 25 if (argc > 2 && !strcmp(argv[2], "recv")) 71 ssize_t bytesReceived = recv(fd, buffer, sizeof(buffer), 0); 76 perror("recv");
|
H A D | tcp_server.c | 122 if ((numBytes = recv(new_fd, buf, MAXDATASIZE, 0)) == -1) { 123 perror("recv");
|
H A D | unix_dgram_test.cpp | 265 status = recv(sock1, buf, sizeof(buf), 0); 267 REPORT_ERROR("recv() failed: %s\n", strerror(errno)); 271 REPORT_ERROR("recv() received unexpected data: %s\n", buf); 281 REPORT_ERROR("recv() failed: %s\n", strerror(errno)); 285 REPORT_ERROR("recv() received unexpected data: %s\n", buf); 289 REPORT_ERROR("recv() received unexpected address: %s\n", addr3.sun_path); 306 status = recv(sock1, buf, 4, 0); 308 REPORT_ERROR("recv() failed: %s\n", strerror(errno)); 312 REPORT_ERROR("recv() received unexpected data: %s\n", buf); 318 status = recv(sock [all...] |
/haiku/headers/private/drivers/ |
H A D | ksocket.h | 23 #define krecv recv 47 #define krecv recv 75 #define krecv (gSocket->recv)
|
/haiku/src/add-ons/kernel/file_systems/nfs/ |
H A D | ksocket.h | 23 #define krecv recv 50 #define krecv (gSocket->recv) 88 #define krecv (gSocket->recv)
|
/haiku/src/add-ons/kernel/file_systems/websearchfs/ |
H A D | ksocket.h | 23 #define krecv recv 45 #define krecv recv 73 #define krecv (gSocket->recv)
|
/haiku/src/add-ons/kernel/bus_managers/firewire/ |
H A D | fwmem.cpp | 75 xfer->recv.pay_len = rlen; 104 xfer->recv.payload = (uint32_t *)data; 140 xfer->send.payload = xfer->recv.payload = NULL; 179 xfer->recv.payload = (uint32_t*)data; 217 xfer->recv.payload = NULL;
|
H A D | firewire.cpp | 1079 fw_dump_hdr(&xfer->recv.hdr, "recv"); 1162 xfer->recv.pay_len = recv_len; 1180 /* xfer->recv.payload = malloc(recv_len); 1181 if (xfer->recv.payload == NULL) { 1187 xfer->recv.payArea = alloc_mem(&recv_virt, &recv_phy, 1189 if (xfer->recv.payArea < B_OK){ 1198 xfer->recv.payload = (uint32_t *)recv_virt; 1199 xfer->recv.bus_addr = (bus_addr_t)(addr_t)recv_phy; 1267 if(xfer->recv [all...] |
/haiku/src/bin/debug/strace/ |
H A D | network.cpp | 104 Syscall *recv = get_syscall("_kern_recv"); local 105 recv->GetParameter("flags")->SetHandler(new FlagsTypeHandler(kRecvFlags));
|
/haiku/src/tests/system/network/ipv6/ |
H A D | tcp_udp_server.cpp | 32 int status = recv(fd, buffer, sizeof(buffer) - 1, 0); 34 perror("recv");
|
/haiku/src/kits/network/libnetapi/ |
H A D | Socket.cpp | 84 ssize_t bytesReceived = recv(Socket(), buffer, size, 0);
|
H A D | DatagramSocket.cpp | 124 ssize_t bytesReceived = recv(Socket(), buffer, size, 0);
|
/haiku/src/add-ons/kernel/drivers/bus/firewire/ |
H A D | fw_raw.c | 318 fp = &xfer->recv.hdr; 337 // err = uiomove((void *)xfer->recv.payload, xfer->recv.pay_len, uio); 338 len = xfer->recv.pay_len; 340 err = user_memcpy(buf, (void *)xfer->recv.payload, len); 349 xfer->recv.pay_len = B_PAGE_SIZE; 810 tinfo = &fc->tcode[xfer->recv.hdr.mode.hdr.tcode]; 811 if (xfer->recv.hdr.mode.hdr.tcode == FWTCODE_RRESB || 812 xfer->recv.hdr.mode.hdr.tcode == FWTCODE_LRES) { 813 pay_len = xfer->recv [all...] |
/haiku/src/bin/network/telnet/ |
H A D | sys_bsd.c | 1045 c = recv(net, netiring.supply, canread, MSG_OOB); 1047 c = recv(net, netiring.supply, canread, 0); 1055 * recv(MSG_OOB). So, we do one. If it 1064 i = recv(net, netiring.supply + c, canread - c, MSG_OOB); 1087 c = recv(net, netiring.supply, canread, 0); 1090 c = recv(net, netiring.supply, canread, 0); 1094 c = recv(net, (char *)netiring.supply, canread, 0);
|
/haiku/headers/private/net/ |
H A D | net_stack_interface.h | 40 ssize_t (*recv)(net_socket* socket, void* data, size_t length, int flags); member in struct:net_stack_interface_module_info
|
/haiku/src/add-ons/kernel/file_systems/netfs/shared/ |
H A D | InsecureChannel.cpp | 107 int32 bytesRead = recv(fSocket, buffer, size, 0);
|
/haiku/src/add-ons/print/transports/shared/ |
H A D | Socket.cpp | 148 size = ::recv(__sock, buffer, size, flags); 150 sprintf(__error_msg, "recv failed. errno = %d", errno);
|
/haiku/src/tests/system/network/tcptester/ |
H A D | tcptester.cpp | 158 int size = recv(ctx->sock, ctx->buffer + index, 1, 0);
|