mirror/v
1
0
Fork 0
mirror of https://github.com/vlang/v.git synced 2023-08-10 21:13:21 +03:00
Code Issues Projects Releases Wiki Activity

all: wrap up unsafe { nil } (p. 3)

Browse Source
This commit is contained in:
Alexander Medvednikov
2022-07-21 21:01:30 +03:00
parent a68d03ac59
commit 9099594a49
51 changed files with 86 additions and 86 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
vlib/sync/channels.c.v
View File

@@ -124,10 +124,10 @@ pub fn (mut ch Channel) close() {
if !C.atomic_compare_exchange_strong_u16(&ch.closed, &open_val, 1) {
return
}
mut nulladr := unsafe { voidptr(0) }
mut nulladr := unsafe { nil }
for !C.atomic_compare_exchange_weak_ptr(unsafe { &voidptr(&ch.adr_written) }, &nulladr,
voidptr(-1)) {
nulladr = unsafe { voidptr(0) }
nulladr = unsafe { nil }
}
ch.readsem_im.post()
ch.readsem.post()
@@ -191,10 +191,10 @@ fn (mut ch Channel) try_push_priv(src voidptr, no_block bool) ChanState {
{
// there is a reader waiting for us
unsafe { C.memcpy(wradr, src, ch.objsize) }
mut nulladr := unsafe { voidptr(0) }
mut nulladr := unsafe { nil }
for !C.atomic_compare_exchange_weak_ptr(unsafe { &voidptr(&ch.adr_written) },
&nulladr, wradr) {
nulladr = unsafe { voidptr(0) }
nulladr = unsafe { nil }
}
ch.readsem_im.post()
return .success
@@ -382,7 +382,7 @@ fn (mut ch Channel) try_pop_priv(dest voidptr, no_block bool) ChanState {
{
// there is a writer waiting for us
unsafe { C.memcpy(dest, rdadr, ch.objsize) }
mut nulladr := unsafe { voidptr(0) }
mut nulladr := unsafe { nil }
for !C.atomic_compare_exchange_weak_ptr(unsafe { &voidptr(&ch.adr_read) },
&nulladr, rdadr) {
nulladr = unsafe { nil }

4
vlib/sync/pool/pool.v
View File

@@ -7,7 +7,7 @@ import runtime
fn C.atomic_fetch_add_u32(voidptr, u32) u32
pub const (
no_result = voidptr(0)
no_result = unsafe { nil }
)
pub struct PoolProcessor {
@@ -48,7 +48,7 @@ pub fn new_pool_processor(context PoolProcessorConfig) &PoolProcessor {
mut pool := PoolProcessor{
items: []
results: []
shared_context: voidptr(0)
shared_context: unsafe { nil }
thread_contexts: []
njobs: context.maxjobs
ntask: 0