Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 92) sorted by relevance

1234

/xnu-11215/osfmk/vm/
H A Dvm_purgeable.c273 assert(queue->token_q_head == 0 && queue->token_q_unripe == 0); in vm_purgeable_token_add()
298 queue->type, in vm_purgeable_token_add()
323 if (queue->token_q_head == queue->token_q_unripe) { in vm_purgeable_token_remove_first()
332 if (queue->token_q_tail == queue->token_q_head) { in vm_purgeable_token_remove_first()
356 queue->type, in vm_purgeable_token_remove_first()
378 if (queue->token_q_tail == queue->token_q_head) { in vm_purgeable_token_remove_last()
414 queue->type, in vm_purgeable_token_remove_last()
499 queue->token_q_unripe = tokens[queue->token_q_unripe].next; in vm_purgeable_q_advance_all()
502 queue->type, in vm_purgeable_q_advance_all()
1059 queue->type, in vm_purgeable_object_add()
[all …]
H A Dvm_purgeable_internal.h90 kern_return_t vm_purgeable_token_add(purgeable_q_t queue);
93 void vm_purgeable_token_delete_first(purgeable_q_t queue);
94 void vm_purgeable_token_delete_last(purgeable_q_t queue);
106 void vm_purgeable_object_add(vm_object_t object, purgeable_q_t queue, int group);
/xnu-11215/bsd/man/man3/
H A DMakefile10 queue.3 \
26 queue.3 CIRCLEQ_ENTRY.3 \
27 queue.3 CIRCLEQ_HEAD.3 \
28 queue.3 CIRCLEQ_INIT.3 \
34 queue.3 LIST_ENTRY.3 \
35 queue.3 LIST_HEAD.3 \
36 queue.3 LIST_INIT.3 \
40 queue.3 LIST_REMOVE.3 \
41 queue.3 TAILQ_ENTRY.3 \
42 queue.3 TAILQ_HEAD.3 \
[all …]
/xnu-11215/iokit/Kernel/
H A DIOKitDebug.cpp380 return queue; in IOTrackingQueueAlloc()
396 IOTrackingReset(queue); in IOTrackingQueueFree()
397 remque(&queue->link); in IOTrackingQueueFree()
402 kfree_type(IOTrackingQueue, queue_head_t, queue->numSiteQs, queue); in IOTrackingQueueFree()
525 queue->siteCount++; in IOTrackingAddUser()
540 queue->siteCount--; in IOTrackingRemoveUser()
595 que = &queue->sites[crc % queue->numSiteQs]; in IOTrackingAdd()
620 site->queue = queue; in IOTrackingAdd()
638 queue->siteCount++; in IOTrackingAdd()
707 queue->siteCount--; in IOTrackingRemoveInternal()
[all …]
H A DIOCommandQueue.cpp100 queue = (void *)kalloc_type(commandEntryT, size, Z_WAITOK_ZERO); in OSDefineMetaClassAndStructors()
101 if (!queue) { in OSDefineMetaClassAndStructors()
142 if (queue) { in free()
143 kfree_type(commandEntryT, size, queue); in free()
170 commandEntryT *q = (commandEntryT *) queue; in checkForWork()
254 commandEntryT *q = (commandEntryT *) queue; in enqueueCommand()
300 commandEntryT *q = (commandEntryT *) queue; in performAndFlush()
H A DIOSharedDataQueue.cpp195 head = (IODataQueueEntry *)((char *)dataQueue->queue + headOffset); in peek()
209 entry = dataQueue->queue; in peek()
245 entry = (IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail); in enqueue()
259 dataQueue->queue->size = dataSize; in enqueue()
266 ((IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail))->size = dataSize; in enqueue()
269 __nochk_memcpy(&dataQueue->queue->data, data, dataSize); in enqueue()
279 entry = (IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail); in enqueue()
341 head = (IODataQueueEntry *)((char *)dataQueue->queue + headOffset); in dequeue()
353 entry = dataQueue->queue; in dequeue()
H A DIOPlatformActions.cpp87 iocpu_add_platform_action(queue_head_t * queue, iocpu_platform_action_entry_t * entry) in iocpu_add_platform_action() argument
91 queue_iterate(queue, next, iocpu_platform_action_entry_t *, link) in iocpu_add_platform_action()
94 queue_insert_before(queue, entry, next, iocpu_platform_action_entry_t *, link); in iocpu_add_platform_action()
98 queue_enter(queue, entry, iocpu_platform_action_entry_t *, link); // at tail in iocpu_add_platform_action()
108 iocpu_run_platform_actions(queue_head_t * queue, uint32_t first_priority, uint32_t last_priority, in iocpu_run_platform_actions() argument
116 queue_iterate(queue, next, iocpu_platform_action_entry_t *, link) in iocpu_run_platform_actions()
277 queue_head_t * queue = &gActionQueues[qidx]; in IOInstallServicePlatformAction() local
292 queue_iterate(queue, entry, iocpu_platform_action_entry_t *, link) in IOInstallServicePlatformAction()
312 iocpu_add_platform_action(queue, entry); in IOInstallServicePlatformAction()
H A DIODataQueue.cpp192 entry = (IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail); in enqueue()
206 dataQueue->queue->size = dataSize; in enqueue()
213 ((IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail))->size = dataSize; in enqueue()
216 __nochk_memcpy(&dataQueue->queue->data, data, dataSize); in enqueue()
226 entry = (IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail); in enqueue()
/xnu-11215/iokit/DriverKit/
H A DIODataQueueDispatchSource.iig47 * of the OSAction, not this queue.
54 IODispatchQueue * queue,
118 * @return True if the queue is non-empty.
144 * @brief As a producer, enqueue a queue entry.
148 * kIOReturnOverrun if the queue was full.
175 * kIOReturnOverrun if the queue was full.
182 …* @brief As a producer, check if the queue has sufficient free space for a queue entry with …
185 * kIOReturnOverrun if the queue is full
186 * kIOReturnError if the queue was corrupt
192 …* @brief As a producer, check if the queue has sufficient free space for queue entries with …
[all …]
H A DIODispatchQueue.iig76 * @brief Creates a new dispatch queue object.
90 IODispatchQueue ** queue) LOCAL;
100 …iscussion Determines if the current thread is running on the queue, including if the queue invoke…
101 …* second queue (ie. OnQueue can return true for more than one queue in a given contex…
108 * @brief Return the name the queue was created with.
116 * @brief Stop the queue from executing futher work.
128 …* @discussion Schedules work to be done on the queue without waiting for it to complete. The queu…
159 * @brief Execute a block on the queue synchronously.
160 * @discussion Execute a block on the queue synchronously.
186 * @brief Put a thread that is currently running the queue to sleep, releasing the queue.
[all …]
/xnu-11215/osfmk/ipc/
H A Dipc_kmsg.h209 #define ipc_kmsg_queue_init(queue) circle_queue_init(queue) argument
211 #define ipc_kmsg_queue_empty(queue) circle_queue_empty(queue) argument
216 #define ipc_kmsg_queue_first(queue) \ argument
219 #define ipc_kmsg_queue_next(queue, elt) \ argument
222 #define ipc_kmsg_enqueue(queue, kmsg) \ argument
225 #define ipc_kmsg_rmqueue(queue, kmsg) \ argument
226 circle_dequeue(queue, &(kmsg)->ikm_link)
229 ipc_kmsg_queue_t queue,
233 ipc_kmsg_queue_t queue,
239 ipc_kmsg_queue_t queue,
[all …]
/xnu-11215/osfmk/i386/
H A Di386_timer.c91 abstime >= mytimer->queue.earliest_soft_deadline); in timer_intr()
100 mytimer->queue.earliest_soft_deadline, in timer_intr()
250 queue_count = mytimer->queue.count; in timer_resync_deadlines()
341 mpqueue_head_t *queue; in timer_queue_assign() local
344 queue = &cdp->rtclock_timer.queue; in timer_queue_assign()
350 queue = &cpu_datap(master_cpu)->rtclock_timer.queue; in timer_queue_assign()
353 return queue; in timer_queue_assign()
358 mpqueue_head_t *queue, in timer_queue_cancel() argument
362 if (queue == &current_cpu_datap()->rtclock_timer.queue) { in timer_queue_cancel()
402 &target_cdp->rtclock_timer.queue); in timer_queue_migrate_cpu()
[all …]
/xnu-11215/tests/sched/sched_test_harness/shadow_headers/
H A Dsched_prim.c127 circle_queue_t queue = &rq->queues[rq->highq]; in run_queue_dequeue() local
142 if (circle_queue_empty(queue)) { in run_queue_dequeue()
164 circle_queue_t queue = &rq->queues[thread->sched_pri]; in run_queue_enqueue() local
167 if (circle_queue_empty(queue)) { in run_queue_enqueue()
168 circle_enqueue_tail(queue, &thread->runq_links); in run_queue_enqueue()
177 circle_enqueue_tail(queue, &thread->runq_links); in run_queue_enqueue()
179 circle_enqueue_head(queue, &thread->runq_links); in run_queue_enqueue()
202 circle_queue_t queue = &rq->queues[thread->sched_pri]; in run_queue_remove() local
206 circle_dequeue(queue, &thread->runq_links); in run_queue_remove()
212 if (circle_queue_empty(queue)) { in run_queue_remove()
[all …]
/xnu-11215/osfmk/arm/
H A Darm_timer.c103 mytimer->deadline = timer_queue_expire(&mytimer->queue, abstime); in timer_intr()
200 mytimer->deadline = timer_queue_expire(&mytimer->queue, abstime); in timer_queue_expire_local()
221 mpqueue_head_t *queue; in timer_queue_assign() local
224 queue = &cpu_data_ptr->rtclock_timer.queue; in timer_queue_assign()
237 queue = &cpu_datap(master_cpu)->rtclock_timer.queue; in timer_queue_assign()
240 return queue; in timer_queue_assign()
245 mpqueue_head_t *queue, in timer_queue_cancel() argument
249 if (queue == &getCpuDatap()->rtclock_timer.queue) { in timer_queue_cancel()
259 return &cpu_datap(cpu)->rtclock_timer.queue; in timer_queue_cpu()
/xnu-11215/osfmk/kern/
H A Dtest_mpsc_queue.c41 struct mpsc_daemon_queue queue; member
52 assert(&q->queue == dq); in mpsc_test_pingpong_invoke()
58 mpsc_daemon_enqueue(&q->other->queue, &q->other->link, in mpsc_test_pingpong_invoke()
92 kr = mpsc_daemon_queue_init_with_thread(&ping.queue, in mpsc_test_pingpong()
99 kr = mpsc_daemon_queue_init_with_thread(&pong.queue, in mpsc_test_pingpong()
120 mpsc_daemon_enqueue(&ping.queue, &ping.link, MPSC_QUEUE_DISABLE_PREEMPTION); in mpsc_test_pingpong()
129 mpsc_daemon_queue_cancel_and_wait(&ping.queue); in mpsc_test_pingpong()
130 mpsc_daemon_queue_cancel_and_wait(&pong.queue); in mpsc_test_pingpong()
H A Dtimer_call.c76 #define timer_queue_unlock(queue) lck_ticket_unlock(&(queue)->lock_data) argument
457 queue->count++; in timer_call_entry_enqueue_tail()
531 if (old_queue != queue) { in timer_call_enqueue_deadline_unlocked()
545 timer_queue_unlock(queue); in timer_call_enqueue_deadline_unlocked()
724 if (queue == NULL) { in timer_call_enter_internal()
900 timer_queue_unlock(queue); in timer_queue_shutdown()
1107 timer_queue_unlock(queue); in timer_queue_expire_with_options()
1263 timer_queue_unlock(queue); in timer_queue_trace()
1486 tlp->queue.count, 0); in timer_longterm_update_locked()
1541 tlp->queue.count, 0); in timer_longterm_update_locked()
[all …]
H A Dexclaves_inspection.h67 exclaves_inspection_queue_add(queue_t queue, queue_entry_t elm) in exclaves_inspection_queue_add() argument
69 assert(queue == &exclaves_inspection_queue_stackshot || queue == &exclaves_inspection_queue_kperf); in exclaves_inspection_queue_add()
72 enqueue_head(queue, elm); in exclaves_inspection_queue_add()
H A Dtimer_queue.h60 mpqueue_head_t *queue,
124 mpqueue_head_t *queue,
134 mpqueue_head_t *queue,
164 mpqueue_head_t *queue);
/xnu-11215/bsd/kern/
H A Dkern_aio.c435 aio_workq_t queue; in aio_entry_try_workq_remove() local
439 aio_workq_lock_spin(queue); in aio_entry_try_workq_remove()
442 aio_workq_unlock(queue); in aio_entry_try_workq_remove()
445 aio_workq_unlock(queue); in aio_entry_try_workq_remove()
1347 aio_workq_lock_spin(queue); in aio_try_enqueue_work_locked()
1349 waitq_wakeup64_one(&queue->aioq_waitq, CAST_EVENT64_T(queue), in aio_try_enqueue_work_locked()
1351 aio_workq_unlock(queue); in aio_try_enqueue_work_locked()
1599 aio_workq_lock_spin(queue); in aio_get_some_work()
1615 aio_workq_unlock(queue); in aio_get_some_work()
1646 waitq_assert_wait64(&queue->aioq_waitq, CAST_EVENT64_T(queue), THREAD_UNINT, 0); in aio_get_some_work()
[all …]
/xnu-11215/iokit/System/
H A DIODataQueueDispatchSourceShared.h13 IODataQueueEntry queue[0]; member
75 IODispatchQueue * queue, in Create_Impl() argument
320 head = (IODataQueueEntry *)((uintptr_t)dataQueue->queue + headOffset); in Peek()
338 entry = dataQueue->queue; in Peek()
407 head = (IODataQueueEntry *)((uintptr_t)dataQueue->queue + headOffset); in DequeueWithCoalesce()
423 entry = dataQueue->queue; in DequeueWithCoalesce()
533 entry = (IODataQueueEntry *)((uintptr_t)dataQueue->queue + tail); in EnqueueWithCoalesce()
545 entry = (IODataQueueEntry *)((uintptr_t)dataQueue->queue); in EnqueueWithCoalesce()
559 ((IODataQueueEntry *)((uintptr_t)dataQueue->queue + tail))->size = dataSize; in EnqueueWithCoalesce()
571 entry = (IODataQueueEntry *)((uintptr_t)dataQueue->queue + tail); in EnqueueWithCoalesce()
/xnu-11215/bsd/nfs/
H A Dnfs_upcall.c304 struct nfsrv_uc_queue *queue = &nfsrv_uc_queue_tbl[i]; in nfsrv_uc_cleanup() local
306 lck_mtx_lock(&queue->ucq_lock); in nfsrv_uc_cleanup()
307 while (!TAILQ_EMPTY(queue->ucq_queue)) { in nfsrv_uc_cleanup()
308 struct nfsrv_uc_arg *ep = TAILQ_FIRST(queue->ucq_queue); in nfsrv_uc_cleanup()
309 TAILQ_REMOVE(queue->ucq_queue, ep, nua_svcq); in nfsrv_uc_cleanup()
312 lck_mtx_unlock(&queue->ucq_lock); in nfsrv_uc_cleanup()
/xnu-11215/tests/
H A Dpwrite.c123 int queue = kqueue(); variable
124 T_ASSERT_POSIX_SUCCESS(queue, "Got kqueue");
126 test_pwrite_should_fail(queue, ESPIPE);
128 T_ASSERT_POSIX_SUCCESS(close(queue), "Close queue");
H A Dpread.c155 int queue = kqueue(); variable
156 T_ASSERT_POSIX_SUCCESS(queue, "Got kqueue");
158 test_pread_should_fail(queue, ESPIPE);
160 T_ASSERT_POSIX_SUCCESS(close(queue), "Closed queue");
/xnu-11215/tools/tests/affinity/
H A Dsets.c74 TAILQ_HEAD(, work) queue;
243 workp = TAILQ_FIRST(&(sp->input->queue)); in manager_fn()
253 TAILQ_REMOVE(&(sp->input->queue), workp, link); in manager_fn()
267 TAILQ_INSERT_TAIL(&(sp->output->queue), workp, link); in manager_fn()
444 TAILQ_INIT(&sp->bufq.queue); in main()
469 TAILQ_INSERT_TAIL(&lp->stage[0]->bufq.queue, &work_array[j], link); in main()
H A Dpool.c75 TAILQ_HEAD(, work) queue;
254 workp = TAILQ_FIRST(&(sp->input->queue)); in manager_fn()
264 TAILQ_REMOVE(&(sp->input->queue), workp, link); in manager_fn()
289 TAILQ_INSERT_TAIL(&(sp->output->queue), workp, link); in manager_fn()
411 TAILQ_INIT(&sp->bufq.queue); in main()
440 TAILQ_INSERT_TAIL(&stage_info[0].bufq.queue, &work_array[j], link); in main()

1234