| /haiku/src/kits/app/ |
| H A D | PortLink.cpp | 16 PortLink::PortLink(port_id send, port_id receive) argument
19 fReceiver = new LinkReceiver(receive);
|
| /haiku/headers/private/net/ |
| H A D | net_socket.h | 41 } send, receive; member in struct:net_socket
107 ssize_t (*receive)(net_socket* socket, struct msghdr* , void* data, member in struct:net_socket_module_info
|
| H A D | ProtocolUtilities.h | 311 if (fSocket->receive.buffer_size > 0
312 && (fCurrentBytes + buffer->size) > fSocket->receive.buffer_size)
378 bigtime_t timeout = fSocket->receive.timeout;
|
| H A D | net_stack.h | 64 status_t (*receive)(struct net_device_monitor* monitor, member in struct:net_device_monitor
|
| /haiku/headers/posix/net/ |
| H A D | if.h | 28 struct ifreq_stream_stats receive; member in struct:ifreq_stats
75 #define IFF_PROMISC 0x0100 /* receive all packets */
76 #define IFF_ALLMULTI 0x0200 /* receive all multicast packets */
77 #define IFF_SIMPLEX 0x0800 /* doesn't receive own transmissions */
|
| /haiku/src/add-ons/kernel/network/stack/ |
| H A D | net_socket.cpp | 109 receive.buffer_size = 65535;
110 receive.low_water_mark = 1;
111 receive.timeout = B_INFINITE_TIMEOUT;
650 socket->receive = parent->receive;
831 if ((ssize_t)socket->receive.low_water_mark <= available
875 if ((ssize_t)socket->receive.low_water_mark > value
1039 *size = socket->receive.buffer_size;
1055 *size = socket->receive.low_water_mark;
1070 timeout = socket->receive
[all...] |
| H A D | stack_interface.cpp | 77 return gNetSocketModule.receive(socket, NULL, data, length, flags);
98 ssize_t received = gNetSocketModule.receive(socket, &message, data, length,
118 return gNetSocketModule.receive(socket, message, buffer, length, flags);
|
| H A D | device_interfaces.cpp | 45 as available, deframes them, and puts them into the receive queue of the
67 atomic_add((int32*)&device->stats.receive.dropped, 1);
74 atomic_add((int32*)&device->stats.receive.packets, 1);
75 atomic_add64((int64*)&device->stats.receive.bytes, packetSize);
78 atomic_add((int32*)&device->stats.receive.dropped, 1);
84 atomic_add((int32*)&device->stats.receive.errors, 1);
152 /*! The domain's device receive handler - this will inject the net_buffers into
153 the protocol layer (the domain's registered receive handler).
186 recursive_lock_init(&interface->receive_lock, "device interface receive");
190 snprintf(name, sizeof(name), "%s receive queu
[all...] |
| H A D | link.cpp | 91 fMonitor.receive = _MonitorData;
172 // receive any buffers
626 // We never receive any data this way
|
| /haiku/src/apps/activitymonitor/ |
| H A D | SystemInfo.cpp | 174 fBytesReceived += stats.receive.bytes;
|
| /haiku/src/bin/network/ifconfig/ |
| H A D | ifconfig.cpp | 613 "dropped\n", stats.receive.packets, stats.receive.errors,
614 stats.receive.bytes, stats.receive.multicast_packets,
615 stats.receive.dropped);
|
| /haiku/src/tests/system/network/tcp_shell/ |
| H A D | tcp_shell.cpp | 290 socket->receive.buffer_size = 65535;
291 socket->receive.low_water_mark = 1;
292 socket->receive.timeout = B_INFINITE_TIMEOUT;
508 socket->receive = parent->receive;
623 if ((ssize_t)socket->receive.low_water_mark > value && value >= B_OK)
693 NULL, // receive,
1374 context.wait_sem = create_sem(0, "receive wait");
|
| /haiku/src/add-ons/kernel/network/protocols/tcp/ |
| H A D | TCPEndpoint.cpp | 110 out.Print("tcp:%p (%12s) receive buffer %p (%" B_PRIu32 " bytes), "
443 fReceiveWindow(socket->receive.buffer_size),
445 fReceiveQueue(socket->receive.buffer_size),
460 fReceiveCondition.Init(this, "tcp receive");
692 bigtime_t timeout = absolute_timeout(socket->receive.timeout);
704 if (status == B_TIMED_OUT && socket->receive.timeout == 0)
953 timeout = absolute_timeout(socket->receive.timeout);
969 size_t dataNeeded = socket->receive.low_water_mark;
1032 socket->receive.low_water_mark = 0;
1259 // #pragma mark - receive
[all...] |
| /haiku/src/add-ons/kernel/network/protocols/unix/ |
| H A D | UnixStreamEndpoint.cpp | 344 bigtime_t timeout = absolute_timeout(socket->receive.timeout);
481 timeout = absolute_timeout(socket->receive.timeout);
731 // Write shutdown the receive FIFO.
|
| H A D | UnixDatagramEndpoint.cpp | 335 timeout = absolute_timeout(socket->receive.timeout);
|
| /haiku/headers/private/userlandfs/fuse/ |
| H A D | fuse_lowlevel_compat.h | 145 int (*receive)(struct fuse_chan *ch, char *buf, size_t size); member in struct:fuse_chan_ops_compat24
|
| H A D | fuse_lowlevel.h | 154 * receive a request handle (fuse_req_t) as their first argument.
217 * Inodes with a non-zero lookup count may receive request from
233 * receive corresponding forget messages for the affected
1730 int (*receive)(struct fuse_chan **chp, char *buf, size_t size); member in struct:fuse_chan_ops
1759 * @param bufsize the minimal receive buffer size
1775 * Query the minimal receive buffer size
|
| /haiku/src/preferences/network/ |
| H A D | InterfaceView.cpp | 222 string_for_size(stats.receive.bytes, buffer, sizeof(buffer));
|
| /haiku/src/add-ons/kernel/network/devices/ethernet/ |
| H A D | ethernet.cpp | 390 atomic_add((int32*)&device->stats.receive.dropped, 1);
|
| /haiku/src/add-ons/kernel/network/devices/dialup/ |
| H A D | dialup.cpp | 501 atomic_add((int32*)&device->stats.receive.dropped, 1);
|