jyapayne/Nim
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Update channels.nim (#17717)

Browse source
This commit is contained in:
flywind 2021-04-14 22:45:22 +08:00 • committed by GitHub
commit 58f44c8b4e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
lib/std/channels.nim
View file

@ -307,8 +307,8 @@ proc sendUnbufferedMpmc(chan: ChannelRaw, data: sink pointer, size: int, nonBloc
chan.head = 1 chan.head = 1
release(chan.headLock)
signal(chan.notEmptyCond) signal(chan.notEmptyCond)
release(chan.headLock)
result = true result = true
proc sendMpmc(chan: ChannelRaw, data: sink pointer, size: int, nonBlocking: bool): bool = proc sendMpmc(chan: ChannelRaw, data: sink pointer, size: int, nonBlocking: bool): bool =
@ -343,8 +343,8 @@ proc sendMpmc(chan: ChannelRaw, data: sink pointer, size: int, nonBlocking: bool
if chan.tail == 2 * chan.size: if chan.tail == 2 * chan.size:
chan.tail = 0 chan.tail = 0
release(chan.tailLock)
signal(chan.notEmptyCond) signal(chan.notEmptyCond)
release(chan.tailLock)
result = true result = true
proc recvUnbufferedMpmc(chan: ChannelRaw, data: pointer, size: int, nonBlocking: bool): bool = proc recvUnbufferedMpmc(chan: ChannelRaw, data: pointer, size: int, nonBlocking: bool): bool =
@ -368,8 +368,8 @@ proc recvUnbufferedMpmc(chan: ChannelRaw, data: pointer, size: int, nonBlocking:
chan.head = 0 chan.head = 0
release(chan.headLock)
signal(chan.notFullCond) signal(chan.notFullCond)
release(chan.headLock)
result = true result = true
proc recvMpmc(chan: ChannelRaw, data: pointer, size: int, nonBlocking: bool): bool = proc recvMpmc(chan: ChannelRaw, data: pointer, size: int, nonBlocking: bool): bool =
@ -404,8 +404,8 @@ proc recvMpmc(chan: ChannelRaw, data: pointer, size: int, nonBlocking: bool): bo
if chan.head == 2 * chan.size: if chan.head == 2 * chan.size:
chan.head = 0 chan.head = 0
release(chan.headLock)
signal(chan.notFullCond) signal(chan.notFullCond)
release(chan.headLock)
result = true result = true
proc channelCloseMpmc(chan: ChannelRaw): bool = proc channelCloseMpmc(chan: ChannelRaw): bool =