client => {
func => sub { errignore(@_); write_stream(@_); },
len => 2**17,
+ sndbuf => 2**15,
down => "Client print failed: Broken pipe",
nocheck => 1,
},
relay => {
func => sub { sleep 3; relay(@_); shutin(@_); sleep 1; },
max => 32117,
+ rcvbuf => 2**15,
big => 1,
},
len => 32117,
relay => {
nonblocking => 1,
readblocking => 1,
- sndbuf => 2**12,
rcvbuf => 2**12,
+ sndbuf => 2**12,
},
server => {
# wait until all buffers are filled and client sends eof
alarm => 1,
func => sub { solingerout(@_); write_stream(@_); },
len => 2**19,
+ sndbuf => 2**15,
nocheck => 1,
},
relay => {
},
server => {
func => sub { sleep 3; read_stream(@_); },
+ rcvbuf => 2**15,
nocheck => 1,
},
len => 131072,
client => {
func => sub { errignore(@_); write_stream(@_); },
len => 2**17,
+ sndbuf => 2**15,
},
relay => {
func => sub { errignore(@_); relay(@_); },
- sndbuf => 2**12,
rcvbuf => 2**12,
+ sndbuf => 2**12,
down => "Broken pipe|Connection reset by peer",
},
server => {
},
server => {
alarm => 3,
+ rcvbuf => 2**15,
nocheck => 1,
},
noecho => 1,
},
server => {
func => sub { sleep 3; read_stream(@_); },
+ rcvbuf => 2**15,
},
len => 131072,
md5 => "31e5ad3d0d2aeb1ad8aaa847dfa665c2",
len => 2**17,
},
relay => {
- sndbuf => 2**12,
rcvbuf => 2**12,
+ sndbuf => 2**12,
},
len => 131072,
md5 => "31e5ad3d0d2aeb1ad8aaa847dfa665c2",
},
server => {
func => sub { sleep 3; read_stream(@_); },
+ rcvbuf => 2**15,
},
len => 131072,
md5 => "31e5ad3d0d2aeb1ad8aaa847dfa665c2",
},
server => {
func => sub { sleep 3; read_stream(@_); },
+ rcvbuf => 2**15,
},
len => 131072,
md5 => "31e5ad3d0d2aeb1ad8aaa847dfa665c2",
our %args = (
client => {
- len => 2**17,
func => sub { errignore(@_); write_stream(@_); },
+ len => 2**17,
+ sndbuf => 2**15,
},
relay => {
func => sub {
},
server => {
func => sub { sleep 3; read_stream(@_); },
+ rcvbuf => 2**15,
},
noecho => 1,
nocheck => 1,