/illumos-gate/usr/src/lib/udapl/udapl_tavor/common/ |
H A D | dapl_cookie.c | 132 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 D | iscsi_queue.c | 37 * | 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 D | DoPrinterUtil.java | 534 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 D | main.c | 48 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 D | util_ordering.c | 56 } 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 D | xge-queue.c | 24 #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 D | xgehal-fifo.c | 155 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 D | xgehal-ring.c | 245 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 D | xgehal-mgmt.c | 491 * @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 D | beep.h | 82 /* 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 D | ns_bsd_addr.c | 267 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 D | glue5.c | 345 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 D | multi_thread_def.h | 88 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 D | md_notify.c | 64 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 D | x_call.c | 59 * 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 D | i40e_intr.c | 25 * - '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 D | lpd-port.c | 553 /* 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 D | eventlog_log.c | 216 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 D | rcm_impl.h | 129 rcm_queue_t queue; /* per module queue */ member in struct:client
|
H A D | rcm_script_impl.h | 80 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 D | tlx.c | 403 /* 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 D | atq.c | 21 * 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 D | fgrep.c | 615 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 D | sm_statd.c | 351 * 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 D | error.c | 46 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...] |