Home
last modified time | relevance | path

Searched refs:rqp (Results 1 – 16 of 16) sorted by relevance

/freebsd/contrib/smbfs/lib/smb/
H A Dnbns_rq.c140 nbns_rq_done(rqp); in nbns_resolvename()
151 rqp = malloc(sizeof(*rqp)); in nbns_rq_create()
152 if (rqp == NULL) in nbns_rq_create()
154 bzero(rqp, sizeof(*rqp)); in nbns_rq_create()
157 free(rqp); in nbns_rq_create()
163 *rqpp = rqp; in nbns_rq_create()
170 if (rqp == NULL) in nbns_rq_done()
176 free(rqp); in nbns_rq_done()
309 rqp->nr_dest.sin_addr.s_addr = rqp->nr_if->id_addr.s_addr | ~rqp->nr_if->id_mask.s_addr; in nbns_rq_opensocket()
323 (struct sockaddr*)&rqp->nr_dest, sizeof(rqp->nr_dest)) < 0) in nbns_rq_send()
[all …]
H A Drq.c57 struct smb_rq *rqp; in smb_rq_init() local
59 rqp = malloc(sizeof(*rqp)); in smb_rq_init()
60 if (rqp == NULL) in smb_rq_init()
62 bzero(rqp, sizeof(*rqp)); in smb_rq_init()
63 rqp->rq_cmd = cmd; in smb_rq_init()
64 rqp->rq_ctx = ctx; in smb_rq_init()
67 *rqpp = rqp; in smb_rq_init()
74 mb_done(&rqp->rq_rp); in smb_rq_done()
75 mb_done(&rqp->rq_rq); in smb_rq_done()
76 free(rqp); in smb_rq_done()
[all …]
H A Dprint.c59 struct smb_rq *rqp; in smb_smb_open_print_file() local
66 mbp = smb_rq_getrequest(rqp); in smb_smb_open_print_file()
69 smb_rq_wend(rqp); in smb_smb_open_print_file()
72 error = smb_rq_simple(rqp); in smb_smb_open_print_file()
74 mbp = smb_rq_getreply(rqp); in smb_smb_open_print_file()
77 smb_rq_done(rqp); in smb_smb_open_print_file()
84 struct smb_rq *rqp; in smb_smb_close_print_file() local
91 mbp = smb_rq_getrequest(rqp); in smb_smb_close_print_file()
93 smb_rq_wend(rqp); in smb_smb_close_print_file()
94 error = smb_rq_simple(rqp); in smb_smb_close_print_file()
[all …]
/freebsd/sys/netsmb/
H A Dsmb_rq.c66 rqp = malloc(sizeof(*rqp), M_SMBRQ, M_WAITOK); in smb_rq_alloc()
67 if (rqp == NULL) in smb_rq_alloc()
75 *rqpp = rqp; in smb_rq_alloc()
87 bzero(rqp, sizeof(*rqp)); in smb_rq_init()
89 error = smb_rq_getenv(layer, &rqp->sr_vc, &rqp->sr_share); in smb_rq_init()
101 rqp->sr_mid = smb_vc_nextmid(rqp->sr_vc); in smb_rq_init()
216 rqp->sr_wcount = mb_reserve(&rqp->sr_rq, sizeof(u_int8_t)); in smb_rq_wstart()
229 *rqp->sr_wcount = rqp->sr_rq.mb_count / 2; in smb_rq_wend()
235 rqp->sr_bcount = mb_reserve(&rqp->sr_rq, sizeof(u_short)); in smb_rq_bstart()
361 rqp->sr_rpmid, rqp->sr_rppid, rqp->sr_rpuid, rqp->sr_rptid, in smb_rq_reply()
[all …]
H A Dsmb_iod.c69 SMBRQ_SLOCK(rqp); in smb_iod_rqprocessed()
71 rqp->sr_rpgen++; in smb_iod_rqprocessed()
74 SMBRQ_SUNLOCK(rqp); in smb_iod_rqprocessed()
80 struct smb_rq *rqp; in smb_iod_invrq() local
244 smb_iod_rqprocessed(rqp, rqp->sr_lerror); in smb_iod_sendrq()
498 if (rqp->sr_rpgen != rqp->sr_rplast) in smb_iod_waitrq()
505 SMBRQ_SLOCK(rqp); in smb_iod_waitrq()
506 if (rqp->sr_rpgen == rqp->sr_rplast) in smb_iod_waitrq()
507 msleep(&rqp->sr_state, SMBRQ_SLOCKPTR(rqp), PWAIT, "90wrq", 0); in smb_iod_waitrq()
508 rqp->sr_rplast++; in smb_iod_waitrq()
[all …]
H A Dsmb_smb.c115 struct smb_rq *rqp; in smb_smb_negotiate() local
142 smb_rq_wend(rqp); in smb_smb_negotiate()
148 smb_rq_bend(rqp); in smb_smb_negotiate()
286 smb_rq_done(rqp); in smb_smb_negotiate()
415 smb_rq_bend(rqp); in smb_smb_ssnsetup()
423 if (rqp->sr_errclass == ERRDOS && rqp->sr_serror == ERRnoaccess) in smb_smb_ssnsetup()
431 smb_rq_done(rqp); in smb_smb_ssnsetup()
458 smb_rq_wend(rqp); in smb_smb_ssnclose()
460 smb_rq_bend(rqp); in smb_smb_ssnclose()
463 smb_rq_done(rqp); in smb_smb_ssnclose()
[all …]
H A Dsmb_rq.h53 #define SMBRQ_SLOCK(rqp) smb_sl_lock(&(rqp)->sr_slock) argument
54 #define SMBRQ_SUNLOCK(rqp) smb_sl_unlock(&(rqp)->sr_slock) argument
55 #define SMBRQ_SLOCKPTR(rqp) (&(rqp)->sr_slock) argument
131 void smb_rq_done(struct smb_rq *rqp);
133 int smb_rq_getreply(struct smb_rq *rqp, struct mdchain **mbpp);
134 void smb_rq_wstart(struct smb_rq *rqp);
135 void smb_rq_wend(struct smb_rq *rqp);
136 void smb_rq_bstart(struct smb_rq *rqp);
137 void smb_rq_bend(struct smb_rq *rqp);
138 int smb_rq_intr(struct smb_rq *rqp);
[all …]
H A Dsmb_crypt.c200 smb_rq_sign(struct smb_rq *rqp) in smb_rq_sign() argument
202 struct smb_vc *vcp = rqp->sr_vc; in smb_rq_sign()
223 if (rqp->sr_t2 == NULL || in smb_rq_sign()
234 KASSERT(rqp->sr_t2 == NULL || in smb_rq_sign()
236 rqp->sr_t2->t2_rq == rqp, in smb_rq_sign()
241 le32enc(rqp->sr_rqsig, rqp->sr_seqno); in smb_rq_sign()
242 le32enc(rqp->sr_rqsig + 4, 0); in smb_rq_sign()
248 smb_rq_getrequest(rqp, &mbp); in smb_rq_sign()
254 bcopy(digest, rqp->sr_rqsig, 8); in smb_rq_sign()
263 smb_rq_verify(struct smb_rq *rqp) in smb_rq_verify() argument
[all …]
H A Dsmb_usr.c214 struct smb_rq *rqp; in smb_usr_simplerequest() local
236 free(rqp, M_SMBTEMP); in smb_usr_simplerequest()
239 mbp = &rqp->sr_rq; in smb_usr_simplerequest()
240 smb_rq_wstart(rqp); in smb_usr_simplerequest()
244 smb_rq_wend(rqp); in smb_usr_simplerequest()
245 smb_rq_bstart(rqp); in smb_usr_simplerequest()
249 smb_rq_bend(rqp); in smb_usr_simplerequest()
250 error = smb_rq_simple(rqp); in smb_usr_simplerequest()
253 mdp = &rqp->sr_rp; in smb_usr_simplerequest()
275 smb_rq_done(rqp); in smb_usr_simplerequest()
[all …]
H A Dsmb_subr.h118 int smb_put_string(struct smb_rq *rqp, const char *src);
119 int smb_put_asunistring(struct smb_rq *rqp, const char *src);
120 int smb_rq_sign(struct smb_rq *rqp);
121 int smb_rq_verify(struct smb_rq *rqp);
H A Dsmb_subr.c361 smb_put_asunistring(struct smb_rq *rqp, const char *src) in smb_put_asunistring() argument
363 struct mbchain *mbp = &rqp->sr_rq; in smb_put_asunistring()
364 struct iconv_drv *dp = rqp->sr_vc->vc_toserver; in smb_put_asunistring()
H A Dsmb_conn.h461 int smb_iod_addrq(struct smb_rq *rqp);
462 int smb_iod_waitrq(struct smb_rq *rqp);
463 int smb_iod_removerq(struct smb_rq *rqp);
/freebsd/sys/fs/smbfs/
H A Dsmbfs_smb.c112 smb_rq_wend(rqp); in smbfs_smb_lockandx()
117 smb_rq_bend(rqp); in smbfs_smb_lockandx()
119 smb_rq_done(rqp); in smbfs_smb_lockandx()
229 scred, &rqp); in smbfs_query_info_disk()
233 smb_rq_wend(rqp); in smbfs_query_info_disk()
235 smb_rq_bend(rqp); in smbfs_query_info_disk()
380 &rqp); in smbfs_smb_query_info()
434 &rqp); in smbfs_smb_setpattr()
591 &rqp); in smbfs_smb_setftime()
898 &rqp); in smbfs_smb_mkdir()
[all …]
/freebsd/contrib/smbfs/include/netsmb/
H A Dsmb_lib.h200 #define smb_rq_getrequest(rqp) (&(rqp)->rq_rq) argument
201 #define smb_rq_getreply(rqp) (&(rqp)->rq_rp) argument
/freebsd/sys/dev/usb/wlan/
H A Dif_zyd.c687 struct zyd_rq *rqp; in zyd_intr_read_callback() local
699 if (rqp->olen != datalen) in zyd_intr_read_callback()
710 memcpy(rqp->odata, cmd->data, rqp->olen); in zyd_intr_read_callback()
713 rqp, rqp->olen, (char *)rqp->odata, ":"); in zyd_intr_read_callback()
714 wakeup(rqp); /* wakeup caller */ in zyd_intr_read_callback()
717 if (rqp == NULL) { in zyd_intr_read_callback()
753 struct zyd_rq *rqp, *cmd; in zyd_intr_write_callback() local
762 if (rqp == cmd && in zyd_intr_write_callback()
775 usbd_copy_in(pc, 0, rqp->cmd, rqp->ilen); in zyd_intr_write_callback()
778 usbd_xfer_set_priv(xfer, rqp); in zyd_intr_write_callback()
[all …]
/freebsd/sys/dev/mlx4/mlx4_core/
H A Dmlx4_resource_tracker.c3962 struct res_qp *rqp, u8 *gid) in find_gid() argument
3984 spin_lock_irq(&rqp->mcg_spl); in add_mcg_res()
3996 spin_unlock_irq(&rqp->mcg_spl); in add_mcg_res()
4008 spin_lock_irq(&rqp->mcg_spl); in rem_mcg_res()
4094 struct res_qp *rqp; in mlx4_QP_ATTACH_wrapper() local
4252 struct res_qp *rqp; in mlx4_UPDATE_QP_wrapper() local
4338 struct res_qp *rqp; in mlx4_QP_FLOW_STEERING_ATTACH_wrapper() local
4434 atomic_inc(&rqp->ref_count); in mlx4_QP_FLOW_STEERING_ATTACH_wrapper()
4471 struct res_qp *rqp; in mlx4_QP_FLOW_STEERING_DETACH_wrapper() local
4518 atomic_dec(&rqp->ref_count); in mlx4_QP_FLOW_STEERING_DETACH_wrapper()
[all …]