Lines Matching refs:sr
48 smb_opipe_alloc(smb_request_t *sr) in smb_opipe_alloc() argument
50 smb_server_t *sv = sr->sr_server; in smb_opipe_alloc()
55 KSOCKET_SLEEP, sr->user_cr) != 0) in smb_opipe_alloc()
111 smb_opipe_cancel(smb_request_t *sr) in smb_opipe_cancel() argument
115 switch (sr->session->s_state) { in smb_opipe_cancel()
118 if ((so = sr->cancel_arg2) != NULL) in smb_opipe_cancel()
119 (void) ksocket_shutdown(so, SHUT_RDWR, sr->user_cr); in smb_opipe_cancel()
128 smb_opipe_connect(smb_request_t *sr, smb_opipe_t *opipe) in smb_opipe_connect() argument
131 smb_arg_open_t *op = &sr->sr_open; in smb_opipe_connect()
149 sizeof (saddr), sr->user_cr); in smb_opipe_connect()
186 smb_opipe_send_userinfo(smb_request_t *sr, smb_opipe_t *opipe, in smb_opipe_send_userinfo() argument
203 smb_user_netinfo_init(sr->uid_user, &nui); in smb_opipe_send_userinfo()
219 mutex_enter(&sr->sr_mutex); in smb_opipe_send_userinfo()
220 if (sr->sr_state != SMB_REQ_STATE_ACTIVE) { in smb_opipe_send_userinfo()
221 mutex_exit(&sr->sr_mutex); in smb_opipe_send_userinfo()
225 sr->sr_state = SMB_REQ_STATE_WAITING_PIPE; in smb_opipe_send_userinfo()
226 sr->cancel_method = smb_opipe_cancel; in smb_opipe_send_userinfo()
227 sr->cancel_arg2 = opipe->p_socket; in smb_opipe_send_userinfo()
228 mutex_exit(&sr->sr_mutex); in smb_opipe_send_userinfo()
231 &iocnt, sr->user_cr); in smb_opipe_send_userinfo()
236 0, &iocnt, sr->user_cr); in smb_opipe_send_userinfo()
243 mutex_enter(&sr->sr_mutex); in smb_opipe_send_userinfo()
245 switch (sr->sr_state) { in smb_opipe_send_userinfo()
248 sr->sr_state = SMB_REQ_STATE_ACTIVE; in smb_opipe_send_userinfo()
252 cv_wait(&sr->sr_st_cv, &sr->sr_mutex); in smb_opipe_send_userinfo()
261 sr->cancel_method = NULL; in smb_opipe_send_userinfo()
262 sr->cancel_arg2 = NULL; in smb_opipe_send_userinfo()
263 mutex_exit(&sr->sr_mutex); in smb_opipe_send_userinfo()
303 smb_opipe_open(smb_request_t *sr, smb_ofile_t *ofile) in smb_opipe_open() argument
305 smb_arg_open_t *op = &sr->sr_open; in smb_opipe_open()
310 opipe = smb_opipe_alloc(sr); in smb_opipe_open()
314 if (smb_opipe_connect(sr, opipe) != 0) { in smb_opipe_open()
319 smb_opipe_send_userinfo(sr, opipe, &err); in smb_opipe_open()
331 if (!smb_tree_is_connected(sr->tid_tree)) { in smb_opipe_open()
341 smb_ofile_open(sr, op, ofile); in smb_opipe_open()
361 sr->smb_fid = ofile->f_fid; in smb_opipe_open()
362 sr->fid_ofile = ofile; in smb_opipe_open()
404 smb_opipe_write(smb_request_t *sr, struct uio *uio) in smb_opipe_write() argument
413 ofile = sr->fid_ofile; in smb_opipe_write()
454 smb_opipe_read(smb_request_t *sr, struct uio *uio) in smb_opipe_read() argument
463 ofile = sr->fid_ofile; in smb_opipe_read()
479 mutex_enter(&sr->sr_mutex); in smb_opipe_read()
480 if (sr->sr_state != SMB_REQ_STATE_ACTIVE) { in smb_opipe_read()
481 mutex_exit(&sr->sr_mutex); in smb_opipe_read()
485 sr->sr_state = SMB_REQ_STATE_WAITING_PIPE; in smb_opipe_read()
486 sr->cancel_method = smb_opipe_cancel; in smb_opipe_read()
487 sr->cancel_arg2 = sock; in smb_opipe_read()
488 mutex_exit(&sr->sr_mutex); in smb_opipe_read()
504 mutex_enter(&sr->sr_mutex); in smb_opipe_read()
506 switch (sr->sr_state) { in smb_opipe_read()
509 sr->sr_state = SMB_REQ_STATE_ACTIVE; in smb_opipe_read()
513 cv_wait(&sr->sr_st_cv, &sr->sr_mutex); in smb_opipe_read()
522 sr->cancel_method = NULL; in smb_opipe_read()
523 sr->cancel_arg2 = NULL; in smb_opipe_read()
524 mutex_exit(&sr->sr_mutex); in smb_opipe_read()
543 smb_opipe_ioctl(smb_request_t *sr, int cmd, void *arg, int *rvalp) in smb_opipe_ioctl() argument
550 ofile = sr->fid_ofile; in smb_opipe_ioctl()
608 smb_opipe_fsctl(smb_request_t *sr, smb_fsctl_t *fsctl) in smb_opipe_fsctl() argument
612 if (!STYPE_ISIPC(sr->tid_tree->t_res_type)) in smb_opipe_fsctl()
617 status = smb_opipe_transceive(sr, fsctl); in smb_opipe_fsctl()
625 status = smb_opipe_wait(sr, fsctl); in smb_opipe_fsctl()
638 smb_opipe_transceive(smb_request_t *sr, smb_fsctl_t *fsctl) in smb_opipe_transceive() argument
651 ofile = sr->fid_ofile; in smb_opipe_transceive()
659 vdb = smb_srm_zalloc(sr, sizeof (*vdb)); in smb_opipe_transceive()
667 rc = smb_opipe_write(sr, &vdb->vdb_uio); in smb_opipe_transceive()
680 rc = smb_opipe_read(sr, &vdb->vdb_uio); in smb_opipe_transceive()
703 rc = smb_opipe_ioctl(sr, FIONREAD, &nread, &trval); in smb_opipe_transceive()
712 smb_opipe_wait(smb_request_t *sr, smb_fsctl_t *fsctl) in smb_opipe_wait() argument
727 sr, /* % */ in smb_opipe_wait()