diff options
Diffstat (limited to 'regress/sys/kern/sosplice/tcp/args-relay-read-forked.pl')
-rw-r--r-- | regress/sys/kern/sosplice/tcp/args-relay-read-forked.pl | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/regress/sys/kern/sosplice/tcp/args-relay-read-forked.pl b/regress/sys/kern/sosplice/tcp/args-relay-read-forked.pl new file mode 100644 index 00000000000..374e07c26ee --- /dev/null +++ b/regress/sys/kern/sosplice/tcp/args-relay-read-forked.pl @@ -0,0 +1,39 @@ +# test concurrent read and splice + +use strict; +use warnings; +use POSIX; +use Time::HiRes; + +our %args = ( + client => { + len => 2**20, + }, + relay => { + nonblocking => 1, + func => sub { + defined(my $pid = fork()) + or die "relay func: fork failed: $!"; + if ($pid == 0) { + my $n; + do { + $n = sysread(STDIN, my $buf, 10); + } while (!defined($n) || $n); + POSIX::_exit(0); + } + # give the userland a moment to read, even if splicing + sleep .1; + relay(@_); + kill 9, $pid; + }, + # As sysread() may extract data from the socket before splicing starts, + # the spliced content length is not reliable. Disable the checks. + nocheck => 1, + }, + server => { + func => sub { sleep 2; read_stream(@_); }, + nocheck => 1, + }, + len => 1048576, + md5 => '6649bbec13f3d7efaedf01c0cfa54f88', +); |