srctree

// Two threads could race against the same emutls_control.

 

// Use atomic for reading coherent value lockless.

 

if (index_lockless != 0) {

// index is already initialized, return it.

}

 

// Store a new index atomically (for having coherent index_lockless reading).

 

// Increment the next available index

emutls_control.next_index += 1;

 

assert(std.c.pthread_mutex_lock(&bucket.mutex) == .SUCCESS);

defer assert(std.c.pthread_mutex_unlock(&bucket.mutex) == .SUCCESS);

 

if (cancelled) {

return;

}

// The pending count increment in wait() must also now use seq_cst for the update + this pending load

// to be in the same modification order as our load isn't using release/acquire to guarantee it.

bucket.pending.fence(.seq_cst);

return;

}

 

// Keep a list of all the waiters notified and wake then up outside the mutex critical section.

var notified = WaitList{};

defer if (notified.len > 0) {

assert(pending >= notified.len);

 

while (notified.pop()) |waiter| {

defer assert(std.c.pthread_mutex_unlock(&bucket.mutex) == .SUCCESS);

 

// Another pending check again to avoid the WaitQueue lookup if not necessary.

notified = WaitQueue.remove(&bucket.treap, address, max_waiters);

}

}

 

 

try testing.expectEqual(num_writes, runner.writes);

 

}

 

// acquire ensures count decrement and code before

// previous unrefs()s happens-before we call dropFn

// below.

// fetchSub count decrement but it's extra barrier in

// possibly hot path.

rc.count.fence(.acquire);

 

/// Result type is always `void`.

/// Uses the `bin_op` field. LHS is pointer, RHS is element.

atomic_store_unordered,

atomic_store_monotonic,

atomic_store_release,

atomic_store_seq_cst,

/// Atomically read-modify-write via a pointer.

/// Result type is the element type of the pointer.

 

.call_never_tail => try self.airCall(inst, .never_tail),

.call_never_inline => try self.airCall(inst, .never_inline),

 

 

.struct_field_ptr_index_0 => try self.airStructFieldPtrIndex(inst, 0),

.struct_field_ptr_index_1 => try self.airStructFieldPtrIndex(inst, 1),