Home
last modified time | relevance | path

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

1234567

/illumos-gate/usr/src/uts/common/io/xge/hal/xgehal/
H A Dxge-queue.c47 __queue_consume(xge_queue_t *queue, int data_max_size, xge_queue_item_t *item) in __queue_consume() argument
52 if (xge_list_is_empty(&queue->list_head)) in __queue_consume()
55 elem = (xge_queue_item_t *)queue->list_head.next; in __queue_consume()
61 if (queue->head_ptr == elem) { in __queue_consume()
62 queue->head_ptr = (char *)queue->head_ptr + real_size; in __queue_consume()
68 (u64)(ulong_t)queue->start_ptr, in __queue_consume()
69 (u64)(ulong_t)queue->head_ptr, in __queue_consume()
70 (u64)(ulong_t)queue->tail_ptr, in __queue_consume()
71 (u64)(ulong_t)queue->end_ptr, in __queue_consume()
74 } else if ((char *)queue->tail_ptr - real_size == (char*)elem) { in __queue_consume()
[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()
254 ring->indicate_max_pkts = queue->indicate_max_pkts; in __hal_ring_open()
255 ring->buffer_mode = queue->buffer_mode; in __hal_ring_open()
257 xge_assert(queue->configured); in __hal_ring_open()
270 ring->rxd_size = XGE_HAL_RING_RXD_SIZEOF(queue->buffer_mode); in __hal_ring_open()
276 ring->rxds_per_block = XGE_HAL_RING_RXDS_PER_BLOCK(queue->buffer_mode); in __hal_ring_open()
282 sizeof(void*) * queue->max * ring->rxds_per_block); in __hal_ring_open()
294 queue->initial, queue->max, in __hal_ring_open()
306 queue->initial * ring->rxds_per_block, in __hal_ring_open()
[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()
201 (int)(XGE_HAL_TX_FIFO_NO_SNOOP(queue->no_snoop_bits)); 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()
399 int priority = hldev->config.fifo.queue[i].priority; in __hal_fifo_hw_initialize()
401 vBIT((hldev->config.fifo.queue[i].max-1), in __hal_fifo_hw_initialize()
[all …]
/illumos-gate/usr/src/man/man3head/
H A DMakefile65 queue.h.3head \
311 LIST_CLASS_ENTRY.3head := LINKSRC = queue.h.3head
312 LIST_CLASS_HEAD.3head := LINKSRC = queue.h.3head
313 LIST_CONCAT.3head := LINKSRC = queue.h.3head
314 LIST_EMPTY.3head := LINKSRC = queue.h.3head
315 LIST_ENTRY.3head := LINKSRC = queue.h.3head
316 LIST_FIRST.3head := LINKSRC = queue.h.3head
317 LIST_FOREACH.3head := LINKSRC = queue.h.3head
318 LIST_FOREACH_FROM.3head := LINKSRC = queue.h.3head
319 LIST_FOREACH_FROM_SAFE.3head := LINKSRC = queue.h.3head
[all …]
/illumos-gate/usr/src/uts/common/gssapi/mechs/krb5/mech/
H A Dutil_ordering.c56 } queue; typedef
129 queue_insert(queue *q, int after, gssint_uint64 seqnum) in queue_insert()
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()
[all …]
/illumos-gate/usr/src/uts/common/io/xge/drv/
H A Dxge.c277 device_config->ring.queue[index].configured = in xge_ring_config()
282 if (!device_config->ring.queue[index].configured) in xge_ring_config()
286 device_config->ring.queue[index].no_snoop_bits = 1; in xge_ring_config()
290 device_config->ring.queue[index].max = in xge_ring_config()
296 device_config->ring.queue[index].initial = in xge_ring_config()
301 if (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()
309 device_config->ring.queue[index].buffer_mode = in xge_ring_config()
315 device_config->ring.queue[index].dram_size_mb = in xge_ring_config()
[all …]
/illumos-gate/usr/src/lib/smbsrv/libmlsvc/common/
H A Deventlog_log.c216 logr_syslog_destroy_queue(list_t *queue) in logr_syslog_destroy_queue() argument
220 while ((head = list_head(queue)) != NULL) { in logr_syslog_destroy_queue()
221 list_remove(queue, head); in logr_syslog_destroy_queue()
224 list_destroy(queue); in logr_syslog_destroy_queue()
228 logr_syslog_construct_queue(FILE *fp, list_t *queue) in logr_syslog_construct_queue() argument
234 list_create(queue, sizeof (logr_syslog_node_t), in logr_syslog_construct_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()
[all …]
/illumos-gate/usr/src/lib/print/libipp-listener/common/
H A Dcups-accept-jobs.c42 char *queue = NULL; in cups_accept_jobs() local
52 get_printer_id(operational, &queue, NULL); in cups_accept_jobs()
53 if (queue == NULL) { in cups_accept_jobs()
59 if ((status = papiPrinterResume(svc, queue)) != PAPI_OK) { in cups_accept_jobs()
61 (queue ? queue : "(null)"), in cups_accept_jobs()
H A Denable-printer.c42 char *queue = NULL; in ipp_enable_printer() local
52 get_printer_id(operational, &queue, NULL); in ipp_enable_printer()
53 if (queue == NULL) { in ipp_enable_printer()
59 if ((status = papiPrinterEnable(svc, queue)) != PAPI_OK) { in ipp_enable_printer()
61 (queue ? queue : "(null)"), in ipp_enable_printer()
H A Dresume-printer.c42 char *queue = NULL; in ipp_resume_printer() local
52 get_printer_id(operational, &queue, NULL); in ipp_resume_printer()
53 if (queue == NULL) { in ipp_resume_printer()
59 if ((status = papiPrinterResume(svc, queue)) != PAPI_OK) { in ipp_resume_printer()
61 (queue ? queue : "(null)"), in ipp_resume_printer()
H A Dcups-reject-jobs.c42 char *queue = NULL; in cups_reject_jobs() local
52 get_printer_id(operational, &queue, NULL); in cups_reject_jobs()
53 if (queue == NULL) { in cups_reject_jobs()
59 if ((status = papiPrinterPause(svc, queue, NULL)) != PAPI_OK) { in cups_reject_jobs()
61 (queue ? queue : "(null)"), in cups_reject_jobs()
H A Dpause-printer.c42 char *queue = NULL; in ipp_pause_printer() local
52 get_printer_id(operational, &queue, NULL); in ipp_pause_printer()
53 if (queue == NULL) { in ipp_pause_printer()
59 if ((status = papiPrinterPause(svc, queue, NULL)) != PAPI_OK) { in ipp_pause_printer()
61 (queue ? queue : "(null)"), in ipp_pause_printer()
H A Dpurge-jobs.c43 char *queue = NULL; in ipp_purge_jobs() local
53 get_printer_id(operational, &queue, NULL); in ipp_purge_jobs()
54 if (queue == NULL) { in ipp_purge_jobs()
60 if ((status = papiPrinterPurgeJobs(svc, queue, &jobs)) != PAPI_OK) { in ipp_purge_jobs()
62 (queue ? queue : "(null)"), in ipp_purge_jobs()
H A Ddisable-printer.c42 char *queue = NULL; in ipp_disable_printer() local
54 get_printer_id(operational, &queue, NULL); in ipp_disable_printer()
55 if (queue == NULL) { in ipp_disable_printer()
68 if ((status = papiPrinterDisable(svc, queue, message)) != PAPI_OK) { in ipp_disable_printer()
70 (queue ? queue : "(null)"), in ipp_disable_printer()
H A Dcancel-job.c43 char *queue = NULL; in ipp_cancel_job() local
54 get_printer_id(operational, &queue, &id); in ipp_cancel_job()
59 } else if (queue == NULL) { in ipp_cancel_job()
72 status = papiJobCancel(svc, queue, id); in ipp_cancel_job()
76 (queue ? queue : "(null)"), id, in ipp_cancel_job()
H A Dhold-job.c43 char *queue = NULL; in ipp_hold_job() local
54 get_printer_id(operational, &queue, &id); in ipp_hold_job()
59 } else if (queue == NULL) { in ipp_hold_job()
73 if ((status = papiJobHold(svc, queue, id)) != PAPI_OK) { in ipp_hold_job()
76 (queue ? queue : "(null)"), id, in ipp_hold_job()
H A Drelease-job.c43 char *queue = NULL; in ipp_release_job() local
54 get_printer_id(operational, &queue, &id); in ipp_release_job()
59 } else if (queue == NULL) { in ipp_release_job()
72 if ((status = papiJobRelease(svc, queue, id)) != PAPI_OK) { in ipp_release_job()
75 (queue ? queue : "(null)"), id, in ipp_release_job()
H A Dcups-move-job.c44 char *queue = NULL; in cups_move_job() local
68 get_printer_id(operational, &queue, &id); in cups_move_job()
73 } else if (queue == NULL) { in cups_move_job()
93 if ((status = papiJobMove(svc, queue, id, dest)) != PAPI_OK) in cups_move_job()
96 (queue ? queue : "(null)"), id, in cups_move_job()
H A Drestart-job.c44 char *queue = NULL; in ipp_restart_job() local
55 get_printer_id(operational, &queue, &id); in ipp_restart_job()
60 } else if (queue == NULL) { in ipp_restart_job()
76 if ((status = papiJobRestart(svc, queue, id)) != PAPI_OK) { in ipp_restart_job()
79 (queue ? queue : "(null)"), id, in ipp_restart_job()
H A Dset-printer-attributes.c44 char *queue = NULL; in ipp_set_printer_attributes() local
54 get_printer_id(operational, &queue, NULL); in ipp_set_printer_attributes()
55 if (queue == NULL) { in ipp_set_printer_attributes()
66 status = papiPrinterModify(svc, queue, printer_attributes, &p); in ipp_set_printer_attributes()
/illumos-gate/usr/src/cmd/bhyve/common/
H A Dpci_virtio_input.c469 struct vtinput_eventqueue *queue, struct input_event *e) in vtinput_eventqueue_add_event() argument
472 if (queue->idx >= queue->size) { in vtinput_eventqueue_add_event()
474 const uint32_t newSize = queue->idx; in vtinput_eventqueue_add_event()
475 void *newPtr = realloc(queue->events, in vtinput_eventqueue_add_event()
476 queue->size * sizeof(struct vtinput_event_elem)); in vtinput_eventqueue_add_event()
482 queue->events = newPtr; in vtinput_eventqueue_add_event()
483 queue->size = newSize; in vtinput_eventqueue_add_event()
487 struct vtinput_event *event = &queue->events[queue->idx].event; in vtinput_eventqueue_add_event()
491 queue->idx++; in vtinput_eventqueue_add_event()
497 vtinput_eventqueue_clear(struct vtinput_eventqueue *queue) in vtinput_eventqueue_clear() argument
[all …]
/illumos-gate/usr/src/uts/common/io/
H A Dbeep.c88 beep_entry_t *queue; in beep_init() local
106 queue = kmem_zalloc(sizeof (beep_entry_t) * beep_queue_size, in beep_init()
112 (unsigned long)queue)); in beep_init()
114 if (queue == NULL) { in beep_init()
130 beep_state.queue = queue; in beep_init()
155 if (beep_state.queue != NULL) in beep_fini()
156 kmem_free(beep_state.queue, in beep_fini()
169 beep_state.queue = (beep_entry_t *)NULL; in beep_fini()
379 beep_state.queue[beep_state.queue_tail]. in beep_mktone()
382 beep_state.queue[beep_state.queue_tail]. in beep_mktone()
[all …]
/illumos-gate/usr/src/uts/common/io/i40e/
H A Di40e_intr.c386 i40e_set_lnklstn(i40e_t *i40e, uint_t vector, uint_t queue) in i40e_set_lnklstn() argument
391 reg = (queue << I40E_PFINT_LNKLSTN_FIRSTQ_INDX_SHIFT) | in i40e_set_lnklstn()
405 i40e_set_rqctl(i40e_t *i40e, uint_t vector, uint_t queue) in i40e_set_rqctl() argument
410 ASSERT3U(vector, ==, i40e->i40e_trqpairs[queue].itrq_rx_intrvec); in i40e_set_rqctl()
414 (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()
427 i40e_set_tqctl(i40e_t *i40e, uint_t vector, uint_t queue, uint_t next_queue) in i40e_set_tqctl() argument
432 ASSERT3U(vector, ==, i40e->i40e_trqpairs[queue].itrq_tx_intrvec); in i40e_set_tqctl()
440 I40E_WRITE_REG(hw, I40E_QINT_TQCTL(queue), reg); in i40e_set_tqctl()
[all …]
/illumos-gate/usr/src/uts/common/fs/zfs/
H A Ddsl_scan.c333 const zbookmark_phys_t *zb, dsl_scan_io_queue_t *queue);
334 static void scan_io_queue_insert_impl(dsl_scan_io_queue_t *queue,
1239 dsl_scan_io_queue_t *queue; in dsl_scan_should_clear() local
1242 queue = tvd->vdev_scan_io_queue; in dsl_scan_should_clear()
1243 if (queue != NULL) { in dsl_scan_should_clear()
1248 mused += zfs_btree_numnodes(&queue->q_exts_by_size) * in dsl_scan_should_clear()
1249 3 * sizeof (range_seg_gap_t) + queue->q_sio_memused; in dsl_scan_should_clear()
2730 scan_io_queue_issue(dsl_scan_io_queue_t *queue, list_t *io_list) in scan_io_queue_issue() argument
2732 dsl_scan_t *scn = queue->q_scn; in scan_io_queue_issue()
2748 &sio->sio_zb, queue); in scan_io_queue_issue()
[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()

1234567