diff options
| author | ruki <[email protected]> | 2022-04-06 22:40:37 +0800 |
|---|---|---|
| committer | ruki <[email protected]> | 2022-04-06 22:40:37 +0800 |
| commit | 90ad0edfa8645b5b7044db79090ad90ac22a85a2 (patch) | |
| tree | 0f24a012796c0235d4ce7b26376c2483e5f1030d /tests/modules/pipe/sched_echo_server.lua | |
| parent | cc8c6dee305ab37f2ba18bbd4d04cc62ad0a9f2e (diff) | |
improve pipe read
Diffstat (limited to 'tests/modules/pipe/sched_echo_server.lua')
| -rw-r--r-- | tests/modules/pipe/sched_echo_server.lua | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/tests/modules/pipe/sched_echo_server.lua b/tests/modules/pipe/sched_echo_server.lua index 6a89131d0..55d355ece 100644 --- a/tests/modules/pipe/sched_echo_server.lua +++ b/tests/modules/pipe/sched_echo_server.lua @@ -1,4 +1,5 @@ import("core.base.pipe") +import("core.base.bytes") import("core.base.scheduler") function _session(id) @@ -8,8 +9,9 @@ function _session(id) print("%s/%d: connected", pipefile, id) local count = 0 local result = nil + local buff = bytes(8192) while count < 10000 do - local read, data = pipefile:read(13, {block = true}) + local read, data = pipefile:read(buff, 13, {block = true}) if read > 0 then result = data count = count + 1 |