13db3f65cSamw /* 23db3f65cSamw * CDDL HEADER START 33db3f65cSamw * 43db3f65cSamw * The contents of this file are subject to the terms of the 53db3f65cSamw * Common Development and Distribution License (the "License"). 63db3f65cSamw * You may not use this file except in compliance with the License. 73db3f65cSamw * 83db3f65cSamw * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 93db3f65cSamw * or http://www.opensolaris.org/os/licensing. 103db3f65cSamw * See the License for the specific language governing permissions 113db3f65cSamw * and limitations under the License. 123db3f65cSamw * 133db3f65cSamw * When distributing Covered Code, include this CDDL HEADER in each 143db3f65cSamw * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 153db3f65cSamw * If applicable, add the following below this CDDL HEADER, with the 163db3f65cSamw * fields enclosed by brackets "[]" replaced with your own identifying 173db3f65cSamw * information: Portions Copyright [yyyy] [name of copyright owner] 183db3f65cSamw * 193db3f65cSamw * CDDL HEADER END 203db3f65cSamw */ 213db3f65cSamw /* 22148c5f43SAlan Wright * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved. 2368b2bbf2SGordon Ross * Copyright 2015 Nexenta Systems, Inc. All rights reserved. 243db3f65cSamw */ 253db3f65cSamw 263db3f65cSamw /* 273db3f65cSamw * This module provides the interface to NDR RPC. 283db3f65cSamw */ 293db3f65cSamw 303db3f65cSamw #include <sys/stat.h> 313db3f65cSamw #include <sys/uio.h> 323db3f65cSamw #include <sys/ksynch.h> 3368b2bbf2SGordon Ross #include <sys/stropts.h> 3468b2bbf2SGordon Ross #include <sys/socket.h> 3568b2bbf2SGordon Ross #include <sys/filio.h> 36bbf6f00cSJordan Brown #include <smbsrv/smb_kproto.h> 373db3f65cSamw #include <smbsrv/smb_xdr.h> 383db3f65cSamw 3968b2bbf2SGordon Ross /* 4068b2bbf2SGordon Ross * Allocate a new opipe and return it, or NULL, in which case 4168b2bbf2SGordon Ross * the caller will report "internal error". 4268b2bbf2SGordon Ross */ 4368b2bbf2SGordon Ross static smb_opipe_t * 4468b2bbf2SGordon Ross smb_opipe_alloc(smb_request_t *sr) 459fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 4668b2bbf2SGordon Ross smb_server_t *sv = sr->sr_server; 479fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_opipe_t *opipe; 4868b2bbf2SGordon Ross ksocket_t sock; 4968b2bbf2SGordon Ross 5068b2bbf2SGordon Ross if (ksocket_socket(&sock, AF_UNIX, SOCK_STREAM, 0, 5168b2bbf2SGordon Ross KSOCKET_SLEEP, sr->user_cr) != 0) 5268b2bbf2SGordon Ross return (NULL); 539fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 548622ec45SGordon Ross opipe = kmem_cache_alloc(smb_cache_opipe, KM_SLEEP); 559fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 569fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States bzero(opipe, sizeof (smb_opipe_t)); 579fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_init(&opipe->p_mutex, NULL, MUTEX_DEFAULT, NULL); 589fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cv_init(&opipe->p_cv, NULL, CV_DEFAULT, NULL); 599fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States opipe->p_magic = SMB_OPIPE_MAGIC; 609fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States opipe->p_server = sv; 6168b2bbf2SGordon Ross opipe->p_refcnt = 1; 6268b2bbf2SGordon Ross opipe->p_socket = sock; 639fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 649fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States return (opipe); 659fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 669fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 6768b2bbf2SGordon Ross /* 6868b2bbf2SGordon Ross * Destroy an opipe. This is normally called from smb_ofile_delete 6968b2bbf2SGordon Ross * when the ofile has no more references and is about to be free'd. 7068b2bbf2SGordon Ross * This is also called here in error handling code paths, before 7168b2bbf2SGordon Ross * the opipe is installed under an ofile. 7268b2bbf2SGordon Ross */ 739fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States void 749fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_opipe_dealloc(smb_opipe_t *opipe) 759fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States { 769fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States smb_server_t *sv; 779fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 789fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_OPIPE_VALID(opipe); 799fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States sv = opipe->p_server; 809fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_SERVER_VALID(sv); 819fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 8268b2bbf2SGordon Ross /* 8368b2bbf2SGordon Ross * This is called in the error path when opening, 8468b2bbf2SGordon Ross * in which case we close the socket here. 8568b2bbf2SGordon Ross */ 8668b2bbf2SGordon Ross if (opipe->p_socket != NULL) 8768b2bbf2SGordon Ross (void) ksocket_close(opipe->p_socket, zone_kcred()); 889fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 899fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States opipe->p_magic = (uint32_t)~SMB_OPIPE_MAGIC; 909fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States cv_destroy(&opipe->p_cv); 919fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States mutex_destroy(&opipe->p_mutex); 929fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 938622ec45SGordon Ross kmem_cache_free(smb_cache_opipe, opipe); 949fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States } 959fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 963db3f65cSamw /* 9768b2bbf2SGordon Ross * Helper for open: build pipe name and connect. 9868b2bbf2SGordon Ross */ 9968b2bbf2SGordon Ross static int 10068b2bbf2SGordon Ross smb_opipe_connect(smb_request_t *sr, smb_opipe_t *opipe) 10168b2bbf2SGordon Ross { 10268b2bbf2SGordon Ross struct sockaddr_un saddr; 10368b2bbf2SGordon Ross smb_arg_open_t *op = &sr->sr_open; 10468b2bbf2SGordon Ross const char *name; 10568b2bbf2SGordon Ross int rc; 10668b2bbf2SGordon Ross 10768b2bbf2SGordon Ross name = op->fqi.fq_path.pn_path; 10868b2bbf2SGordon Ross name += strspn(name, "\\"); 10968b2bbf2SGordon Ross if (smb_strcasecmp(name, "PIPE", 4) == 0) { 11068b2bbf2SGordon Ross name += 4; 11168b2bbf2SGordon Ross name += strspn(name, "\\"); 11268b2bbf2SGordon Ross } 11368b2bbf2SGordon Ross (void) strlcpy(opipe->p_name, name, SMB_OPIPE_MAXNAME); 11468b2bbf2SGordon Ross (void) smb_strlwr(opipe->p_name); 11568b2bbf2SGordon Ross 11668b2bbf2SGordon Ross bzero(&saddr, sizeof (saddr)); 11768b2bbf2SGordon Ross saddr.sun_family = AF_UNIX; 11868b2bbf2SGordon Ross (void) snprintf(saddr.sun_path, sizeof (saddr.sun_path), 11968b2bbf2SGordon Ross "%s/%s", SMB_PIPE_DIR, opipe->p_name); 12068b2bbf2SGordon Ross rc = ksocket_connect(opipe->p_socket, (struct sockaddr *)&saddr, 12168b2bbf2SGordon Ross sizeof (saddr), sr->user_cr); 12268b2bbf2SGordon Ross 12368b2bbf2SGordon Ross return (rc); 12468b2bbf2SGordon Ross } 12568b2bbf2SGordon Ross 12668b2bbf2SGordon Ross /* 12768b2bbf2SGordon Ross * Helper for open: encode and send the user info. 12868b2bbf2SGordon Ross * 12968b2bbf2SGordon Ross * We send information about this client + user to the 13068b2bbf2SGordon Ross * pipe service so it can use it for access checks. 13168b2bbf2SGordon Ross * The service MAY deny the open based on this info, 13268b2bbf2SGordon Ross * (i.e. anonymous session trying to open a pipe that 13368b2bbf2SGordon Ross * requires authentication) in which case we will read 13468b2bbf2SGordon Ross * an error status from the service and return that. 13568b2bbf2SGordon Ross */ 13668b2bbf2SGordon Ross static void 13768b2bbf2SGordon Ross smb_opipe_send_userinfo(smb_request_t *sr, smb_opipe_t *opipe, 13868b2bbf2SGordon Ross smb_error_t *errp) 13968b2bbf2SGordon Ross { 14068b2bbf2SGordon Ross XDR xdrs; 14168b2bbf2SGordon Ross smb_netuserinfo_t nui; 14268b2bbf2SGordon Ross smb_pipehdr_t phdr; 14368b2bbf2SGordon Ross char *buf; 14468b2bbf2SGordon Ross uint32_t buflen; 14568b2bbf2SGordon Ross uint32_t status; 14668b2bbf2SGordon Ross size_t iocnt = 0; 14768b2bbf2SGordon Ross int rc; 14868b2bbf2SGordon Ross 14968b2bbf2SGordon Ross /* 15068b2bbf2SGordon Ross * Any errors building the XDR message etc. 15168b2bbf2SGordon Ross */ 15268b2bbf2SGordon Ross errp->status = NT_STATUS_INTERNAL_ERROR; 15368b2bbf2SGordon Ross 15468b2bbf2SGordon Ross smb_user_netinfo_init(sr->uid_user, &nui); 15568b2bbf2SGordon Ross phdr.ph_magic = SMB_PIPE_HDR_MAGIC; 15668b2bbf2SGordon Ross phdr.ph_uilen = xdr_sizeof(smb_netuserinfo_xdr, &nui); 15768b2bbf2SGordon Ross 15868b2bbf2SGordon Ross buflen = sizeof (phdr) + phdr.ph_uilen; 15968b2bbf2SGordon Ross buf = kmem_alloc(buflen, KM_SLEEP); 16068b2bbf2SGordon Ross 16168b2bbf2SGordon Ross bcopy(&phdr, buf, sizeof (phdr)); 16268b2bbf2SGordon Ross xdrmem_create(&xdrs, buf + sizeof (phdr), 16368b2bbf2SGordon Ross buflen - (sizeof (phdr)), XDR_ENCODE); 16468b2bbf2SGordon Ross if (!smb_netuserinfo_xdr(&xdrs, &nui)) 16568b2bbf2SGordon Ross goto out; 16668b2bbf2SGordon Ross 16768b2bbf2SGordon Ross /* 16868b2bbf2SGordon Ross * If we fail sending the netuserinfo or recv'ing the 16968b2bbf2SGordon Ross * status reponse, we have probably run into the limit 17068b2bbf2SGordon Ross * on the number of open pipes. That's this status: 17168b2bbf2SGordon Ross */ 17268b2bbf2SGordon Ross errp->status = NT_STATUS_PIPE_NOT_AVAILABLE; 17368b2bbf2SGordon Ross 17468b2bbf2SGordon Ross rc = ksocket_send(opipe->p_socket, buf, buflen, 0, 17568b2bbf2SGordon Ross &iocnt, sr->user_cr); 17668b2bbf2SGordon Ross if (rc == 0 && iocnt != buflen) 17768b2bbf2SGordon Ross rc = EIO; 17868b2bbf2SGordon Ross if (rc != 0) 17968b2bbf2SGordon Ross goto out; 18068b2bbf2SGordon Ross 18168b2bbf2SGordon Ross rc = ksocket_recv(opipe->p_socket, &status, sizeof (status), 0, 18268b2bbf2SGordon Ross &iocnt, sr->user_cr); 18368b2bbf2SGordon Ross if (rc != 0 || iocnt != sizeof (status)) 18468b2bbf2SGordon Ross goto out; 18568b2bbf2SGordon Ross 18668b2bbf2SGordon Ross /* 18768b2bbf2SGordon Ross * Return the status we read from the pipe service, 18868b2bbf2SGordon Ross * normally NT_STATUS_SUCCESS, but could be something 18968b2bbf2SGordon Ross * else like NT_STATUS_ACCESS_DENIED. 19068b2bbf2SGordon Ross */ 19168b2bbf2SGordon Ross errp->status = status; 19268b2bbf2SGordon Ross 19368b2bbf2SGordon Ross out: 19468b2bbf2SGordon Ross xdr_destroy(&xdrs); 19568b2bbf2SGordon Ross kmem_free(buf, buflen); 19668b2bbf2SGordon Ross smb_user_netinfo_fini(&nui); 19768b2bbf2SGordon Ross } 19868b2bbf2SGordon Ross 19968b2bbf2SGordon Ross /* 2003db3f65cSamw * smb_opipe_open 2013db3f65cSamw * 20268b2bbf2SGordon Ross * Open an RPC named pipe. This routine should be called if 2033db3f65cSamw * a file open is requested on a share of type STYPE_IPC. 2043db3f65cSamw * If we recognize the pipe, we setup a new ofile. 2053db3f65cSamw * 20668b2bbf2SGordon Ross * Returns 0 on success, Otherwise an NT status code. 2073db3f65cSamw */ 2083db3f65cSamw int 20968b2bbf2SGordon Ross smb_opipe_open(smb_request_t *sr, uint32_t uniqid) 2103db3f65cSamw { 211148c5f43SAlan Wright smb_arg_open_t *op = &sr->sr_open; 21268b2bbf2SGordon Ross smb_ofile_t *ofile; 2133db3f65cSamw smb_opipe_t *opipe; 2143db3f65cSamw smb_error_t err; 2153db3f65cSamw 21668b2bbf2SGordon Ross opipe = smb_opipe_alloc(sr); 21768b2bbf2SGordon Ross if (opipe == NULL) 21868b2bbf2SGordon Ross return (NT_STATUS_INTERNAL_ERROR); 2193db3f65cSamw 22068b2bbf2SGordon Ross if (smb_opipe_connect(sr, opipe) != 0) { 22168b2bbf2SGordon Ross smb_opipe_dealloc(opipe); 2228b2cc8acSafshin salek ardakani - Sun Microsystems - Irvine United States return (NT_STATUS_OBJECT_NAME_NOT_FOUND); 2238b2cc8acSafshin salek ardakani - Sun Microsystems - Irvine United States } 2248b2cc8acSafshin salek ardakani - Sun Microsystems - Irvine United States 22568b2bbf2SGordon Ross smb_opipe_send_userinfo(sr, opipe, &err); 22668b2bbf2SGordon Ross if (err.status != 0) { 22768b2bbf2SGordon Ross smb_opipe_dealloc(opipe); 22868b2bbf2SGordon Ross return (err.status); 22968b2bbf2SGordon Ross } 23068b2bbf2SGordon Ross 23168b2bbf2SGordon Ross /* 23268b2bbf2SGordon Ross * Note: If smb_ofile_open succeeds, the new ofile is 23368b2bbf2SGordon Ross * in the FID lists can can be used by I/O requests. 23468b2bbf2SGordon Ross */ 23568b2bbf2SGordon Ross op->create_options = 0; 23668b2bbf2SGordon Ross op->pipe = opipe; 23768b2bbf2SGordon Ross ofile = smb_ofile_open(sr, NULL, op, 23868b2bbf2SGordon Ross SMB_FTYPE_MESG_PIPE, uniqid, &err); 23968b2bbf2SGordon Ross op->pipe = NULL; 24068b2bbf2SGordon Ross if (ofile == NULL) { 24168b2bbf2SGordon Ross smb_opipe_dealloc(opipe); 24268b2bbf2SGordon Ross return (err.status); 24368b2bbf2SGordon Ross } 24468b2bbf2SGordon Ross 24568b2bbf2SGordon Ross /* An "up" pointer, for debug. */ 24668b2bbf2SGordon Ross opipe->p_ofile = ofile; 24768b2bbf2SGordon Ross 2483db3f65cSamw op->dsize = 0x01000; 2493db3f65cSamw op->dattr = FILE_ATTRIBUTE_NORMAL; 2503db3f65cSamw op->ftype = SMB_FTYPE_MESG_PIPE; 2513db3f65cSamw op->action_taken = SMB_OACT_LOCK | SMB_OACT_OPENED; /* 0x8001 */ 2523db3f65cSamw op->devstate = SMB_PIPE_READMODE_MESSAGE 2533db3f65cSamw | SMB_PIPE_TYPE_MESSAGE 2543db3f65cSamw | SMB_PIPE_UNLIMITED_INSTANCES; /* 0x05ff */ 25568b2bbf2SGordon Ross op->fileid = ofile->f_fid; 2563db3f65cSamw 25768b2bbf2SGordon Ross sr->smb_fid = ofile->f_fid; 25868b2bbf2SGordon Ross sr->fid_ofile = ofile; 2593db3f65cSamw 2603db3f65cSamw return (NT_STATUS_SUCCESS); 2613db3f65cSamw } 2623db3f65cSamw 2633db3f65cSamw /* 2643db3f65cSamw * smb_opipe_close 2653db3f65cSamw * 26668b2bbf2SGordon Ross * Called by smb_ofile_close for pipes. 26768b2bbf2SGordon Ross * 26868b2bbf2SGordon Ross * Note: ksocket_close may block while waiting for 26968b2bbf2SGordon Ross * any I/O threads with a hold to get out. 2703db3f65cSamw */ 2713db3f65cSamw void 2723db3f65cSamw smb_opipe_close(smb_ofile_t *of) 2733db3f65cSamw { 2743db3f65cSamw smb_opipe_t *opipe; 27568b2bbf2SGordon Ross ksocket_t sock; 2763db3f65cSamw 27768b2bbf2SGordon Ross ASSERT(of->f_state == SMB_OFILE_STATE_CLOSING); 2783db3f65cSamw ASSERT(of->f_ftype == SMB_FTYPE_MESG_PIPE); 2793db3f65cSamw opipe = of->f_pipe; 2809fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_OPIPE_VALID(opipe); 2819fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 28268b2bbf2SGordon Ross mutex_enter(&opipe->p_mutex); 28368b2bbf2SGordon Ross sock = opipe->p_socket; 28468b2bbf2SGordon Ross opipe->p_socket = NULL; 28568b2bbf2SGordon Ross mutex_exit(&opipe->p_mutex); 2863db3f65cSamw 28768b2bbf2SGordon Ross (void) ksocket_shutdown(sock, SHUT_RDWR, of->f_cr); 28868b2bbf2SGordon Ross (void) ksocket_close(sock, of->f_cr); 2893db3f65cSamw } 2903db3f65cSamw 2913db3f65cSamw /* 2923db3f65cSamw * smb_opipe_write 2933db3f65cSamw * 2943db3f65cSamw * Write RPC request data to the pipe. The client should call smb_opipe_read 2953db3f65cSamw * to complete the exchange and obtain the RPC response. 2963db3f65cSamw * 2973db3f65cSamw * Returns 0 on success or an errno on failure. 2983db3f65cSamw */ 2993db3f65cSamw int 3003db3f65cSamw smb_opipe_write(smb_request_t *sr, struct uio *uio) 3013db3f65cSamw { 30268b2bbf2SGordon Ross struct nmsghdr msghdr; 30368b2bbf2SGordon Ross smb_ofile_t *ofile; 3043db3f65cSamw smb_opipe_t *opipe; 30568b2bbf2SGordon Ross ksocket_t sock; 30668b2bbf2SGordon Ross size_t sent = 0; 30768b2bbf2SGordon Ross int rc = 0; 3083db3f65cSamw 30968b2bbf2SGordon Ross ofile = sr->fid_ofile; 31068b2bbf2SGordon Ross ASSERT(ofile->f_ftype == SMB_FTYPE_MESG_PIPE); 31168b2bbf2SGordon Ross opipe = ofile->f_pipe; 3129fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_OPIPE_VALID(opipe); 3133db3f65cSamw 31468b2bbf2SGordon Ross mutex_enter(&opipe->p_mutex); 31568b2bbf2SGordon Ross sock = opipe->p_socket; 31668b2bbf2SGordon Ross if (sock != NULL) 31768b2bbf2SGordon Ross ksocket_hold(sock); 31868b2bbf2SGordon Ross mutex_exit(&opipe->p_mutex); 31968b2bbf2SGordon Ross if (sock == NULL) 3203db3f65cSamw return (EBADF); 32168b2bbf2SGordon Ross 32268b2bbf2SGordon Ross bzero(&msghdr, sizeof (msghdr)); 32368b2bbf2SGordon Ross msghdr.msg_iov = uio->uio_iov; 32468b2bbf2SGordon Ross msghdr.msg_iovlen = uio->uio_iovcnt; 32568b2bbf2SGordon Ross 32668b2bbf2SGordon Ross /* 32768b2bbf2SGordon Ross * This should block until we've sent it all, 32868b2bbf2SGordon Ross * or given up due to errors (pipe closed). 32968b2bbf2SGordon Ross */ 33068b2bbf2SGordon Ross while (uio->uio_resid > 0) { 33168b2bbf2SGordon Ross rc = ksocket_sendmsg(sock, &msghdr, 0, &sent, ofile->f_cr); 33268b2bbf2SGordon Ross if (rc != 0) 33368b2bbf2SGordon Ross break; 33468b2bbf2SGordon Ross uio->uio_resid -= sent; 3353db3f65cSamw } 3363db3f65cSamw 33768b2bbf2SGordon Ross ksocket_rele(sock); 3383db3f65cSamw 33968b2bbf2SGordon Ross return (rc); 3403db3f65cSamw } 3413db3f65cSamw 3423db3f65cSamw /* 3433db3f65cSamw * smb_opipe_read 3443db3f65cSamw * 34568b2bbf2SGordon Ross * This interface may be called from smb_opipe_transact (write, read) 34668b2bbf2SGordon Ross * or from smb_read / smb2_read to get the rest of an RPC response. 34768b2bbf2SGordon Ross * The response data (and length) are returned via the uio. 3483db3f65cSamw */ 3493db3f65cSamw int 3503db3f65cSamw smb_opipe_read(smb_request_t *sr, struct uio *uio) 3513db3f65cSamw { 35268b2bbf2SGordon Ross struct nmsghdr msghdr; 35368b2bbf2SGordon Ross smb_ofile_t *ofile; 3543db3f65cSamw smb_opipe_t *opipe; 35568b2bbf2SGordon Ross ksocket_t sock; 35668b2bbf2SGordon Ross size_t recvcnt = 0; 3573db3f65cSamw int rc; 3583db3f65cSamw 35968b2bbf2SGordon Ross ofile = sr->fid_ofile; 36068b2bbf2SGordon Ross ASSERT(ofile->f_ftype == SMB_FTYPE_MESG_PIPE); 36168b2bbf2SGordon Ross opipe = ofile->f_pipe; 3629fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States SMB_OPIPE_VALID(opipe); 3639fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 36468b2bbf2SGordon Ross mutex_enter(&opipe->p_mutex); 36568b2bbf2SGordon Ross sock = opipe->p_socket; 36668b2bbf2SGordon Ross if (sock != NULL) 36768b2bbf2SGordon Ross ksocket_hold(sock); 36868b2bbf2SGordon Ross mutex_exit(&opipe->p_mutex); 36968b2bbf2SGordon Ross if (sock == NULL) 3703db3f65cSamw return (EBADF); 3713db3f65cSamw 37268b2bbf2SGordon Ross bzero(&msghdr, sizeof (msghdr)); 37368b2bbf2SGordon Ross msghdr.msg_iov = uio->uio_iov; 37468b2bbf2SGordon Ross msghdr.msg_iovlen = uio->uio_iovcnt; 3759fb67ea3Safshin salek ardakani - Sun Microsystems - Irvine United States 3763db3f65cSamw /* 37768b2bbf2SGordon Ross * This should block only if there's no data. 37868b2bbf2SGordon Ross * A single call to recvmsg does just that. 37968b2bbf2SGordon Ross * (Intentionaly no recv loop here.) 3803db3f65cSamw */ 38168b2bbf2SGordon Ross rc = ksocket_recvmsg(sock, &msghdr, 0, 38268b2bbf2SGordon Ross &recvcnt, ofile->f_cr); 38368b2bbf2SGordon Ross if (rc != 0) 38468b2bbf2SGordon Ross goto out; 3853db3f65cSamw 38668b2bbf2SGordon Ross if (recvcnt == 0) { 38768b2bbf2SGordon Ross /* Other side closed. */ 38868b2bbf2SGordon Ross rc = EPIPE; 38968b2bbf2SGordon Ross goto out; 3903db3f65cSamw } 39168b2bbf2SGordon Ross uio->uio_resid -= recvcnt; 3923db3f65cSamw 393*bce01b59SGordon Ross out: 394*bce01b59SGordon Ross ksocket_rele(sock); 395*bce01b59SGordon Ross 396*bce01b59SGordon Ross return (rc); 39768b2bbf2SGordon Ross } 39868b2bbf2SGordon Ross 399*bce01b59SGordon Ross int 400*bce01b59SGordon Ross smb_opipe_get_nread(smb_request_t *sr, int *nread) 401*bce01b59SGordon Ross { 402*bce01b59SGordon Ross smb_ofile_t *ofile; 403*bce01b59SGordon Ross smb_opipe_t *opipe; 404*bce01b59SGordon Ross ksocket_t sock; 405*bce01b59SGordon Ross int rc, trval; 406*bce01b59SGordon Ross 407*bce01b59SGordon Ross ofile = sr->fid_ofile; 408*bce01b59SGordon Ross ASSERT(ofile->f_ftype == SMB_FTYPE_MESG_PIPE); 409*bce01b59SGordon Ross opipe = ofile->f_pipe; 410*bce01b59SGordon Ross SMB_OPIPE_VALID(opipe); 411*bce01b59SGordon Ross 412*bce01b59SGordon Ross mutex_enter(&opipe->p_mutex); 413*bce01b59SGordon Ross sock = opipe->p_socket; 414*bce01b59SGordon Ross if (sock != NULL) 415*bce01b59SGordon Ross ksocket_hold(sock); 416*bce01b59SGordon Ross mutex_exit(&opipe->p_mutex); 417*bce01b59SGordon Ross if (sock == NULL) 418*bce01b59SGordon Ross return (EBADF); 419*bce01b59SGordon Ross 420*bce01b59SGordon Ross rc = ksocket_ioctl(sock, FIONREAD, (intptr_t)nread, &trval, 421*bce01b59SGordon Ross ofile->f_cr); 422*bce01b59SGordon Ross 42368b2bbf2SGordon Ross ksocket_rele(sock); 42468b2bbf2SGordon Ross 42568b2bbf2SGordon Ross return (rc); 4263db3f65cSamw } 427