diff options
| author | ruki <[email protected]> | 2022-04-04 23:41:22 +0800 |
|---|---|---|
| committer | ruki <[email protected]> | 2022-04-04 23:41:22 +0800 |
| commit | d19a15f735dbc8b07bed1178e1a077b495179a07 (patch) | |
| tree | 576969f8ae155ed689d0826e39e10be03cc91e91 /tests/modules/socket | |
| parent | d7115ae9ce36bf98d54d4c48705c304f543c8c7b (diff) | |
add socket.ctrl
Diffstat (limited to 'tests/modules/socket')
| -rw-r--r-- | tests/modules/socket/sched_tcp/echo_client.lua | 2 | ||||
| -rw-r--r-- | tests/modules/socket/sched_tcp/echo_server.lua | 2 |
2 files changed, 4 insertions, 0 deletions
diff --git a/tests/modules/socket/sched_tcp/echo_client.lua b/tests/modules/socket/sched_tcp/echo_client.lua index 37470613e..61b53bdfd 100644 --- a/tests/modules/socket/sched_tcp/echo_client.lua +++ b/tests/modules/socket/sched_tcp/echo_client.lua @@ -42,6 +42,8 @@ function _session(addr, port) if sock then print("%s: connected!", sock) table.insert(socks, sock) + sock:ctrl(socket.CTRL_SET_SENDBUFF, 100000 * 20) + sock:ctrl(socket.CTRL_SET_RECVBUFF, 100000 * 20) scheduler.co_group_begin("test", function () scheduler.co_start(_session_recv, sock) scheduler.co_start(_session_send, sock) diff --git a/tests/modules/socket/sched_tcp/echo_server.lua b/tests/modules/socket/sched_tcp/echo_server.lua index f1f502764..4ecd80191 100644 --- a/tests/modules/socket/sched_tcp/echo_server.lua +++ b/tests/modules/socket/sched_tcp/echo_server.lua @@ -45,6 +45,8 @@ function _listen(addr, port) if sock_client then print("%s: accepted", sock_client) table.insert(sock_clients, sock_client) + sock_client:ctrl(socket.CTRL_SET_SENDBUFF, 100000 * 20) + sock_client:ctrl(socket.CTRL_SET_RECVBUFF, 100000 * 20) scheduler.co_start(_session_recv, sock_client) scheduler.co_start(_session_send, sock_client) end |