Home
last modified time | relevance | path

Searched refs:pq (Results 1 – 25 of 26) sorted by relevance

12

/dragonfly/sys/dev/disk/iscsi/initiator/
H A Discsivar.h323 return pq; in pdu_alloc()
329 if(pq->mp) in pdu_free()
365 return pq; in i_dqueue_rsp()
390 return pq; in i_dqueue_rsv()
415 return pq; in i_dqueue_csnd()
440 return pq; in i_dqueue_isnd()
465 return pq; in i_dqueue_wsnd()
473 pq = NULL; in i_dqueue_snd()
492 return pq; in i_dqueue_snd()
500 TAILQ_INSERT_TAIL(pq->pduq, pq, pq_link); in i_rqueue_pdu()
[all …]
H A Discsi_subr.c194 if(pq != NULL) in _scsi_done()
195 debug(3, "mp=%p buf=%p len=%d", pq->mp, pq->buf, pq->len); in _scsi_done()
206 if((pq != NULL) && (pq->mp != NULL) && getSenseData(status, ccb, pq)) in _scsi_done()
250 pduq_t *pq; in iscsi_requeue() local
274 pduq_t *pq; in i_pdu_flush() local
313 if(pq->ccb) in iscsi_cleanup()
320 if(pq->ccb) in iscsi_cleanup()
448 pduq_t *pq; in scsi_encap() local
540 pq, opq, bhp->opcode, pq->pdu.ds_len); in scsi_decap()
544 pq, opq, bhp->opcode, pq->pdu.ds_len); in scsi_decap()
[all …]
H A Disc_sm.c73 iscsi_async(sp, pq); in _async()
115 iscsi_r2t(sp, opq, pq); in _r2t()
134 debug(5, "itt=%x pq=%p opq=%p", ntohl(pq->pdu.ipdu.bhs.itt), pq, opq); in _scsi_rsp()
168 pduq_t *pq; in _nop_out() local
291 pq->len = len; in i_prepPDU()
309 if(pq->len == 0 && (error = i_prepPDU(sp, pq))) in isc_qout()
468 pduq_t *pq; in proc_out() local
494 pp = &pq->pdu; in proc_out()
527 if(pq->ccb) in proc_out()
538 if(pq->ccb) in proc_out()
[all …]
H A Disc_soc.c104 pdu_t *pp = &pq->pdu; in isc_sendPDU()
130 pq->pdu.hdr_dig = sp->hdrDigest(&pp->ahs, pp->ahs_len, pq->pdu.hdr_dig); in isc_sendPDU()
143 if(pq->pdu.ds) { in isc_sendPDU()
154 pq->refcnt++; in isc_sendPDU()
224 pq->pdu.hdr_dig = sp->hdrDigest(&pp->ahs, pp->ahs_len, pq->pdu.hdr_dig); in isc_sendPDU()
232 if(pq->pdu.ds) { in isc_sendPDU()
382 pp = &pq->pdu; in so_recv()
461 pq->iov[1].iov_len = len - pq->pdu.ds_len; in so_recv()
481 pq->mp = sbp.sb_mb; in so_recv()
488 pq->len += len; in so_recv()
[all …]
H A Discsi.c299 pduq_t *pq; in iscsi_read() local
332 pq->pdu.ipdu.bhs.opcode, ntohl(pq->pdu.ipdu.bhs.itt),\ in iscsi_read()
442 pduq_t *pq; in i_send() local
453 pp = &pq->pdu; in i_send()
511 pduq_t *pq; in i_recv() local
553 if(pq->mp) { in i_recv()
668 pduq_t *pq; in iscsi_counters() local
673 pq->pdu.ipdu.bhs.opcode, ntohl(pq->pdu.ipdu.bhs.itt),\ in iscsi_counters()
674 (long)pq->ts.sec, pq->ts.frac, pq->flags);\ in iscsi_counters()
679 _puke(h, pq); in iscsi_counters()
[all …]
/dragonfly/crypto/libressl/ssl/
H A Dpqueue.c99 pqueue_free(pqueue_s *pq) in pqueue_free() argument
101 free(pq); in pqueue_free()
109 if (pq->items == NULL) { in pqueue_insert()
110 pq->items = item; in pqueue_insert()
124 pq->items = item; in pqueue_insert()
140 pqueue_peek(pqueue_s *pq) in pqueue_peek() argument
142 return pq->items; in pqueue_peek()
146 pqueue_pop(pqueue_s *pq) in pqueue_pop() argument
150 if (pq->items != NULL) in pqueue_pop()
151 pq->items = pq->items->next; in pqueue_pop()
[all …]
/dragonfly/crypto/libressl/include/
H A Dpqueue.h80 void pqueue_free(pqueue pq);
82 pitem *pqueue_insert(pqueue pq, pitem *item);
83 pitem *pqueue_peek(pqueue pq);
84 pitem *pqueue_pop(pqueue pq);
85 pitem *pqueue_find(pqueue pq, unsigned char *prio64be);
86 pitem *pqueue_iterator(pqueue pq);
89 int pqueue_size(pqueue pq);
/dragonfly/lib/libusb/
H A Dlibusb20_ugen20.c980 pq->vid = q.vid; in ugen20_root_get_dev_quirk()
981 pq->pid = q.pid; in ugen20_root_get_dev_quirk()
984 strlcpy(pq->quirkname, q.quirkname, sizeof(pq->quirkname)); in ugen20_root_get_dev_quirk()
991 struct libusb20_quirk *pq) in ugen20_root_get_quirk_name() argument
1007 strlcpy(pq->quirkname, q.quirkname, sizeof(pq->quirkname)); in ugen20_root_get_quirk_name()
1014 struct libusb20_quirk *pq) in ugen20_root_add_dev_quirk() argument
1021 q.vid = pq->vid; in ugen20_root_add_dev_quirk()
1022 q.pid = pq->pid; in ugen20_root_add_dev_quirk()
1038 struct libusb20_quirk *pq) in ugen20_root_remove_dev_quirk() argument
1045 q.vid = pq->vid; in ugen20_root_remove_dev_quirk()
[all …]
H A Dlibusb20_int.h53 …b20_root_get_dev_quirk_t)(struct libusb20_backend *pbe, uint16_t index, struct libusb20_quirk *pq);
54 …20_root_get_quirk_name_t)(struct libusb20_backend *pbe, uint16_t index, struct libusb20_quirk *pq);
55 typedef int (libusb20_root_add_dev_quirk_t)(struct libusb20_backend *pbe, struct libusb20_quirk *pq…
56 …ef int (libusb20_root_remove_dev_quirk_t)(struct libusb20_backend *pbe, struct libusb20_quirk *pq);
H A Dlibusb20.h276 …libusb20_be_get_dev_quirk(struct libusb20_backend *pbe, uint16_t index, struct libusb20_quirk *pq);
277 …ibusb20_be_get_quirk_name(struct libusb20_backend *pbe, uint16_t index, struct libusb20_quirk *pq);
278 int libusb20_be_add_dev_quirk(struct libusb20_backend *pbe, struct libusb20_quirk *pq);
279 int libusb20_be_remove_dev_quirk(struct libusb20_backend *pbe, struct libusb20_quirk *pq);
H A Dlibusb20.c1124 uint16_t quirk_index, struct libusb20_quirk *pq) in libusb20_be_get_dev_quirk() argument
1126 return (pbe->methods->root_get_dev_quirk(pbe, quirk_index, pq)); in libusb20_be_get_dev_quirk()
1131 uint16_t quirk_index, struct libusb20_quirk *pq) in libusb20_be_get_quirk_name() argument
1133 return (pbe->methods->root_get_quirk_name(pbe, quirk_index, pq)); in libusb20_be_get_quirk_name()
1138 struct libusb20_quirk *pq) in libusb20_be_add_dev_quirk() argument
1140 return (pbe->methods->root_add_dev_quirk(pbe, pq)); in libusb20_be_add_dev_quirk()
1145 struct libusb20_quirk *pq) in libusb20_be_remove_dev_quirk() argument
1147 return (pbe->methods->root_remove_dev_quirk(pbe, pq)); in libusb20_be_remove_dev_quirk()
/dragonfly/sys/bus/u4b/
H A Dusb_transfer.c2047 pq = &info->done_q; in usbd_transfer_pending()
2338 pq->recurse_2 = 0; in usbd_callback_ss_done_defer()
2509 if (pq) { in usbd_transfer_dequeue()
2591 pq = &info->dma_q; in usbd_transfer_done()
2709 xfer = pq->curr; in usbd_pipe_start()
3054 pq->curr = NULL; in usb_command_wrapper()
3062 pq->recurse_1 = 1; in usb_command_wrapper()
3063 pq->recurse_2 = 1; in usb_command_wrapper()
3077 (pq->command) (pq); in usb_command_wrapper()
3083 pq->recurse_1 = 0; in usb_command_wrapper()
[all …]
H A Dusb_transfer.h232 void usb_command_wrapper(struct usb_xfer_queue *pq,
235 void usbd_pipe_start(struct usb_xfer_queue *pq);
238 void usbd_transfer_enqueue(struct usb_xfer_queue *pq,
H A Dusb_busdma.h149 void usb_bdma_work_loop(struct usb_xfer_queue *pq);
H A Dusb_busdma.c864 usb_bdma_work_loop(struct usb_xfer_queue *pq) in usb_bdma_work_loop() argument
870 xfer = pq->curr; in usb_bdma_work_loop()
978 usb_command_wrapper(pq, NULL); in usb_bdma_work_loop()
H A Dusbdi.h126 void (*command) (struct usb_xfer_queue *pq);
/dragonfly/usr.sbin/pfctl/
H A Dpfctl_qstats.c127 struct pfioc_qstats pq; in pfctl_update_qstats() local
133 memset(&pq, 0, sizeof(pq)); in pfctl_update_qstats()
155 pq.nr = nr; in pfctl_update_qstats()
156 pq.ticket = pa.ticket; in pfctl_update_qstats()
157 pq.buf = &qstats.data; in pfctl_update_qstats()
158 pq.nbytes = sizeof(qstats.data); in pfctl_update_qstats()
159 if (ioctl(dev, DIOCGETQSTATS, &pq)) { in pfctl_update_qstats()
/dragonfly/usr.bin/systat/
H A Daltqs.c79 struct pfioc_qstats pq; member
406 struct pfioc_qstats pq; in load_altqs() local
414 bzero(&pq, sizeof(pq)); in load_altqs()
444 q->pq.nr = i; in load_altqs()
445 q->pq.ticket = q->pa.ticket; in load_altqs()
446 q->pq.buf = &q->nstats; in load_altqs()
447 q->pq.nbytes = sizeof(q->nstats); in load_altqs()
448 if (ioctl(pf_fd, DIOCGETQSTATS, &q->pq) < 0) { in load_altqs()
/dragonfly/sys/vm/
H A Dvm_page.c1023 struct vpgqueues *pq; in _vm_page_rem_queue_spinlocked() local
1056 pq->cnt_offset); in _vm_page_rem_queue_spinlocked()
1058 pq->cnt_offset); in _vm_page_rem_queue_spinlocked()
1067 pq->lcnt--; in _vm_page_rem_queue_spinlocked()
1089 struct vpgqueues *pq; in _vm_page_add_queue_spinlocked() local
1099 ++pq->lcnt; in _vm_page_add_queue_spinlocked()
1107 pq->cnt_offset); in _vm_page_add_queue_spinlocked()
1109 pq->cnt_offset); in _vm_page_add_queue_spinlocked()
2010 struct vpgqueues *pq; in _vm_page_list_find() local
2028 pq->lastq = -1; in _vm_page_list_find()
[all …]
H A Dvm_contig.c148 struct vpgqueues *pq = &vm_page_queues[queue]; in vm_contig_pg_clean() local
160 TAILQ_INSERT_HEAD(&pq->pl, &marker, pageq); in vm_contig_pg_clean()
178 TAILQ_REMOVE(&pq->pl, &marker, pageq); in vm_contig_pg_clean()
179 TAILQ_INSERT_AFTER(&pq->pl, m, &marker, pageq); in vm_contig_pg_clean()
235 TAILQ_REMOVE(&pq->pl, &marker, pageq); in vm_contig_pg_clean()
H A Dvm_pageout.c1964 struct vpgqueues *pq = &vm_page_queues[PQ_ACTIVE + q]; in vm_pageout_page_stats() local
2011 pcount = pq->lcnt; in vm_pageout_page_stats()
2026 TAILQ_REMOVE(&pq->pl, marker, pageq); in vm_pageout_page_stats()
2027 TAILQ_INSERT_AFTER(&pq->pl, m, marker, pageq); in vm_pageout_page_stats()
2093 TAILQ_REMOVE(&pq->pl, m, pageq); in vm_pageout_page_stats()
2094 TAILQ_INSERT_TAIL(&pq->pl, m, pageq); in vm_pageout_page_stats()
2121 TAILQ_REMOVE(&pq->pl, m, pageq); in vm_pageout_page_stats()
2122 TAILQ_INSERT_TAIL(&pq->pl, m, pageq); in vm_pageout_page_stats()
2144 TAILQ_REMOVE(&pq->pl, marker, pageq); in vm_pageout_page_stats()
2145 TAILQ_INSERT_HEAD(&pq->pl, marker, pageq); in vm_pageout_page_stats()
/dragonfly/sys/bus/u4b/wlan/
H A Dif_run.c1075 memset(pq, 0, sizeof(*pq)); in run_setup_tx_list()
1077 STAILQ_INIT(&pq->tx_qh); in run_setup_tx_list()
1078 STAILQ_INIT(&pq->tx_fh); in run_setup_tx_list()
1080 for (data = &pq->tx_data[0]; in run_setup_tx_list()
1094 pq->tx_nfree = 0; in run_unsetup_tx_list()
1095 STAILQ_INIT(&pq->tx_fh); in run_unsetup_tx_list()
1096 STAILQ_INIT(&pq->tx_qh); in run_unsetup_tx_list()
1099 for (data = &pq->tx_data[0]; in run_unsetup_tx_list()
3051 pq->tx_nfree++; in run_tx_free()
3076 run_tx_free(pq, data, 0); in run_bulk_tx_callbackN()
[all …]
/dragonfly/contrib/ldns/
H A Dstr2host.c316 uint8_t *q, *pq, label_len; in ldns_str2rdf_dname() local
344 pq = buf; in ldns_str2rdf_dname()
360 *pq = label_len; in ldns_str2rdf_dname()
362 pq = q; in ldns_str2rdf_dname()
391 *pq = label_len; in ldns_str2rdf_dname()
/dragonfly/sys/net/pf/
H A Dpf_ioctl.c2098 struct pfioc_qstats *pq = (struct pfioc_qstats *)addr; in pfioctl() local
2103 if (pq->ticket != ticket_altqs_active) { in pfioctl()
2107 nbytes = pq->nbytes; in pfioctl()
2110 while ((altq != NULL) && (nr < pq->nr)) { in pfioctl()
2118 error = altq_getqstats(altq, pq->buf, &nbytes); in pfioctl()
2120 pq->scheduler = altq->scheduler; in pfioctl()
2121 pq->nbytes = nbytes; in pfioctl()
/dragonfly/sys/dev/raid/mps/
H A Dmps.c1484 u_int pq; in mps_intr_locked() local
1490 pq = sc->replypostindex; in mps_intr_locked()
1607 if (pq != sc->replypostindex) { in mps_intr_locked()

12