usr/src/cmd/bhyve/common/pci_ahci.c

1132

ata_ident->queue = 31;

usr/src/cmd/bhyve/common/pci_virtio_input.c

488

struct vtinput_eventqueue *queue, struct input_event *e)

usr/src/cmd/bhyve/common/pci_virtio_input.c

491

if (queue->idx >= queue->size) {

usr/src/cmd/bhyve/common/pci_virtio_input.c

493

const uint32_t newSize = queue->idx;

usr/src/cmd/bhyve/common/pci_virtio_input.c

494

void *newPtr = realloc(queue->events,

usr/src/cmd/bhyve/common/pci_virtio_input.c

495

queue->size * sizeof(struct vtinput_event_elem));

usr/src/cmd/bhyve/common/pci_virtio_input.c

501

queue->events = newPtr;

usr/src/cmd/bhyve/common/pci_virtio_input.c

502

queue->size = newSize;

usr/src/cmd/bhyve/common/pci_virtio_input.c

506

struct vtinput_event *event = &queue->events[queue->idx].event;

usr/src/cmd/bhyve/common/pci_virtio_input.c

510

queue->idx++;

usr/src/cmd/bhyve/common/pci_virtio_input.c

516

vtinput_eventqueue_clear(struct vtinput_eventqueue *queue)

usr/src/cmd/bhyve/common/pci_virtio_input.c

519

queue->idx = 0;

usr/src/cmd/bhyve/common/pci_virtio_input.c

524

struct vtinput_eventqueue *queue, struct vqueue_info *vq)

usr/src/cmd/bhyve/common/pci_virtio_input.c

530

for (uint32_t i = 0; i < queue->idx; ++i) {

usr/src/cmd/bhyve/common/pci_virtio_input.c

540

__func__, queue->idx));

usr/src/cmd/bhyve/common/pci_virtio_input.c

569

queue->events[i].iov = iov;

usr/src/cmd/bhyve/common/pci_virtio_input.c

570

queue->events[i].idx = req.idx;

usr/src/cmd/bhyve/common/pci_virtio_input.c

577

for (uint32_t i = 0; i < queue->idx; ++i) {

usr/src/cmd/bhyve/common/pci_virtio_input.c

578

struct vtinput_event_elem event = queue->events[i];

usr/src/cmd/bhyve/common/pci_virtio_input.c

585

vtinput_eventqueue_clear(queue);

usr/src/cmd/bhyve/common/pci_virtio_scsi.c

945

struct pci_vtscsi_queue *queue, int num)

usr/src/cmd/bhyve/common/pci_virtio_scsi.c

950

queue->vsq_sc = sc;

usr/src/cmd/bhyve/common/pci_virtio_scsi.c

951

queue->vsq_vq = &sc->vss_vq[num];

usr/src/cmd/bhyve/common/pci_virtio_scsi.c

953

pthread_mutex_init(&queue->vsq_rmtx, NULL);

usr/src/cmd/bhyve/common/pci_virtio_scsi.c

954

pthread_mutex_init(&queue->vsq_fmtx, NULL);

usr/src/cmd/bhyve/common/pci_virtio_scsi.c

955

pthread_mutex_init(&queue->vsq_qmtx, NULL);

usr/src/cmd/bhyve/common/pci_virtio_scsi.c

956

pthread_cond_init(&queue->vsq_cv, NULL);

usr/src/cmd/bhyve/common/pci_virtio_scsi.c

957

STAILQ_INIT(&queue->vsq_requests);

usr/src/cmd/bhyve/common/pci_virtio_scsi.c

958

STAILQ_INIT(&queue->vsq_free_requests);

usr/src/cmd/bhyve/common/pci_virtio_scsi.c

959

LIST_INIT(&queue->vsq_workers);

usr/src/cmd/bhyve/common/pci_virtio_scsi.c

968

pci_vtscsi_put_request(&queue->vsq_free_requests, req);

usr/src/cmd/bhyve/common/pci_virtio_scsi.c

977

worker->vsw_queue = queue;

usr/src/cmd/bhyve/common/pci_virtio_scsi.c

984

LIST_INSERT_HEAD(&queue->vsq_workers, worker, vsw_link);

usr/src/cmd/cmd-inet/usr.lib/inetd/tlx.c

405

queue_conind(uu_list_t *queue, struct t_call *call)

usr/src/cmd/cmd-inet/usr.lib/inetd/tlx.c

416

(void) uu_list_insert_after(queue, NULL, ci);

usr/src/cmd/cmd-inet/usr.lib/inetd/tlx.c

426

dequeue_conind(uu_list_t *queue)

usr/src/cmd/cmd-inet/usr.lib/inetd/tlx.c

429

tlx_conn_ind_t *ci = uu_list_first(queue);

usr/src/cmd/cmd-inet/usr.lib/inetd/tlx.c

435

uu_list_remove(queue, ci);

usr/src/cmd/cron/at.c

788

list_jobs(int argc, char **argv, int qflag, int queue)

usr/src/cmd/cron/at.c

854

check_queue(ptr, queue)))

usr/src/cmd/cron/at.c

860

check_queue(ptr, queue)))

usr/src/cmd/cron/at.c

887

