Lines Matching refs:buf_size
375 size_t buf_size; in test_seqpacket_msg_bounds_client() local
381 buf_size = page_size + in test_seqpacket_msg_bounds_client()
384 buf_size = 1 + (rand() % page_size); in test_seqpacket_msg_bounds_client()
386 buf = malloc(buf_size); in test_seqpacket_msg_bounds_client()
393 memset(buf, rand() & 0xff, buf_size); in test_seqpacket_msg_bounds_client()
402 send_buf(fd, buf, buf_size, flags, buf_size); in test_seqpacket_msg_bounds_client()
413 curr_hash += hash_djb2(buf, buf_size); in test_seqpacket_msg_bounds_client()
624 size_t buf_size; in test_seqpacket_bigmsg_client() local
646 buf_size = (size_t)sock_buf_size; in test_seqpacket_bigmsg_client()
647 if (buf_size != sock_buf_size) { in test_seqpacket_bigmsg_client()
652 data = malloc(buf_size); in test_seqpacket_bigmsg_client()
658 send_buf(fd, data, buf_size, 0, -EMSGSIZE); in test_seqpacket_bigmsg_client()
689 int buf_size = getpagesize() * 3; in test_seqpacket_invalid_rec_buffer_client() local
697 buf1 = malloc(buf_size); in test_seqpacket_invalid_rec_buffer_client()
703 buf2 = malloc(buf_size); in test_seqpacket_invalid_rec_buffer_client()
709 memset(buf1, BUF_PATTERN_1, buf_size); in test_seqpacket_invalid_rec_buffer_client()
710 memset(buf2, BUF_PATTERN_2, buf_size); in test_seqpacket_invalid_rec_buffer_client()
712 send_buf(fd, buf1, buf_size, 0, buf_size); in test_seqpacket_invalid_rec_buffer_client()
714 send_buf(fd, buf2, buf_size, 0, buf_size); in test_seqpacket_invalid_rec_buffer_client()
725 int buf_size = page_size * 3; in test_seqpacket_invalid_rec_buffer_server() local
738 broken_buf = mmap(NULL, buf_size, prot, flags, -1, 0); in test_seqpacket_invalid_rec_buffer_server()
750 valid_buf = mmap(NULL, buf_size, prot, flags, -1, 0); in test_seqpacket_invalid_rec_buffer_server()
757 res = read(fd, broken_buf, buf_size); in test_seqpacket_invalid_rec_buffer_server()
771 res = read(fd, valid_buf, buf_size); in test_seqpacket_invalid_rec_buffer_server()
777 if (res != buf_size) { in test_seqpacket_invalid_rec_buffer_server()
780 buf_size, res); in test_seqpacket_invalid_rec_buffer_server()
784 for (i = 0; i < buf_size; i++) { in test_seqpacket_invalid_rec_buffer_server()
796 munmap(valid_buf, buf_size); in test_seqpacket_invalid_rec_buffer_server()
1409 size_t buf_size; in test_stream_rcvlowat_def_cred_upd_client() local
1420 buf_size = RCVLOWAT_CREDIT_UPD_BUF_SIZE + 1; in test_stream_rcvlowat_def_cred_upd_client()
1422 buf = malloc(buf_size); in test_stream_rcvlowat_def_cred_upd_client()
1431 if (send(fd, buf, buf_size, 0) != buf_size) { in test_stream_rcvlowat_def_cred_upd_client()
1445 size_t buf_size; in test_stream_credit_update_test() local
1456 buf_size = RCVLOWAT_CREDIT_UPD_BUF_SIZE; in test_stream_credit_update_test()
1459 sock_buf_size = buf_size; in test_stream_credit_update_test()
1484 buf = malloc(buf_size); in test_stream_credit_update_test()
1494 res = recv(fd, buf, buf_size, MSG_PEEK); in test_stream_credit_update_test()
1495 if (res == buf_size) in test_stream_credit_update_test()