Home
last modified time | relevance | path

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

1234567

/illumos-gate/usr/src/uts/common/io/xge/hal/xgehal/
H A Dxge-queue.c100 xge_assert(queue->tail_ptr >= queue->head_ptr); in __queue_consume()
101 xge_assert(queue->tail_ptr >= queue->start_ptr && in __queue_consume()
102 queue->tail_ptr <= queue->end_ptr); in __queue_consume()
103 xge_assert(queue->head_ptr >= queue->start_ptr && in __queue_consume()
104 queue->head_ptr < queue->end_ptr); in __queue_consume()
111 queue->head_ptr = queue->tail_ptr = queue->start_ptr; in __queue_consume()
217 queue->tail_ptr <= queue->end_ptr); in xge_queue_produce()
219 queue->head_ptr < queue->end_ptr); in xge_queue_produce()
275 queue->head_ptr = queue->tail_ptr = queue->start_ptr; in xge_queue_create()
276 queue->end_ptr = (char *)queue->start_ptr + in xge_queue_create()
[all …]
H A Dxgehal-ring.c245 xge_hal_ring_queue_t *queue; in __hal_ring_open() local
253 queue = &ring->config->queue[attr->post_qid]; in __hal_ring_open()
257 xge_assert(queue->configured); in __hal_ring_open()
294 queue->initial, queue->max, in __hal_ring_open()
347 xge_hal_ring_queue_t *queue; in __hal_ring_close() local
355 queue = &ring->config->queue[ring->channel.post_qid]; in __hal_ring_close()
390 xge_hal_ring_queue_t *queue; in __hal_ring_prc_enable() local
398 queue = &ring->config->queue[ring->channel.post_qid]; in __hal_ring_prc_enable()
401 queue->buffer_mode == 5); in __hal_ring_prc_enable()
406 block_num = queue->initial; in __hal_ring_prc_enable()
[all …]
H A Dxgehal-fifo.c155 xge_hal_fifo_queue_t *queue; in __hal_fifo_open() local
161 queue = &fifo->config->queue[attr->post_qid]; in __hal_fifo_open()
197 if (queue->intr) { in __hal_fifo_open()
256 queue->initial, in __hal_fifo_open()
257 queue->max, in __hal_fifo_open()
267 queue->initial, queue->max, in __hal_fifo_open()
398 if (hldev->config.fifo.queue[i].configured) { in __hal_fifo_hw_initialize()
401 vBIT((hldev->config.fifo.queue[i].max-1), in __hal_fifo_hw_initialize()
463 if (!hldev->config.fifo.queue[i].configured || in __hal_fifo_hw_initialize()
464 !hldev->config.fifo.queue[i].intr_vector) in __hal_fifo_hw_initialize()
[all …]
/illumos-gate/usr/src/man/man3head/
H A DMakefile65 queue.h.3head \
312 LIST_EMPTY.3head := LINKSRC = queue.h.3head
313 LIST_ENTRY.3head := LINKSRC = queue.h.3head
314 LIST_FIRST.3head := LINKSRC = queue.h.3head
319 LIST_HEAD.3head := LINKSRC = queue.h.3head
321 LIST_INIT.3head := LINKSRC = queue.h.3head
325 LIST_NEXT.3head := LINKSRC = queue.h.3head
326 LIST_PREV.3head := LINKSRC = queue.h.3head
328 LIST_SWAP.3head := LINKSRC = queue.h.3head
339 SLIST_HEAD.3head := LINKSRC = queue.h.3head
[all …]
/illumos-gate/usr/src/uts/common/gssapi/mechs/krb5/mech/
H A Dutil_ordering.c56 } queue; typedef
163 queue *q; in g_order_init()
165 if ((q = (queue *) MALLOC(sizeof(queue))) == NULL) in g_order_init()
184 queue *q; in g_order_check()
188 q = (queue *) (*vqueue); in g_order_check()
256 queue *q; in g_order_free()
258 q = (queue *) (*vqueue); in g_order_free()
260 FREE (q, sizeof (queue)); in g_order_free()
273 *sizep += sizeof(queue); in g_queue_size()
281 *buf += sizeof(queue); in g_queue_externalize()
[all …]
/illumos-gate/usr/src/uts/common/io/xge/drv/
H A Dxge.c290 device_config->ring.queue[index].max = in xge_ring_config()
296 device_config->ring.queue[index].initial = in xge_ring_config()
303 device_config->ring.queue[index].initial = in xge_ring_config()
304 device_config->ring.queue[index].max = in xge_ring_config()
335 device_config->ring.queue[index].priority = in xge_ring_config()
347 device_config->ring.queue[index].rti.ufc_a = in xge_ring_config()
359 device_config->ring.queue[index].rti.ufc_b = in xge_ring_config()
442 device_config->fifo.queue[index].initial = in xge_fifo_config()
462 device_config->fifo.queue[index].max = in xge_fifo_config()
908 if (fifo_conf->queue[i].configured) { in xge_add_intrs()
[all …]
/illumos-gate/usr/src/lib/smbsrv/libmlsvc/common/
H A Deventlog_log.c221 list_remove(queue, head); in logr_syslog_destroy_queue()
224 list_destroy(queue); in logr_syslog_destroy_queue()
241 head = list_head(queue); in logr_syslog_construct_queue()
242 list_remove(queue, head); in logr_syslog_construct_queue()
247 logr_syslog_destroy_queue(queue); in logr_syslog_construct_queue()
253 list_insert_tail(queue, node); in logr_syslog_construct_queue()
276 list_t queue; in logr_syslog_load() local
282 node = list_head(&queue); in logr_syslog_load()
287 node = list_next(&queue, node); in logr_syslog_load()
294 node = list_next(&queue, node); in logr_syslog_load()
[all …]
/illumos-gate/usr/src/lib/print/libipp-listener/common/
H A Dcups-accept-jobs.c44 char *queue = NULL; in cups_accept_jobs() local
54 get_printer_id(operational, &queue, NULL); in cups_accept_jobs()
55 if (queue == NULL) { in cups_accept_jobs()
61 if ((status = papiPrinterResume(svc, queue)) != PAPI_OK) { in cups_accept_jobs()
63 (queue ? queue : "(null)"), in cups_accept_jobs()
H A Denable-printer.c44 char *queue = NULL; in ipp_enable_printer() local
54 get_printer_id(operational, &queue, NULL); in ipp_enable_printer()
55 if (queue == NULL) { in ipp_enable_printer()
61 if ((status = papiPrinterEnable(svc, queue)) != PAPI_OK) { in ipp_enable_printer()
63 (queue ? queue : "(null)"), in ipp_enable_printer()
H A Dresume-printer.c44 char *queue = NULL; in ipp_resume_printer() local
54 get_printer_id(operational, &queue, NULL); in ipp_resume_printer()
55 if (queue == NULL) { in ipp_resume_printer()
61 if ((status = papiPrinterResume(svc, queue)) != PAPI_OK) { in ipp_resume_printer()
63 (queue ? queue : "(null)"), in ipp_resume_printer()
H A Dcups-reject-jobs.c44 char *queue = NULL; in cups_reject_jobs() local
54 get_printer_id(operational, &queue, NULL); in cups_reject_jobs()
55 if (queue == NULL) { in cups_reject_jobs()
61 if ((status = papiPrinterPause(svc, queue, NULL)) != PAPI_OK) { in cups_reject_jobs()
63 (queue ? queue : "(null)"), in cups_reject_jobs()
H A Dpause-printer.c44 char *queue = NULL; in ipp_pause_printer() local
54 get_printer_id(operational, &queue, NULL); in ipp_pause_printer()
55 if (queue == NULL) { in ipp_pause_printer()
61 if ((status = papiPrinterPause(svc, queue, NULL)) != PAPI_OK) { in ipp_pause_printer()
63 (queue ? queue : "(null)"), in ipp_pause_printer()
H A Dpurge-jobs.c45 char *queue = NULL; in ipp_purge_jobs() local
55 get_printer_id(operational, &queue, NULL); in ipp_purge_jobs()
56 if (queue == NULL) { in ipp_purge_jobs()
62 if ((status = papiPrinterPurgeJobs(svc, queue, &jobs)) != PAPI_OK) { in ipp_purge_jobs()
64 (queue ? queue : "(null)"), in ipp_purge_jobs()
H A Ddisable-printer.c44 char *queue = NULL; in ipp_disable_printer() local
56 get_printer_id(operational, &queue, NULL); in ipp_disable_printer()
57 if (queue == NULL) { in ipp_disable_printer()
70 if ((status = papiPrinterDisable(svc, queue, message)) != PAPI_OK) { in ipp_disable_printer()
72 (queue ? queue : "(null)"), in ipp_disable_printer()
H A Dhold-job.c45 char *queue = NULL; in ipp_hold_job() local
56 get_printer_id(operational, &queue, &id); in ipp_hold_job()
61 } else if (queue == NULL) { in ipp_hold_job()
75 if ((status = papiJobHold(svc, queue, id)) != PAPI_OK) { in ipp_hold_job()
78 (queue ? queue : "(null)"), id, in ipp_hold_job()
H A Drelease-job.c45 char *queue = NULL; in ipp_release_job() local
56 get_printer_id(operational, &queue, &id); in ipp_release_job()
61 } else if (queue == NULL) { in ipp_release_job()
74 if ((status = papiJobRelease(svc, queue, id)) != PAPI_OK) { in ipp_release_job()
77 (queue ? queue : "(null)"), id, in ipp_release_job()
H A Dcancel-job.c45 char *queue = NULL; in ipp_cancel_job() local
56 get_printer_id(operational, &queue, &id); in ipp_cancel_job()
61 } else if (queue == NULL) { in ipp_cancel_job()
74 status = papiJobCancel(svc, queue, id); in ipp_cancel_job()
78 (queue ? queue : "(null)"), id, in ipp_cancel_job()
H A Dcups-move-job.c46 char *queue = NULL; in cups_move_job() local
70 get_printer_id(operational, &queue, &id); in cups_move_job()
75 } else if (queue == NULL) { in cups_move_job()
95 if ((status = papiJobMove(svc, queue, id, dest)) != PAPI_OK) in cups_move_job()
98 (queue ? queue : "(null)"), id, in cups_move_job()
H A Drestart-job.c46 char *queue = NULL; in ipp_restart_job() local
57 get_printer_id(operational, &queue, &id); in ipp_restart_job()
62 } else if (queue == NULL) { in ipp_restart_job()
78 if ((status = papiJobRestart(svc, queue, id)) != PAPI_OK) { in ipp_restart_job()
81 (queue ? queue : "(null)"), id, in ipp_restart_job()
H A Dset-printer-attributes.c46 char *queue = NULL; in ipp_set_printer_attributes() local
56 get_printer_id(operational, &queue, NULL); in ipp_set_printer_attributes()
57 if (queue == NULL) { in ipp_set_printer_attributes()
68 status = papiPrinterModify(svc, queue, printer_attributes, &p); in ipp_set_printer_attributes()
/illumos-gate/usr/src/cmd/bhyve/
H A Dpci_virtio_input.c476 if (queue->idx >= queue->size) { in vtinput_eventqueue_add_event()
478 const uint32_t newSize = queue->idx; in vtinput_eventqueue_add_event()
488 queue->size = newSize; in vtinput_eventqueue_add_event()
492 struct vtinput_event *event = &queue->events[queue->idx].event; in vtinput_eventqueue_add_event()
496 queue->idx++; in vtinput_eventqueue_add_event()
505 queue->idx = 0; in vtinput_eventqueue_clear()
516 for (uint32_t i = 0; i < queue->idx; ++i) { in vtinput_eventqueue_send_events()
526 __func__, queue->idx)); in vtinput_eventqueue_send_events()
555 queue->events[i].iov = iov; in vtinput_eventqueue_send_events()
556 queue->events[i].idx = req.idx; in vtinput_eventqueue_send_events()
[all …]
/illumos-gate/usr/src/uts/common/io/
H A Dbeep.c90 beep_entry_t *queue; in beep_init() local
114 (unsigned long)queue)); in beep_init()
116 if (queue == NULL) { in beep_init()
132 beep_state.queue = queue; in beep_init()
157 if (beep_state.queue != NULL) in beep_fini()
158 kmem_free(beep_state.queue, in beep_fini()
171 beep_state.queue = (beep_entry_t *)NULL; in beep_fini()
381 beep_state.queue[beep_state.queue_tail]. in beep_mktone()
384 beep_state.queue[beep_state.queue_tail]. in beep_mktone()
464 frequency = beep_state.queue[next].frequency; in beep_timeout()
[all …]
/illumos-gate/usr/src/uts/common/io/i40e/
H A Di40e_intr.c414 (queue << I40E_QINT_RQCTL_NEXTQ_INDX_SHIFT) | in i40e_set_rqctl()
418 I40E_WRITE_REG(hw, I40E_QINT_RQCTL(queue), reg); in i40e_set_rqctl()
419 DEBUGOUT2("QINT_RQCTL[%u] = 0x%x", queue, reg); in i40e_set_rqctl()
440 I40E_WRITE_REG(hw, I40E_QINT_TQCTL(queue), reg); in i40e_set_tqctl()
441 DEBUGOUT2("QINT_TQCTL[%u] = 0x%x", queue, reg); in i40e_set_tqctl()
531 uint_t queue = itrq->itrq_index; in i40e_intr_rx_queue_enable() local
537 reg = I40E_READ_REG(hw, I40E_QINT_RQCTL(queue)); in i40e_intr_rx_queue_enable()
540 I40E_WRITE_REG(hw, I40E_QINT_RQCTL(queue), reg); in i40e_intr_rx_queue_enable()
552 uint_t queue = itrq->itrq_index; in i40e_intr_rx_queue_disable() local
558 reg = I40E_READ_REG(hw, I40E_QINT_RQCTL(queue)); in i40e_intr_rx_queue_disable()
[all …]
/illumos-gate/usr/src/lib/libslp/clib/
H A Dslp_queue.c58 struct queue { struct
77 struct queue *q; in slp_new_queue()
118 struct queue *q = qa; in slp_enqueue()
147 struct queue *q = qa; in slp_enqueue_at_head()
169 static void *dequeue_nolock(struct queue *q) { in dequeue_nolock()
194 struct queue *q = qa; in slp_dequeue_timed()
239 struct queue *q = qa; in slp_flush_queue()
253 struct queue *q = qa; in slp_destroy_queue()
/illumos-gate/usr/src/uts/common/fs/zfs/
H A Ddsl_scan.c1234 if (queue != NULL) { in dsl_scan_should_clear()
2736 &sio->sio_zb, queue); in scan_io_queue_issue()
2922 queue->q_segs_this_txg = 0; in scan_io_queues_run_one()
2924 queue->q_zios_this_txg = 0; in scan_io_queues_run_one()
3094 if (queue == NULL) in dsl_scan_update_stats()
3889 if (queue == NULL) { in dsl_scan_scrub_done()
3925 if (queue == NULL) { in scan_exec_io()
3935 while (queue->q_inflight_bytes >= queue->q_maxinflight_bytes) in scan_exec_io()
4061 range_tree_vacate(queue->q_exts_by_addr, NULL, queue); in dsl_scan_io_queue_destroy()
4066 kmem_free(queue, sizeof (*queue)); in dsl_scan_io_queue_destroy()
[all …]

1234567