| /linux/tools/testing/selftests/bpf/prog_tests/ |
| H A D | sockmap_strp.c | 23 int recvd; in sockmap_strp_consume_pre_data() local
29 recvd = recv_timeout(p, rcv, sizeof(rcv), 0, 1); in sockmap_strp_consume_pre_data()
30 if (recvd < 0 && errno == EAGAIN && retried == false) { in sockmap_strp_consume_pre_data()
39 if (!ASSERT_EQ(recvd, STRP_PKT_FULL_LEN, "recv error or truncated data") || in sockmap_strp_consume_pre_data()
92 int i, j, zero = 0, one = 1, recvd; in test_sockmap_strp_dispatch_pkt() local
144 recvd = recv_timeout(*send_dir[i].receiver, rcv, in test_sockmap_strp_dispatch_pkt()
147 if (!ASSERT_EQ(recvd, expected, "recv_timeout()")) in test_sockmap_strp_dispatch_pkt()
149 if (!ASSERT_OK(memcmp(send_dir[i].data, rcv, recvd), in test_sockmap_strp_dispatch_pkt()
171 int sent, recvd, total; in test_sockmap_strp_multiple_pkt() local
207 recvd = recv_timeout(p, rcv, total + 1, MSG_DONTWAIT, IO_TIMEOUT_SEC); in test_sockmap_strp_multiple_pkt()
[all …]
|
| H A D | sockmap_ktls.c | 137 int c = 0, p = 0, sent, recvd; in test_sockmap_ktls_offload() local
149 recvd = recv(p, rcv, sizeof(rcv), 0); in test_sockmap_ktls_offload()
151 !ASSERT_EQ(recvd, sent, "length mismatch")) in test_sockmap_ktls_offload()
168 int c = 0, p = 0, one = 1, sent, recvd; in test_sockmap_ktls_tx_cork() local
210 recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, 1); in test_sockmap_ktls_tx_cork()
211 if (!ASSERT_EQ(-1, recvd, "expected no data")) in test_sockmap_ktls_tx_cork()
219 recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, 1); in test_sockmap_ktls_tx_cork()
221 !ASSERT_EQ(recvd, sizeof(msg) + push_len, "check length mismatch")) in test_sockmap_ktls_tx_cork()
224 for (i = 0, j = 0; i < recvd;) { in test_sockmap_ktls_tx_cork()
320 int c = 0, p = 0, one = 1, sent, recvd; in test_sockmap_ktls_tx_pop() local
[all …]
|
| H A D | sockmap_basic.c | 542 int expected, zero = 0, sent, recvd, avail; in test_sockmap_skb_verdict_fionread() local
584 recvd = recv_timeout(c1, &buf, sizeof(buf), MSG_DONTWAIT, IO_TIMEOUT_SEC); in test_sockmap_skb_verdict_fionread()
585 ASSERT_EQ(recvd, sizeof(buf), "recv_timeout(c0)"); in test_sockmap_skb_verdict_fionread()
604 int c1, p1, sent, recvd; in test_sockmap_skb_verdict_change_tail() local
625 recvd = recv(c1, buf, 2, 0); in test_sockmap_skb_verdict_change_tail()
626 ASSERT_EQ(recvd, 1, "recv(c1)"); in test_sockmap_skb_verdict_change_tail()
631 recvd = recv(c1, buf, 2, 0); in test_sockmap_skb_verdict_change_tail()
632 ASSERT_EQ(recvd, 2, "recv(c1)"); in test_sockmap_skb_verdict_change_tail()
637 recvd = recv(c1, buf, 1, 0); in test_sockmap_skb_verdict_change_tail()
638 ASSERT_EQ(recvd, 1, "recv(c1)"); in test_sockmap_skb_verdict_change_tail()
[all …]
|
| H A D | mptcp.c | 445 int server_fd1 = -1, server_fd2 = -1, sent, recvd; in test_sockmap_with_mptcp_fallback() local
477 recvd = recv(client_fd2, rcv, sizeof(rcv), 0); in test_sockmap_with_mptcp_fallback()
478 if (!ASSERT_EQ(recvd, sizeof(snd), "sockmap-fb:recv(client_fd2)")) in test_sockmap_with_mptcp_fallback()
|
| /linux/fs/nfs/ |
| H A D | nfs2xdr.c | 95 u32 recvd, count; in decode_nfsdata() local
102 recvd = xdr_read_pages(xdr, count); in decode_nfsdata()
103 if (unlikely(count > recvd)) in decode_nfsdata()
111 "count %u > recvd %u\n", count, recvd); in decode_nfsdata()
112 count = recvd; in decode_nfsdata()
428 u32 length, recvd; in decode_path() local
437 recvd = xdr_read_pages(xdr, length); in decode_path()
438 if (unlikely(length > recvd)) in decode_path()
447 "length %u > received %u\n", length, recvd); in decode_path()
|
| H A D | nfs3xdr.c | 228 u32 recvd, count; in decode_nfspath3() local
237 recvd = xdr_read_pages(xdr, count); in decode_nfspath3()
238 if (unlikely(count > recvd)) in decode_nfspath3()
248 "count %u > recvd %u\n", count, recvd); in decode_nfspath3()
1605 u32 eof, count, ocount, recvd; in decode_read3resok() local
1616 recvd = xdr_read_pages(xdr, count); in decode_read3resok()
1617 if (unlikely(count > recvd)) in decode_read3resok()
1629 "count %u > recvd %u\n", count, recvd); in decode_read3resok()
1630 count = recvd; in decode_read3resok()
|
| H A D | nfs4xdr.c | 5417 uint32_t count, eof, recvd; in decode_read() local
5428 recvd = xdr_read_pages(xdr, count); in decode_read()
5429 if (count > recvd) { in decode_read()
5431 "count %u > recvd %u\n", count, recvd); in decode_read()
5432 count = recvd; in decode_read()
5459 u32 len, recvd; in decode_readlink() local
5476 recvd = xdr_read_pages(xdr, len); in decode_readlink()
5477 if (recvd < len) { in decode_readlink()
5479 "count %u > recvd %u\n", len, recvd); in decode_readlink()
6161 u32 recvd; in decode_layoutget() local
[all …]
|
| /linux/drivers/iio/pressure/ |
| H A D | hsc030pa.c | 352 u32 recvd; in hsc_read_raw() local
360 recvd = get_unaligned_be32(data->buffer); in hsc_read_raw()
363 *val = FIELD_GET(HSC_PRESSURE_MASK, recvd); in hsc_read_raw()
366 *val = FIELD_GET(HSC_TEMPERATURE_MASK, recvd); in hsc_read_raw()
|