Home
last modified time | relevance | path

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

12

/NextBSD/sys/dev/iscsi_initiator/
HDiscsivar.h228 int isc_sendPDU(isc_session_t *sp, pduq_t *pq);
229 int isc_qout(isc_session_t *sp, pduq_t *pq);
230 int i_prepPDU(isc_session_t *sp, pduq_t *pq);
243 void ism_recv(isc_session_t *sp, pduq_t *pq);
249 int scsi_decap(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
250 void iscsi_r2t(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
251 void iscsi_done(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
252 void iscsi_reject(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
253 void iscsi_async(isc_session_t *sp, pduq_t *pq);
302 pduq_t *pq; in pdu_alloc() local
[all …]
HDiscsi_subr.c63 iscsi_r2t(isc_session_t *sp, pduq_t *opq, pduq_t *pq) in iscsi_r2t() argument
69 r2t_t *r2t = &pq->pdu.ipdu.r2t; in iscsi_r2t()
148 getSenseData(u_int status, union ccb *ccb, pduq_t *pq) in getSenseData() argument
150 pdu_t *pp = &pq->pdu; in getSenseData()
153 struct mbuf *m = pq->mp; in getSenseData()
159 bp = mtod(pq->mp, caddr_t); in getSenseData()
170 i_mbufcopy(pq->mp, bp, sense_len); in getSenseData()
197 _scsi_done(isc_session_t *sp, u_int response, u_int status, union ccb *ccb, pduq_t *pq) in _scsi_done() argument
204 sdebug(3, "response=%x status=%x ccb=%p pq=%p", response, status, ccb, pq); in _scsi_done()
205 if(pq != NULL) in _scsi_done()
[all …]
HDisc_sm.c70 _async(isc_session_t *sp, pduq_t *pq) in _async() argument
74 iscsi_async(sp, pq); in _async()
76 pdu_free(sp->isc, pq); in _async()
80 _reject(isc_session_t *sp, pduq_t *pq) in _reject() argument
88 pdu = mtod(pq->mp, pdu_t *); in _reject()
90 reject = &pq->pdu.ipdu.reject; in _reject()
94 iscsi_reject(sp, opq, pq); in _reject()
96 switch(pq->pdu.ipdu.bhs.opcode) { in _reject()
102 sp->sid, ntohl(pq->pdu.ipdu.bhs.itt)); in _reject()
105 pdu_free(sp->isc, pq); in _reject()
[all …]
HDiscsi.c277 pduq_t *pq; in iscsi_read() local
299 #define pukeit(i, pq) do {\ in iscsi_read() argument
301 i, ntohl(pq->pdu.ipdu.bhs.CmdSN),\ in iscsi_read()
302 pq->pdu.ipdu.bhs.opcode, ntohl(pq->pdu.ipdu.bhs.itt),\ in iscsi_read()
303 ntohl(pq->pdu.ipdu.bhs.ExpStSN),\ in iscsi_read()
304 (intmax_t)pq->ts.sec);\ in iscsi_read()
309 TAILQ_FOREACH(pq, &sp->hld, pq_link) { in iscsi_read()
312 pukeit(i, pq); i++; in iscsi_read()
318 TAILQ_FOREACH(pq, &sp->rsp, pq_link) { in iscsi_read()
321 pukeit(i, pq); i++; in iscsi_read()
[all …]
HDisc_soc.c74 pduq_t *pq = b; in ext_free() local
76 if(pq->buf != NULL) { in ext_free()
77 debug(3, "ou_refcnt=%d a=%p b=%p", ou_refcnt, a, pq->buf); in ext_free()
78 free(pq->buf, M_ISCSIBUF); in ext_free()
79 pq->buf = NULL; in ext_free()
84 isc_sendPDU(isc_session_t *sp, pduq_t *pq) in isc_sendPDU() argument
87 pdu_t *pp = &pq->pdu; in isc_sendPDU()
127 if(pp->ds_len && pq->pdu.ds_addr) { in isc_sendPDU()
138 debug(4, "setting ext_free(arg=%p len/l=%d/%d)", pq->buf, len, l); in isc_sendPDU()
143 pq, 0, EXT_EXTREF); in isc_sendPDU()
[all …]
/NextBSD/crypto/openssl/crypto/pqueue/
HDpqueue.c93 pqueue_s *pq = (pqueue_s *)OPENSSL_malloc(sizeof(pqueue_s)); in pqueue_new() local
94 if (pq == NULL) in pqueue_new()
97 memset(pq, 0x00, sizeof(pqueue_s)); in pqueue_new()
98 return pq; in pqueue_new()
101 void pqueue_free(pqueue_s *pq) in pqueue_free() argument
103 if (pq == NULL) in pqueue_free()
106 OPENSSL_free(pq); in pqueue_free()
109 pitem *pqueue_insert(pqueue_s *pq, pitem *item) in pqueue_insert() argument
113 if (pq->items == NULL) { in pqueue_insert()
114 pq->items = item; in pqueue_insert()
[all …]
HDpq_test.c65 pqueue pq; in main() local
67 pq = pqueue_new(); in main()
70 pqueue_insert(pq, item); in main()
73 pqueue_insert(pq, item); in main()
76 pqueue_insert(pq, item); in main()
78 item = pqueue_find(pq, 1); in main()
81 item = pqueue_find(pq, 2); in main()
84 item = pqueue_find(pq, 3); in main()
87 pqueue_print(pq); in main()
89 for (item = pqueue_pop(pq); item != NULL; item = pqueue_pop(pq)) in main()
[all …]
HDpqueue.h84 void pqueue_free(pqueue pq);
86 pitem *pqueue_insert(pqueue pq, pitem *item);
87 pitem *pqueue_peek(pqueue pq);
88 pitem *pqueue_pop(pqueue pq);
89 pitem *pqueue_find(pqueue pq, unsigned char *prio64be);
90 pitem *pqueue_iterator(pqueue pq);
93 void pqueue_print(pqueue pq);
94 int pqueue_size(pqueue pq);
/NextBSD/sys/vm/
HDvm_page.h244 #define vm_pagequeue_assert_locked(pq) mtx_assert(&(pq)->pq_mutex, MA_OWNED) argument
245 #define vm_pagequeue_lock(pq) mtx_lock(&(pq)->pq_mutex) argument
246 #define vm_pagequeue_trylock(pq) mtx_trylock(&(pq)->pq_mutex) argument
247 #define vm_pagequeue_unlock(pq) mtx_unlock(&(pq)->pq_mutex) argument
251 vm_pagequeue_cnt_add(struct vm_pagequeue *pq, int addend) in vm_pagequeue_cnt_add() argument
255 vm_pagequeue_assert_locked(pq); in vm_pagequeue_cnt_add()
257 pq->pq_cnt += addend; in vm_pagequeue_cnt_add()
258 atomic_add_int(pq->pq_vcnt, addend); in vm_pagequeue_cnt_add()
260 #define vm_pagequeue_cnt_inc(pq) vm_pagequeue_cnt_add((pq), 1) argument
261 #define vm_pagequeue_cnt_dec(pq) vm_pagequeue_cnt_add((pq), -1) argument
HDvm_pageout.c285 struct vm_pagequeue *pq; in vm_pageout_fallback_object_lock() local
293 pq = vm_page_pagequeue(m); in vm_pageout_fallback_object_lock()
296 TAILQ_INSERT_AFTER(&pq->pq_pl, m, &marker, plinks.q); in vm_pageout_fallback_object_lock()
297 vm_pagequeue_unlock(pq); in vm_pageout_fallback_object_lock()
301 vm_pagequeue_lock(pq); in vm_pageout_fallback_object_lock()
318 TAILQ_REMOVE(&pq->pq_pl, &marker, plinks.q); in vm_pageout_fallback_object_lock()
335 struct vm_pagequeue *pq; in vm_pageout_page_lock() local
346 pq = vm_page_pagequeue(m); in vm_pageout_page_lock()
348 TAILQ_INSERT_AFTER(&pq->pq_pl, m, &marker, plinks.q); in vm_pageout_page_lock()
349 vm_pagequeue_unlock(pq); in vm_pageout_page_lock()
[all …]
HDvm_page.c480 struct vm_pagequeue *pq; in vm_page_domain_init() local
497 pq = &vmd->vmd_pagequeues[i]; in vm_page_domain_init()
498 TAILQ_INIT(&pq->pq_pl); in vm_page_domain_init()
499 mtx_init(&pq->pq_mutex, pq->pq_name, "vm pagequeue", in vm_page_domain_init()
502 pq->pq_cnt = 0; in vm_page_domain_init()
2773 struct vm_pagequeue *pq; in vm_page_dequeue() local
2778 pq = vm_page_pagequeue_deferred(m); in vm_page_dequeue()
2780 TAILQ_REMOVE(&pq->pq_pl, m, plinks.q); in vm_page_dequeue()
2781 vm_pagequeue_cnt_dec(pq); in vm_page_dequeue()
2785 vm_pagequeue_lock(pq); in vm_page_dequeue()
[all …]
/NextBSD/lib/libusb/
HDlibusb20_ugen20.c964 uint16_t quirk_index, struct libusb20_quirk *pq) in ugen20_root_get_dev_quirk() argument
980 pq->vid = q.vid; in ugen20_root_get_dev_quirk()
981 pq->pid = q.pid; in ugen20_root_get_dev_quirk()
982 pq->bcdDeviceLow = q.bcdDeviceLow; in ugen20_root_get_dev_quirk()
983 pq->bcdDeviceHigh = q.bcdDeviceHigh; 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()
[all …]
HDlibusb20_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);
HDlibusb20.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);
HDlibusb20.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()
/NextBSD/sys/dev/usb/
HDusb_transfer.c2001 struct usb_xfer_queue *pq; in usbd_transfer_pending() local
2020 pq = &info->done_q; in usbd_transfer_pending()
2022 if (pq->curr == xfer) { in usbd_transfer_pending()
2285 struct usb_xfer_queue *pq = &info->done_q; in usbd_callback_ss_done_defer() local
2289 if (pq->curr != xfer) { in usbd_callback_ss_done_defer()
2290 usbd_transfer_enqueue(pq, xfer); in usbd_callback_ss_done_defer()
2292 if (!pq->recurse_1) { in usbd_callback_ss_done_defer()
2303 pq->recurse_2 = 0; in usbd_callback_ss_done_defer()
2318 usbd_callback_wrapper(struct usb_xfer_queue *pq) in usbd_callback_wrapper() argument
2320 struct usb_xfer *xfer = pq->curr; in usbd_callback_wrapper()
[all …]
HDusb_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,
/NextBSD/sbin/pfctl/
HDpfctl_qstats.c143 struct pfioc_qstats pq; local
149 memset(&pq, 0, sizeof(pq));
176 pq.nr = nr;
177 pq.ticket = pa.ticket;
178 pq.buf = &qstats.data;
179 pq.nbytes = sizeof(qstats.data);
180 if (ioctl(dev, DIOCGETQSTATS, &pq)) {
/NextBSD/contrib/ntp/sntp/libopts/
HDcook.c34 contiguous_quote(char ** pps, char * pq, int * lnct_p);
145 contiguous_quote(char ** pps, char * pq, int * lnct_p) in contiguous_quote() argument
161 *pq = *(ps++); /* assign new quote character and return */ in contiguous_quote()
/NextBSD/contrib/llvm/include/llvm/CodeGen/
HDLatencyPriorityQueue.h27 explicit latency_sort(LatencyPriorityQueue *pq) : PQ(pq) {} in latency_sort()
HDResourcePriorityQueue.h33 explicit resource_sort(ResourcePriorityQueue *pq) : PQ(pq) {} in resource_sort()
/NextBSD/contrib/apr-util/dbd/
HDapr_dbd.c378 char *p, *pq; in apr_dbd_prepare() local
400 pq = apr_palloc(pool, qlen); in apr_dbd_prepare()
403 for (p = pq, q = query, i = 0; *q; q++) { in apr_dbd_prepare()
466 p += apr_snprintf(p, qlen - (p - pq), driver->pformat, ++i); in apr_dbd_prepare()
478 return driver->prepare(pool,handle,pq,label,nargs,nvals,t,statement); in apr_dbd_prepare()
/NextBSD/sys/boot/usb/
HDusb_busdma_loader.c414 usb_bdma_work_loop(struct usb_xfer_queue *pq) in usb_bdma_work_loop() argument
420 xfer = pq->curr; in usb_bdma_work_loop()
528 usb_command_wrapper(pq, NULL); in usb_bdma_work_loop()
/NextBSD/sbin/sysctl/
HDsysctl.c503 char line[BUFSIZ], *p, *pq, *pdq; in parsefile() local
512 pq = strchr(line, '\''); in parsefile()
516 if (pq != NULL && p > pq) { in parsefile()
517 if ((p = strchr(pq+1, '\'')) != NULL) in parsefile()
/NextBSD/sys/dev/usb/wlan/
HDif_run.c397 static void run_tx_free(struct run_endpoint_queue *pq,
1067 run_setup_tx_list(struct run_softc *sc, struct run_endpoint_queue *pq) in run_setup_tx_list() argument
1071 memset(pq, 0, sizeof(*pq)); in run_setup_tx_list()
1073 STAILQ_INIT(&pq->tx_qh); in run_setup_tx_list()
1074 STAILQ_INIT(&pq->tx_fh); in run_setup_tx_list()
1076 for (data = &pq->tx_data[0]; in run_setup_tx_list()
1077 data < &pq->tx_data[RUN_TX_RING_COUNT]; data++) { in run_setup_tx_list()
1079 STAILQ_INSERT_TAIL(&pq->tx_fh, data, next); in run_setup_tx_list()
1081 pq->tx_nfree = RUN_TX_RING_COUNT; in run_setup_tx_list()
1085 run_unsetup_tx_list(struct run_softc *sc, struct run_endpoint_queue *pq) in run_unsetup_tx_list() argument
[all …]

12