Home
last modified time | relevance | path

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

1234567

/titanic_41/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 …]
/titanic_41/usr/src/uts/common/io/lvm/notify/
H A Dmd_notify.c64 md_flush_queue(md_event_queue_t *queue) in md_flush_queue() argument
72 if (queue->mdn_waiting) in md_flush_queue()
79 element = queue->mdn_front; in md_flush_queue()
85 queue->mdn_front = queue->mdn_tail = NULL; in md_flush_queue()
95 md_event_queue_t *queue; in md_put_event() local
102 for (queue = md_event_queue; queue; queue = queue->mdn_nextq) { in md_put_event()
103 if (queue->mdn_size >= md_max_notify_queue) { in md_put_event()
104 ASSERT(queue->mdn_front != NULL); in md_put_event()
105 ASSERT(queue->mdn_front->mdn_next != NULL); in md_put_event()
106 entry = queue->mdn_front; in md_put_event()
[all …]
/titanic_41/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 …]
/titanic_41/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 …]
/titanic_41/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 …]
/titanic_41/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 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 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 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()
H A Dget-job-attributes.c47 char *queue = NULL; in ipp_get_job_attributes() local
58 get_printer_id(operational, &queue, &id); in ipp_get_job_attributes()
63 } else if (queue == NULL) { in ipp_get_job_attributes()
75 if ((status = papiJobQuery(svc, queue, id, req_attrs, &j)) != PAPI_OK) { in ipp_get_job_attributes()
H A Dget-printer-attributes.c48 char *queue = NULL; in ipp_get_printer_attributes() local
58 get_printer_id(operational, &queue, NULL); in ipp_get_printer_attributes()
59 if (queue == NULL) { in ipp_get_printer_attributes()
73 status = papiPrinterQuery(svc, queue, req_attrs, NULL, &p); in ipp_get_printer_attributes()
/titanic_41/usr/src/uts/common/io/
H A Dbeep.c90 beep_entry_t *queue; in beep_init() local
108 queue = kmem_zalloc(sizeof (beep_entry_t) * beep_queue_size, in beep_init()
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()
[all …]
/titanic_41/usr/src/lib/libslp/clib/
H A Dslp_queue.c60 struct queue { struct
79 struct queue *q; in slp_new_queue()
120 struct queue *q = qa; in slp_enqueue()
149 struct queue *q = qa; in slp_enqueue_at_head()
171 static void *dequeue_nolock(struct queue *q) { in dequeue_nolock()
196 struct queue *q = qa; in slp_dequeue_timed()
241 struct queue *q = qa; in slp_flush_queue()
255 struct queue *q = qa; in slp_destroy_queue()
/titanic_41/usr/src/cmd/fgrep/
H A Dfgrep.c615 struct words **queue = NULL; in cfail() local
627 if ((queue = (struct words **)calloc(qsize, sizeof (struct words *))) in cfail()
632 front = rear = queue; in cfail()
640 if (rear >= &queue[qsize - 1]) { in cfail()
641 frontoffset = front - queue; in cfail()
642 rearoffset = rear - queue; in cfail()
644 if ((queue = (struct words **)realloc(queue, in cfail()
649 front = queue + frontoffset; in cfail()
650 rear = queue + rearoffset; in cfail()
666 if (rear >= &queue[qsize - 1]) { in cfail()
[all …]
/titanic_41/usr/src/cmd/krb5/kadmin/gui/visualrt/sunsoft/jws/visual/rt/base/
H A DRegistry.java64 queue = new Vector(1); in Registry()
74 private Vector queue; field in Registry
149 queue.addElement(msg); in publish()
162 if (queue.size() == 0) { in run()
168 if (queue.size() != 0) { in run()
169 msg = (Message)queue.firstElement(); in run()
170 queue.removeElementAt(0); in run()

1234567