Searched refs:pq (Results 1 - 25 of 34) sorted by relevance

12

/freebsd-9.3-release/crypto/openssl/crypto/pqueue/
H A Dpq_test.c65 pqueue pq; local
67 pq = pqueue_new();
70 pqueue_insert(pq, item);
73 pqueue_insert(pq, item);
76 pqueue_insert(pq, item);
78 item = pqueue_find(pq, 1);
81 item = pqueue_find(pq, 2);
84 item = pqueue_find(pq, 3);
87 pqueue_print(pq);
89 for (item = pqueue_pop(pq); ite
[all...]
H A Dpqueue.h83 void pqueue_free(pqueue pq);
85 pitem *pqueue_insert(pqueue pq, pitem *item);
86 pitem *pqueue_peek(pqueue pq);
87 pitem *pqueue_pop(pqueue pq);
88 pitem *pqueue_find(pqueue pq, PQ_64BIT priority);
89 pitem *pqueue_iterator(pqueue pq);
92 void pqueue_print(pqueue pq);
93 int pqueue_size(pqueue pq);
H A Dpqueue.c95 pqueue_s *pq = (pqueue_s *)OPENSSL_malloc(sizeof(pqueue_s)); local
96 if (pq == NULL)
99 memset(pq, 0x00, sizeof(pqueue_s));
100 return pq;
103 void pqueue_free(pqueue_s *pq) argument
105 if (pq == NULL)
108 OPENSSL_free(pq);
111 pitem *pqueue_insert(pqueue_s *pq, pitem *item) argument
115 if (pq->items == NULL) {
116 pq
143 pqueue_peek(pqueue_s *pq) argument
148 pqueue_pop(pqueue_s *pq) argument
158 pqueue_find(pqueue_s *pq, PQ_64BIT priority) argument
184 pqueue_print(pqueue_s *pq) argument
195 pqueue_iterator(pqueue_s *pq) argument
214 pqueue_size(pqueue_s *pq) argument
[all...]
/freebsd-9.3-release/lib/libkse/thread/
H A Dthr_priority_queue.c44 static void pq_insert_prio_list(pq_queue_t *pq, int prio);
50 #define PQ_SET_ACTIVE(pq) (pq)->pq_flags |= PQF_ACTIVE
51 #define PQ_CLEAR_ACTIVE(pq) (pq)->pq_flags &= ~PQF_ACTIVE
52 #define PQ_ASSERT_ACTIVE(pq, msg) do { \
53 if (((pq)->pq_flags & PQF_ACTIVE) == 0) \
56 #define PQ_ASSERT_INACTIVE(pq, msg) do { \
57 if (((pq)->pq_flags & PQF_ACTIVE) != 0) \
75 #define PQ_SET_ACTIVE(pq)
86 _pq_alloc(pq_queue_t *pq, int minprio, int maxprio) argument
108 _pq_free(pq_queue_t *pq) argument
115 _pq_init(pq_queue_t *pq) argument
138 _pq_remove(pq_queue_t *pq, pthread_t pthread) argument
167 _pq_insert_head(pq_queue_t *pq, pthread_t pthread) argument
193 _pq_insert_tail(pq_queue_t *pq, pthread_t pthread) argument
219 _pq_first(pq_queue_t *pq) argument
254 _pq_first_debug(pq_queue_t *pq) argument
301 pq_insert_prio_list(pq_queue_t *pq, int prio) argument
[all...]
H A Dthr_private.h1121 void _pq_remove(struct pq_queue *pq, struct pthread *);
1122 void _pq_insert_head(struct pq_queue *pq, struct pthread *);
1123 void _pq_insert_tail(struct pq_queue *pq, struct pthread *);
1124 struct pthread *_pq_first(struct pq_queue *pq);
1125 struct pthread *_pq_first_debug(struct pq_queue *pq);
/freebsd-9.3-release/sys/dev/iscsi/initiator/
H A Discsivar.h229 int isc_sendPDU(isc_session_t *sp, pduq_t *pq);
230 int isc_qout(isc_session_t *sp, pduq_t *pq);
231 int i_prepPDU(isc_session_t *sp, pduq_t *pq);
244 void ism_recv(isc_session_t *sp, pduq_t *pq);
250 int scsi_decap(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
251 void iscsi_r2t(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
252 void iscsi_done(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
253 void iscsi_reject(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
254 void iscsi_async(isc_session_t *sp, pduq_t *pq);
303 pduq_t *pq; local
323 pdu_free(struct isc_softc *isc, pduq_t *pq) argument
340 i_nqueue_rsp(isc_session_t *sp, pduq_t *pq) argument
352 pduq_t *pq; local
365 i_nqueue_rsv(isc_session_t *sp, pduq_t *pq) argument
377 pduq_t *pq; local
390 i_nqueue_csnd(isc_session_t *sp, pduq_t *pq) argument
402 pduq_t *pq; local
415 i_nqueue_isnd(isc_session_t *sp, pduq_t *pq) argument
427 pduq_t *pq; local
440 i_nqueue_wsnd(isc_session_t *sp, pduq_t *pq) argument
452 pduq_t *pq; local
467 pduq_t *pq; local
492 i_rqueue_pdu(isc_session_t *sp, pduq_t *pq) argument
504 i_nqueue_hld(isc_session_t *sp, pduq_t *pq) argument
516 i_remove_hld(isc_session_t *sp, pduq_t *pq) argument
527 pduq_t *pq; local
542 pduq_t *pq, *tmp; local
564 pduq_t *pq, *tmp; local
[all...]
H A Discsi_subr.c63 iscsi_r2t(isc_session_t *sp, pduq_t *opq, pduq_t *pq) argument
69 r2t_t *r2t = &pq->pdu.ipdu.r2t;
148 getSenseData(u_int status, union ccb *ccb, pduq_t *pq) argument
150 pdu_t *pp = &pq->pdu;
153 struct mbuf *m = pq->mp;
159 bp = mtod(pq->mp, caddr_t);
170 i_mbufcopy(pq->mp, bp, sense_len);
197 _scsi_done(isc_session_t *sp, u_int response, u_int status, union ccb *ccb, pduq_t *pq) argument
204 sdebug(3, "response=%x status=%x ccb=%p pq=%p", response, status, ccb, pq);
261 pduq_t *pq; local
286 pduq_t *pq; local
319 pduq_t *pq, *pqtmp; local
349 iscsi_done(isc_session_t *sp, pduq_t *opq, pduq_t *pq) argument
371 iscsi_async(isc_session_t *sp, pduq_t *pq) argument
404 iscsi_reject(isc_session_t *sp, pduq_t *opq, pduq_t *pq) argument
457 pduq_t *pq; local
536 scsi_decap(isc_session_t *sp, pduq_t *opq, pduq_t *pq) argument
[all...]
H A Disc_sm.c69 _async(isc_session_t *sp, pduq_t *pq) argument
73 iscsi_async(sp, pq);
75 pdu_free(sp->isc, pq);
79 _reject(isc_session_t *sp, pduq_t *pq) argument
87 pdu = mtod(pq->mp, pdu_t *);
89 reject = &pq->pdu.ipdu.reject;
93 iscsi_reject(sp, opq, pq);
95 switch(pq->pdu.ipdu.bhs.opcode) {
101 sp->sid, ntohl(pq->pdu.ipdu.bhs.itt));
104 pdu_free(sp->isc, pq);
108 _r2t(isc_session_t *sp, pduq_t *pq) argument
128 _scsi_rsp(isc_session_t *sp, pduq_t *pq) argument
146 _read_data(isc_session_t *sp, pduq_t *pq) argument
170 pduq_t *pq; local
197 _nop_in(isc_session_t *sp, pduq_t *pq) argument
262 i_prepPDU(isc_session_t *sp, pduq_t *pq) argument
305 isc_qout(isc_session_t *sp, pduq_t *pq) argument
358 ism_recv(isc_session_t *sp, pduq_t *pq) argument
427 pduq_t *pq; local
[all...]
H A Discsi.c277 pduq_t *pq; local
299 #define pukeit(i, pq) do {\
301 i, ntohl(pq->pdu.ipdu.bhs.CmdSN),\
302 pq->pdu.ipdu.bhs.opcode, ntohl(pq->pdu.ipdu.bhs.itt),\
303 ntohl(pq->pdu.ipdu.bhs.ExpStSN),\
304 (intmax_t)pq->ts.sec);\
309 TAILQ_FOREACH(pq, &sp->hld, pq_link) {
312 pukeit(i, pq); i++;
318 TAILQ_FOREACH(pq,
411 pduq_t *pq; local
481 pduq_t *pq; local
645 pduq_t *pq; local
[all...]
H A Disc_soc.c74 pduq_t *pq = b; local
76 if(pq->buf != NULL) {
77 debug(3, "ou_refcnt=%d a=%p b=%p", ou_refcnt, a, pq->buf);
78 free(pq->buf, M_ISCSIBUF);
79 pq->buf = NULL;
84 isc_sendPDU(isc_session_t *sp, pduq_t *pq) argument
87 pdu_t *pp = &pq->pdu;
127 if(pp->ds_len && pq->pdu.ds_addr) {
138 debug(4, "setting ext_free(arg=%p len/l=%d/%d)", pq->buf, len, l);
143 pq,
185 isc_sendPDU(isc_session_t *sp, pduq_t *pq) argument
368 so_recv(isc_session_t *sp, pduq_t *pq) argument
555 pduq_t *pq; local
[all...]
/freebsd-9.3-release/contrib/llvm/include/llvm/CodeGen/
H A DLatencyPriorityQueue.h27 explicit latency_sort(LatencyPriorityQueue *pq) : PQ(pq) {} argument
H A DResourcePriorityQueue.h33 explicit resource_sort(ResourcePriorityQueue *pq) : PQ(pq) {} argument
/freebsd-9.3-release/contrib/ntp/sntp/libopts/
H A Dcook.c34 contiguous_quote(char ** pps, char * pq, int * lnct_p);
145 contiguous_quote(char ** pps, char * pq, int * lnct_p) argument
161 *pq = *(ps++); /* assign new quote character and return */
/freebsd-9.3-release/sys/dev/usb/
H A Dusb_transfer.h118 void usb_command_wrapper(struct usb_xfer_queue *pq,
121 void usbd_pipe_start(struct usb_xfer_queue *pq);
124 void usbd_transfer_enqueue(struct usb_xfer_queue *pq,
H A Dusb_transfer.c1867 struct usb_xfer_queue *pq; local
1886 pq = &info->done_q;
1888 if (pq->curr == xfer) {
2151 struct usb_xfer_queue *pq = &info->done_q; local
2155 if (pq->curr != xfer) {
2156 usbd_transfer_enqueue(pq, xfer);
2158 if (!pq->recurse_1) {
2171 pq->recurse_2 = 0;
2186 usbd_callback_wrapper(struct usb_xfer_queue *pq) argument
2188 struct usb_xfer *xfer = pq
2338 struct usb_xfer_queue *pq; local
2356 usbd_transfer_enqueue(struct usb_xfer_queue *pq, struct usb_xfer *xfer) argument
2414 struct usb_xfer_queue *pq; local
2532 usbd_pipe_start(struct usb_xfer_queue *pq) argument
2881 usb_command_wrapper(struct usb_xfer_queue *pq, struct usb_xfer *xfer) argument
[all...]
H A Dusb_busdma.h151 void usb_bdma_work_loop(struct usb_xfer_queue *pq);
/freebsd-9.3-release/contrib/ntp/include/
H A Dlibssl_compat.h52 const BIGNUM **pq);
61 const BIGNUM **pq, const BIGNUM **pg);
/freebsd-9.3-release/contrib/ntp/libntp/
H A Dlibssl_compat.c164 const BIGNUM ** pq
171 if (pq)
172 *pq = prsa->q;
255 const BIGNUM ** pq,
263 if (pq != NULL)
264 *pq = pdsa->q;
252 sslshim_DSA_get0_pqg( const DSA * pdsa, const BIGNUM ** pp, const BIGNUM ** pq, const BIGNUM ** pg ) argument
/freebsd-9.3-release/lib/libusb/
H A Dlibusb20_ugen20.c946 uint16_t quirk_index, struct libusb20_quirk *pq)
962 pq->vid = q.vid;
963 pq->pid = q.pid;
964 pq->bcdDeviceLow = q.bcdDeviceLow;
965 pq->bcdDeviceHigh = q.bcdDeviceHigh;
966 strlcpy(pq->quirkname, q.quirkname, sizeof(pq->quirkname));
973 struct libusb20_quirk *pq)
989 strlcpy(pq->quirkname, q.quirkname, sizeof(pq
945 ugen20_root_get_dev_quirk(struct libusb20_backend *pbe, uint16_t quirk_index, struct libusb20_quirk *pq) argument
972 ugen20_root_get_quirk_name(struct libusb20_backend *pbe, uint16_t quirk_index, struct libusb20_quirk *pq) argument
995 ugen20_root_add_dev_quirk(struct libusb20_backend *pbe, struct libusb20_quirk *pq) argument
1019 ugen20_root_remove_dev_quirk(struct libusb20_backend *pbe, struct libusb20_quirk *pq) argument
[all...]
H A Dlibusb20.h279 int libusb20_be_get_dev_quirk(struct libusb20_backend *pbe, uint16_t index, struct libusb20_quirk *pq);
280 int libusb20_be_get_quirk_name(struct libusb20_backend *pbe, uint16_t index, struct libusb20_quirk *pq);
281 int libusb20_be_add_dev_quirk(struct libusb20_backend *pbe, struct libusb20_quirk *pq);
282 int libusb20_be_remove_dev_quirk(struct libusb20_backend *pbe, struct libusb20_quirk *pq);
H A Dlibusb20_int.h53 typedef int (libusb20_root_get_dev_quirk_t)(struct libusb20_backend *pbe, uint16_t index, struct libusb20_quirk *pq);
54 typedef int (libusb20_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 typedef int (libusb20_root_remove_dev_quirk_t)(struct libusb20_backend *pbe, struct libusb20_quirk *pq);
H A Dlibusb20.c1113 uint16_t quirk_index, struct libusb20_quirk *pq)
1115 return (pbe->methods->root_get_dev_quirk(pbe, quirk_index, pq));
1120 uint16_t quirk_index, struct libusb20_quirk *pq)
1122 return (pbe->methods->root_get_quirk_name(pbe, quirk_index, pq));
1127 struct libusb20_quirk *pq)
1129 return (pbe->methods->root_add_dev_quirk(pbe, pq));
1134 struct libusb20_quirk *pq)
1136 return (pbe->methods->root_remove_dev_quirk(pbe, pq));
1112 libusb20_be_get_dev_quirk(struct libusb20_backend *pbe, uint16_t quirk_index, struct libusb20_quirk *pq) argument
1119 libusb20_be_get_quirk_name(struct libusb20_backend *pbe, uint16_t quirk_index, struct libusb20_quirk *pq) argument
1126 libusb20_be_add_dev_quirk(struct libusb20_backend *pbe, struct libusb20_quirk *pq) argument
1133 libusb20_be_remove_dev_quirk(struct libusb20_backend *pbe, struct libusb20_quirk *pq) argument
/freebsd-9.3-release/contrib/pf/pfctl/
H A Dpfctl_qstats.c137 struct pfioc_qstats pq; local
143 memset(&pq, 0, sizeof(pq));
170 pq.nr = nr;
171 pq.ticket = pa.ticket;
172 pq.buf = &qstats.data;
173 pq.nbytes = sizeof(qstats.data);
174 if (ioctl(dev, DIOCGETQSTATS, &pq)) {
/freebsd-9.3-release/contrib/sendmail/src/
H A Drecipient.c391 ADDRESS **pq; local
404 for (pq = sendq; (q = *pq) != NULL; pq = &q->q_next)
460 ADDRESS **pq; local
717 for (pq = sendq; (q = *pq) != NULL; pq = &q->q_next)
780 prev = pq;
783 /* pq shoul
[all...]
/freebsd-9.3-release/crypto/heimdal/lib/krb5/
H A Dcontext.c373 * `pq' isn't free, it's up the the caller
377 krb5_prepend_config_files(const char *filelist, char **pq, char ***ret_pp) argument
408 if (pq != NULL) {
411 for (i = 0; pq[i] != NULL; i++) {
412 fn = strdup(pq[i]);

Completed in 146 milliseconds

12