Skip to content

Commit 2ba183d

Browse files
committed
tests: made a test for duplex cosockets less sensitive to timing error.
1 parent 94248d6 commit 2ba183d

File tree

1 file changed

+13
-8
lines changed

1 file changed

+13
-8
lines changed

t/128-duplex-tcp-socket.t

Lines changed: 13 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -315,19 +315,24 @@ failed to send request: closed)$
315315
316316
local data = ""
317317
local ntm = 0
318-
local done = false
318+
local aborted = false
319319
for i = 1, 3 do
320-
local res, err, part = sock:receive(1)
321-
if not res then
322-
ngx.say("failed to receive: ", err)
323-
return
324-
else
325-
data = data .. res
320+
if not aborted then
321+
local res, err, part = sock:receive(1)
322+
if not res then
323+
ngx.say("failed to receive: ", err)
324+
aborted = true
325+
else
326+
data = data .. res
327+
end
326328
end
329+
327330
ngx.sleep(0.001)
328331
end
329332
330-
ngx.say("received: ", data)
333+
if not aborted then
334+
ngx.say("received: ", data)
335+
end
331336
';
332337
}
333338

0 commit comments

Comments
 (0)