/freebsd-12-stable/contrib/smbfs/lib/smb/ |
H A D | nbns_rq.c | 55 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 D | print.c | 59 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 D | rq.c | 57 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 D | smb_iod.c | 72 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 D | smb_rq.c | 55 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 D | smb_rq.h | 55 #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 D | smb_smb.c | 118 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 D | smb_crypt.c | 205 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 D | smb_subr.h | 121 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 D | smb_usr.c | 217 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 D | smb_subr.c | 364 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 D | smb_conn.h | 465 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 D | altq_rio.c | 494 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 D | altq_red.c | 740 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 D | smbfs_smb.c | 92 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 D | smb_lib.h | 200 #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 D | if_zyd.c | 691 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 D | mlx4_resource_tracker.c | 3962 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...] |