logos-storage/nim-chronos
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-chronos.git synced 2026-01-08 00:13:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

One more attempt to fix freezing test.

Browse Source
This commit is contained in:
cheatfate 2018-10-27 20:49:36 +03:00
parent 163982bc6e
commit 2bc3932ae2
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tests/testdatagram.nim
View File

@ -325,6 +325,7 @@ proc testPointerSendTo(): Future[int] {.async.} =
await dgram2.sendTo(ta, addr data[0], len(data)) await dgram2.sendTo(ta, addr data[0], len(data))
await dgram2.join() await dgram2.join()
dgram1.close() dgram1.close()
await dgram1.join()
result = counter result = counter
proc testPointerSend(): Future[int] {.async.} = proc testPointerSend(): Future[int] {.async.} =
@ -337,6 +338,7 @@ proc testPointerSend(): Future[int] {.async.} =
await dgram2.send(addr data[0], len(data)) await dgram2.send(addr data[0], len(data))
await dgram2.join() await dgram2.join()
dgram1.close() dgram1.close()
await dgram1.join()
result = counter result = counter
proc testStringSendTo(): Future[int] {.async.} = proc testStringSendTo(): Future[int] {.async.} =
@ -349,6 +351,7 @@ proc testStringSendTo(): Future[int] {.async.} =
await dgram2.sendTo(ta, data) await dgram2.sendTo(ta, data)
await dgram2.join() await dgram2.join()
dgram1.close() dgram1.close()
await dgram1.join()
result = counter result = counter
proc testStringSend(): Future[int] {.async.} = proc testStringSend(): Future[int] {.async.} =
@ -361,6 +364,7 @@ proc testStringSend(): Future[int] {.async.} =
await dgram2.send(data) await dgram2.send(data)
await dgram2.join() await dgram2.join()
dgram1.close() dgram1.close()
await dgram1.join()
result = counter result = counter
proc testSeqSendTo(): Future[int] {.async.} = proc testSeqSendTo(): Future[int] {.async.} =
@ -375,6 +379,7 @@ proc testSeqSendTo(): Future[int] {.async.} =
await dgram2.sendTo(ta, dataseq) await dgram2.sendTo(ta, dataseq)
await dgram2.join() await dgram2.join()
dgram1.close() dgram1.close()
await dgram1.join()
result = counter result = counter
proc testSeqSend(): Future[int] {.async.} = proc testSeqSend(): Future[int] {.async.} =
@ -389,6 +394,7 @@ proc testSeqSend(): Future[int] {.async.} =
await dgram2.send(data) await dgram2.send(data)
await dgram2.join() await dgram2.join()
dgram1.close() dgram1.close()
await dgram1.join()
result = counter result = counter
# #
@ -448,6 +454,8 @@ proc testConnReset(): Future[bool] {.async.} =
asyncCheck dgram2.sendTo(ta, data) asyncCheck dgram2.sendTo(ta, data)
await sleepAsync(1000) await sleepAsync(1000)
result = (counter == 0) result = (counter == 0)
dgram2.close()
await dgram2.join()
when isMainModule: when isMainModule:
const const