Skip to content

Commit f9672ae

Browse files
committed
There's 4 of them!
1 parent a080691 commit f9672ae

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

threading/channels.nim

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -211,8 +211,7 @@ proc sendUnbufferedMpmc(chan: ChannelRaw, data: pointer, size: int, blocking: st
211211
chan.tail = 1
212212

213213
release(chan.lock)
214-
when blocking:
215-
signal(chan.dataAvailableCV)
214+
signal(chan.dataAvailableCV)
216215
result = true
217216

218217
proc sendMpmc(chan: ChannelRaw, data: pointer, size: int, blocking: static bool): bool =
@@ -251,8 +250,7 @@ proc sendMpmc(chan: ChannelRaw, data: pointer, size: int, blocking: static bool)
251250
chan.head = 0
252251

253252
release(chan.lock)
254-
when blocking:
255-
signal(chan.dataAvailableCV)
253+
signal(chan.dataAvailableCV)
256254
result = true
257255

258256
proc recvUnbufferedMpmc(chan: ChannelRaw, data: pointer, size: int, blocking: static bool): bool =

0 commit comments

Comments
 (0)