Searched refs:new_queue (Results 1 – 4 of 4) sorted by relevance
157 new_queue: *mut Waiter, field162 let queue = self.queue.swap(self.new_queue, Ordering::AcqRel); in drop()201 if let Err(new_queue) = exchange { in initialize_or_wait()202 curr_queue = new_queue; in initialize_or_wait()205 let mut guard = Guard { queue, new_queue: INCOMPLETE_PTR }; in initialize_or_wait()207 guard.new_queue = COMPLETE_PTR; in initialize_or_wait()236 if let Err(new_queue) = exchange { in wait()237 if strict::addr(new_queue) & STATE_MASK != curr_state { in wait()240 curr_queue = new_queue; in wait()
152 Queue* new_queue = new Queue(); in Map() local155 new_queue->Enqueue(function(node->element())); in Map()158 return new_queue; in Map()
315 Handle<WeakFixedArray> new_queue = in EnsureQueueCapacity() local319 compilation_queue_ = isolate_->global_handles()->Create(*new_queue); in EnsureQueueCapacity()
379 __u32 *new_queue; in btf_dump_add_emit_queue_id() local384 new_queue = libbpf_reallocarray(d->emit_queue, new_cap, sizeof(new_queue[0])); in btf_dump_add_emit_queue_id()385 if (!new_queue) in btf_dump_add_emit_queue_id()387 d->emit_queue = new_queue; in btf_dump_add_emit_queue_id()