Searched refs:rqp (Results 1 - 18 of 18) sorted by relevance

/freebsd-12-stable/contrib/smbfs/lib/smb/
H A Dnbns_rq.c55 static void nbns_rq_done(struct nbns_rq *rqp);
56 static int nbns_rq_getrr(struct nbns_rq *rqp, struct nbns_rr *rrp);
57 static int nbns_rq_prepare(struct nbns_rq *rqp);
58 static int nbns_rq(struct nbns_rq *rqp);
65 struct nbns_rq *rqp; local
73 error = nbns_rq_create(NBNS_OPCODE_QUERY, ctx, &rqp);
80 rqp->nr_nmflags = NBNS_NMFLAG_RD;
81 rqp->nr_qdname = &nn;
82 rqp->nr_qdtype = NBNS_QUESTION_TYPE_NB;
83 rqp
147 struct nbns_rq *rqp; local
168 nbns_rq_done(struct nbns_rq *rqp) argument
184 nbns_rq_getrr(struct nbns_rq *rqp, struct nbns_rr *rrp) argument
209 nbns_rq_prepare(struct nbns_rq *rqp) argument
255 nbns_rq_recv(struct nbns_rq *rqp) argument
291 nbns_rq_opensocket(struct nbns_rq *rqp) argument
317 nbns_rq_send(struct nbns_rq *rqp) argument
329 nbns_rq(struct nbns_rq *rqp) argument
[all...]
H A Dprint.c59 struct smb_rq *rqp; local
63 error = smb_rq_init(ctx, SMB_COM_OPEN_PRINT_FILE, 2, &rqp);
66 mbp = smb_rq_getrequest(rqp);
69 smb_rq_wend(rqp);
72 error = smb_rq_simple(rqp);
74 mbp = smb_rq_getreply(rqp);
77 smb_rq_done(rqp);
84 struct smb_rq *rqp; local
88 error = smb_rq_init(ctx, SMB_COM_CLOSE_PRINT_FILE, 0, &rqp);
91 mbp = smb_rq_getrequest(rqp);
[all...]
H A Drq.c57 struct smb_rq *rqp; local
59 rqp = malloc(sizeof(*rqp));
60 if (rqp == NULL)
62 bzero(rqp, sizeof(*rqp));
63 rqp->rq_cmd = cmd;
64 rqp->rq_ctx = ctx;
65 mb_init(&rqp->rq_rq, M_MINSIZE);
66 mb_init(&rqp
72 smb_rq_done(struct smb_rq *rqp) argument
80 smb_rq_wend(struct smb_rq *rqp) argument
127 smb_rq_simple(struct smb_rq *rqp) argument
[all...]
/freebsd-12-stable/sys/netsmb/
H A Dsmb_iod.c72 smb_iod_rqprocessed(struct smb_rq *rqp, int error) argument
74 SMBRQ_SLOCK(rqp);
75 rqp->sr_lerror = error;
76 rqp->sr_rpgen++;
77 rqp->sr_state = SMBRQ_NOTIFIED;
78 wakeup(&rqp->sr_state);
79 SMBRQ_SUNLOCK(rqp);
85 struct smb_rq *rqp; local
91 TAILQ_FOREACH(rqp, &iod->iod_rqlist, sr_link) {
92 rqp
215 smb_iod_sendrq(struct smbiod *iod, struct smb_rq *rqp) argument
289 struct smb_rq *rqp; local
403 smb_iod_addrq(struct smb_rq *rqp) argument
465 smb_iod_removerq(struct smb_rq *rqp) argument
493 smb_iod_waitrq(struct smb_rq *rqp) argument
536 struct smb_rq *rqp; local
[all...]
H A Dsmb_rq.c55 static int smb_rq_reply(struct smb_rq *rqp);
56 static int smb_rq_enqueue(struct smb_rq *rqp);
59 static int smb_rq_new(struct smb_rq *rqp, u_char cmd);
66 struct smb_rq *rqp; local
69 rqp = malloc(sizeof(*rqp), M_SMBRQ, M_WAITOK);
70 if (rqp == NULL)
72 error = smb_rq_init(rqp, layer, cmd, scred);
73 rqp->sr_flags |= SMBR_ALLOCED;
75 smb_rq_done(rqp);
85 smb_rq_init(struct smb_rq *rqp, struct smb_connobj *layer, u_char cmd, struct smb_cred *scred) argument
109 smb_rq_new(struct smb_rq *rqp, u_char cmd) argument
148 smb_rq_done(struct smb_rq *rqp) argument
161 smb_rq_simple(struct smb_rq *rqp) argument
183 smb_rq_enqueue(struct smb_rq *rqp) argument
217 smb_rq_wstart(struct smb_rq *rqp) argument
224 smb_rq_wend(struct smb_rq *rqp) argument
236 smb_rq_bstart(struct smb_rq *rqp) argument
243 smb_rq_bend(struct smb_rq *rqp) argument
258 smb_rq_intr(struct smb_rq *rqp) argument
266 smb_rq_getrequest(struct smb_rq *rqp, struct mbchain **mbpp) argument
273 smb_rq_getreply(struct smb_rq *rqp, struct mdchain **mbpp) argument
324 smb_rq_reply(struct smb_rq *rqp) argument
446 struct smb_rq *rqp = t2p->t2_rq; local
558 struct smb_rq *rqp; local
[all...]
H A Dsmb_rq.h55 #define SMBRQ_SLOCK(rqp) smb_sl_lock(&(rqp)->sr_slock)
56 #define SMBRQ_SUNLOCK(rqp) smb_sl_unlock(&(rqp)->sr_slock)
57 #define SMBRQ_SLOCKPTR(rqp) (&(rqp)->sr_slock)
132 int smb_rq_init(struct smb_rq *rqp, struct smb_connobj *layer, u_char cmd,
134 void smb_rq_done(struct smb_rq *rqp);
135 int smb_rq_getrequest(struct smb_rq *rqp, struct mbchain **mbpp);
136 int smb_rq_getreply(struct smb_rq *rqp, struc
[all...]
H A Dsmb_smb.c118 struct smb_rq *rqp; local
140 error = smb_rq_alloc(VCTOCP(vcp), SMB_COM_NEGOTIATE, scred, &rqp);
143 smb_rq_getrequest(rqp, &mbp);
144 smb_rq_wstart(rqp);
145 smb_rq_wend(rqp);
146 smb_rq_bstart(rqp);
151 smb_rq_bend(rqp);
152 error = smb_rq_simple(rqp);
156 smb_rq_getreply(rqp, &mdp);
289 smb_rq_done(rqp);
296 struct smb_rq *rqp; local
443 struct smb_rq *rqp; local
502 struct smb_rq rq, *rqp = &rq; local
604 struct smb_rq *rqp; local
629 struct smb_rq *rqp; local
710 struct smb_rq *rqp; local
767 struct smb_rq *rqp; local
846 struct smb_rq *rqp; local
933 struct smb_rq *rqp; local
[all...]
H A Dsmb_crypt.c205 smb_rq_sign(struct smb_rq *rqp) argument
207 struct smb_vc *vcp = rqp->sr_vc;
228 if (rqp->sr_t2 == NULL ||
229 (rqp->sr_t2->t2_flags & SMBT2_SECONDARY) == 0) {
230 rqp->sr_seqno = vcp->vc_seqno++;
231 rqp->sr_rseqno = vcp->vc_seqno++;
239 KASSERT(rqp->sr_t2 == NULL ||
240 (rqp->sr_t2->t2_flags & SMBT2_SECONDARY) == 0 ||
241 rqp->sr_t2->t2_rq == rqp,
268 smb_rq_verify(struct smb_rq *rqp) argument
[all...]
H A Dsmb_subr.h121 int smb_put_string(struct smb_rq *rqp, const char *src);
122 int smb_put_asunistring(struct smb_rq *rqp, const char *src);
123 int smb_rq_sign(struct smb_rq *rqp);
124 int smb_rq_verify(struct smb_rq *rqp);
H A Dsmb_usr.c217 struct smb_rq *rqp; local
236 rqp = malloc(sizeof(struct smb_rq), M_SMBTEMP, M_WAITOK);
237 error = smb_rq_init(rqp, SSTOCP(ssp), dp->ioc_cmd, scred);
239 free(rqp, M_SMBTEMP);
242 mbp = &rqp->sr_rq;
243 smb_rq_wstart(rqp);
247 smb_rq_wend(rqp);
248 smb_rq_bstart(rqp);
252 smb_rq_bend(rqp);
253 error = smb_rq_simple(rqp);
[all...]
H A Dsmb_subr.c364 smb_put_asunistring(struct smb_rq *rqp, const char *src) argument
366 struct mbchain *mbp = &rqp->sr_rq;
367 struct iconv_drv *dp = rqp->sr_vc->vc_toserver;
H A Dsmb_conn.h465 int smb_iod_addrq(struct smb_rq *rqp);
466 int smb_iod_waitrq(struct smb_rq *rqp);
467 int smb_iod_removerq(struct smb_rq *rqp);
/freebsd-12-stable/sys/net/altq/
H A Daltq_rio.c494 rio_queue_t *rqp; local
497 while ((rqp = rio_list) != NULL) {
499 err = rio_detach(rqp);
519 rio_queue_t *rqp; local
546 if ((rqp = altq_lookup(ifacep->rio_ifname, ALTQT_RIO)) == NULL) {
550 error = altq_enable(rqp->rq_ifq);
555 if ((rqp = altq_lookup(ifacep->rio_ifname, ALTQT_RIO)) == NULL) {
559 error = altq_disable(rqp->rq_ifq);
570 rqp = malloc(sizeof(rio_queue_t), M_DEVBUF, M_WAITOK);
571 if (rqp
767 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc; local
793 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc; local
818 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc; local
[all...]
H A Daltq_red.c740 red_queue_t *rqp; local
743 while ((rqp = red_list) != NULL) {
745 err = red_detach(rqp);
765 red_queue_t *rqp; local
790 if ((rqp = altq_lookup(ifacep->red_ifname, ALTQT_RED)) == NULL) {
794 error = altq_enable(rqp->rq_ifq);
799 if ((rqp = altq_lookup(ifacep->red_ifname, ALTQT_RED)) == NULL) {
803 error = altq_disable(rqp->rq_ifq);
814 rqp = malloc(sizeof(red_queue_t), M_DEVBUF, M_WAITOK);
815 if (rqp
1027 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc; local
1050 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc; local
1071 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc; local
[all...]
/freebsd-12-stable/sys/fs/smbfs/
H A Dsmbfs_smb.c92 struct smb_rq *rqp; local
100 error = smb_rq_alloc(SSTOCP(ssp), SMB_COM_LOCKING_ANDX, scred, &rqp);
103 smb_rq_getrequest(rqp, &mbp);
104 smb_rq_wstart(rqp);
114 smb_rq_wend(rqp);
115 smb_rq_bstart(rqp);
119 smb_rq_bend(rqp);
120 error = smb_rq_simple(rqp);
121 smb_rq_done(rqp);
226 struct smb_rq *rqp; local
306 struct smb_rq *rqp; local
341 struct smb_rq *rqp; local
373 struct smb_rq *rqp; local
430 struct smb_rq *rqp; local
587 struct smb_rq *rqp; local
676 struct smb_rq *rqp; local
729 struct smb_rq *rqp; local
757 struct smb_rq *rqp; local
802 struct smb_rq *rqp; local
829 struct smb_rq *rqp; local
862 struct smb_rq *rqp; local
897 struct smb_rq *rqp; local
923 struct smb_rq *rqp; local
950 struct smb_rq *rqp; local
1046 struct smb_rq *rqp; local
1206 struct smb_rq *rqp; local
[all...]
/freebsd-12-stable/contrib/smbfs/include/netsmb/
H A Dsmb_lib.h200 #define smb_rq_getrequest(rqp) (&(rqp)->rq_rq)
201 #define smb_rq_getreply(rqp) (&(rqp)->rq_rp)
/freebsd-12-stable/sys/dev/usb/wlan/
H A Dif_zyd.c691 struct zyd_rq *rqp; local
699 STAILQ_FOREACH(rqp, &sc->sc_rqh, rq) {
703 if (rqp->olen != datalen)
705 count = rqp->olen / sizeof(struct zyd_pair);
707 if (*(((const uint16_t *)rqp->idata) + i) !=
714 memcpy(rqp->odata, cmd->data, rqp->olen);
717 rqp, rqp->olen, (char *)rqp
757 struct zyd_rq *rqp, *cmd; local
[all...]
/freebsd-12-stable/sys/dev/mlx4/mlx4_core/
H A Dmlx4_resource_tracker.c3962 struct res_qp *rqp, u8 *gid)
3966 list_for_each_entry(res, &rqp->mcg_list, list) {
3973 static int add_mcg_res(struct mlx4_dev *dev, int slave, struct res_qp *rqp, argument
3984 spin_lock_irq(&rqp->mcg_spl);
3985 if (find_gid(dev, slave, rqp, gid)) {
3993 list_add_tail(&res->list, &rqp->mcg_list);
3996 spin_unlock_irq(&rqp->mcg_spl);
4001 static int rem_mcg_res(struct mlx4_dev *dev, int slave, struct res_qp *rqp, argument
4008 spin_lock_irq(&rqp->mcg_spl);
4009 res = find_gid(dev, slave, rqp, gi
3961 find_gid(struct mlx4_dev *dev, int slave, struct res_qp *rqp, u8 *gid) argument
4094 struct res_qp *rqp; local
4252 struct res_qp *rqp; local
4338 struct res_qp *rqp; local
4471 struct res_qp *rqp; local
4544 detach_qp(struct mlx4_dev *dev, int slave, struct res_qp *rqp) argument
[all...]

Completed in 211 milliseconds