tests/sendfile: test operation on unix/stream socket

[glebius]

Summary

Although there are already multiple tests in the tests collection
that utilize sendfile(2) support over unix/stream socket, they all
don't exercise the asynchronous part of the operation. This test
framework, however, uses a trick to toggle true async operation and
guarantee that pr_ready method of unix/stream is also tested.

tests/sys/kern/sendfile_helper.c

do {
                 readlen -= rv;
         } while (readlen != 0);
 
         read_done = true;
 
         return NULL;
 }
 
+static void
+usage(void)
+{
+        errx(1, "usage: %s [-u] <file> <start> <len> <flags>", getprogname());
+}
+
 int
 main(int argc, char **argv)
 {
         pthread_t pt;
         off_t start;
-        int fd, ss[2], flags, error;
+        int ch, fd, ss[2], flags, error;
+        bool pf_unix = false;
 
-        if (argc != 5)
-                errx(1, "usage: %s <file> <start> <len> <flags>",
-                    getprogname());
+        while ((ch = getopt(argc, argv, "u")) != -1)
+                switch (ch) {
+                case 'u':
+                        pf_unix = true;
+                        break;
+                default:
+                        usage();
+                }
+        argc -= optind;
+        argv += optind;
 
-        start = strtoull(argv[2], NULL, 0);
-        readlen = strtoull(argv[3], NULL, 0);
-        flags = strtoul(argv[4], NULL, 0);
+        if (argc != 4)
+                usage();
 
-        fd = open(argv[1], O_RDONLY);
+        start = strtoull(argv[1], NULL, 0);
+        readlen = strtoull(argv[2], NULL, 0);
+        flags = strtoul(argv[3], NULL, 0);
+
+        fd = open(argv[0], O_RDONLY);
         if (fd < 0)
                 err(1, "open");
 
+        if (pf_unix) {
+                if (socketpair(PF_LOCAL, SOCK_STREAM, 0, ss) != 0)
+                        err(1, "socketpair");
+        } else
                 tcp_socketpair(ss);
 
         error = pthread_create(&pt, NULL, receiver, &ss[1]);
         if (error)
                 errc(1, error, "pthread_create");
 
         if (sendfile(fd, ss[0], start, readlen, NULL, NULL, flags) < 0)
                 err(3, "sendfile");
 
         while (!read_done)
                 usleep(1000);
 
         exit(0);
 }

tests/sys/kern/sendfile_test.sh

io_fail_async_body()
         atf_check gnop configure -r 100 -e 5 ${md}.nop
         atf_check -s exit:2 -e ignore $HELPER $FILE 0 $BSIZE 0x10000
 }
 io_fail_async_cleanup()
 {
         common_cleanup
 }
 
+atf_test_case unix_success cleanup
+unix_success_head()
+{
+        atf_set "descr" "sendfile via unix(4) where all disk I/O succeeds"
+        atf_set "require.user" "root"
+        atf_set "timeout" 15
+}
+unix_success_body()
+{
+        if [ "$(atf_config_get qemu false)" = "true" ]; then
+            atf_skip "Sendfile(4) unimplemented. https://github.com/qemu-bsd-user/qemu-bsd-user/issues/25"
+        fi
 
+        alloc_md md
+        common_body_setup $md
+
+        atf_check $HELPER -u $FILE 0 0x10000 0x10000
+}
+unix_success_cleanup()
+{
+        common_cleanup
+}
+
+
 atf_init_test_cases()
 {
         atf_add_test_case io_success
         atf_add_test_case io_fail_sync
         atf_add_test_case io_fail_async
+        atf_add_test_case unix_success
 }
 
 alloc_md()
 {
         local _md
 
         [ -c /dev/mdctl ] || atf_skip "no /dev/mdctl to create md devices"
         _md=$(mdconfig -a -t swap -s 256M) || atf_fail "mdconfig -a failed"