Lines Matching refs:self
40 self->notls = false;
47 self->fd = socket(AF_INET, SOCK_STREAM, 0);
58 ret = connect(self->fd, &addr, sizeof(addr));
61 self->cfd = accept(sfd, &addr, &len);
62 ASSERT_GE(self->cfd, 0);
66 ret = setsockopt(self->fd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls"));
69 self->notls = true;
74 ret = setsockopt(self->cfd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls"));
80 close(self->fd);
81 close(self->cfd);
93 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len);
94 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);
126 self->notls = false;
137 self->fd = socket(AF_INET, SOCK_STREAM, 0);
148 ret = connect(self->fd, &addr, sizeof(addr));
151 ret = setsockopt(self->fd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls"));
153 self->notls = true;
157 if (!self->notls) {
158 ret = setsockopt(self->fd, SOL_TLS, TLS_TX, &tls12,
163 self->cfd = accept(sfd, &addr, &len);
164 ASSERT_GE(self->cfd, 0);
166 if (!self->notls) {
167 ret = setsockopt(self->cfd, IPPROTO_TCP, TCP_ULP, "tls",
171 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12,
181 close(self->fd);
182 close(self->cfd);
187 int filefd = open("/proc/self/exe", O_RDONLY);
192 EXPECT_GE(sendfile(self->fd, filefd, 0, st.st_size), 0);
197 int filefd = open("/proc/self/exe", O_RDONLY);
208 EXPECT_EQ(send(self->fd, test_str, to_send, 0), to_send);
209 EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send);
212 EXPECT_GE(sendfile(self->fd, filefd, 0, st.st_size), 0);
213 EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size);
217 struct _test_data_tls *self,
240 ret = sendfile(self->fd, fd, &offset, chunk_size);
245 EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL),
253 chunked_sendfile(_metadata, self, 4096, 4096);
254 chunked_sendfile(_metadata, self, 4096, 0);
255 chunked_sendfile(_metadata, self, 4096, 1);
256 chunked_sendfile(_metadata, self, 4096, 2048);
257 chunked_sendfile(_metadata, self, 8192, 2048);
258 chunked_sendfile(_metadata, self, 4096, 8192);
259 chunked_sendfile(_metadata, self, 8192, 4096);
260 chunked_sendfile(_metadata, self, 12288, 1024);
261 chunked_sendfile(_metadata, self, 12288, 2000);
262 chunked_sendfile(_metadata, self, 15360, 100);
263 chunked_sendfile(_metadata, self, 15360, 300);
264 chunked_sendfile(_metadata, self, 1, 4096);
265 chunked_sendfile(_metadata, self, 2048, 4096);
266 chunked_sendfile(_metadata, self, 2048, 8192);
267 chunked_sendfile(_metadata, self, 4096, 8192);
268 chunked_sendfile(_metadata, self, 1024, 12288);
269 chunked_sendfile(_metadata, self, 2000, 12288);
270 chunked_sendfile(_metadata, self, 100, 15360);
271 chunked_sendfile(_metadata, self, 300, 15360);
280 EXPECT_GE(send(self->fd, buf, send_len, 0), 0);
281 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1);
292 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len);
293 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);
303 EXPECT_EQ(send(self->fd, test_str, send_len, MSG_MORE), send_len);
304 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1);
305 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len);
306 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL),
317 EXPECT_EQ(send(self->fd, test_str, send_len, MSG_MORE), send_len);
318 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1);
335 EXPECT_EQ(sendmsg(self->fd, &msg, 0), send_len);
336 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len);
360 EXPECT_EQ(sendmsg(self->fd, &msg, 0), SEND_LEN * frags);
361 EXPECT_EQ(recv(self->cfd, buf, SEND_LEN * frags, MSG_WAITALL),
387 EXPECT_EQ(sendmsg(self->fd, &msg, 0), send_len);
391 EXPECT_NE(recv(self->cfd, mem, send_len, 0), -1);
420 EXPECT_EQ(sendmsg(self->fd, &msg, 0), total_len);
422 EXPECT_NE(recv(self->cfd, buf, total_len, 0), -1);
457 EXPECT_EQ(sendmsg(self->fd, &msg, 0), total_len);
458 EXPECT_NE(recv(self->cfd, buf, total_len, 0), -1);
476 EXPECT_GE(splice(p[0], NULL, self->fd, NULL, send_len, 0), 0);
477 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len);
492 EXPECT_GE(splice(p[0], NULL, self->fd, NULL, 8000, 0), 0);
494 EXPECT_GE(splice(p2[0], NULL, self->fd, NULL, 8000, 0), 0);
495 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len);
510 EXPECT_EQ(send(self->fd, test_str, send_len2, 0), send_len2);
511 EXPECT_EQ(recv(self->cfd, buf, send_len2, MSG_WAITALL), send_len2);
515 EXPECT_GE(splice(p[0], NULL, self->fd, NULL, send_len, 0), send_len);
517 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len);
529 EXPECT_GE(send(self->fd, mem_send, send_len, 0), 0);
530 EXPECT_GE(splice(self->cfd, NULL, p[1], NULL, send_len, 0), 0);
544 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len);
549 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1);
561 EXPECT_EQ(send(self->fd, send_mem, send_len, 0), send_len);
567 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1);
583 EXPECT_EQ(send(self->fd, buf, send_len, 0), send_len);
592 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1);
607 EXPECT_GE(send(self->fd, send_mem, total_len, 0), 0);
610 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1);
611 EXPECT_NE(recv(self->cfd, recv_mem + send_len, send_len, 0), -1);
622 EXPECT_GE(send(self->fd, send_mem, send_len, 0), 0);
623 EXPECT_GE(send(self->fd, send_mem, send_len, 0), 0);
625 EXPECT_EQ(recv(self->cfd, recv_mem, total_len, MSG_WAITALL), total_len);
638 EXPECT_GE(send(self->fd, send_mem, total_len, 0), 0);
641 EXPECT_EQ(recv(self->cfd, recv_mem, recv_len, 0), recv_len);
642 EXPECT_EQ(recv(self->cfd, recv_mem + recv_len, recv_len, 0), 5);
655 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len);
656 EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_first),
660 EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_second),
671 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1);
682 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len);
683 EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1);
686 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);
698 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len);
700 EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1);
704 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);
717 EXPECT_EQ(send(self->fd, test_str_first, len, 0), len);
720 EXPECT_EQ(send(self->fd, test_str_second, len, 0), len);
724 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len);
732 EXPECT_EQ(recv(self->cfd, buf, len, MSG_WAITALL), len);
744 EXPECT_EQ(send(self->fd, test_str_first, len, MSG_MORE), len);
747 EXPECT_EQ(send(self->fd, test_str_second, len, 0), len);
751 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len);
766 EXPECT_EQ(send(self->fd, test_str_first, len, 0), len);
769 EXPECT_EQ(send(self->fd, test_str_second, len, 0), len);
773 EXPECT_NE((len = recv(self->cfd, buf, len,
785 EXPECT_EQ(send(self->fd, send_mem, 10, 0), 10);
786 EXPECT_EQ(send(self->fd, send_mem, 5, 0), 5);
789 EXPECT_EQ(setsockopt(self->cfd, SOL_SOCKET, SO_RCVLOWAT,
791 EXPECT_EQ(recv(self->cfd, recv_mem, 1, MSG_WAITALL), 1);
792 EXPECT_EQ(recv(self->cfd, recv_mem + 1, 6, MSG_WAITALL), 6);
793 EXPECT_EQ(recv(self->cfd, recv_mem + 7, 10, 0), 8);
806 if (!self->notls) {
813 ret = setsockopt(self->fd, SOL_TLS, TLS_RX, &tls12,
817 ret = setsockopt(self->cfd, SOL_TLS, TLS_TX, &tls12,
824 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len);
825 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);
830 EXPECT_EQ(send(self->cfd, test_str, send_len, 0), send_len);
831 EXPECT_NE(recv(self->fd, buf, send_len, 0), -1);
842 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len);
843 fd.fd = self->cfd;
848 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len);
860 fd.fd = self->cfd;
862 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len);
866 EXPECT_EQ(recv(self->cfd, recv_mem, send_len, MSG_WAITALL), send_len);
875 fd.fd = self->cfd;
878 EXPECT_EQ(send(self->fd, send_mem, sizeof(send_mem), 0),
883 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), MSG_WAITALL),
887 fd.fd = self->cfd;
891 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), 0),
910 int res = send(self->fd, buf,
926 int res = recv(self->cfd, buf,
942 flags = fcntl(self->fd, F_GETFL, 0);
943 fcntl(self->fd, F_SETFL, flags | O_NONBLOCK);
944 fcntl(self->cfd, F_SETFL, flags | O_NONBLOCK);
949 EXPECT_EQ(setsockopt(self->fd, SOL_SOCKET, SO_SNDBUF,
964 int res = send(self->fd, buf,
988 int res = recv(self->cfd, buf,
1004 test_mutliproc(struct __test_metadata *_metadata, struct _test_data_tls *self,
1055 res = recv(self->cfd, rb,
1069 res = sendfile(self->fd, fd, NULL,
1072 res = send(self->fd, buf,
1083 test_mutliproc(_metadata, self, false, 6, 6);
1088 test_mutliproc(_metadata, self, false, 4, 12);
1093 test_mutliproc(_metadata, self, false, 10, 2);
1098 test_mutliproc(_metadata, self, true, 6, 6);
1103 test_mutliproc(_metadata, self, true, 4, 12);
1108 test_mutliproc(_metadata, self, true, 10, 2);
1113 if (self->notls)
1141 EXPECT_EQ(sendmsg(self->fd, &msg, 0), send_len);
1143 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1);
1146 EXPECT_EQ(recvmsg(self->cfd, &msg, MSG_WAITALL | MSG_PEEK), send_len);
1160 EXPECT_EQ(recvmsg(self->cfd, &msg, MSG_WAITALL), send_len);
1178 EXPECT_EQ(send(self->fd, test_str, send_len, 0), send_len);
1179 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);
1182 shutdown(self->fd, SHUT_RDWR);
1183 shutdown(self->cfd, SHUT_RDWR);
1191 EXPECT_EQ(send(self->fd, test_str, send_len, MSG_MORE), send_len);
1193 shutdown(self->fd, SHUT_RDWR);
1194 shutdown(self->cfd, SHUT_RDWR);
1202 shutdown(self->fd, SHUT_RDWR);
1203 shutdown(self->cfd, SHUT_RDWR);
1204 close(self->cfd);
1210 ret = bind(self->fd, &addr, sizeof(addr));
1212 ret = listen(self->fd, 10);
1216 ret = connect(self->fd, &addr, sizeof(addr));