From nobody Fri May 03 14:45:22 2024 X-Original-To: dev-commits-src-main@mlmmj.nyi.freebsd.org Received: from mx1.freebsd.org (mx1.freebsd.org [IPv6:2610:1c1:1:606c::19:1]) by mlmmj.nyi.freebsd.org (Postfix) with ESMTP id 4VWD9t2GRYz5K7RM; Fri, 3 May 2024 14:45:22 +0000 (UTC) (envelope-from git@FreeBSD.org) Received: from mxrelay.nyi.freebsd.org (mxrelay.nyi.freebsd.org [IPv6:2610:1c1:1:606c::19:3]) (using TLSv1.3 with cipher TLS_AES_256_GCM_SHA384 (256/256 bits) key-exchange X25519 server-signature RSA-PSS (4096 bits) server-digest SHA256 client-signature RSA-PSS (4096 bits) client-digest SHA256) (Client CN "mxrelay.nyi.freebsd.org", Issuer "R3" (verified OK)) by mx1.freebsd.org (Postfix) with ESMTPS id 4VWD9t1JT1z4wDR; Fri, 3 May 2024 14:45:22 +0000 (UTC) (envelope-from git@FreeBSD.org) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=freebsd.org; s=dkim; t=1714747522; h=from:from:reply-to:subject:subject:date:date:message-id:message-id: to:to:cc:mime-version:mime-version:content-type:content-type: content-transfer-encoding:content-transfer-encoding; bh=RuHxS6z3bT4NVbZkZ8TIqJ9netPBDekSxpxcmkT0tZw=; b=I2KsDr8d35kZh2YcnJR7jic3MlgiKE6xTf35t4aJ4ALSGJnBOfPKv8MRg2i+KUwZcozbDV wfJ6Y3BRHiC8mfqahH3wsJlwgVjvthUx5ZtB+k1tXXEwW+pYwRRMloi6cNSl7whXmOF2hZ U6suyK5KFiVxoxYSpGyFbYpXuy0ZCghxWUwKtbB7CmpSfSlW9QvJl+n178y0TOyYNJTfNn RKJySiEqRPG9ADzqkrjMOR0Y03VA9DY3yIYhHDLelXqreVA0G/hUiF68ylj9nKxm0ckOAK HB/Xpnrst++bSQX678p+kMf2hTKgnTfkam6PFBcpaBM06BCFFc6zg2RmUknx3Q== ARC-Seal: i=1; s=dkim; d=freebsd.org; t=1714747522; a=rsa-sha256; cv=none; b=jg3z+1IZK0vJCRekX3ohcHA9mrphYmedgAvrJtON0LH7yEzalrMsBlrni5C0aLe2YnGwIn aHSygdUumTSc483qi+Geuou0QmhQIh54tzJOEEGvItacKqmMzX99d9/nNMyARTppORGTWX 37g0q+bZKIpGJyz2AF3kbHVpP57Db3m3Kw6hDho5KsZqXNGa9IOYkeTWmdH4M2z70c+IIA YxkluyM8D5LlRio+mPZbsBjd+diiS+0Wmg0xgkbzardzZOc/UozpBpGiRt/q383FXw9wCN TBKH0g+LufMBsBDF32GCpL2MFPALLPHdniRPQr5+iIfuZhyWcQQoBMs/d96PDQ== ARC-Authentication-Results: i=1; mx1.freebsd.org; none ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=freebsd.org; s=dkim; t=1714747522; h=from:from:reply-to:subject:subject:date:date:message-id:message-id: to:to:cc:mime-version:mime-version:content-type:content-type: content-transfer-encoding:content-transfer-encoding; bh=RuHxS6z3bT4NVbZkZ8TIqJ9netPBDekSxpxcmkT0tZw=; b=uYD8M3ClWWX1WB7A/GRUNBb1mAbYM4AFuynkCVjOLF6BDUIPec5eIrt9xIhCgUXsC9eJOM nQsbhUp1IQIdMImazebF3vUl6kss19Xnqkuyq+Jjbld0MG8frf1EYdp2iBHvAqKxoD4jCc 1HK/nptqeKSHX8OPlqNp7mKUTUK3r47kSb/b13B6T3tbeiqdYudKoJXh70GJblpjXid3Wx qdhb0Ol2repivC/sQoMYSkxXeadQpceFNDlTYqgA6ssSvqHgYMb0LKkXx3FNBj7Yj2qmYp 9+QnE85LjP4CEAnakgBjmHkGs5+pfXDgsyXSGXDoLuHdCrPD7OREblXyNVft7w== Received: from gitrepo.freebsd.org (gitrepo.freebsd.org [IPv6:2610:1c1:1:6068::e6a:5]) (using TLSv1.3 with cipher TLS_AES_256_GCM_SHA384 (256/256 bits) key-exchange X25519 server-signature RSA-PSS (4096 bits) server-digest SHA256) (Client did not present a certificate) by mxrelay.nyi.freebsd.org (Postfix) with ESMTPS id 4VWD9t0wFszqb1; Fri, 3 May 2024 14:45:22 +0000 (UTC) (envelope-from git@FreeBSD.org) Received: from gitrepo.freebsd.org ([127.0.1.44]) by gitrepo.freebsd.org (8.17.1/8.17.1) with ESMTP id 443EjMs1050731; Fri, 3 May 2024 14:45:22 GMT (envelope-from git@gitrepo.freebsd.org) Received: (from git@localhost) by gitrepo.freebsd.org (8.17.1/8.17.1/Submit) id 443EjM64050728; Fri, 3 May 2024 14:45:22 GMT (envelope-from git) Date: Fri, 3 May 2024 14:45:22 GMT Message-Id: <202405031445.443EjM64050728@gitrepo.freebsd.org> To: src-committers@FreeBSD.org, dev-commits-src-all@FreeBSD.org, dev-commits-src-main@FreeBSD.org From: Gleb Smirnoff Subject: git: c368d3f20fc0 - main - tests/sendfile: factor out tcp_socketpair() List-Id: Commit messages for the main branch of the src repository List-Archive: https://lists.freebsd.org/archives/dev-commits-src-main List-Help: List-Post: List-Subscribe: List-Unsubscribe: X-BeenThere: dev-commits-src-main@freebsd.org Sender: owner-dev-commits-src-main@FreeBSD.org MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit X-Git-Committer: glebius X-Git-Repository: src X-Git-Refname: refs/heads/main X-Git-Reftype: branch X-Git-Commit: c368d3f20fc015941a82d112600c3cac740d9c3e Auto-Submitted: auto-generated The branch main has been updated by glebius: URL: https://cgit.FreeBSD.org/src/commit/?id=c368d3f20fc015941a82d112600c3cac740d9c3e commit c368d3f20fc015941a82d112600c3cac740d9c3e Author: Gleb Smirnoff AuthorDate: 2024-05-03 14:45:06 +0000 Commit: Gleb Smirnoff CommitDate: 2024-05-03 14:45:06 +0000 tests/sendfile: factor out tcp_socketpair() It creates a pair of connected TCP sockets for later testing. No functional change. Reviewed by: chs Differential Revision: https://reviews.freebsd.org/D45054 --- tests/sys/kern/sendfile_helper.c | 119 +++++++++++++++++++++------------------ 1 file changed, 65 insertions(+), 54 deletions(-) diff --git a/tests/sys/kern/sendfile_helper.c b/tests/sys/kern/sendfile_helper.c index 13d10eac6673..6a3b4a1ac880 100644 --- a/tests/sys/kern/sendfile_helper.c +++ b/tests/sys/kern/sendfile_helper.c @@ -42,29 +42,73 @@ #include #include -static int ls; static char buf[1024*1024]; -static volatile bool accept_done = false; +ssize_t readlen; static volatile bool read_done = false; -static void * -server(void *arg) +static int +tcp_socketpair(int *sv) { - struct sockaddr_in sin; - ssize_t rv; - socklen_t slen; - int ss; - ssize_t readlen = (uintptr_t)arg; + struct sockaddr_in sin = { + .sin_len = sizeof(struct sockaddr_in), + .sin_family = AF_INET, + .sin_addr.s_addr = htonl(INADDR_LOOPBACK), + }; + int flags; + int ls; + + ls = socket(PF_INET, SOCK_STREAM, 0); + if (ls < 0) + err(1, "socket ls"); + + if (setsockopt(ls, SOL_SOCKET, SO_REUSEADDR, &(socklen_t){1}, + sizeof(int)) < 0) + err(1, "SO_REUSEADDR"); + + if (bind(ls, (struct sockaddr *)&sin, sizeof(sin)) < 0) + err(1, "bind ls"); + + if (getsockname(ls, (struct sockaddr *)&sin, + &(socklen_t){ sizeof(sin) }) < 0) + err(1, "getsockname"); - slen = sizeof(sin); - ss = accept(ls, (void *)&sin, &slen); - if (ss < 0) + if (listen(ls, 5) < 0) + err(1, "listen ls"); + + sv[0] = socket(PF_INET, SOCK_STREAM, 0); + if (sv[0] < 0) + err(1, "socket cs"); + + flags = fcntl(sv[0], F_GETFL); + flags |= O_NONBLOCK; + if (fcntl(sv[0], F_SETFL, flags) == -1) + err(1, "fcntl +O_NONBLOCK"); + + if (connect(sv[0], (void *)&sin, sizeof(sin)) != -1 || + errno != EINPROGRESS) + err(1, "connect cs"); + + sv[1] = accept(ls, NULL, 0); + if (sv[1] < 0) err(1, "accept ls"); - accept_done = true; + flags &= ~O_NONBLOCK; + if (fcntl(sv[0], F_SETFL, flags) == -1) + err(1, "fcntl -O_NONBLOCK"); + + close(ls); + + return (0); +} + +static void * +receiver(void *arg) +{ + int s = *(int *)arg; + ssize_t rv; do { - rv = read(ss, buf, sizeof(buf)); + rv = read(s, buf, sizeof(buf)); if (rv == -1) err(2, "read receiver"); if (rv == 0) @@ -81,61 +125,28 @@ int main(int argc, char **argv) { pthread_t pt; - struct sockaddr_in sin; - off_t start, len; - socklen_t slen; - int fd, cs, on, flags, error; + off_t start; + int fd, ss[2], flags, error; if (argc != 5) errx(1, "usage: %s ", getprogname()); start = strtoull(argv[2], NULL, 0); - len = strtoull(argv[3], NULL, 0); + readlen = strtoull(argv[3], NULL, 0); flags = strtoul(argv[4], NULL, 0); fd = open(argv[1], O_RDONLY); if (fd < 0) - err(1, "open"); - - ls = socket(PF_INET, SOCK_STREAM, 0); - if (ls < 0) - err(1, "socket ls"); - - on = 1; - if (setsockopt(ls, SOL_SOCKET, SO_REUSEADDR, (void *)&on, - (socklen_t)sizeof(on)) < 0) - err(1, "SO_REUSEADDR"); - - sin.sin_len = sizeof(sin); - sin.sin_family = AF_INET; - sin.sin_addr.s_addr = htonl(INADDR_LOOPBACK); - sin.sin_port = 0; - if (bind(ls, (void *)&sin, sizeof(sin)) < 0) - err(1, "bind ls"); - - slen = sizeof(sin); - if (getsockname(ls, (void *)&sin, &slen) < 0) - err(1, "getsockname"); + err(1, "open"); - if (listen(ls, 5) < 0) - err(1, "listen ls"); + tcp_socketpair(ss); - error = pthread_create(&pt, NULL, server, (void *)(uintptr_t)len); + error = pthread_create(&pt, NULL, receiver, &ss[1]); if (error) errc(1, error, "pthread_create"); - cs = socket(PF_INET, SOCK_STREAM, 0); - if (cs < 0) - err(1, "socket cs"); - - if (connect(cs, (void *)&sin, sizeof(sin)) < 0) - err(1, "connect cs"); - - while (!accept_done) - usleep(1000); - - if (sendfile(fd, cs, start, len, NULL, NULL, flags) < 0) + if (sendfile(fd, ss[0], start, readlen, NULL, NULL, flags) < 0) err(3, "sendfile"); while (!read_done)