check_queue(ptr, queue))) {

usr/src/cmd/cron/at.c

924

check_queue(char *name, int queue)

usr/src/cmd/cron/at.c

926

if ((name[strlen(name) - 1] - 'a') == queue)

usr/src/cmd/cron/atq.c

174

if ((numentries = scandir(".", &queue, filewanted,

usr/src/cmd/cron/atq.c

237

if ((stat(queue[i]->d_name, &stbuf)) < 0) {

usr/src/cmd/cron/atq.c

290

if ((stat(queue[i]->d_name, &stbuf)) < 0) {

usr/src/cmd/cron/atq.c

293

curqueue = *(strchr(queue[i]->d_name, '.') + 1);

usr/src/cmd/cron/atq.c

311

printdate(queue[i]->d_name);

usr/src/cmd/cron/atq.c

313

printf("%-14s ", queue[i]->d_name);

usr/src/cmd/cron/atq.c

315

printjobname(queue[i]->d_name);

usr/src/cmd/cron/atq.c

56

struct dirent **queue; /* the queue itself */

usr/src/cmd/cron/cron.c

2158

struct queue *qp;

usr/src/cmd/cron/cron.c

230

static struct queue qq;

usr/src/cmd/fs.d/nfs/statd/sm_statd.c

1002

remove_single_name(name, queue, NULL);

usr/src/cmd/fs.d/nfs/statd/sm_statd.c

992

char *queue;

usr/src/cmd/fs.d/nfs/statd/sm_statd.c

996

queue = CURRENT;

usr/src/cmd/fs.d/nfs/statd/sm_statd.c

999

queue = BACKUP;

usr/src/cmd/hal/hald/hald_dbus.c

3151

GList *queue;

usr/src/cmd/hal/hald/hald_dbus.c

3155

if (g_hash_table_lookup_extended (udi_to_method_queue, d->udi, &origkey, (gpointer) &queue)) {

usr/src/cmd/hal/hald/hald_dbus.c

3157

if (queue != NULL) {

usr/src/cmd/hal/hald/hald_dbus.c

3159

mi = (MethodInvocation *) queue->data;

usr/src/cmd/hal/hald/hald_dbus.c

3178

GList *queue;

usr/src/cmd/hal/hald/hald_dbus.c

3187

if (g_hash_table_lookup_extended (udi_to_method_queue, mi->udi, &origkey, (gpointer) &queue)) {

usr/src/cmd/hal/hald/hald_dbus.c

3189

queue = g_list_append (queue, mi);

usr/src/cmd/hal/hald/hald_dbus.c

3190

g_hash_table_replace (udi_to_method_queue, g_strdup (mi->udi), queue);

usr/src/cmd/hal/hald/hald_dbus.c

3193

queue = g_list_append (NULL, mi);

usr/src/cmd/hal/hald/hald_dbus.c

3194

g_hash_table_insert (udi_to_method_queue, g_strdup (mi->udi), queue);

usr/src/cmd/hal/hald/hald_dbus.c

3205

GList *queue;

usr/src/cmd/hal/hald/hald_dbus.c

3208

if (g_hash_table_lookup_extended (udi_to_method_queue, udi, &origkey, (gpointer) &queue)) {

usr/src/cmd/hal/hald/hald_dbus.c

3211

if (queue != NULL) {

usr/src/cmd/hal/hald/hald_dbus.c

3212

mi = (MethodInvocation *) queue->data;

usr/src/cmd/hal/hald/hald_dbus.c

3213

queue = g_list_delete_link (queue, queue);

usr/src/cmd/hal/hald/hald_dbus.c

3214

if (queue == NULL) {

usr/src/cmd/hal/hald/hald_dbus.c

3242

if (queue != NULL) {

usr/src/cmd/hal/hald/hald_dbus.c

3244

g_hash_table_replace (udi_to_method_queue, g_strdup (udi), queue);

usr/src/cmd/hal/hald/hald_dbus.c

3246

mi = (MethodInvocation *) queue->data;

usr/src/cmd/listen/listen.c

1096

queue(Free_call_p, current);

usr/src/cmd/listen/listen.c

1099

queue(phead, current);

usr/src/cmd/listen/listen.c

1159

queue(Free_call_p, current);

usr/src/cmd/listen/listen.c

1190

queue(Free_call_p, current);

usr/src/cmd/listen/listen.c

1199

queue(Free_call_p, current);

usr/src/cmd/listen/listen.c

1209

queue(Free_call_p, current);

usr/src/cmd/listen/listen.c

1233

queue(Free_call_p, current);

usr/src/cmd/listen/listen.c

1284

queue(Free_call_p, current);

usr/src/cmd/listen/listen.c

1308

queue(Free_call_p, current);

usr/src/cmd/listen/listen.c

1658

queue(Free_call_p, p);

usr/src/cmd/listen/listen.c

1759

queue(Free_call_p, tmp);

usr/src/cmd/lp/lib/msgs/mwrite.c

111

goto queue; /* if there is a queue already, try to write all */

usr/src/cmd/lp/lib/msgs/mwrite.c

123

queue:

usr/src/cmd/lp/lib/papi/job.c

1004

queue = printer_name_from_uri_id(printer, job_id);

usr/src/cmd/lp/lib/papi/job.c

1005

snprintf(req_id, sizeof (req_id), "%s-%d", queue, job_id);

usr/src/cmd/lp/lib/papi/job.c

1006

free(queue);

usr/src/cmd/lp/lib/papi/job.c

997

char *queue;

usr/src/cmd/mdb/common/modules/genunix/genunix.c

4451

"filter and display STREAM queue", queue, queue_help },

usr/src/cmd/mdb/common/modules/genunix/streams.h

56

int queue(uintptr_t, uint_t, int, const mdb_arg_t *);

usr/src/cmd/rcm_daemon/common/rcm_impl.h

127

rcm_queue_t queue; /* per module queue */

usr/src/cmd/rcm_daemon/common/rcm_script.c

1686

client = RCM_STRUCT_BASE_ADDR(client_t, q, queue);

usr/src/cmd/rcm_daemon/common/rcm_script.c

1706

client = RCM_STRUCT_BASE_ADDR(client_t, q, queue);

usr/src/cmd/rcm_daemon/common/rcm_script.c

1729

client = RCM_STRUCT_BASE_ADDR(client_t, q, queue);

usr/src/cmd/rcm_daemon/common/rcm_script.c

1817

drreq = RCM_STRUCT_BASE_ADDR(drreq_t, q, queue);

usr/src/cmd/rcm_daemon/common/rcm_script.c

1826

rcm_enqueue_tail(&rsi->drreq_q, &drreq->queue);

usr/src/cmd/rcm_daemon/common/rcm_script.c

1841

drreq = RCM_STRUCT_BASE_ADDR(drreq_t, q, queue);

usr/src/cmd/rcm_daemon/common/rcm_script.c

1848

rcm_dequeue(&drreq->queue);

usr/src/cmd/rcm_daemon/common/rcm_script.c

1864

rsi->drreq_q.next, queue);

usr/src/cmd/rcm_daemon/common/rcm_script.c

406

rcm_enqueue_tail(&script_info_q, &rsi->queue);

usr/src/cmd/rcm_daemon/common/rcm_script.c

450

rcm_dequeue(&rsi->queue);

usr/src/cmd/rcm_daemon/common/rcm_script_impl.h

78

rcm_queue_t queue;

usr/src/cmd/rcm_daemon/common/rcm_script_impl.h

92

rcm_queue_t queue;

usr/src/cmd/rcm_daemon/common/rcm_subr.c

535

rcm_enqueue_tail(&mod->client_q, &client->queue);

usr/src/cmd/rcm_daemon/common/rcm_subr.c

610

rcm_dequeue(&client->queue);

usr/src/cmd/refer/glue5.c

342

struct words *queue[QSIZE];

usr/src/cmd/refer/glue5.c

348

front = rear = queue;

usr/src/cmd/refer/glue5.c

352

if (rear >= &queue[QSIZE - 1]) overflo();

usr/src/cmd/refer/glue5.c

360

if (front == &queue[QSIZE-1])

usr/src/cmd/refer/glue5.c

361

front = queue;

usr/src/cmd/refer/glue5.c

367

if (rear >= &queue[QSIZE-1])

usr/src/cmd/refer/glue5.c

368

if (front == queue) overflo();

usr/src/cmd/refer/glue5.c

369

else rear = queue;

usr/src/cmd/sgs/mcs/common/main.c

117

queue(ACT_APPEND, optarg);

usr/src/cmd/sgs/mcs/common/main.c

123

queue(ACT_COMPRESS, NULL);

usr/src/cmd/sgs/mcs/common/main.c

129

queue(ACT_DELETE, NULL);

usr/src/cmd/sgs/mcs/common/main.c

134

queue(ACT_ZAP, NULL);

usr/src/cmd/sgs/mcs/common/main.c

147

queue(ACT_PRINT, NULL);

usr/src/cmd/sgs/mcs/common/main.c

216

queue(ACT_DELETE, NULL);

usr/src/cmd/sgs/mcs/common/main.c

51

static void queue(int, char *);

usr/src/lib/krb5/plugins/kdb/db2/libdb2/hash/hash.c

854

TAILQ_INSERT_TAIL(&hashp->curs_queue, new_curs, queue);

usr/src/lib/krb5/plugins/kdb/db2/libdb2/hash/hash.h

61

TAILQ_ENTRY(cursor_t) queue;

usr/src/lib/libslp/clib/slp_queue.c

118

struct queue *q = qa;

usr/src/lib/libslp/clib/slp_queue.c

147

struct queue *q = qa;

usr/src/lib/libslp/clib/slp_queue.c

169

static void *dequeue_nolock(struct queue *q) {

usr/src/lib/libslp/clib/slp_queue.c

194

struct queue *q = qa;

usr/src/lib/libslp/clib/slp_queue.c

239

struct queue *q = qa;

usr/src/lib/libslp/clib/slp_queue.c

253

struct queue *q = qa;

usr/src/lib/libslp/clib/slp_queue.c

77

struct queue *q;

usr/src/lib/libslp/javalib/com/sun/slp/ServiceStoreInMemory.java

1408

Vector queue = ageOutQueue.getContents();

usr/src/lib/libslp/javalib/com/sun/slp/ServiceStoreInMemory.java

1415

for (i = 0; i < queue.size(); i++) {

usr/src/lib/libslp/javalib/com/sun/slp/ServiceStoreInMemory.java

1416

RegRecord qRec = (RegRecord)queue.elementAt(i);

usr/src/lib/libslp/javalib/com/sun/slp/ServiceStoreInMemory.java

1438

queue.removeElementAt(i);

usr/src/lib/libslp/javalib/com/sun/slp/ServiceStoreInMemory.java

1489

if (queue.size() > 0) {

usr/src/lib/libslp/javalib/com/sun/slp/ServiceStoreInMemory.java

1490

RegRecord rec = (RegRecord)queue.elementAt(0);

usr/src/lib/print/libipp-listener/common/cancel-job.c

43

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/cancel-job.c

54

get_printer_id(operational, &queue, &id);

usr/src/lib/print/libipp-listener/common/cancel-job.c

59

} else if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/cancel-job.c

72

status = papiJobCancel(svc, queue, id);

usr/src/lib/print/libipp-listener/common/cancel-job.c

76

(queue ? queue : "(null)"), id,

usr/src/lib/print/libipp-listener/common/create-job.c

44

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/create-job.c

56

get_printer_id(operational, &queue, NULL);

usr/src/lib/print/libipp-listener/common/create-job.c

57

if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/create-job.c

91

status = papiJobCreate(svc, queue, job_attributes, NULL, &j);

usr/src/lib/print/libipp-listener/common/cups-accept-jobs.c

42

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/cups-accept-jobs.c

52

get_printer_id(operational, &queue, NULL);

usr/src/lib/print/libipp-listener/common/cups-accept-jobs.c

53

if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/cups-accept-jobs.c

59

if ((status = papiPrinterResume(svc, queue)) != PAPI_OK) {

usr/src/lib/print/libipp-listener/common/cups-accept-jobs.c

61

(queue ? queue : "(null)"),

usr/src/lib/print/libipp-listener/common/cups-move-job.c

44

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/cups-move-job.c

68

get_printer_id(operational, &queue, &id);

usr/src/lib/print/libipp-listener/common/cups-move-job.c

73

} else if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/cups-move-job.c

93

if ((status = papiJobMove(svc, queue, id, dest)) != PAPI_OK)

usr/src/lib/print/libipp-listener/common/cups-move-job.c

96

(queue ? queue : "(null)"), id,

usr/src/lib/print/libipp-listener/common/cups-reject-jobs.c

42

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/cups-reject-jobs.c

52

get_printer_id(operational, &queue, NULL);

usr/src/lib/print/libipp-listener/common/cups-reject-jobs.c

53

if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/cups-reject-jobs.c

59

if ((status = papiPrinterPause(svc, queue, NULL)) != PAPI_OK) {

usr/src/lib/print/libipp-listener/common/cups-reject-jobs.c

61

(queue ? queue : "(null)"),

usr/src/lib/print/libipp-listener/common/disable-printer.c

42

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/disable-printer.c

54

get_printer_id(operational, &queue, NULL);

usr/src/lib/print/libipp-listener/common/disable-printer.c

55

if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/disable-printer.c

68

if ((status = papiPrinterDisable(svc, queue, message)) != PAPI_OK) {

usr/src/lib/print/libipp-listener/common/disable-printer.c

70

(queue ? queue : "(null)"),

usr/src/lib/print/libipp-listener/common/enable-printer.c

42

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/enable-printer.c

52

get_printer_id(operational, &queue, NULL);

usr/src/lib/print/libipp-listener/common/enable-printer.c

53

if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/enable-printer.c

59

if ((status = papiPrinterEnable(svc, queue)) != PAPI_OK) {

usr/src/lib/print/libipp-listener/common/enable-printer.c

61

(queue ? queue : "(null)"),

usr/src/lib/print/libipp-listener/common/get-job-attributes.c

45

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/get-job-attributes.c

56

get_printer_id(operational, &queue, &id);

usr/src/lib/print/libipp-listener/common/get-job-attributes.c

61

} else if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/get-job-attributes.c

73

if ((status = papiJobQuery(svc, queue, id, req_attrs, &j)) != PAPI_OK) {

usr/src/lib/print/libipp-listener/common/get-jobs.c

44

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/get-jobs.c

58

get_printer_id(operational, &queue, NULL);

usr/src/lib/print/libipp-listener/common/get-jobs.c

59

if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/get-jobs.c

79

status = papiPrinterListJobs(svc, queue, req_attrs, type, limit, &j);

usr/src/lib/print/libipp-listener/common/get-printer-attributes.c

46

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/get-printer-attributes.c

56

get_printer_id(operational, &queue, NULL);

usr/src/lib/print/libipp-listener/common/get-printer-attributes.c

57

if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/get-printer-attributes.c

71

status = papiPrinterQuery(svc, queue, req_attrs, NULL, &p);

usr/src/lib/print/libipp-listener/common/hold-job.c

43

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/hold-job.c

54

get_printer_id(operational, &queue, &id);

usr/src/lib/print/libipp-listener/common/hold-job.c

59

} else if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/hold-job.c

73

if ((status = papiJobHold(svc, queue, id)) != PAPI_OK) {

usr/src/lib/print/libipp-listener/common/hold-job.c

76

(queue ? queue : "(null)"), id,

usr/src/lib/print/libipp-listener/common/pause-printer.c

42

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/pause-printer.c

52

get_printer_id(operational, &queue, NULL);

usr/src/lib/print/libipp-listener/common/pause-printer.c

53

if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/pause-printer.c

59

if ((status = papiPrinterPause(svc, queue, NULL)) != PAPI_OK) {

usr/src/lib/print/libipp-listener/common/pause-printer.c

61

(queue ? queue : "(null)"),

usr/src/lib/print/libipp-listener/common/print-job.c

151

status = papiJobStreamOpen(svc, queue, job_attributes, NULL, &s);

usr/src/lib/print/libipp-listener/common/print-job.c

50

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/print-job.c

66

get_printer_id(operational, &queue, NULL);

usr/src/lib/print/libipp-listener/common/print-job.c

67

if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/purge-jobs.c

43

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/purge-jobs.c

53

get_printer_id(operational, &queue, NULL);

usr/src/lib/print/libipp-listener/common/purge-jobs.c

54

if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/purge-jobs.c

60

if ((status = papiPrinterPurgeJobs(svc, queue, &jobs)) != PAPI_OK) {

usr/src/lib/print/libipp-listener/common/purge-jobs.c

62

(queue ? queue : "(null)"),

usr/src/lib/print/libipp-listener/common/release-job.c

43

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/release-job.c

54

get_printer_id(operational, &queue, &id);

usr/src/lib/print/libipp-listener/common/release-job.c

59

} else if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/release-job.c

72

if ((status = papiJobRelease(svc, queue, id)) != PAPI_OK) {

usr/src/lib/print/libipp-listener/common/release-job.c

75

(queue ? queue : "(null)"), id,

usr/src/lib/print/libipp-listener/common/restart-job.c

44

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/restart-job.c

55

get_printer_id(operational, &queue, &id);

usr/src/lib/print/libipp-listener/common/restart-job.c

60

} else if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/restart-job.c

76

if ((status = papiJobRestart(svc, queue, id)) != PAPI_OK) {

usr/src/lib/print/libipp-listener/common/restart-job.c

79

(queue ? queue : "(null)"), id,

usr/src/lib/print/libipp-listener/common/resume-printer.c

42

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/resume-printer.c

52

get_printer_id(operational, &queue, NULL);

usr/src/lib/print/libipp-listener/common/resume-printer.c

53

if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/resume-printer.c

59

if ((status = papiPrinterResume(svc, queue)) != PAPI_OK) {

usr/src/lib/print/libipp-listener/common/resume-printer.c

61

(queue ? queue : "(null)"),

usr/src/lib/print/libipp-listener/common/send-document.c

103

status = papiJobStreamAdd(svc, queue, id, &s);

usr/src/lib/print/libipp-listener/common/send-document.c

131

status = papiJobCommit(svc, queue, id);

usr/src/lib/print/libipp-listener/common/send-document.c

49

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/send-document.c

67

get_printer_id(operational, &queue, &id);

usr/src/lib/print/libipp-listener/common/send-document.c

72

} else if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/set-job-attributes.c

45

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/set-job-attributes.c

58

get_printer_id(operational, &queue, &id);

usr/src/lib/print/libipp-listener/common/set-job-attributes.c

63

} else if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/set-job-attributes.c

74

status = papiJobModify(svc, queue, id, job_attributes, &j);

usr/src/lib/print/libipp-listener/common/set-printer-attributes.c

44

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/set-printer-attributes.c

54

get_printer_id(operational, &queue, NULL);

usr/src/lib/print/libipp-listener/common/set-printer-attributes.c

55

if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/set-printer-attributes.c

66

status = papiPrinterModify(svc, queue, printer_attributes, &p);

usr/src/lib/print/libipp-listener/common/validate-job.c

44

char *queue = NULL;

usr/src/lib/print/libipp-listener/common/validate-job.c

59

get_printer_id(operational, &queue, NULL);

usr/src/lib/print/libipp-listener/common/validate-job.c

60

if (queue == NULL) {

usr/src/lib/print/libipp-listener/common/validate-job.c

88

status = papiJobValidate(svc, queue, job_attributes, NULL, files, &j);

usr/src/lib/print/libpapi-lpd/common/lpd-cancel.c

107

"job-printer", queue);

usr/src/lib/print/libpapi-lpd/common/lpd-cancel.c

78

char *queue;

usr/src/lib/print/libpapi-lpd/common/lpd-cancel.c

87

queue = queue_name_from_uri(svc->uri);

usr/src/lib/print/libpapi-lpd/common/lpd-port.c

686

char *host = NULL, *queue = NULL;

usr/src/lib/print/libpapi-lpd/common/lpd-port.c

745

queue = optarg;

usr/src/lib/print/libpapi-lpd/common/lpd-port.c

751

queue = optarg;

usr/src/lib/print/libpapi-lpd/common/lpd-port.c

757

queue = optarg;

usr/src/lib/print/libpapi-lpd/common/lpd-port.c

765

if ((host == NULL) || (queue == NULL) || (timeout < 0) ||

usr/src/lib/print/libpapi-lpd/common/lpd-port.c

794

if (submit_job(fd, queue, c, av[optind]) < 0)

usr/src/lib/print/libpapi-lpd/common/lpd-port.c

798

if (query(fd, queue, ac - optind, &av[optind]) < 0)

usr/src/lib/print/libpapi-lpd/common/lpd-port.c

802

if (cancel(fd, queue, ac - optind, &av[optind]) < 0)

usr/src/lib/print/libprint/common/ns_bsd_addr.c

265

char *queue = NULL;

usr/src/lib/print/libprint/common/ns_bsd_addr.c

271

split_name(addr, ": \t", &server, &queue, &extension);

usr/src/lib/print/libprint/common/ns_bsd_addr.c

274

if ((server != NULL) && (queue != NULL))

usr/src/lib/print/libprint/common/ns_bsd_addr.c

276

queue, (extension != NULL ? "," : ""),

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

216

logr_syslog_destroy_queue(list_t *queue)

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

220

while ((head = list_head(queue)) != NULL) {

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

221

list_remove(queue, head);

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

224

list_destroy(queue);

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

228

logr_syslog_construct_queue(FILE *fp, list_t *queue)

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

234

list_create(queue, sizeof (logr_syslog_node_t),

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

241

head = list_head(queue);

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

242

list_remove(queue, head);

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

247

logr_syslog_destroy_queue(queue);

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

253

list_insert_tail(queue, node);

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

276

list_t queue;

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

279

if (logr_syslog_construct_queue(fp, &queue) < 0)

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

282

node = list_head(&queue);

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

287

node = list_next(&queue, node);

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

294

node = list_next(&queue, node);

usr/src/lib/smbsrv/libmlsvc/common/eventlog_log.c

297

logr_syslog_destroy_queue(&queue);

usr/src/lib/udapl/udapl_tavor/common/dapl_cookie.c

132

IN void *queue,

usr/src/lib/udapl/udapl_tavor/common/dapl_cookie.c

161

buffer->pool[i].queue.ep = queue;

usr/src/lib/udapl/udapl_tavor/common/dapl_cookie.c

163

buffer->pool[i].queue.srq = queue;

usr/src/lib/udapl/udapl_tavor/common/dapl_cookie.c

215

curr_buffer->pool[0].queue.ptr, curr_buffer->pool[0].queue_type,

usr/src/lib/udapl/udapl_tavor/common/dapl_evd_util.c

959

ep_ptr = cookie->queue.ep;

usr/src/lib/udapl/udapl_tavor/common/dapl_evd_util.c

962

srq_ptr = cookie->queue.srq;

usr/src/lib/udapl/udapl_tavor/include/dapl.h

636

} queue;

usr/src/lib/udapl/udapl_tavor/include/dapl_cookie.h

53

void *queue,

usr/src/uts/common/c2/audit.h

543

void audit_sock(int, struct queue *, struct msgb *, int);

usr/src/uts/common/fs/sockfs/socktpi.c

4390

struct queue *wqp;

usr/src/uts/common/fs/zfs/dsl_scan.c

1236

dsl_scan_io_queue_t *queue;

usr/src/uts/common/fs/zfs/dsl_scan.c

1239

queue = tvd->vdev_scan_io_queue;

usr/src/uts/common/fs/zfs/dsl_scan.c

1240

if (queue != NULL) {

usr/src/uts/common/fs/zfs/dsl_scan.c

1245

mused += zfs_btree_numnodes(&queue->q_exts_by_size) *

usr/src/uts/common/fs/zfs/dsl_scan.c

1246

3 * sizeof (range_seg_gap_t) + queue->q_sio_memused;

usr/src/uts/common/fs/zfs/dsl_scan.c

2729

scan_io_queue_issue(dsl_scan_io_queue_t *queue, list_t *io_list)

usr/src/uts/common/fs/zfs/dsl_scan.c

2731

dsl_scan_t *scn = queue->q_scn;

usr/src/uts/common/fs/zfs/dsl_scan.c

2747

&sio->sio_zb, queue);

usr/src/uts/common/fs/zfs/dsl_scan.c

2749

scan_io_queues_update_zio_stats(queue, &bp);

usr/src/uts/common/fs/zfs/dsl_scan.c

2765

scan_io_queue_gather(dsl_scan_io_queue_t *queue, range_seg_t *rs, list_t *list)

usr/src/uts/common/fs/zfs/dsl_scan.c

2773

ASSERT(MUTEX_HELD(&queue->q_vd->vdev_scan_io_queue_lock));

usr/src/uts/common/fs/zfs/dsl_scan.c

2777

SIO_SET_OFFSET(srch_sio, rs_get_start(rs, queue->q_exts_by_addr));

usr/src/uts/common/fs/zfs/dsl_scan.c

2783

sio = avl_find(&queue->q_sios_by_addr, srch_sio, &idx);

usr/src/uts/common/fs/zfs/dsl_scan.c

2787

sio = avl_nearest(&queue->q_sios_by_addr, idx, AVL_AFTER);

usr/src/uts/common/fs/zfs/dsl_scan.c

2790

queue->q_exts_by_addr) && num_sios <= 32) {

usr/src/uts/common/fs/zfs/dsl_scan.c

2792

queue->q_exts_by_addr));

usr/src/uts/common/fs/zfs/dsl_scan.c

2794

queue->q_exts_by_addr));

usr/src/uts/common/fs/zfs/dsl_scan.c

2796

next_sio = AVL_NEXT(&queue->q_sios_by_addr, sio);

usr/src/uts/common/fs/zfs/dsl_scan.c

2797

avl_remove(&queue->q_sios_by_addr, sio);

usr/src/uts/common/fs/zfs/dsl_scan.c

2798

queue->q_sio_memused -= SIO_GET_MUSED(sio);

usr/src/uts/common/fs/zfs/dsl_scan.c

2813

queue->q_exts_by_addr)) {

usr/src/uts/common/fs/zfs/dsl_scan.c

2814

range_tree_adjust_fill(queue->q_exts_by_addr, rs,

usr/src/uts/common/fs/zfs/dsl_scan.c

2816

range_tree_resize_segment(queue->q_exts_by_addr, rs,

usr/src/uts/common/fs/zfs/dsl_scan.c

2818

queue->q_exts_by_addr) - SIO_GET_OFFSET(sio));

usr/src/uts/common/fs/zfs/dsl_scan.c

2822

uint64_t rstart = rs_get_start(rs, queue->q_exts_by_addr);

usr/src/uts/common/fs/zfs/dsl_scan.c

2823

uint64_t rend = rs_get_end(rs, queue->q_exts_by_addr);

usr/src/uts/common/fs/zfs/dsl_scan.c

2824

range_tree_remove(queue->q_exts_by_addr, rstart, rend - rstart);

usr/src/uts/common/fs/zfs/dsl_scan.c

2842

scan_io_queue_fetch_ext(dsl_scan_io_queue_t *queue)

usr/src/uts/common/fs/zfs/dsl_scan.c

2844

dsl_scan_t *scn = queue->q_scn;

usr/src/uts/common/fs/zfs/dsl_scan.c

2845

range_tree_t *rt = queue->q_exts_by_addr;

usr/src/uts/common/fs/zfs/dsl_scan.c

2847

ASSERT(MUTEX_HELD(&queue->q_vd->vdev_scan_io_queue_lock));

usr/src/uts/common/fs/zfs/dsl_scan.c

2860

zfs_btree_first(&queue->q_exts_by_size, NULL);

usr/src/uts/common/fs/zfs/dsl_scan.c

2892

range_seg_t *size_rs = zfs_btree_first(&queue->q_exts_by_size,

usr/src/uts/common/fs/zfs/dsl_scan.c

2912

dsl_scan_io_queue_t *queue = arg;

usr/src/uts/common/fs/zfs/dsl_scan.c

2913

kmutex_t *q_lock = &queue->q_vd->vdev_scan_io_queue_lock;

usr/src/uts/common/fs/zfs/dsl_scan.c

2919

uint64_t nr_leaves = dsl_scan_count_leaves(queue->q_vd);

usr/src/uts/common/fs/zfs/dsl_scan.c

2921

ASSERT(queue->q_scn->scn_is_sorted);

usr/src/uts/common/fs/zfs/dsl_scan.c

2928

queue->q_maxinflight_bytes =

usr/src/uts/common/fs/zfs/dsl_scan.c

2932

queue->q_total_seg_size_this_txg = 0;

usr/src/uts/common/fs/zfs/dsl_scan.c

2933

queue->q_segs_this_txg = 0;

usr/src/uts/common/fs/zfs/dsl_scan.c

2934

queue->q_total_zio_size_this_txg = 0;

usr/src/uts/common/fs/zfs/dsl_scan.c

2935

queue->q_zios_this_txg = 0;

usr/src/uts/common/fs/zfs/dsl_scan.c

2938

while ((rs = (range_seg_t *)scan_io_queue_fetch_ext(queue)) != NULL) {

usr/src/uts/common/fs/zfs/dsl_scan.c

2952

more_left = scan_io_queue_gather(queue, rs, &sio_list);

usr/src/uts/common/fs/zfs/dsl_scan.c

2969

suspended = scan_io_queue_issue(queue, &sio_list);

usr/src/uts/common/fs/zfs/dsl_scan.c

2976

scan_io_queues_update_seg_stats(queue, seg_start, seg_end);

usr/src/uts/common/fs/zfs/dsl_scan.c

2989

scan_io_queue_insert_impl(queue, sio);

usr/src/uts/common/fs/zfs/dsl_scan.c

3103

dsl_scan_io_queue_t *queue = vd->vdev_scan_io_queue;

usr/src/uts/common/fs/zfs/dsl_scan.c

3105

if (queue == NULL)

usr/src/uts/common/fs/zfs/dsl_scan.c

3108

seg_size_total += queue->q_total_seg_size_this_txg;

usr/src/uts/common/fs/zfs/dsl_scan.c

3109

zio_size_total += queue->q_total_zio_size_this_txg;

usr/src/uts/common/fs/zfs/dsl_scan.c

3110

seg_count_total += queue->q_segs_this_txg;

usr/src/uts/common/fs/zfs/dsl_scan.c

3111

zio_count_total += queue->q_zios_this_txg;

usr/src/uts/common/fs/zfs/dsl_scan.c

330

const zbookmark_phys_t *zb, dsl_scan_io_queue_t *queue);

usr/src/uts/common/fs/zfs/dsl_scan.c

331

static void scan_io_queue_insert_impl(dsl_scan_io_queue_t *queue,

usr/src/uts/common/fs/zfs/dsl_scan.c

3742

scan_io_queue_insert_impl(dsl_scan_io_queue_t *queue, scan_io_t *sio)

usr/src/uts/common/fs/zfs/dsl_scan.c

3746

dsl_scan_t *scn = queue->q_scn;

usr/src/uts/common/fs/zfs/dsl_scan.c

3748

ASSERT(MUTEX_HELD(&queue->q_vd->vdev_scan_io_queue_lock));

usr/src/uts/common/fs/zfs/dsl_scan.c

3750

if (avl_find(&queue->q_sios_by_addr, sio, &idx) != NULL) {

usr/src/uts/common/fs/zfs/dsl_scan.c

3756

avl_insert(&queue->q_sios_by_addr, sio, idx);

usr/src/uts/common/fs/zfs/dsl_scan.c

3757

queue->q_sio_memused += SIO_GET_MUSED(sio);

usr/src/uts/common/fs/zfs/dsl_scan.c

3758

range_tree_add(queue->q_exts_by_addr, SIO_GET_OFFSET(sio), asize);

usr/src/uts/common/fs/zfs/dsl_scan.c

3768

scan_io_queue_insert(dsl_scan_io_queue_t *queue, const blkptr_t *bp, int dva_i,

usr/src/uts/common/fs/zfs/dsl_scan.c

3771

dsl_scan_t *scn = queue->q_scn;

usr/src/uts/common/fs/zfs/dsl_scan.c

3775

ASSERT(MUTEX_HELD(&queue->q_vd->vdev_scan_io_queue_lock));

usr/src/uts/common/fs/zfs/dsl_scan.c

3788

scan_io_queue_insert_impl(queue, sio);

usr/src/uts/common/fs/zfs/dsl_scan.c

3896

dsl_scan_io_queue_t *queue = zio->io_private;

usr/src/uts/common/fs/zfs/dsl_scan.c

3900

if (queue == NULL) {

usr/src/uts/common/fs/zfs/dsl_scan.c

3907

mutex_enter(&queue->q_vd->vdev_scan_io_queue_lock);

usr/src/uts/common/fs/zfs/dsl_scan.c

3908

ASSERT3U(queue->q_inflight_bytes, >=, BP_GET_PSIZE(bp));

usr/src/uts/common/fs/zfs/dsl_scan.c

3909

queue->q_inflight_bytes -= BP_GET_PSIZE(bp);

usr/src/uts/common/fs/zfs/dsl_scan.c

3910

cv_broadcast(&queue->q_zio_cv);

usr/src/uts/common/fs/zfs/dsl_scan.c

3911

mutex_exit(&queue->q_vd->vdev_scan_io_queue_lock);

usr/src/uts/common/fs/zfs/dsl_scan.c

3929

const zbookmark_phys_t *zb, dsl_scan_io_queue_t *queue)

usr/src/uts/common/fs/zfs/dsl_scan.c

3936

if (queue == NULL) {

usr/src/uts/common/fs/zfs/dsl_scan.c

3943

kmutex_t *q_lock = &queue->q_vd->vdev_scan_io_queue_lock;

usr/src/uts/common/fs/zfs/dsl_scan.c

3946

while (queue->q_inflight_bytes >= queue->q_maxinflight_bytes)

usr/src/uts/common/fs/zfs/dsl_scan.c

3947

cv_wait(&queue->q_zio_cv, q_lock);

usr/src/uts/common/fs/zfs/dsl_scan.c

3948

queue->q_inflight_bytes += BP_GET_PSIZE(bp);

usr/src/uts/common/fs/zfs/dsl_scan.c

3954

dsl_scan_scrub_done, queue, ZIO_PRIORITY_SCRUB, zio_flags, zb));

usr/src/uts/common/fs/zfs/dsl_scan.c

4052

dsl_scan_io_queue_destroy(dsl_scan_io_queue_t *queue)

usr/src/uts/common/fs/zfs/dsl_scan.c

4054

dsl_scan_t *scn = queue->q_scn;

usr/src/uts/common/fs/zfs/dsl_scan.c

4059

ASSERT(MUTEX_HELD(&queue->q_vd->vdev_scan_io_queue_lock));

usr/src/uts/common/fs/zfs/dsl_scan.c

4061

while ((sio = avl_destroy_nodes(&queue->q_sios_by_addr, &cookie)) !=

usr/src/uts/common/fs/zfs/dsl_scan.c

4063

ASSERT(range_tree_contains(queue->q_exts_by_addr,

usr/src/uts/common/fs/zfs/dsl_scan.c

4066

queue->q_sio_memused -= SIO_GET_MUSED(sio);

usr/src/uts/common/fs/zfs/dsl_scan.c

4070

ASSERT0(queue->q_sio_memused);

usr/src/uts/common/fs/zfs/dsl_scan.c

4072

range_tree_vacate(queue->q_exts_by_addr, NULL, queue);

usr/src/uts/common/fs/zfs/dsl_scan.c

4073

range_tree_destroy(queue->q_exts_by_addr);

usr/src/uts/common/fs/zfs/dsl_scan.c

4074

avl_destroy(&queue->q_sios_by_addr);

usr/src/uts/common/fs/zfs/dsl_scan.c

4075

cv_destroy(&queue->q_zio_cv);

usr/src/uts/common/fs/zfs/dsl_scan.c

4077

kmem_free(queue, sizeof (*queue));

usr/src/uts/common/fs/zfs/dsl_scan.c

4124

dsl_scan_io_queue_t *queue;

usr/src/uts/common/fs/zfs/dsl_scan.c

4132

queue = vdev->vdev_scan_io_queue;

usr/src/uts/common/fs/zfs/dsl_scan.c

4135

if (queue == NULL) {

usr/src/uts/common/fs/zfs/dsl_scan.c

4163

sio = avl_find(&queue->q_sios_by_addr, srch_sio, &idx);

usr/src/uts/common/fs/zfs/dsl_scan.c

4173

avl_remove(&queue->q_sios_by_addr, sio);

usr/src/uts/common/fs/zfs/dsl_scan.c

4174

queue->q_sio_memused -= SIO_GET_MUSED(sio);

usr/src/uts/common/fs/zfs/dsl_scan.c

4176

ASSERT(range_tree_contains(queue->q_exts_by_addr, start, size));

usr/src/uts/common/fs/zfs/dsl_scan.c

4177

range_tree_remove_fill(queue->q_exts_by_addr, start, size);

usr/src/uts/common/fs/zfs/sys/dsl_scan.h

183

void dsl_scan_io_queue_destroy(dsl_scan_io_queue_t *queue);

usr/src/uts/common/gssapi/mechs/krb5/include/gssapiP_generic.h

214

gss_int32 g_order_init (void **queue, gssint_uint64 seqnum,

usr/src/uts/common/gssapi/mechs/krb5/include/gssapiP_generic.h

217

gss_int32 g_order_check (void **queue, gssint_uint64 seqnum);

usr/src/uts/common/gssapi/mechs/krb5/include/gssapiP_generic.h

219

void g_order_free (void **queue);

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

129

queue_insert(queue *q, int after, gssint_uint64 seqnum)

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

163

queue *q;

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

165

if ((q = (queue *) MALLOC(sizeof(queue))) == NULL)

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

184

queue *q;

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

188

q = (queue *) (*vqueue);

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

256

queue *q;

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

258

q = (queue *) (*vqueue);

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

260

FREE (q, sizeof (queue));

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

273

*sizep += sizeof(queue);

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

280

(void) memcpy(*buf, vqueue, sizeof(queue));

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

281

*buf += sizeof(queue);

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

282

*lenremain -= sizeof(queue);

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

292

if ((q = (void *) MALLOC(sizeof(queue))) == 0)

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

294

(void) memcpy(q, *buf, sizeof(queue));

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

295

*buf += sizeof(queue);

usr/src/uts/common/gssapi/mechs/krb5/mech/util_ordering.c

296

*lenremain -= sizeof(queue);

usr/src/uts/common/io/aac/aac.c

3208

aac_fib_enqueue(struct aac_softstate *softs, int queue, uint32_t fib_addr,

usr/src/uts/common/io/aac/aac.c

3217

ASSERT(queue == AAC_ADAP_NORM_CMD_Q || queue == AAC_ADAP_NORM_RESP_Q);

usr/src/uts/common/io/aac/aac.c

3220

(void) ddi_dma_sync(dma, (uintptr_t)softs->qtablep->qt_qindex[queue] - \

usr/src/uts/common/io/aac/aac.c

3229

&softs->qtablep->qt_qindex[queue][AAC_PRODUCER_INDEX]);

usr/src/uts/common/io/aac/aac.c

3231

&softs->qtablep->qt_qindex[queue][AAC_CONSUMER_INDEX]);

usr/src/uts/common/io/aac/aac.c

3237

if (pi >= aac_qinfo[queue].size)

usr/src/uts/common/io/aac/aac.c

3245

ddi_put32(acc, &((softs->qentries[queue] + pi)->aq_fib_size), fib_size);

usr/src/uts/common/io/aac/aac.c

3246

ddi_put32(acc, &((softs->qentries[queue] + pi)->aq_fib_addr), fib_addr);

usr/src/uts/common/io/aac/aac.c

3247

(void) ddi_dma_sync(dma, (uintptr_t)(softs->qentries[queue] + pi) - \

usr/src/uts/common/io/aac/aac.c

3252

ddi_put32(acc, &softs->qtablep->qt_qindex[queue][AAC_PRODUCER_INDEX],

usr/src/uts/common/io/aac/aac.c

3255

(uintptr_t)&softs->qtablep->qt_qindex[queue][AAC_PRODUCER_INDEX] - \

usr/src/uts/common/io/aac/aac.c

3259

if (aac_qinfo[queue].notify != 0)

usr/src/uts/common/io/aac/aac.c

3260

AAC_NOTIFY(softs, aac_qinfo[queue].notify);

usr/src/uts/common/io/aac/aac.c

3269

aac_fib_dequeue(struct aac_softstate *softs, int queue, int *idxp)

usr/src/uts/common/io/aac/aac.c

3281

(void) ddi_dma_sync(dma, (uintptr_t)softs->qtablep->qt_qindex[queue] - \

usr/src/uts/common/io/aac/aac.c

3285

&softs->qtablep->qt_qindex[queue][AAC_PRODUCER_INDEX]);

usr/src/uts/common/io/aac/aac.c

3287

&softs->qtablep->qt_qindex[queue][AAC_CONSUMER_INDEX]);

usr/src/uts/common/io/aac/aac.c

3293

if (pi >= aac_qinfo[queue].size)

usr/src/uts/common/io/aac/aac.c

3304

if (ci >= aac_qinfo[queue].size)

usr/src/uts/common/io/aac/aac.c

3308

(void) ddi_dma_sync(dma, (uintptr_t)(softs->qentries[queue] + pi) - \

usr/src/uts/common/io/aac/aac.c

3316

switch (queue) {

usr/src/uts/common/io/aac/aac.c

3320

&(softs->qentries[queue] + ci)->aq_fib_addr);

usr/src/uts/common/io/aac/aac.c

3326

&(softs->qentries[queue] + ci)->aq_fib_addr) / AAC_FIB_SIZE;

usr/src/uts/common/io/aac/aac.c

3335

ddi_put32(acc, &softs->qtablep->qt_qindex[queue][AAC_CONSUMER_INDEX],

usr/src/uts/common/io/aac/aac.c

3338

(uintptr_t)&softs->qtablep->qt_qindex[queue][AAC_CONSUMER_INDEX] - \

usr/src/uts/common/io/aac/aac.c

3342

if (unfull && aac_qinfo[queue].notify != 0)

usr/src/uts/common/io/aac/aac.c

3343

AAC_NOTIFY(softs, aac_qinfo[queue].notify);

usr/src/uts/common/io/arn/arn_core.h

998

int arn_get_hal_qnum(uint16_t queue, struct arn_softc *sc);

usr/src/uts/common/io/arn/arn_main.c

1278

arn_get_hal_qnum(uint16_t queue, struct arn_softc *sc)

usr/src/uts/common/io/arn/arn_main.c

1282

switch (queue) {

usr/src/uts/common/io/beep.c

106

queue = kmem_zalloc(sizeof (beep_entry_t) * beep_queue_size,

usr/src/uts/common/io/beep.c

112

(unsigned long)queue));

usr/src/uts/common/io/beep.c

114

if (queue == NULL) {

usr/src/uts/common/io/beep.c

130

beep_state.queue = queue;

usr/src/uts/common/io/beep.c

155

if (beep_state.queue != NULL)

usr/src/uts/common/io/beep.c

156

kmem_free(beep_state.queue,

usr/src/uts/common/io/beep.c

169

beep_state.queue = (beep_entry_t *)NULL;

usr/src/uts/common/io/beep.c

379

beep_state.queue[beep_state.queue_tail].

usr/src/uts/common/io/beep.c

382

beep_state.queue[beep_state.queue_tail].

usr/src/uts/common/io/beep.c

462

frequency = beep_state.queue[next].frequency;

usr/src/uts/common/io/beep.c

464

duration = beep_state.queue[next].duration;

usr/src/uts/common/io/beep.c

88

beep_entry_t *queue;

usr/src/uts/common/io/bnxe/577xx/hsi/mcp/multi_thread_def.h

120

struct tasks_queue_t queue;

usr/src/uts/common/io/i40e/core/i40e_adminq_cmd.h

1365

__le16 queue;

usr/src/uts/common/io/i40e/core/i40e_common.c

1155

void i40e_pre_tx_queue_cfg(struct i40e_hw *hw, u32 queue, bool enable)

usr/src/uts/common/io/i40e/core/i40e_common.c

1157

u32 abs_queue_idx = hw->func_caps.base_queue + queue;

usr/src/uts/common/io/i40e/core/i40e_common.c

5581

u16 vsi_seid, u16 queue, bool is_add,

usr/src/uts/common/io/i40e/core/i40e_common.c

5600

cmd->queue = CPU_TO_LE16(queue);

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.c

1301

u16 queue,

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.c

1307

err = i40e_hmc_get_object_va(hw, &context_bytes, I40E_HMC_LAN_TX, queue);

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.c

1321

u16 queue)

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.c

1326

err = i40e_hmc_get_object_va(hw, &context_bytes, I40E_HMC_LAN_TX, queue);

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.c

1340

u16 queue,

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.c

1346

err = i40e_hmc_get_object_va(hw, &context_bytes, I40E_HMC_LAN_TX, queue);

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.c

1361

u16 queue,

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.c

1367

err = i40e_hmc_get_object_va(hw, &context_bytes, I40E_HMC_LAN_RX, queue);

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.c

1381

u16 queue)

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.c

1386

err = i40e_hmc_get_object_va(hw, &context_bytes, I40E_HMC_LAN_RX, queue);

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.c

1400

u16 queue,

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.c

1406

err = i40e_hmc_get_object_va(hw, &context_bytes, I40E_HMC_LAN_RX, queue);

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.h

181

u16 queue,

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.h

184

u16 queue);

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.h

186

u16 queue,

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.h

189

u16 queue,

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.h

192

u16 queue);

usr/src/uts/common/io/i40e/core/i40e_lan_hmc.h

194

u16 queue,

usr/src/uts/common/io/i40e/core/i40e_prototype.h

457

void i40e_pre_tx_queue_cfg(struct i40e_hw *hw, u32 queue, bool enable);

usr/src/uts/common/io/i40e/core/i40e_prototype.h

558

u16 vsi_seid, u16 queue, bool is_add,

usr/src/uts/common/io/i40e/i40e_intr.c

386

i40e_set_lnklstn(i40e_t *i40e, uint_t vector, uint_t queue)

usr/src/uts/common/io/i40e/i40e_intr.c

391

reg = (queue << I40E_PFINT_LNKLSTN_FIRSTQ_INDX_SHIFT) |

usr/src/uts/common/io/i40e/i40e_intr.c

405

i40e_set_rqctl(i40e_t *i40e, uint_t vector, uint_t queue)

usr/src/uts/common/io/i40e/i40e_intr.c

410

ASSERT3U(vector, ==, i40e->i40e_trqpairs[queue].itrq_rx_intrvec);

usr/src/uts/common/io/i40e/i40e_intr.c

414

(queue << I40E_QINT_RQCTL_NEXTQ_INDX_SHIFT) |

usr/src/uts/common/io/i40e/i40e_intr.c

418

I40E_WRITE_REG(hw, I40E_QINT_RQCTL(queue), reg);

usr/src/uts/common/io/i40e/i40e_intr.c

419

DEBUGOUT2("QINT_RQCTL[%u] = 0x%x", queue, reg);

usr/src/uts/common/io/i40e/i40e_intr.c

427

i40e_set_tqctl(i40e_t *i40e, uint_t vector, uint_t queue, uint_t next_queue)

usr/src/uts/common/io/i40e/i40e_intr.c

432

ASSERT3U(vector, ==, i40e->i40e_trqpairs[queue].itrq_tx_intrvec);

usr/src/uts/common/io/i40e/i40e_intr.c

440

I40E_WRITE_REG(hw, I40E_QINT_TQCTL(queue), reg);

usr/src/uts/common/io/i40e/i40e_intr.c

441

DEBUGOUT2("QINT_TQCTL[%u] = 0x%x", queue, reg);

usr/src/uts/common/io/i40e/i40e_intr.c

531

uint_t queue = itrq->itrq_index;

usr/src/uts/common/io/i40e/i40e_intr.c

535

ASSERT(queue < itrq->itrq_i40e->i40e_num_trqpairs);

usr/src/uts/common/io/i40e/i40e_intr.c

537

reg = I40E_READ_REG(hw, I40E_QINT_RQCTL(queue));

usr/src/uts/common/io/i40e/i40e_intr.c

540

I40E_WRITE_REG(hw, I40E_QINT_RQCTL(queue), reg);

usr/src/uts/common/io/i40e/i40e_intr.c

552

uint_t queue = itrq->itrq_index;

usr/src/uts/common/io/i40e/i40e_intr.c

556

ASSERT(queue < itrq->itrq_i40e->i40e_num_trqpairs);

usr/src/uts/common/io/i40e/i40e_intr.c

558

reg = I40E_READ_REG(hw, I40E_QINT_RQCTL(queue));

usr/src/uts/common/io/i40e/i40e_intr.c

562

I40E_WRITE_REG(hw, I40E_QINT_RQCTL(queue), reg);

usr/src/uts/common/io/igc/igc.c

1171

igc_write_ivar(igc_t *igc, uint32_t queue, bool rx, uint32_t msix)

usr/src/uts/common/io/igc/igc.c

1173

const uint32_t ivarno = queue >> 1;

usr/src/uts/common/io/igc/igc.c

1179

if ((queue % 2) == 0) {

usr/src/uts/common/io/igc/igc.c

1185

if ((queue % 2) == 0) {

usr/src/uts/common/io/igc/igc.c

622

uintptr_t queue = (uintptr_t)arg2;

usr/src/uts/common/io/igc/igc.c

626

ASSERT3U(queue, <, igc->igc_nrx_rings);

usr/src/uts/common/io/igc/igc.c

627

ring = &igc->igc_rx_rings[queue];

usr/src/uts/common/io/ixgbe/core/ixgbe_82599.c

1565

u8 queue)

usr/src/uts/common/io/ixgbe/core/ixgbe_82599.c

1599

fdircmd |= (u32)queue << IXGBE_FDIRCMD_RX_QUEUE_SHIFT;

usr/src/uts/common/io/ixgbe/core/ixgbe_82599.c

1611

DEBUGOUT2("Tx Queue=%x hash=%x\n", queue, (u32)fdirhashcmd);

usr/src/uts/common/io/ixgbe/core/ixgbe_82599.c

1902

u16 soft_id, u8 queue, bool cloud_mode)

usr/src/uts/common/io/ixgbe/core/ixgbe_82599.c

1972

if (queue == IXGBE_FDIR_DROP_QUEUE)

usr/src/uts/common/io/ixgbe/core/ixgbe_82599.c

1977

fdircmd |= (u32)queue << IXGBE_FDIRCMD_RX_QUEUE_SHIFT;

usr/src/uts/common/io/ixgbe/core/ixgbe_82599.c

2041

u16 soft_id, u8 queue, bool cloud_mode)

usr/src/uts/common/io/ixgbe/core/ixgbe_82599.c

2092

soft_id, queue, cloud_mode);

usr/src/uts/common/io/ixgbe/core/ixgbe_api.h

160

u8 queue);

usr/src/uts/common/io/ixgbe/core/ixgbe_api.h

165

u16 soft_id, u8 queue, bool cloud_mode);

usr/src/uts/common/io/ixgbe/core/ixgbe_api.h

173

u8 queue,

usr/src/uts/common/io/myri10ge/firmware/myri10ge_mcp.h

509

uint8_t queue;

usr/src/uts/common/io/ntxn/unm_inc.h

1551

int side, int group, int queue, int *image);

usr/src/uts/common/io/overlay/overlay_target.c

617

boolean_t queue = B_FALSE;

usr/src/uts/common/io/overlay/overlay_target.c

625

queue = B_TRUE;

usr/src/uts/common/io/overlay/overlay_target.c

627

if (queue == B_TRUE)

usr/src/uts/common/io/overlay/overlay_target.c

707

boolean_t queue = B_FALSE;

usr/src/uts/common/io/overlay/overlay_target.c

743

queue = B_TRUE;

usr/src/uts/common/io/overlay/overlay_target.c

750

if (queue == B_TRUE)

usr/src/uts/common/io/ppp/sppp/sppp.c

465

sppp_ioctl(struct queue *q, mblk_t *mp)

usr/src/uts/common/io/qede/579xx/drivers/ecore/ecore_spq.c

1062

(found->queue == &p_spq->unlimited_pending))

usr/src/uts/common/io/qede/579xx/drivers/ecore/ecore_spq.c

704

p_ent->queue = &p_spq->unlimited_pending;

usr/src/uts/common/io/qede/579xx/drivers/ecore/ecore_spq.c

710

p_ent->queue = &p_spq->pending;

usr/src/uts/common/io/qede/579xx/drivers/ecore/ecore_spq.c

755

if (p_ent->queue == &p_spq->unlimited_pending) {

usr/src/uts/common/io/qede/579xx/drivers/ecore/ecore_spq.c

944

p_ent->queue == &p_spq->unlimited_pending);

usr/src/uts/common/io/qede/579xx/drivers/ecore/ecore_spq.c

946

if (p_ent->queue == &p_spq->unlimited_pending) {

usr/src/uts/common/io/qede/579xx/drivers/ecore/ecore_spq.h

146

osal_list_t *queue;

usr/src/uts/common/io/scsi/adapters/iscsi/iscsi.h

1256

void iscsi_init_queue(iscsi_queue_t *queue);

usr/src/uts/common/io/scsi/adapters/iscsi/iscsi.h

1257

void iscsi_destroy_queue(iscsi_queue_t *queue);

usr/src/uts/common/io/scsi/adapters/iscsi/iscsi_queue.c

55

iscsi_init_queue(iscsi_queue_t *queue)

usr/src/uts/common/io/scsi/adapters/iscsi/iscsi_queue.c

57

ASSERT(queue != NULL);

usr/src/uts/common/io/scsi/adapters/iscsi/iscsi_queue.c

59

queue->head = NULL;

usr/src/uts/common/io/scsi/adapters/iscsi/iscsi_queue.c

60

queue->tail = NULL;

usr/src/uts/common/io/scsi/adapters/iscsi/iscsi_queue.c

61

queue->count = 0;

usr/src/uts/common/io/scsi/adapters/iscsi/iscsi_queue.c

62

mutex_init(&queue->mutex, NULL, MUTEX_DRIVER, NULL);

usr/src/uts/common/io/scsi/adapters/iscsi/iscsi_queue.c

69

iscsi_destroy_queue(iscsi_queue_t *queue)

usr/src/uts/common/io/scsi/adapters/iscsi/iscsi_queue.c

71

ASSERT(queue != NULL);

usr/src/uts/common/io/scsi/adapters/iscsi/iscsi_queue.c

72

ASSERT(queue->count == 0);

usr/src/uts/common/io/scsi/adapters/iscsi/iscsi_queue.c

74

mutex_destroy(&queue->mutex);

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

256

lmrc_get_next_reply_desc(lmrc_t *lmrc, int queue)

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

262

desc += (queue * lmrc->l_reply_alloc_sz) / sizeof (*desc);

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

263

desc += lmrc->l_last_reply_idx[queue];

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

280

lmrc->l_last_reply_idx[queue]++;

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

281

if (lmrc->l_last_reply_idx[queue] >= lmrc->l_reply_q_depth)

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

282

lmrc->l_last_reply_idx[queue] = 0;

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

293

lmrc_write_rphi(lmrc_t *lmrc, uint32_t queue)

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

296

uint32_t val = (queue << 24) | lmrc->l_last_reply_idx[queue];

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

299

VERIFY3U(queue, ==, 0);

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

302

reg = queue / 8;

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

428

lmrc_process_replies(lmrc_t *lmrc, uint8_t queue)

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

433

for (desc = lmrc_get_next_reply_desc(lmrc, queue);

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

435

desc = lmrc_get_next_reply_desc(lmrc, queue)) {

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

510

lmrc_write_rphi(lmrc, queue);

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc.c

514

lmrc_write_rphi(lmrc, queue);

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc_ddi.c

629

int queue = (int)(uintptr_t)arg2;

usr/src/uts/common/io/scsi/adapters/lmrc/lmrc_ddi.c

638

ret = lmrc_process_replies(lmrc, queue);

usr/src/uts/common/io/usb/clients/audio/usb_ah/usb_ah.c

118

_NOTE(SCHEME_PROTECTS_DATA("unique per call", queue))

usr/src/uts/common/io/usb/clients/hid/hid.c

163

_NOTE(SCHEME_PROTECTS_DATA("unique per call", queue))

usr/src/uts/common/io/usb/clients/usbser/usbser.c

206

_NOTE(SCHEME_PROTECTS_DATA("unique per call", iocblk datab msgb queue copyreq))

usr/src/uts/common/io/wscons.c

140

_NOTE(SCHEME_PROTECTS_DATA("Unshared data", queue))

usr/src/uts/common/io/xge/drv/xge.c

1194

if (device_config->fifo.queue[i].configured)

usr/src/uts/common/io/xge/drv/xge.c

1197

if (device_config->ring.queue[i].configured)

usr/src/uts/common/io/xge/drv/xge.c

277

device_config->ring.queue[index].configured =

usr/src/uts/common/io/xge/drv/xge.c

282

if (!device_config->ring.queue[index].configured)

usr/src/uts/common/io/xge/drv/xge.c

286

device_config->ring.queue[index].no_snoop_bits = 1;

usr/src/uts/common/io/xge/drv/xge.c

290

device_config->ring.queue[index].max =

usr/src/uts/common/io/xge/drv/xge.c

296

device_config->ring.queue[index].initial =

usr/src/uts/common/io/xge/drv/xge.c

301

if (device_config->ring.queue[index].initial ==

usr/src/uts/common/io/xge/drv/xge.c

303

device_config->ring.queue[index].initial =

usr/src/uts/common/io/xge/drv/xge.c

304

device_config->ring.queue[index].max =

usr/src/uts/common/io/xge/drv/xge.c

309

device_config->ring.queue[index].buffer_mode =

usr/src/uts/common/io/xge/drv/xge.c

315

device_config->ring.queue[index].dram_size_mb =

usr/src/uts/common/io/xge/drv/xge.c

322

device_config->ring.queue[index].backoff_interval_us =

usr/src/uts/common/io/xge/drv/xge.c

328

device_config->ring.queue[index].max_frm_len =

usr/src/uts/common/io/xge/drv/xge.c

335

device_config->ring.queue[index].priority =

usr/src/uts/common/io/xge/drv/xge.c

341

device_config->ring.queue[index].rti.urange_a =

usr/src/uts/common/io/xge/drv/xge.c

347

device_config->ring.queue[index].rti.ufc_a =

usr/src/uts/common/io/xge/drv/xge.c

353

device_config->ring.queue[index].rti.urange_b =

usr/src/uts/common/io/xge/drv/xge.c

359

device_config->ring.queue[index].rti.ufc_b =

usr/src/uts/common/io/xge/drv/xge.c

367

device_config->ring.queue[index].rti.urange_c =

usr/src/uts/common/io/xge/drv/xge.c

373

device_config->ring.queue[index].rti.ufc_c =

usr/src/uts/common/io/xge/drv/xge.c

381

device_config->ring.queue[index].rti.ufc_d =

usr/src/uts/common/io/xge/drv/xge.c

387

device_config->ring.queue[index].rti.timer_val_us =

usr/src/uts/common/io/xge/drv/xge.c

393

device_config->ring.queue[index].rti.timer_ac_en =

usr/src/uts/common/io/xge/drv/xge.c

400

device_config->ring.queue[index].indicate_max_pkts =

usr/src/uts/common/io/xge/drv/xge.c

411

device_config->ring.queue[index].rth_en = 1;

usr/src/uts/common/io/xge/drv/xge.c

424

device_config->fifo.queue[index].configured =

usr/src/uts/common/io/xge/drv/xge.c

429

if (!device_config->fifo.queue[index].configured)

usr/src/uts/common/io/xge/drv/xge.c

433

device_config->fifo.queue[index].no_snoop_bits = 1;

usr/src/uts/common/io/xge/drv/xge.c

437

device_config->fifo.queue[index].max = ddi_prop_get_int(DDI_DEV_T_ANY,

usr/src/uts/common/io/xge/drv/xge.c

442

device_config->fifo.queue[index].initial =

usr/src/uts/common/io/xge/drv/xge.c

447

if (device_config->fifo.queue[index].initial ==

usr/src/uts/common/io/xge/drv/xge.c

450

device_config->fifo.queue[index].initial =

usr/src/uts/common/io/xge/drv/xge.c

451

device_config->fifo.queue[index].max =

usr/src/uts/common/io/xge/drv/xge.c

454

device_config->fifo.queue[index].initial =

usr/src/uts/common/io/xge/drv/xge.c

455

device_config->fifo.queue[index].max =

usr/src/uts/common/io/xge/drv/xge.c

460

if (device_config->fifo.queue[index].initial ==

usr/src/uts/common/io/xge/drv/xge.c

462

device_config->fifo.queue[index].max =

usr/src/uts/common/io/xge/drv/xge.c

463

device_config->fifo.queue[index].initial =

usr/src/uts/common/io/xge/drv/xge.c

469

device_config->fifo.queue[index].intr = ddi_prop_get_int(DDI_DEV_T_ANY,

usr/src/uts/common/io/xge/drv/xge.c

477

device_config->fifo.queue[index].tti[index].enabled = ddi_prop_get_int(

usr/src/uts/common/io/xge/drv/xge.c

481

device_config->fifo.queue[index].tti[index].urange_a = ddi_prop_get_int(

usr/src/uts/common/io/xge/drv/xge.c

486

device_config->fifo.queue[index].tti[index].ufc_a = ddi_prop_get_int(

usr/src/uts/common/io/xge/drv/xge.c

491

device_config->fifo.queue[index].tti[index].urange_b = ddi_prop_get_int(

usr/src/uts/common/io/xge/drv/xge.c

496

device_config->fifo.queue[index].tti[index].ufc_b = ddi_prop_get_int(

usr/src/uts/common/io/xge/drv/xge.c

501

device_config->fifo.queue[index].tti[index].urange_c = ddi_prop_get_int(

usr/src/uts/common/io/xge/drv/xge.c

506

device_config->fifo.queue[index].tti[index].ufc_c = ddi_prop_get_int(

usr/src/uts/common/io/xge/drv/xge.c

511

device_config->fifo.queue[index].tti[index].ufc_d = ddi_prop_get_int(

usr/src/uts/common/io/xge/drv/xge.c

516

device_config->fifo.queue[index].tti[index].timer_ac_en =

usr/src/uts/common/io/xge/drv/xge.c

521

device_config->fifo.queue[index].tti[index].timer_val_us =

usr/src/uts/common/io/xge/drv/xge.c

526

device_config->fifo.queue[index].tti[index].timer_ci_en =

usr/src/uts/common/io/xge/drv/xge.c

652

if (device_config->ring.queue[i].configured)

usr/src/uts/common/io/xge/drv/xge.c

716

if (device_config->fifo.queue[i].configured)

usr/src/uts/common/io/xge/drv/xge.c

748

device_config->ring.queue[XGELL_RX_RING_MAIN].initial *

usr/src/uts/common/io/xge/drv/xge.c

753

device_config->ring.queue[XGELL_RX_RING_MAIN].initial *

usr/src/uts/common/io/xge/drv/xge.c

908

if (fifo_conf->queue[i].configured) {

usr/src/uts/common/io/xge/drv/xge.c

913

if (ring_conf->queue[i].configured) {

usr/src/uts/common/io/xge/drv/xgell.c

1871

hldev->config.ring.queue[XGELL_RX_RING_MAIN].rti.ufc_b =

usr/src/uts/common/io/xge/drv/xgell.c

1876

hldev->config.ring.queue[XGELL_RX_RING_MAIN].rti.ufc_c =

usr/src/uts/common/io/xge/hal/include/xgehal-config.h

302

xge_hal_fifo_queue_t queue[XGE_HAL_MAX_FIFO_NUM];

usr/src/uts/common/io/xge/hal/include/xgehal-config.h

467

xge_hal_ring_queue_t queue[XGE_HAL_MAX_RING_NUM];

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

100

xge_assert(queue->tail_ptr >= queue->head_ptr);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

101

xge_assert(queue->tail_ptr >= queue->start_ptr &&

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

102

queue->tail_ptr <= queue->end_ptr);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

103

xge_assert(queue->head_ptr >= queue->start_ptr &&

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

104

queue->head_ptr < queue->end_ptr);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

109

if (xge_list_is_empty(&queue->list_head)) {

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

111

queue->head_ptr = queue->tail_ptr = queue->start_ptr;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

142

xge_queue_t *queue = (xge_queue_t *)queueh;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

149

xge_os_spin_lock_irq(&queue->lock, flags);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

151

if (is_critical && !queue->has_critical_event) {

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

158

while (__queue_consume(queue,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

165

if ((char *)queue->tail_ptr + real_size <= (char *)queue->end_ptr) {

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

166

elem = (xge_queue_item_t *) queue->tail_ptr;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

167

queue->tail_ptr = (void *)((char *)queue->tail_ptr + real_size);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

173

(u64)(ulong_t)queue->start_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

174

(u64)(ulong_t)queue->head_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

175

(u64)(ulong_t)queue->tail_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

176

(u64)(ulong_t)queue->end_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

179

} else if ((char *)queue->head_ptr - real_size >=

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

180

(char *)queue->start_ptr) {

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

181

elem = (xge_queue_item_t *) ((char *)queue->head_ptr - real_size);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

182

queue->head_ptr = elem;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

188

(u64)(ulong_t)queue->start_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

189

(u64)(ulong_t)queue->head_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

190

(u64)(ulong_t)queue->tail_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

191

(u64)(ulong_t)queue->end_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

196

if (queue->pages_current >= queue->pages_max) {

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

197

xge_os_spin_unlock_irq(&queue->lock, flags);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

201

if (queue->has_critical_event) {

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

202

xge_os_spin_unlock_irq(&queue->lock, flags);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

209

xge_os_spin_unlock_irq(&queue->lock, flags);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

215

xge_assert(queue->tail_ptr >= queue->head_ptr);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

216

xge_assert(queue->tail_ptr >= queue->start_ptr &&

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

217

queue->tail_ptr <= queue->end_ptr);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

218

xge_assert(queue->head_ptr >= queue->start_ptr &&

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

219

queue->head_ptr < queue->end_ptr);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

224

queue->has_critical_event = 1;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

227

xge_list_insert_before(&elem->item, &queue->list_head);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

228

xge_os_spin_unlock_irq(&queue->lock, flags);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

231

queue->queued_func(queue->queued_data, event_type);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

259

xge_queue_t *queue;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

261

if ((queue = (xge_queue_t *) xge_os_malloc(pdev, sizeof(xge_queue_t))) == NULL)

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

264

queue->queued_func = queued;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

265

queue->queued_data = queued_data;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

266

queue->pdev = pdev;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

267

queue->irqh = irqh;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

268

queue->pages_current = pages_initial;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

269

queue->start_ptr = xge_os_malloc(pdev, queue->pages_current *

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

271

if (queue->start_ptr == NULL) {

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

272

xge_os_free(pdev, queue, sizeof(xge_queue_t));

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

275

queue->head_ptr = queue->tail_ptr = queue->start_ptr;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

276

queue->end_ptr = (char *)queue->start_ptr +

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

277

queue->pages_current * XGE_QUEUE_BUF_SIZE;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

278

xge_os_spin_lock_init_irq(&queue->lock, irqh);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

279

queue->pages_initial = pages_initial;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

280

queue->pages_max = pages_max;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

281

xge_list_init(&queue->list_head);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

283

return queue;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

296

xge_queue_t *queue = (xge_queue_t *)queueh;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

297

xge_os_spin_lock_destroy_irq(&queue->lock, queue->irqh);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

298

if (!xge_list_is_empty(&queue->list_head)) {

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

300

XGE_OS_LLXFMT, (u64)(ulong_t)queue);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

302

xge_os_free(queue->pdev, queue->start_ptr, queue->pages_current *

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

305

xge_os_free(queue->pdev, queue, sizeof(xge_queue_t));

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

323

xge_queue_t *queue = (xge_queue_t *)queueh;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

329

(u64)(ulong_t)queue, queue->pages_current);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

331

newbuf = xge_os_malloc(queue->pdev,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

332

(queue->pages_current + 1) * XGE_QUEUE_BUF_SIZE);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

336

xge_os_memcpy(newbuf, queue->start_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

337

queue->pages_current * XGE_QUEUE_BUF_SIZE);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

338

oldbuf = queue->start_ptr;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

341

queue->start_ptr = newbuf;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

342

queue->end_ptr = (char *)newbuf +

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

343

(queue->pages_current + 1) * XGE_QUEUE_BUF_SIZE;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

344

queue->tail_ptr = (char *)newbuf + ((char *)queue->tail_ptr -

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

346

queue->head_ptr = (char *)newbuf + ((char *)queue->head_ptr -

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

348

xge_assert(!xge_list_is_empty(&queue->list_head));

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

349

queue->list_head.next = (xge_list_t *) (void *)((char *)newbuf +

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

350

((char *)queue->list_head.next - (char *)oldbuf));

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

351

queue->list_head.prev = (xge_list_t *) (void *)((char *)newbuf +

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

352

((char *)queue->list_head.prev - (char *)oldbuf));

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

354

xge_list_for_each(item, &queue->list_head) {

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

356

if (elem->item.next != &queue->list_head) {

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

361

if (elem->item.prev != &queue->list_head) {

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

367

xge_os_free(queue->pdev, oldbuf,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

368

queue->pages_current * XGE_QUEUE_BUF_SIZE);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

369

queue->pages_current++;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

394

xge_queue_t *queue = (xge_queue_t *)queueh;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

398

xge_os_spin_lock_irq(&queue->lock, flags);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

399

status = __queue_consume(queue, data_max_size, item);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

400

xge_os_spin_unlock_irq(&queue->lock, flags);

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

442

xge_queue_t* queue = (xge_queue_t*)qh;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

443

int c = queue->has_critical_event;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

445

queue->has_critical_event = 0;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

47

__queue_consume(xge_queue_t *queue, int data_max_size, xge_queue_item_t *item)

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

52

if (xge_list_is_empty(&queue->list_head))

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

55

elem = (xge_queue_item_t *)queue->list_head.next;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

61

if (queue->head_ptr == elem) {

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

62

queue->head_ptr = (char *)queue->head_ptr + real_size;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

68

(u64)(ulong_t)queue->start_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

69

(u64)(ulong_t)queue->head_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

70

(u64)(ulong_t)queue->tail_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

71

(u64)(ulong_t)queue->end_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

74

} else if ((char *)queue->tail_ptr - real_size == (char*)elem) {

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

75

queue->tail_ptr = (char *)queue->tail_ptr - real_size;

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

81

(u64)(ulong_t)queue->start_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

82

(u64)(ulong_t)queue->head_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

83

(u64)(ulong_t)queue->tail_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

84

(u64)(ulong_t)queue->end_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

93

(u64)(ulong_t)queue->start_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

94

(u64)(ulong_t)queue->head_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

95

(u64)(ulong_t)queue->tail_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xge-queue.c

96

(u64)(ulong_t)queue->end_ptr,

usr/src/uts/common/io/xge/hal/xgehal/xgehal-config.c

398

if (!new_config->queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-config.c

402

&new_config->queue[i])) != XGE_HAL_OK) {

usr/src/uts/common/io/xge/hal/xgehal/xgehal-config.c

406

total_fifo_length += new_config->queue[i].max;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-config.c

436

if (!new_config->queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-config.c

439

if ((status = __hal_ring_queue_check(&new_config->queue[i]))

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

1051

if (!hldev->config.fifo.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

1057

if (!hldev->config.fifo.queue[i].tti[j].enabled)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

1064

&hldev->config.fifo.queue[i].tti[j],

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

1120

xge_hal_rti_config_t *rti = &hldev->config.ring.queue[i].rti;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

1122

if (!hldev->config.ring.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

1541

xge_hal_ring_queue_t *queue = &hldev->config.ring.queue[rnum];

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

1543

if (!queue->configured || queue->rts_port_en)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

1547

xge_hal_rts_port_t *port = &queue->rts_ports[pnum];

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

1644

if (hldev->config.ring.queue[j].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

1858

if (hldev->config.ring.queue[rnum].configured &&

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

1859

hldev->config.ring.queue[rnum].rth_en)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

2917

if (!hldev->config.fifo.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

2920

if (hldev->config.fifo.queue[i].tti[j].enabled)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

2921

hldev->config.fifo.queue[i].tti[j].enabled = 0;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

3426

ufc = hldev->config.ring.queue[ring_no].rti.ufc_a;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

3435

hldev->config.ring.queue[i].rti.ufc_a = ufc;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

3445

hldev->config.ring.queue[i].rti.ufc_a = ufc;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

3652

if (!hldev->config.ring.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

3654

if (hldev->config.ring.queue[i].rti.urange_a)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

3667

if (!hldev->config.ring.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

5259

if (!device_config->fifo.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

5280

if (!device_config->ring.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

5282

if (device_config->ring.queue[i].dram_size_mb ==

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

5287

total_dram_size += device_config->ring.queue[i].dram_size_mb;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

5304

if (!device_config->ring.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

5307

if (device_config->ring.queue[i].dram_size_mb ==

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

5309

hldev->config.ring.queue[i].dram_size_mb =

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

5310

device_config->ring.queue[i].dram_size_mb =

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

6670

hldev->config.ring.queue[channel->post_qid].intr_vector =

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

6680

hldev->config.fifo.queue[channel->post_qid].intr_vector =

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

913

if (!hldev->config.ring.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-device.c

915

rti = &hldev->config.ring.queue[i].rti;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-fifo.c

155

xge_hal_fifo_queue_t *queue;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-fifo.c

161

queue = &fifo->config->queue[attr->post_qid];

usr/src/uts/common/io/xge/hal/xgehal/xgehal-fifo.c

197

if (queue->intr) {

usr/src/uts/common/io/xge/hal/xgehal/xgehal-fifo.c

201

(int)(XGE_HAL_TX_FIFO_NO_SNOOP(queue->no_snoop_bits));

usr/src/uts/common/io/xge/hal/xgehal/xgehal-fifo.c

256

queue->initial,

usr/src/uts/common/io/xge/hal/xgehal/xgehal-fifo.c

257

queue->max,

usr/src/uts/common/io/xge/hal/xgehal/xgehal-fifo.c

267

queue->initial, queue->max,

usr/src/uts/common/io/xge/hal/xgehal/xgehal-fifo.c

398

if (hldev->config.fifo.queue[i].configured) {

usr/src/uts/common/io/xge/hal/xgehal/xgehal-fifo.c

399

int priority = hldev->config.fifo.queue[i].priority;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-fifo.c

401

vBIT((hldev->config.fifo.queue[i].max-1),

usr/src/uts/common/io/xge/hal/xgehal/xgehal-fifo.c

463

if (!hldev->config.fifo.queue[i].configured ||

usr/src/uts/common/io/xge/hal/xgehal/xgehal-fifo.c

464

!hldev->config.fifo.queue[i].intr_vector)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-fifo.c

481

hldev->config.fifo.queue[i].intr_vector);

usr/src/uts/common/io/xge/hal/xgehal/xgehal-mgmt.c

497

__hal_update_ring_bump(xge_hal_device_t *hldev, int queue,

usr/src/uts/common/io/xge/hal/xgehal/xgehal-mgmt.c

502

int reg = (queue / 4);

usr/src/uts/common/io/xge/hal/xgehal/xgehal-mgmt.c

508

chinfo->ring_bump_cnt = XGE_HAL_RING_BUMP_CNT(queue, rbc);

usr/src/uts/common/io/xge/hal/xgehal/xgehal-mgmtaux.c

1612

ring = &dev_config->ring.queue[i];

usr/src/uts/common/io/xge/hal/xgehal/xgehal-mgmtaux.c

1713

fifo = &dev_config->fifo.queue[i];

usr/src/uts/common/io/xge/hal/xgehal/xgehal-mgmtaux.c

1736

tti = &dev_config->fifo.queue[i].tti[j];

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

245

xge_hal_ring_queue_t *queue;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

253

queue = &ring->config->queue[attr->post_qid];

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

254

ring->indicate_max_pkts = queue->indicate_max_pkts;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

255

ring->buffer_mode = queue->buffer_mode;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

257

xge_assert(queue->configured);

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

270

ring->rxd_size = XGE_HAL_RING_RXD_SIZEOF(queue->buffer_mode);

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

276

ring->rxds_per_block = XGE_HAL_RING_RXDS_PER_BLOCK(queue->buffer_mode);

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

282

sizeof(void*) * queue->max * ring->rxds_per_block);

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

294

queue->initial, queue->max,

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

306

queue->initial * ring->rxds_per_block,

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

307

queue->max * ring->rxds_per_block,

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

347

xge_hal_ring_queue_t *queue;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

355

queue = &ring->config->queue[ring->channel.post_qid];

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

364

sizeof(void*) * queue->max * ring->rxds_per_block);

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

390

xge_hal_ring_queue_t *queue;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

398

queue = &ring->config->queue[ring->channel.post_qid];

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

399

xge_assert(queue->buffer_mode == 1 ||

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

400

queue->buffer_mode == 3 ||

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

401

queue->buffer_mode == 5);

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

406

block_num = queue->initial;

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

419

!queue->rth_en) {

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

424

val64 |= vBIT((queue->buffer_mode >> 1),14,2);/* 1,3 or 5 => 0,1 or 2 */

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

427

(hldev->config.pci_freq_mherz * queue->backoff_interval_us));

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

430

val64 |= XGE_HAL_PRC_CTRL_NO_SNOOP(queue->no_snoop_bits);

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

456

ring->channel.post_qid, queue->buffer_mode);

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

491

if (!hldev->config.ring.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

493

val64 |= vBIT(hldev->config.ring.queue[i].priority,

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

504

if (!hldev->config.ring.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

506

val64 |= vBIT(hldev->config.ring.queue[i].dram_size_mb,(i*8),8);

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

527

if (!hldev->config.ring.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

529

if (!hldev->config.ring.queue[i].rth_en)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

547

if (hldev->config.ring.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

608

if (!hldev->config.ring.queue[i].configured ||

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

609

!hldev->config.ring.queue[i].intr_vector)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

626

hldev->config.ring.queue[i].intr_vector);

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

641

if (!hldev->config.ring.queue[i].configured)

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

643

if (hldev->config.ring.queue[i].max_frm_len !=

usr/src/uts/common/io/xge/hal/xgehal/xgehal-ring.c

647

hldev->config.ring.queue[i].max_frm_len),

usr/src/uts/common/os/contract.c

669

list_t *queue = &ct->ct_events.ctq_events;

usr/src/uts/common/os/contract.c

681

for (ev = list_head(queue); ev; ev = list_next(queue, ev)) {

usr/src/uts/common/os/contract.c

749

list_t *queue = &ct->ct_events.ctq_events;

usr/src/uts/common/os/contract.c

756

for (ev = list_head(queue); ev; ev = list_next(queue, ev)) {

usr/src/uts/common/os/contract.c

789

list_t *queue = &ct->ct_events.ctq_events;

usr/src/uts/common/os/contract.c

796

for (ev = list_head(queue); ev; ev = list_next(queue, ev)) {

usr/src/uts/common/os/driver_lyr.c

1495

ldi_ident_from_stream(struct queue *sq, ldi_ident_t *lip)

usr/src/uts/common/os/msg.c

1404

msg_rcvq_sleep(list_t *queue, msgq_wakeup_t *entry, kmutex_t **lock,

usr/src/uts/common/os/msg.c

1411

list_insert_tail(queue, entry);

usr/src/uts/common/os/msg.c

1422

list_remove(queue, entry);

usr/src/uts/common/os/streamio.c

2819

struct queue *wqp;

usr/src/uts/common/os/strsubr.c

176

static struct queue *qhead;

usr/src/uts/common/os/strsubr.c

177

static struct queue *qtail;

usr/src/uts/common/sys/beep.h

93

beep_entry_t *queue;

usr/src/uts/common/sys/ddi.h

149

extern struct queue *OTHERQ(queue_t *); /* stream.h */

usr/src/uts/common/sys/ddi.h

150

extern struct queue *RD(queue_t *);

usr/src/uts/common/sys/ddi.h

151

extern struct queue *WR(queue_t *);

usr/src/uts/common/sys/fs/fifonode.h

166

struct queue;

usr/src/uts/common/sys/sata/adapters/nv_sata/nv_sata.h

232

int (*nvslot_start)(nv_port_t *nvp, int queue);

usr/src/uts/common/sys/stream.h

120

struct queue *q_next; /* Q9S: next Q in stream */

usr/src/uts/common/sys/stream.h

121

struct queue *q_link; /* SVLK: next Q for scheduling */

usr/src/uts/common/sys/stream.h

135

struct queue *q_nfsrv; /* STR: next Q with svc routine */

usr/src/uts/common/sys/stream.h

149

struct queue *q_sqnext; /* SQLK: next Q on syncq list */

usr/src/uts/common/sys/stream.h

150

struct queue *q_sqprev; /* SQLK: prev Q on syncq list */

usr/src/uts/common/sys/strsubr.h

1335

extern struct queue *OTHERQ(queue_t *); /* stream.h */

usr/src/uts/common/sys/strsubr.h

1336

extern struct queue *RD(queue_t *);

usr/src/uts/common/sys/strsubr.h

1337

extern struct queue *WR(queue_t *);

usr/src/uts/common/sys/strsubr.h

183

struct queue *sd_wrq; /* write queue */

usr/src/uts/common/sys/strsubr.h

215

struct queue *sd_struiordq; /* sync barrier struio() read queue */

usr/src/uts/common/sys/strsubr.h

216

struct queue *sd_struiowrq; /* sync barrier struio() write queue */

usr/src/uts/common/sys/strsubr.h

241

struct queue *sd_qhead; /* Head of queues to be serviced. */

usr/src/uts/common/sys/strsubr.h

242

struct queue *sd_qtail; /* Tail of queues to be serviced. */

usr/src/uts/common/sys/strsubr.h

720

struct queue qu_rqueue; /* read queue - must be first */

usr/src/uts/common/sys/strsubr.h

721

struct queue qu_wqueue; /* write queue - must be second */

usr/src/uts/common/sys/sunldi.h

89

extern int ldi_ident_from_stream(struct queue *, ldi_ident_t *);

usr/src/uts/common/sys/usb/usba/usba_impl.h

204

#define USBA_WRQUEUE2WRP(queue) (usba_req_wrapper_t *)(queue)

usr/src/uts/common/sys/usb/usba/usba_impl.h

207

#define USBA_ALLOCQ2WRP(queue) (usba_req_wrapper_t *)((uintptr_t) \

usr/src/uts/common/sys/usb/usba/usba_impl.h

208

(queue) - sizeof (usba_list_entry_t) - sizeof (usb_opaque_t))

usr/src/uts/i86pc/os/x_call.c

142

xc_insert(void *queue, xc_msg_t *msg)

usr/src/uts/i86pc/os/x_call.c

152

queue == &cpu[msg->xc_master]->cpu_m.xc_free);

usr/src/uts/i86pc/os/x_call.c

155

old_head = (xc_msg_t *)*(volatile xc_msg_t **)queue;

usr/src/uts/i86pc/os/x_call.c

157

} while (atomic_cas_ptr(queue, old_head, msg) != old_head);

usr/src/uts/i86pc/os/x_call.c

166

xc_extract(xc_msg_t **queue)

usr/src/uts/i86pc/os/x_call.c

171

old_head = (xc_msg_t *)*(volatile xc_msg_t **)queue;

usr/src/uts/i86pc/os/x_call.c

174

} while (atomic_cas_ptr(queue, old_head, old_head->xc_next) !=

usr/src/uts/intel/io/ecpp.c

477

_NOTE(SCHEME_PROTECTS_DATA("unique per call", queue))

usr/src/uts/sun4u/cpu/spitfire.c

817

int queue = 1;

usr/src/uts/sun4u/cpu/spitfire.c

884

queue = 0;

usr/src/uts/sun4u/cpu/spitfire.c

898

if (queue) {

usr/src/uts/sun4u/cpu/spitfire.c

908

if (queue) {

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu.c

2145

stp_queue = WR(ctrl->queue);

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu.c

2182

altn_queue = WR(ctrl->queue);

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu.c

2226

stp_queue = WR(ctrl->queue);

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu.c

555

ctrl->queue = urq;

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu.c

667

ctrl->queue = NULL;

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_cmn_func.c

1259

usr_queue = ctrl->queue;

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_cmn_func.c

1438

dst_queue = RD(ctrl->queue);

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_cmn_func.c

1504

dst_queue = RD(ctrl->queue);

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_cmn_func.c

565

oplmsu_cmn_put_xoffxon(queue_t *queue, int data)

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_cmn_func.c

573

(void) putq(queue, mp);

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_cmn_func.c

579

(void) putq(queue, mp);

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_ioctl_lrp.c

183

(void) putq(RD(ctrl->queue), hndl_mp);

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_ioctl_lrp.c

228

temp_queue = WR(ctrl->queue);

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_ioctl_lrp.c

487

dst_queue = RD(ctrl->queue);

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_ioctl_lrp.c

593

noenable(WR(ctrl->queue));

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_ioctl_lrp.c

710

noenable(WR(ctrl->queue));

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_ioctl_lrp.c

744

(void) putq(RD(ctrl->queue), lpath->hndl_mp);

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_ioctl_lrp.c

751

noenable(WR(ctrl->queue));

usr/src/uts/sun4u/opl/io/oplmsu/oplmsu_ioctl_lrp.c

783

temp_queue = WR(ctrl->queue);

usr/src/uts/sun4u/opl/sys/oplmsu/oplmsu.h

247

queue_t *queue;

usr/src/uts/sun4v/os/error.c

920

errh_er_print(errh_er_t *errh_erp, const char *queue)

usr/src/uts/sun4v/os/error.c

944

cmn_err(CE_CONT, "received on %s\n", queue);

usr/src/uts/sun4v/sys/hypervisor_api.h

363

extern uint64_t hv_cpu_qconf(int queue, uint64_t paddr, int size);