| /third_party/lwip/test/sockets/ |
| D | sockets_stresstest.c | 154 recv_and_check_data_return_offset(int s, char *rxbuf, size_t rxbufsize, size_t rxoff, int *closed, … in recv_and_check_data_return_offset() argument
158 ret = lwip_read(s, &rxbuf[rxoff], rxbufsize - rxoff); in recv_and_check_data_return_offset()
175 return check_test_data(rxbuf, rxoff + ret); in recv_and_check_data_return_offset()
408 char rxbuf[TEST_TXRX_BUFSIZE]; in sockets_stresstest_conn_client_r() local
415 rxoff = recv_and_check_data_return_offset(s, rxbuf, sizeof(rxbuf), rxoff, &closed, "cli"); in sockets_stresstest_conn_client_r()
437 char rxbuf[TEST_TXRX_BUFSIZE]; in sockets_stresstest_conn_client() local
482 rxoff = recv_and_check_data_return_offset(s, rxbuf, sizeof(rxbuf), rxoff, &closed, "cli"); in sockets_stresstest_conn_client()
514 char rxbuf[TEST_TXRX_BUFSIZE]; in sockets_stresstest_conn_server() local
531 rxoff = recv_and_check_data_return_offset(s, rxbuf, sizeof(rxbuf), rxoff, &closed, "srv"); in sockets_stresstest_conn_server()
|
| /third_party/lwip/test/unit/mqtt/ |
| D | test_mqtt.c | 83 unsigned char rxbuf[] = {0x20, 0x02, 0x00, 0x00}; in START_TEST() local
94 p = pbuf_alloc(PBUF_RAW, sizeof(rxbuf), PBUF_REF); in START_TEST()
96 p->payload = rxbuf; in START_TEST()
|
| /third_party/lwip/test/unit/api/ |
| D | test_sockets.c | 697 char rxbuf[16]; in START_TEST() local
790 ret = lwip_recv(spass, rxbuf, sizeof(rxbuf), 0); in START_TEST()
796 ret = lwip_recv(spass, rxbuf, sizeof(rxbuf), 0); in START_TEST()
804 ret = lwip_recv(spass, rxbuf, sizeof(rxbuf), 0); in START_TEST()
812 ret = lwip_recv(spass, rxbuf, sizeof(rxbuf), 0); in START_TEST()
|
| /third_party/libnl/lib/ |
| D | socket.c | 813 int nl_socket_set_buffer_size(struct nl_sock *sk, int rxbuf, int txbuf) in nl_socket_set_buffer_size() argument
817 if (rxbuf <= 0) in nl_socket_set_buffer_size()
818 rxbuf = 32768; in nl_socket_set_buffer_size()
835 &rxbuf, sizeof(rxbuf)); in nl_socket_set_buffer_size()
|
| /third_party/boost/libs/beast/test/beast/core/ |
| D | flat_stream.cpp | 217 net::mutable_buffer rxbuf, in testAwaitableCompiles() argument
222 stream.async_read_some(rxbuf, net::use_awaitable))>); in testAwaitableCompiles()
|
| D | buffered_read_stream.cpp | 229 net::mutable_buffer rxbuf, in testAwaitableCompiles() argument
234 stream.async_read_some(rxbuf, net::use_awaitable))>); in testAwaitableCompiles()
|
| /third_party/boost/boost/move/algo/detail/ |
| D | merge.hpp | 905 range_xbuf<Pointer, size_type, move_op> rxbuf(buffer, buffer + buffer_size); in merge_adaptive_ONlogN_recursive() local
906 buffered_merge(first, middle, last, comp, rxbuf); in merge_adaptive_ONlogN_recursive()
|
| /third_party/lwip/src/api/ |
| D | sockets.c | 3844 struct netbuf *rxbuf; in lwip_ioctl() local
3845 err_t err = netconn_recv_udp_raw_netbuf_flags(sock->conn, &rxbuf, NETCONN_DONTBLOCK); in lwip_ioctl()
3849 sock->lastdata.netbuf = rxbuf; in lwip_ioctl()
3850 *((int *)argp) = rxbuf->p->tot_len; in lwip_ioctl()
|