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/process/sched_process_pipe.lua | |
| parent | cc8c6dee305ab37f2ba18bbd4d04cc62ad0a9f2e (diff) | |
improve pipe read
Diffstat (limited to 'tests/modules/process/sched_process_pipe.lua')
| -rw-r--r-- | tests/modules/process/sched_process_pipe.lua | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/tests/modules/process/sched_process_pipe.lua b/tests/modules/process/sched_process_pipe.lua index 02bf70a93..65bfb6cbe 100644 --- a/tests/modules/process/sched_process_pipe.lua +++ b/tests/modules/process/sched_process_pipe.lua @@ -5,12 +5,13 @@ import("core.base.scheduler") function _session_read_pipe(id, rpipeopt) local results = {} + local buff = bytes(8192) local rpipe = rpipeopt.rpipe print("%s/%d: read ..", rpipe, id) while not rpipeopt.stop do - local real, data = rpipe:read(8192) + local real, data = rpipe:read(buff, 8192) if real > 0 then - table.insert(results, bytes(data, 1, real)) + table.insert(results, data:clone()) -- TODO elseif real == 0 then if rpipe:wait(pipe.EV_READ, -1) < 0 then break |