Searched defs:queue (Results 26 - 50 of 74) sorted by relevance

123

/illumos-gate/usr/src/lib/udapl/udapl_tavor/common/
H A Ddapl_cookie.c132 IN void *queue,
161 buffer->pool[i].queue.ep = queue;
163 buffer->pool[i].queue.srq = queue;
211 * create a new cookie buffer, the queue type and queue ptr remain the
215 curr_buffer->pool[0].queue.ptr, curr_buffer->pool[0].queue_type,
130 dapls_cb_create( IN DAPL_COOKIE_BUFFER *buffer, IN void *queue, IN DAPL_COOKIE_QUEUE_TYPE type, IN DAT_COUNT size) argument
/illumos-gate/usr/src/uts/common/io/scsi/adapters/iscsi/
H A Discsi_queue.c37 * | public queue functions |
40 * Public queue locking rules. When acquiring multiple queue locks
47 * If a cmd_mutex is held, it is either held after the pending queue
48 * mutex or after the active queue mutex.
52 * iscsi_init_queue - used to initialize iscsi queue
55 iscsi_init_queue(iscsi_queue_t *queue) argument
57 ASSERT(queue != NULL);
59 queue->head = NULL;
60 queue
69 iscsi_destroy_queue(iscsi_queue_t *queue) argument
[all...]
/illumos-gate/usr/src/cmd/print/printmgr/com/sun/admin/pm/server/
H A DDoPrinterUtil.java534 String queue) throws Exception
539 Debug.message("SVR: DoPrinterUtil.isLocalhost():queue " + queue);
542 syscmd.exec("/usr/bin/grep " + queue + " /etc/printers.conf");
546 "SVR:DoPrinterUtil:isLocalhost:failed:queue: " + queue);
533 isLocalhost( String queue) argument
/illumos-gate/usr/src/cmd/sgs/mcs/common/
H A Dmain.c48 static void queue(int, char *);
114 queue(ACT_APPEND, optarg);
120 queue(ACT_COMPRESS, NULL);
126 queue(ACT_DELETE, NULL);
131 queue(ACT_ZAP, NULL);
144 queue(ACT_PRINT, NULL);
213 queue(ACT_DELETE, NULL);
241 queue(int activity, char *string) function
/illumos-gate/usr/src/uts/common/gssapi/mechs/krb5/mech/
H A Dutil_ordering.c56 } queue; typedef in typeref:struct:_queue
59 * - the queue is a circular queue. The first element (q->elem[q->start])
129 queue_insert(queue *q, int after, gssint_uint64 seqnum)
163 queue *q;
165 if ((q = (queue *) MALLOC(sizeof(queue))) == NULL)
184 queue *q;
188 q = (queue *) (*vqueue);
256 queue *
[all...]
/illumos-gate/usr/src/uts/common/io/xge/hal/xgehal/
H A Dxge-queue.c24 #include "xge-queue.h"
33 * user-defined portion of the queue item.
41 * __queue_consume - (Lockless) dequeue an item from the specified queue.
43 * @queue: Event queue.
47 __queue_consume(xge_queue_t *queue, int data_max_size, xge_queue_item_t *item) argument
52 if (xge_list_is_empty(&queue->list_head))
55 elem = (xge_queue_item_t *)queue->list_head.next;
61 if (queue->head_ptr == elem) {
62 queue
142 xge_queue_t *queue = (xge_queue_t *)queueh; local
259 xge_queue_t *queue; local
296 xge_queue_t *queue = (xge_queue_t *)queueh; local
323 xge_queue_t *queue = (xge_queue_t *)queueh; local
394 xge_queue_t *queue = (xge_queue_t *)queueh; local
442 xge_queue_t* queue = (xge_queue_t*)qh; local
[all...]
H A Dxgehal-fifo.c155 xge_hal_fifo_queue_t *queue; local
161 queue = &fifo->config->queue[attr->post_qid];
189 * the FIFO queue pointer and as a location of FIFO control
197 if (queue->intr) {
201 (int)(XGE_HAL_TX_FIFO_NO_SNOOP(queue->no_snoop_bits));
256 queue->initial,
257 queue->max,
267 queue->initial, queue
[all...]
H A Dxgehal-ring.c245 xge_hal_ring_queue_t *queue; local
253 queue = &ring->config->queue[attr->post_qid];
254 ring->indicate_max_pkts = queue->indicate_max_pkts;
255 ring->buffer_mode = queue->buffer_mode;
257 xge_assert(queue->configured);
270 ring->rxd_size = XGE_HAL_RING_RXD_SIZEOF(queue->buffer_mode);
276 ring->rxds_per_block = XGE_HAL_RING_RXDS_PER_BLOCK(queue->buffer_mode);
282 sizeof(void*) * queue->max * ring->rxds_per_block);
294 queue
347 xge_hal_ring_queue_t *queue; local
390 xge_hal_ring_queue_t *queue; local
[all...]
H A Dxgehal-mgmt.c491 * @queue: the queue who's data is to be collected.
497 __hal_update_ring_bump(xge_hal_device_t *hldev, int queue, argument
502 int reg = (queue / 4);
508 chinfo->ring_bump_cnt = XGE_HAL_RING_BUMP_CNT(queue, rbc);
/illumos-gate/usr/src/uts/common/sys/
H A Dbeep.h82 /* and queue */
85 /* Index of head of queue */
88 /* Index of tail of queue */
91 /* Max queue size */
95 beep_entry_t *queue; member in struct:beep_state
/illumos-gate/usr/src/lib/print/libprint/common/
H A Dns_bsd_addr.c267 char *queue = NULL; local
273 split_name(addr, ": \t", &server, &queue, &extension);
276 if ((server != NULL) && (queue != NULL))
278 queue, (extension != NULL ? "," : ""),
/illumos-gate/usr/src/cmd/refer/
H A Dglue5.c345 struct words *queue[QSIZE]; local
351 front = rear = queue;
355 if (rear >= &queue[QSIZE - 1]) overflo();
363 if (front == &queue[QSIZE-1])
364 front = queue;
370 if (rear >= &queue[QSIZE-1])
371 if (front == queue) overflo();
372 else rear = queue;
/illumos-gate/usr/src/uts/common/io/bnxe/577xx/hsi/mcp/
H A Dmulti_thread_def.h88 struct task_t task[MAX_THREAD_QUEUE]; /* The request queue. */
89 u32 front; /* For de-queue */
120 struct tasks_queue_t queue; member in struct:thread_t
/illumos-gate/usr/src/uts/common/io/lvm/notify/
H A Dmd_notify.c64 md_flush_queue(md_event_queue_t *queue) argument
72 if (queue->mdn_waiting)
79 element = queue->mdn_front;
85 queue->mdn_front = queue->mdn_tail = NULL;
95 md_event_queue_t *queue; local
102 for (queue = md_event_queue; queue; queue = queue
203 md_event_queue_t *orig_queue, *queue, *queue_free; local
[all...]
/illumos-gate/usr/src/uts/i86pc/os/
H A Dx_call.c59 * on a target(s) CPU's work queue. Any synchronization is handled by passing
107 #define XC_MSG_FREE (0) /* msg in xc_free queue */
153 * Put a message into a queue. The insertion is atomic no matter
154 * how many different inserts/extracts to the same queue happen.
157 xc_insert(void *queue, xc_msg_t *msg) argument
163 * the xc_master CPUs xc_free queue.
167 queue == &cpu[msg->xc_master]->cpu_m.xc_free);
170 old_head = (xc_msg_t *)*(volatile xc_msg_t **)queue;
172 } while (atomic_cas_ptr(queue, old_head, msg) != old_head);
176 * Extract a message from a queue
181 xc_extract(xc_msg_t **queue) argument
[all...]
/illumos-gate/usr/src/uts/common/io/i40e/
H A Di40e_intr.c25 * - 'Other Interrupts', such as the administrative queue
28 * being posted to the administrative queue, unrecoverable ECC errors, and more.
29 * If we have something being posted to the administrative queue, then we go
59 * By default, the admin queue, which consists of the asynchronous other
71 * registers can also be used to enable and disable whether or not the queue is
75 * first queue must be programmed in I40E_QINT_LNKLSTN(%vector) register. Each
76 * queue defines the next one in either the I40E_QINT_RQCTL or I40E_QINT_TQCTL
79 * Because we only have a single queue enabled at the moment and we always have
81 * data queue in the interrupt handler. Longer term, we'll need to think harder
89 * Note that this means that both the individual queue an
462 i40e_intr_rx_queue_enable(i40e_t *i40e, uint_t queue) argument
482 i40e_intr_rx_queue_disable(i40e_t *i40e, uint_t queue) argument
602 i40e_intr_rx_work(i40e_t *i40e, int queue) argument
621 i40e_intr_tx_work(i40e_t *i40e, int queue) argument
[all...]
/illumos-gate/usr/src/lib/print/libpapi-lpd/common/
H A Dlpd-port.c553 /* no such (or disabled) queue, got to love rfc-1179 */
662 fprintf(stderr, "usage:\t%s -H host [-t timeout] -s queue control ]\n",
664 fprintf(stderr, "\t%s -H host [-t timeout] -c queue [user|job ...]\n",
666 fprintf(stderr, "\t%s -H host [-t timeout] -q queue [user|job ...]\n",
686 char *host = NULL, *queue = NULL; local
745 queue = optarg;
751 queue = optarg;
757 queue = optarg;
765 if ((host == NULL) || (queue == NULL) || (timeout < 0) ||
794 if (submit_job(fd, queue,
[all...]
/illumos-gate/usr/src/lib/smbsrv/libmlsvc/common/
H A Deventlog_log.c216 logr_syslog_destroy_queue(list_t *queue) argument
220 while ((head = list_head(queue)) != NULL) {
221 list_remove(queue, head);
224 list_destroy(queue);
228 logr_syslog_construct_queue(FILE *fp, list_t *queue) argument
234 list_create(queue, sizeof (logr_syslog_node_t),
239 /* Read the last 1024 entries in the queue */
241 head = list_head(queue);
242 list_remove(queue, head);
247 logr_syslog_destroy_queue(queue);
276 list_t queue; local
[all...]
/illumos-gate/usr/src/cmd/rcm_daemon/common/
H A Drcm_impl.h129 rcm_queue_t queue; /* per module queue */ member in struct:client
H A Drcm_script_impl.h80 rcm_queue_t queue; member in struct:__anon1317
91 * Used to maintain a queue of script_info structures
92 * Global variable script_info_q is the head of the queue.
94 rcm_queue_t queue; member in struct:script_info
96 rcm_queue_t drreq_q; /* queue head for current dr'ed resources */
/illumos-gate/usr/src/cmd/cmd-inet/usr.lib/inetd/
H A Dtlx.c403 /* Add 'call' to the connection indication queue 'queue'. */
405 queue_conind(uu_list_t *queue, struct t_call *call) argument
416 (void) uu_list_insert_after(queue, NULL, ci);
422 * Remove and return a pointer to the first call on queue 'queue'. However,
423 * if the queue is empty returns NULL.
426 dequeue_conind(uu_list_t *queue) argument
429 tlx_conn_ind_t *ci = uu_list_first(queue);
435 uu_list_remove(queue, c
[all...]
/illumos-gate/usr/src/cmd/cron/
H A Datq.c21 * Print the queue of files waiting to be executed. These files
54 struct dirent **queue; /* the queue itself */ variable in typeref:struct:dirent
78 /* queue */
81 int filewanted(); /* should file be included in queue? */
82 int countfiles(); /* count the number of files in queue */
148 printf("Printing queue information only "
167 * files in the queue structure. The queue comes back sorted by
172 if ((numentries = scandir(".", &queue, filewante
[all...]
/illumos-gate/usr/src/cmd/fgrep/
H A Dfgrep.c615 struct words **queue = NULL; local
627 if ((queue = (struct words **)calloc(qsize, sizeof (struct words *)))
632 front = rear = queue;
637 * Reallocates the queue if the number of distinct starting
640 if (rear >= &queue[qsize - 1]) {
641 frontoffset = front - queue;
642 rearoffset = rear - queue;
644 if ((queue = (struct words **)realloc(queue,
649 front = queue
[all...]
/illumos-gate/usr/src/cmd/fs.d/nfs/statd/
H A Dsm_statd.c351 * been put on the recovery queue for retry.
480 * If we queued a symlink name in the recovery queue,
666 /* Exit loop if queue is empty */
996 char *queue; local
1000 queue = CURRENT;
1003 queue = BACKUP;
1006 remove_single_name(name, queue, NULL);
1171 * If op == 1 then the name is added to the queue otherwise the name is
/illumos-gate/usr/src/uts/sun4v/os/
H A Derror.c46 errorq_t *ue_queue; /* queue of uncorrectable errors */
47 errorq_t *ce_queue; /* queue of correctable errors */
48 errorq_t *errh_queue; /* queue of sun4v error reports */
121 /* kernel buffer starts right after the resumable queue */
133 /* Increment the queue head */
190 * Handle resumable queue full case.
197 * Queue the error on ce or ue queue depend on flt_panic.
229 /* kernel buffer starts right after the nonresumable queue */
243 /* Increment the queue head */
273 * For the first error packet on the queue, chec
920 errh_er_print(errh_er_t *errh_erp, const char *queue) argument
[all...]

Completed in 3078 milliseconds

123