Lines Matching refs:EXPECT_EQ
205 EXPECT_EQ(cmsg->cmsg_level, SOL_TLS); in tls_recv_cmsg()
206 EXPECT_EQ(cmsg->cmsg_type, TLS_GET_RECORD_TYPE); in tls_recv_cmsg()
208 EXPECT_EQ(ctype, record_type); in tls_recv_cmsg()
239 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len); in TEST_F()
241 EXPECT_EQ(memcmp(buf, test_str, send_len), 0); in TEST_F()
250 …EXPECT_EQ(setsockopt(self->fd, SOL_TLS, TLS_TX, &tls12, sizeof(struct tls12_crypto_info_aes_gcm_12… in TEST_F()
254 …EXPECT_EQ(setsockopt(self->fd, SOL_TLS, TLS_TX, &tls12, sizeof(struct tls12_crypto_info_aes_gcm_12… in TEST_F()
258 …EXPECT_EQ(setsockopt(self->fd, SOL_TLS, TLS_TX, &tls12, sizeof(struct tls12_crypto_info_aes_gcm_12… in TEST_F()
262 …EXPECT_EQ(setsockopt(self->fd, SOL_TLS, TLS_TX, &tls12, sizeof(struct tls12_crypto_info_aes_gcm_12… in TEST_F()
266 …EXPECT_EQ(setsockopt(self->fd, SOL_TLS, TLS_TX, &tls12, sizeof(struct tls12_crypto_info_aes_gcm_12… in TEST_F()
424 EXPECT_EQ(send(self->fd, test_str, to_send, 0), to_send); in TEST_F()
425 EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send); in TEST_F()
426 EXPECT_EQ(memcmp(test_str, recv_buf, to_send), 0); in TEST_F()
429 EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size); in TEST_F()
452 EXPECT_EQ(size, test_payload_size); in chunked_sendfile()
461 EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL), in chunked_sendfile()
500 EXPECT_EQ(memcmp(buf, recv_mem, send_len), 0); in TEST_F()
510 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len); in TEST_F()
512 EXPECT_EQ(memcmp(buf, test_str, send_len), 0); in TEST_F()
521 EXPECT_EQ(send(self->fd, test_str, send_len, MSG_MORE), send_len); in TEST_F()
522 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
523 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len); in TEST_F()
524 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL), in TEST_F()
526 EXPECT_EQ(memcmp(buf, test_str, send_len), 0); in TEST_F()
535 EXPECT_EQ(send(self->fd, test_str, send_len, MSG_MORE), send_len); in TEST_F()
536 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
545 EXPECT_EQ(send(self->fd, test_str, send_len, MSG_EOR), send_len); in TEST_F()
546 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
547 EXPECT_EQ(memcmp(buf, test_str, send_len), 0); in TEST_F()
564 EXPECT_EQ(sendmsg(self->fd, &msg, 0), send_len); in TEST_F()
565 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
566 EXPECT_EQ(memcmp(buf, test_str, send_len), 0); in TEST_F()
589 EXPECT_EQ(sendmsg(self->fd, &msg, 0), SEND_LEN * frags); in TEST_F()
590 EXPECT_EQ(recv(self->cfd, buf, SEND_LEN * frags, MSG_WAITALL), in TEST_F()
594 EXPECT_EQ(memcmp(buf + SEND_LEN * i, in TEST_F()
616 EXPECT_EQ(sendmsg(self->fd, &msg, 0), send_len); in TEST_F()
649 EXPECT_EQ(sendmsg(self->fd, &msg, 0), total_len); in TEST_F()
653 EXPECT_EQ(memcmp(test_strs[i], buf + len_cmp, in TEST_F()
686 EXPECT_EQ(sendmsg(self->fd, &msg, 0), total_len); in TEST_F()
706 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
707 EXPECT_EQ(memcmp(mem_send, mem_recv, send_len), 0); in TEST_F()
721 EXPECT_EQ(splice(p[0], NULL, self->fd, NULL, send_pipe, f), 1); in TEST_F()
736 EXPECT_EQ(write(p[1], mem_send, 8000), 8000); in TEST_F()
737 EXPECT_EQ(splice(p[0], NULL, self->fd, NULL, 8000, 0), 8000); in TEST_F()
738 EXPECT_EQ(write(p2[1], mem_send + 8000, 8000), 8000); in TEST_F()
739 EXPECT_EQ(splice(p2[0], NULL, self->fd, NULL, 8000, 0), 8000); in TEST_F()
740 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
741 EXPECT_EQ(memcmp(mem_send, mem_recv, send_len), 0); in TEST_F()
755 EXPECT_EQ(send(self->fd, test_str, send_len2, 0), send_len2); in TEST_F()
756 EXPECT_EQ(recv(self->cfd, buf, send_len2, MSG_WAITALL), send_len2); in TEST_F()
757 EXPECT_EQ(memcmp(test_str, buf, send_len2), 0); in TEST_F()
762 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
763 EXPECT_EQ(memcmp(mem_send, mem_recv, send_len), 0); in TEST_F()
776 EXPECT_EQ(send(self->fd, mem_send, send_len, 0), send_len); in TEST_F()
777 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), send_len); in TEST_F()
778 EXPECT_EQ(read(p[0], mem_recv, send_len), send_len); in TEST_F()
779 EXPECT_EQ(memcmp(mem_send, mem_recv, send_len), 0); in TEST_F()
794 EXPECT_EQ(tls_send_cmsg(self->fd, 100, test_str, send_len, 0), 10); in TEST_F()
795 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1); in TEST_F()
796 EXPECT_EQ(errno, EINVAL); in TEST_F()
797 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
798 EXPECT_EQ(errno, EIO); in TEST_F()
799 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
802 EXPECT_EQ(memcmp(test_str, buf, send_len), 0); in TEST_F()
817 EXPECT_EQ(tls_send_cmsg(self->fd, 100, test_str, send_len, 0), 10); in TEST_F()
818 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
819 EXPECT_EQ(errno, EIO); in TEST_F()
820 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1); in TEST_F()
821 EXPECT_EQ(errno, EINVAL); in TEST_F()
822 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
825 EXPECT_EQ(memcmp(test_str, buf, send_len), 0); in TEST_F()
837 EXPECT_EQ(send(self->fd, mem_send, send_len, 0), send_len); in TEST_F()
839 EXPECT_EQ(recv(self->cfd, mem_recv, half, MSG_WAITALL), half); in TEST_F()
840 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, half, SPLICE_F_NONBLOCK), in TEST_F()
842 EXPECT_EQ(read(p[0], &mem_recv[half], half), half); in TEST_F()
843 EXPECT_EQ(memcmp(mem_send, mem_recv, send_len), 0); in TEST_F()
858 EXPECT_EQ(send(self->fd, &mem_send[chunk * i], chunk, 0), in TEST_F()
861 EXPECT_EQ(recv(self->cfd, mem_recv, chunk * 5 / 2, in TEST_F()
864 EXPECT_EQ(memcmp(mem_send, mem_recv, chunk * 5 / 2), 0); in TEST_F()
872 EXPECT_EQ(n, send_len); in TEST_F()
873 EXPECT_EQ(read(p[0], mem_recv, send_len), send_len); in TEST_F()
874 EXPECT_EQ(memcmp(mem_send, mem_recv, send_len), 0); in TEST_F()
886 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len); in TEST_F()
892 EXPECT_EQ(memcmp(test_str, buf, send_len), 0); in TEST_F()
905 EXPECT_EQ(send(self->fd, send_mem, send_len, 0), send_len); in TEST_F()
912 EXPECT_EQ(memcmp(send_mem, recv_mem, send_len), 0); in TEST_F()
928 EXPECT_EQ(send(self->fd, buf, send_len, 0), send_len); in TEST_F()
957 EXPECT_EQ(memcmp(send_mem, recv_mem, total_len), 0); in TEST_F()
972 EXPECT_EQ(recv(self->cfd, recv_mem, total_len, MSG_WAITALL), total_len); in TEST_F()
974 EXPECT_EQ(memcmp(send_mem, recv_mem, send_len), 0); in TEST_F()
975 EXPECT_EQ(memcmp(send_mem, recv_mem + send_len, send_len), 0); in TEST_F()
990 EXPECT_EQ(recv(self->cfd, recv_mem, recv_len, 0), recv_len); in TEST_F()
991 EXPECT_EQ(recv(self->cfd, recv_mem + recv_len, recv_len, 0), 5); in TEST_F()
992 EXPECT_EQ(memcmp(send_mem, recv_mem, total_len), 0); in TEST_F()
1004 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len); in TEST_F()
1005 EXPECT_EQ(recv(self->cfd, recv_mem, strlen(test_str_first), in TEST_F()
1007 EXPECT_EQ(memcmp(test_str_first, recv_mem, strlen(test_str_first)), 0); in TEST_F()
1009 EXPECT_EQ(recv(self->cfd, recv_mem, strlen(test_str_second), in TEST_F()
1011 EXPECT_EQ(memcmp(test_str_second, recv_mem, strlen(test_str_second)), in TEST_F()
1020 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
1022 EXPECT_EQ(err, true); in TEST_F()
1031 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len); in TEST_F()
1032 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_PEEK), send_len); in TEST_F()
1033 EXPECT_EQ(memcmp(test_str, buf, send_len), 0); in TEST_F()
1035 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1036 EXPECT_EQ(memcmp(test_str, buf, send_len), 0); in TEST_F()
1047 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len); in TEST_F()
1050 EXPECT_EQ(memcmp(test_str, buf, send_len), 0); in TEST_F()
1054 EXPECT_EQ(memcmp(test_str, buf, send_len), 0); in TEST_F()
1066 EXPECT_EQ(send(self->fd, test_str_first, len, 0), len); in TEST_F()
1069 EXPECT_EQ(send(self->fd, test_str_second, len, 0), len); in TEST_F()
1073 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
1077 EXPECT_EQ(memcmp(test_str_first, buf, len), 0); in TEST_F()
1081 EXPECT_EQ(recv(self->cfd, buf, len, MSG_WAITALL), len); in TEST_F()
1087 EXPECT_EQ(memcmp(test_str, buf, len), 0); in TEST_F()
1093 EXPECT_EQ(send(self->fd, test_str_first, len, MSG_MORE), len); in TEST_F()
1096 EXPECT_EQ(send(self->fd, test_str_second, len, 0), len); in TEST_F()
1100 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
1103 EXPECT_EQ(memcmp(test_str, buf, len), 0); in TEST_F()
1115 EXPECT_EQ(send(self->fd, test_str_first, len, 0), len); in TEST_F()
1118 EXPECT_EQ(send(self->fd, test_str_second, len, 0), len); in TEST_F()
1125 EXPECT_EQ(memcmp(test_str, buf, len), 0); in TEST_F()
1134 EXPECT_EQ(send(self->fd, send_mem, 10, 0), 10); in TEST_F()
1135 EXPECT_EQ(send(self->fd, send_mem, 5, 0), 5); in TEST_F()
1138 EXPECT_EQ(setsockopt(self->cfd, SOL_SOCKET, SO_RCVLOWAT, in TEST_F()
1140 EXPECT_EQ(recv(self->cfd, recv_mem, 1, MSG_WAITALL), 1); in TEST_F()
1141 EXPECT_EQ(recv(self->cfd, recv_mem + 1, 6, MSG_WAITALL), 6); in TEST_F()
1142 EXPECT_EQ(recv(self->cfd, recv_mem + 7, 10, 0), 8); in TEST_F()
1144 EXPECT_EQ(memcmp(send_mem, recv_mem, 10), 0); in TEST_F()
1145 EXPECT_EQ(memcmp(send_mem, recv_mem + 10, 5), 0); in TEST_F()
1172 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len); in TEST_F()
1174 EXPECT_EQ(memcmp(buf, test_str, send_len), 0); in TEST_F()
1178 EXPECT_EQ(send(self->cfd, test_str, send_len, 0), send_len); in TEST_F()
1180 EXPECT_EQ(memcmp(buf, test_str, send_len), 0); in TEST_F()
1190 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len); in TEST_F()
1194 EXPECT_EQ(poll(&fd, 1, 20), 1); in TEST_F()
1195 EXPECT_EQ(fd.revents & POLLIN, 1); in TEST_F()
1196 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
1198 EXPECT_EQ(poll(&fd, 1, 20), 0); in TEST_F()
1210 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len); in TEST_F()
1212 EXPECT_EQ(poll(&fd, 1, -1), 1); in TEST_F()
1213 EXPECT_EQ(fd.revents & POLLIN, 1); in TEST_F()
1214 EXPECT_EQ(recv(self->cfd, recv_mem, send_len, MSG_WAITALL), send_len); in TEST_F()
1226 EXPECT_EQ(send(self->fd, send_mem, sizeof(send_mem), 0), in TEST_F()
1229 EXPECT_EQ(poll(&fd, 1, -1), 1); in TEST_F()
1230 EXPECT_EQ(fd.revents & POLLIN, 1); in TEST_F()
1231 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), MSG_WAITALL), in TEST_F()
1237 EXPECT_EQ(poll(&fd, 1, -1), 1); in TEST_F()
1238 EXPECT_EQ(fd.revents & POLLIN, 1); in TEST_F()
1239 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), 0), in TEST_F()
1266 EXPECT_EQ(status, 0); in TEST_F()
1267 EXPECT_EQ(res, pid2); in TEST_F()
1297 EXPECT_EQ(setsockopt(self->fd, SOL_SOCKET, SO_SNDBUF, in TEST_F()
1327 EXPECT_EQ(status, 0); in TEST_F()
1328 EXPECT_EQ(res, pid2); in TEST_F()
1389 EXPECT_EQ(status, 0); in test_mutliproc()
1469 EXPECT_EQ(tls_send_cmsg(self->fd, record_type, test_str, send_len, 0), in TEST_F()
1472 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1474 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
1477 EXPECT_EQ(memcmp(buf, test_str, send_len), 0); in TEST_F()
1482 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
1485 EXPECT_EQ(memcmp(buf, test_str, send_len), 0); in TEST_F()
1498 EXPECT_EQ(tls_send_cmsg(self->fd, 100, rec1, send_len, 0), send_len); in TEST_F()
1499 EXPECT_EQ(tls_send_cmsg(self->fd, 100, rec2, send_len, 0), send_len); in TEST_F()
1501 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1502 EXPECT_EQ(memcmp(buf, rec1, send_len), 0); in TEST_F()
1504 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1505 EXPECT_EQ(memcmp(buf, rec1, send_len), 0); in TEST_F()
1507 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), 0), send_len); in TEST_F()
1508 EXPECT_EQ(memcmp(buf, rec1, send_len), 0); in TEST_F()
1510 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), 0), send_len); in TEST_F()
1511 EXPECT_EQ(memcmp(buf, rec2, send_len), 0); in TEST_F()
1525 EXPECT_EQ(send(self->fd, rec1, send_len, 0), send_len); in TEST_F()
1526 EXPECT_EQ(tls_send_cmsg(self->fd, 100, rec2, send_len, 0), send_len); in TEST_F()
1527 EXPECT_EQ(send(self->fd, rec3, send_len, 0), send_len); in TEST_F()
1529 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1530 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1541 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len); in TEST_F()
1543 EXPECT_EQ(memcmp(buf, test_str, send_len), 0); in TEST_F()
1554 EXPECT_EQ(send(self->fd, test_str, send_len, MSG_MORE), send_len); in TEST_F()
1574 EXPECT_EQ(ret, 0); in TEST_F()
1576 EXPECT_EQ(ret, -1); in TEST_F()
1577 EXPECT_EQ(errno, EINVAL); in TEST_F()
1580 EXPECT_EQ(ret, -1); in TEST_F()
1581 EXPECT_EQ(errno, EISCONN); in TEST_F()
1592 EXPECT_EQ(getsockopt(self->fd, SOL_TLS, TLS_TX, &get, &len), 0); in TEST_F()
1593 EXPECT_EQ(len, sizeof(struct tls_crypto_info)); in TEST_F()
1594 EXPECT_EQ(get.crypto_info.version, variant->tls_version); in TEST_F()
1595 EXPECT_EQ(get.crypto_info.cipher_type, variant->cipher_type); in TEST_F()
1601 EXPECT_EQ(getsockopt(self->fd, SOL_TLS, TLS_TX, &get, &len), 0); in TEST_F()
1602 EXPECT_EQ(len, expect.len); in TEST_F()
1603 EXPECT_EQ(get.crypto_info.version, variant->tls_version); in TEST_F()
1604 EXPECT_EQ(get.crypto_info.cipher_type, variant->cipher_type); in TEST_F()
1605 EXPECT_EQ(memcmp(&get, &expect, expect.len), 0); in TEST_F()
1609 EXPECT_EQ(getsockopt(self->fd, SOL_TLS, TLS_TX, &get, &len), -1); in TEST_F()
1610 EXPECT_EQ(errno, EINVAL); in TEST_F()
1614 EXPECT_EQ(getsockopt(self->fd, SOL_TLS, TLS_TX, &get, &len), -1); in TEST_F()
1615 EXPECT_EQ(errno, EINVAL); in TEST_F()
1630 EXPECT_EQ(send(self->fd, rec1, 10, 0), 10); in TEST_F()
1631 EXPECT_EQ(send(self->fd, rec2, 10, 0), 10); in TEST_F()
1641 EXPECT_EQ(recv(self->cfd, recv_mem, 1, 0), 1); in TEST_F()
1642 EXPECT_EQ(recv_mem[0], rec1[0]); in TEST_F()
1647 EXPECT_EQ(memcmp(rec1, recv_mem, 9), 0); in TEST_F()
1649 EXPECT_EQ(memcmp(rec2, recv_mem + 9, ret - 9), 0); in TEST_F()
1710 EXPECT_EQ(send(self->fd2, buf, sizeof(buf), 0), sizeof(buf)); in TEST_F()
1711 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), 0), -1); in TEST_F()
1712 EXPECT_EQ(errno, EMSGSIZE); in TEST_F()
1713 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
1714 EXPECT_EQ(errno, EAGAIN); in TEST_F()
1726 EXPECT_EQ(send(self->fd, buf, sizeof(buf) / 2, 0), sizeof(buf) / 2); in TEST_F()
1732 EXPECT_EQ(send(self->fd2, buf, n, 0), n); in TEST_F()
1733 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), 0), -1); in TEST_F()
1734 EXPECT_EQ(errno, EBADMSG); in TEST_F()
1735 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), 0), -1); in TEST_F()
1736 EXPECT_EQ(errno, EBADMSG); in TEST_F()
1752 EXPECT_EQ(send(self->fd, txt[i], sizeof(txt[i]), 0), in TEST_F()
1759 EXPECT_EQ(send(self->fd2, cip[i], n, 0), n); in TEST_F()
1763 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), 0), sizeof(txt[0]) * 2); in TEST_F()
1764 EXPECT_EQ(memcmp(buf, txt[0], sizeof(txt[0])), 0); in TEST_F()
1765 EXPECT_EQ(memcmp(buf + sizeof(txt[0]), txt[1], sizeof(txt[1])), 0); in TEST_F()
1767 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), 0), -1); in TEST_F()
1768 EXPECT_EQ(errno, EBADMSG); in TEST_F()
1769 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), 0), -1); in TEST_F()
1770 EXPECT_EQ(errno, EBADMSG); in TEST_F()
1787 EXPECT_EQ(send(self->fd, txt, sizeof(txt), 0), sizeof(txt)); in TEST_F()
1790 EXPECT_EQ(send(self->fd2, cip, n, 0), n); in TEST_F()
1792 EXPECT_EQ(tls_send_cmsg(self->fd, 100, test_str, send_len, 0), 10); in TEST_F()
1796 EXPECT_EQ(send(self->fd2, cip, n, 0), n); in TEST_F()
1798 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), 0), sizeof(txt)); in TEST_F()
1799 EXPECT_EQ(memcmp(buf, txt, sizeof(txt)), 0); in TEST_F()
1800 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), 0), -1); in TEST_F()
1801 EXPECT_EQ(errno, EBADMSG); in TEST_F()
1802 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), 0), -1); in TEST_F()
1803 EXPECT_EQ(errno, EBADMSG); in TEST_F()
1824 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), 0), -1); in TEST_F()
1825 EXPECT_EQ(errno, EAGAIN); in TEST_F()
1827 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), 0), -1); in TEST_F()
1828 EXPECT_EQ(errno, EAGAIN); in TEST_F()
1832 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), 0), -1); in TEST_F()
1833 EXPECT_EQ(errno, EAGAIN); in TEST_F()
1850 EXPECT_EQ(poll(&pfd, 1, 1), 0); in TEST_F()
1853 EXPECT_EQ(send(self->fd, buf, sizeof(buf), 0), sizeof(buf)); in TEST_F()
1858 EXPECT_EQ(send(self->fd2, rec, 100, 0), 100); in TEST_F()
1862 EXPECT_EQ(poll(&pfd, 1, 1), 0); in TEST_F()
1864 EXPECT_EQ(send(self->fd2, rec + 100, rec_len - 100, 0), rec_len - 100); in TEST_F()
1867 EXPECT_EQ(poll(&pfd, 1, 1), 1); in TEST_F()
1868 EXPECT_EQ(recv(self->cfd2, rec, sizeof(rec), 0), sizeof(buf)); in TEST_F()
1869 EXPECT_EQ(memcmp(buf, rec, sizeof(buf)), 0); in TEST_F()
1891 EXPECT_EQ(epoll_wait(epollfd, events, 10, 0), 0); in TEST_F()
1894 EXPECT_EQ(send(self->fd, buf, sizeof(buf), 0), sizeof(buf)); in TEST_F()
1899 EXPECT_EQ(send(self->fd2, rec, 100, 0), 100); in TEST_F()
1901 EXPECT_EQ(epoll_wait(epollfd, events, 10, 0), 0); in TEST_F()
1903 EXPECT_EQ(send(self->fd2, rec + 100, rec_len - 100, 0), rec_len - 100); in TEST_F()
1904 EXPECT_EQ(epoll_wait(epollfd, events, 10, 0), 1); in TEST_F()
1905 EXPECT_EQ(recv(self->cfd2, rec, sizeof(rec), 0), sizeof(buf)); in TEST_F()
1906 EXPECT_EQ(memcmp(buf, rec, sizeof(buf)), 0); in TEST_F()
1927 EXPECT_EQ(send(self->fd, buf, sizeof(buf), 0), sizeof(buf)); in TEST_F()
1940 EXPECT_EQ(send(self->fd2, rec, 100, 0), 100); in TEST_F()
1942 EXPECT_EQ(read(p[0], &token, 1), 1); /* Barrier #1 */ in TEST_F()
1944 EXPECT_EQ(send(self->fd2, rec + 100, rec_len - 100, 0), in TEST_F()
1948 EXPECT_EQ(pid2, ret); in TEST_F()
1949 EXPECT_EQ(status, 0); in TEST_F()
1956 EXPECT_EQ(poll(&pfd, 1, 20), 0); in TEST_F()
1958 EXPECT_EQ(write(p[1], &token, 1), 1); /* Barrier #1 */ in TEST_F()
1962 EXPECT_EQ(poll(&pfd, 1, 20), 1); in TEST_F()
1993 EXPECT_EQ(ret, -1); in TEST()
1997 EXPECT_EQ(errno, ENOTCONN); in TEST()
2000 EXPECT_EQ(ret, -1); in TEST()
2001 EXPECT_EQ(errno, ENOTCONN); in TEST()
2013 EXPECT_EQ(ret, -1); in TEST()
2014 EXPECT_EQ(errno, EEXIST); in TEST()
2034 EXPECT_EQ(ret, 0); in TEST()
2038 EXPECT_EQ(ret, 0); in TEST()
2061 EXPECT_EQ(ret, 0); in TEST()
2064 EXPECT_EQ(ret, 0); in TEST()
2069 EXPECT_EQ(ret, 0); in TEST()
2075 EXPECT_EQ(ret, 0); in TEST()
2076 EXPECT_EQ(val, 1); in TEST()
2077 EXPECT_EQ(len, 4); in TEST()
2082 EXPECT_EQ(ret, 0); in TEST()
2088 EXPECT_EQ(ret, 0); in TEST()
2089 EXPECT_EQ(val, 0); in TEST()
2090 EXPECT_EQ(len, 4); in TEST()
2144 EXPECT_EQ(len2, len); in TEST()
2145 EXPECT_EQ(memcmp(&addr, &addr2, len), 0); in TEST()
2184 EXPECT_EQ(send(fd, buf, sizeof(buf), MSG_DONTWAIT), sizeof(buf)); in TEST()
2188 EXPECT_EQ(recv(cfd, buf2, sizeof(buf2), MSG_WAITALL), sizeof(buf2)); in TEST()
2190 EXPECT_EQ(memcmp(buf, buf2, sizeof(buf)), 0); in TEST()