xref: /dragonfly/sys/netproto/smb/smb_smb.c (revision 25a2db75)
1 /*
2  * Copyright (c) 2000-2001 Boris Popov
3  * All rights reserved.
4  *
5  * Redistribution and use in source and binary forms, with or without
6  * modification, are permitted provided that the following conditions
7  * are met:
8  * 1. Redistributions of source code must retain the above copyright
9  *    notice, this list of conditions and the following disclaimer.
10  * 2. Redistributions in binary form must reproduce the above copyright
11  *    notice, this list of conditions and the following disclaimer in the
12  *    documentation and/or other materials provided with the distribution.
13  * 3. All advertising materials mentioning features or use of this software
14  *    must display the following acknowledgement:
15  *    This product includes software developed by Boris Popov.
16  * 4. Neither the name of the author nor the names of any co-contributors
17  *    may be used to endorse or promote products derived from this software
18  *    without specific prior written permission.
19  *
20  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
21  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
22  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
23  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
24  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
25  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
26  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
27  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
28  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
29  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
30  * SUCH DAMAGE.
31  *
32  * $FreeBSD: src/sys/netsmb/smb_smb.c,v 1.1.2.3 2002/12/14 14:44:19 fjoe Exp $
33  */
34 /*
35  * various SMB requests. Most of the routines merely packs data into mbufs.
36  */
37 #include <sys/param.h>
38 #include <sys/systm.h>
39 #include <sys/kernel.h>
40 #include <sys/malloc.h>
41 #include <sys/proc.h>
42 #include <sys/lock.h>
43 #include <sys/sysctl.h>
44 #include <sys/socket.h>
45 #include <sys/uio.h>
46 
47 #include <sys/iconv.h>
48 #include <machine/limits.h>
49 
50 #include "smb.h"
51 #include "smb_subr.h"
52 #include "smb_rq.h"
53 #include "smb_conn.h"
54 #include "smb_tran.h"
55 
56 struct smb_dialect {
57 	int		d_id;
58 	const char *	d_name;
59 };
60 
61 static struct smb_dialect smb_dialects[] = {
62 	{SMB_DIALECT_CORE,	"PC NETWORK PROGRAM 1.0"},
63 	{SMB_DIALECT_COREPLUS,	"MICROSOFT NETWORKS 1.03"},
64 	{SMB_DIALECT_LANMAN1_0,	"MICROSOFT NETWORKS 3.0"},
65 	{SMB_DIALECT_LANMAN1_0,	"LANMAN1.0"},
66 	{SMB_DIALECT_LANMAN2_0,	"LM1.2X002"},
67 	{SMB_DIALECT_LANMAN2_0,	"Samba"},
68 	{SMB_DIALECT_NTLM0_12,	"NT LANMAN 1.0"},
69 	{SMB_DIALECT_NTLM0_12,	"NT LM 0.12"},
70 	{-1,			NULL}
71 };
72 
73 #define	SMB_DIALECT_MAX	(NELEM(smb_dialects) - 2)
74 
75 static int
76 smb_smb_nomux(struct smb_vc *vcp, struct smb_cred *scred, const char *name)
77 {
78 	if (scred->scr_td == vcp->vc_iod->iod_td)
79 		return 0;
80 	SMBERROR("wrong function called(%s)\n", name);
81 	return EINVAL;
82 }
83 
84 int
85 smb_smb_negotiate(struct smb_vc *vcp, struct smb_cred *scred)
86 {
87 	struct smb_dialect *dp;
88 	struct smb_sopt *sp = NULL;
89 	struct smb_rq *rqp;
90 	struct mbchain *mbp;
91 	struct mdchain *mdp;
92 	u_int8_t wc, stime[8], sblen;
93 	u_int16_t dindex, tw, tw1, swlen, bc;
94 	int error, maxqsz;
95 
96 	if (smb_smb_nomux(vcp, scred, __func__) != 0)
97 		return EINVAL;
98 	vcp->vc_hflags = 0;
99 	vcp->vc_hflags2 = 0;
100 	vcp->obj.co_flags &= ~(SMBV_ENCRYPT);
101 	sp = &vcp->vc_sopt;
102 	bzero(sp, sizeof(struct smb_sopt));
103 	error = smb_rq_alloc(VCTOCP(vcp), SMB_COM_NEGOTIATE, scred, &rqp);
104 	if (error)
105 		return error;
106 	smb_rq_getrequest(rqp, &mbp);
107 	smb_rq_wstart(rqp);
108 	smb_rq_wend(rqp);
109 	smb_rq_bstart(rqp);
110 	for(dp = smb_dialects; dp->d_id != -1; dp++) {
111 		mb_put_uint8(mbp, SMB_DT_DIALECT);
112 		smb_put_dstring(mbp, vcp, dp->d_name, SMB_CS_NONE);
113 	}
114 	smb_rq_bend(rqp);
115 	error = smb_rq_simple(rqp);
116 	SMBSDEBUG("%d\n", error);
117 	if (error)
118 		goto bad;
119 	smb_rq_getreply(rqp, &mdp);
120 	do {
121 		error = md_get_uint8(mdp, &wc);
122 		if (error)
123 			break;
124 		error = md_get_uint16le(mdp, &dindex);
125 		if (error)
126 			break;
127 		if (dindex > 7) {
128 			SMBERROR("Don't know how to talk with server %s (%d)\n", "xxx", dindex);
129 			error = EBADRPC;
130 			break;
131 		}
132 		dp = smb_dialects + dindex;
133 		sp->sv_proto = dp->d_id;
134 		SMBSDEBUG("Dialect %s (%d, %d)\n", dp->d_name, dindex, wc);
135 		error = EBADRPC;
136 		if (dp->d_id >= SMB_DIALECT_NTLM0_12) {
137 			if (wc != 17)
138 				break;
139 			md_get_uint8(mdp, &sp->sv_sm);
140 			md_get_uint16le(mdp, &sp->sv_maxmux);
141 			md_get_uint16le(mdp, &sp->sv_maxvcs);
142 			md_get_uint32le(mdp, &sp->sv_maxtx);
143 			md_get_uint32le(mdp, &sp->sv_maxraw);
144 			md_get_uint32le(mdp, &sp->sv_skey);
145 			md_get_uint32le(mdp, &sp->sv_caps);
146 			md_get_mem(mdp, stime, 8, MB_MSYSTEM);
147 			md_get_uint16le(mdp, (u_int16_t*)&sp->sv_tz);
148 			md_get_uint8(mdp, &sblen);
149 			if (sblen && (sp->sv_sm & SMB_SM_ENCRYPT)) {
150 				if (sblen != SMB_MAXCHALLENGELEN) {
151 					SMBERROR("Unexpected length of security blob (%d)\n", sblen);
152 					break;
153 				}
154 				error = md_get_uint16(mdp, &bc);
155 				if (error)
156 					break;
157 				if (sp->sv_caps & SMB_CAP_EXT_SECURITY)
158 					md_get_mem(mdp, NULL, 16, MB_MSYSTEM);
159 				error = md_get_mem(mdp, vcp->vc_ch, sblen, MB_MSYSTEM);
160 				if (error)
161 					break;
162 				vcp->vc_chlen = sblen;
163 				vcp->obj.co_flags |= SMBV_ENCRYPT;
164 			}
165 			vcp->vc_hflags2 |= SMB_FLAGS2_KNOWS_LONG_NAMES;
166 			if (dp->d_id == SMB_DIALECT_NTLM0_12 &&
167 			    sp->sv_maxtx < 4096 &&
168 			    (sp->sv_caps & SMB_CAP_NT_SMBS) == 0) {
169 				vcp->obj.co_flags |= SMBV_WIN95;
170 				SMBSDEBUG("Win95 detected\n");
171 			}
172 		} else if (dp->d_id > SMB_DIALECT_CORE) {
173 			md_get_uint16le(mdp, &tw);
174 			sp->sv_sm = tw;
175 			md_get_uint16le(mdp, &tw);
176 			sp->sv_maxtx = tw;
177 			md_get_uint16le(mdp, &sp->sv_maxmux);
178 			md_get_uint16le(mdp, &sp->sv_maxvcs);
179 			md_get_uint16le(mdp, &tw);	/* rawmode */
180 			md_get_uint32le(mdp, &sp->sv_skey);
181 			if (wc == 13) {		/* >= LANMAN1 */
182 				md_get_uint16(mdp, &tw);		/* time */
183 				md_get_uint16(mdp, &tw1);		/* date */
184 				md_get_uint16le(mdp, (u_int16_t*)&sp->sv_tz);
185 				md_get_uint16le(mdp, &swlen);
186 				if (swlen > SMB_MAXCHALLENGELEN)
187 					break;
188 				md_get_uint16(mdp, NULL);	/* mbz */
189 				if (md_get_uint16(mdp, &bc) != 0)
190 					break;
191 				if (bc < swlen)
192 					break;
193 				if (swlen && (sp->sv_sm & SMB_SM_ENCRYPT)) {
194 					error = md_get_mem(mdp, vcp->vc_ch, swlen, MB_MSYSTEM);
195 					if (error)
196 						break;
197 					vcp->vc_chlen = swlen;
198 					vcp->obj.co_flags |= SMBV_ENCRYPT;
199 				}
200 			}
201 			vcp->vc_hflags2 |= SMB_FLAGS2_KNOWS_LONG_NAMES;
202 		} else {	/* an old CORE protocol */
203 			sp->sv_maxmux = 1;
204 		}
205 		error = 0;
206 	} while (0);
207 	if (error == 0) {
208 		vcp->vc_maxvcs = sp->sv_maxvcs;
209 		if (vcp->vc_maxvcs <= 1) {
210 			if (vcp->vc_maxvcs == 0)
211 				vcp->vc_maxvcs = 1;
212 		}
213 		if (sp->sv_maxtx <= 0 || sp->sv_maxtx > 0xffff)
214 			sp->sv_maxtx = 1024;
215 		SMB_TRAN_GETPARAM(vcp, SMBTP_SNDSZ, &maxqsz);
216 		vcp->vc_txmax = min(sp->sv_maxtx, maxqsz);
217 		SMBSDEBUG("TZ = %d\n", sp->sv_tz);
218 		SMBSDEBUG("CAPS = %x\n", sp->sv_caps);
219 		SMBSDEBUG("MAXMUX = %d\n", sp->sv_maxmux);
220 		SMBSDEBUG("MAXVCS = %d\n", sp->sv_maxvcs);
221 		SMBSDEBUG("MAXRAW = %d\n", sp->sv_maxraw);
222 		SMBSDEBUG("MAXTX = %d\n", sp->sv_maxtx);
223 	}
224 bad:
225 	smb_rq_done(rqp);
226 	return error;
227 }
228 
229 int
230 smb_smb_ssnsetup(struct smb_vc *vcp, struct smb_cred *scred)
231 {
232 	struct smb_rq *rqp;
233 	struct mbchain *mbp;
234 /*	u_int8_t wc;
235 	u_int16_t tw, tw1;*/
236 	smb_uniptr unipp, ntencpass = NULL;
237 	char *pp, *up, *pbuf, *encpass;
238 	int error, plen, uniplen;
239 
240 	vcp->vc_smbuid = SMB_UID_UNKNOWN;
241 
242 	if (smb_smb_nomux(vcp, scred, __func__) != 0)
243 		return EINVAL;
244 
245 	error = smb_rq_alloc(VCTOCP(vcp), SMB_COM_SESSION_SETUP_ANDX, scred, &rqp);
246 	if (error)
247 		return error;
248 	pbuf = kmalloc(SMB_MAXPASSWORDLEN + 1, M_SMBTEMP, M_WAITOK);
249 	encpass = kmalloc(24, M_SMBTEMP, M_WAITOK);
250 	if (vcp->vc_sopt.sv_sm & SMB_SM_USER) {
251 		iconv_convstr(vcp->vc_toupper, pbuf, smb_vc_getpass(vcp));
252 		iconv_convstr(vcp->vc_toserver, pbuf, pbuf);
253 		if (vcp->vc_sopt.sv_sm & SMB_SM_ENCRYPT) {
254 			uniplen = plen = 24;
255 			smb_encrypt(pbuf, vcp->vc_ch, encpass);
256 			ntencpass = kmalloc(uniplen, M_SMBTEMP, M_WAITOK);
257 			iconv_convstr(vcp->vc_toserver, pbuf, smb_vc_getpass(vcp));
258 			smb_ntencrypt(pbuf, vcp->vc_ch, (u_char*)ntencpass);
259 			pp = encpass;
260 			unipp = ntencpass;
261 		} else {
262 			plen = strlen(pbuf) + 1;
263 			pp = pbuf;
264 			uniplen = plen * 2;
265 			ntencpass = kmalloc(uniplen, M_SMBTEMP, M_WAITOK);
266 			smb_strtouni(ntencpass, smb_vc_getpass(vcp));
267 			plen--;
268 
269 			/*
270 			 * The uniplen is zeroed because Samba cannot deal
271 			 * with this 2nd cleartext password.  This Samba
272 			 * "bug" is actually a workaround for problems in
273 			 * Microsoft clients.
274 			 */
275 			uniplen = 0/*-= 2*/;
276 			unipp = ntencpass;
277 		}
278 	} else {
279 		/*
280 		 * In the share security mode password will be used
281 		 * only in the tree authentication
282 		 */
283 		 pp = "";
284 		 plen = 1;
285 		 unipp = &smb_unieol;
286 		 uniplen = 0 /* sizeof(smb_unieol) */;
287 	}
288 	smb_rq_wstart(rqp);
289 	mbp = &rqp->sr_rq;
290 	up = vcp->vc_username;
291 	mb_put_uint8(mbp, 0xff);
292 	mb_put_uint8(mbp, 0);
293 	mb_put_uint16le(mbp, 0);
294 	mb_put_uint16le(mbp, vcp->vc_sopt.sv_maxtx);
295 	mb_put_uint16le(mbp, vcp->vc_sopt.sv_maxmux);
296 	mb_put_uint16le(mbp, vcp->vc_number);
297 	mb_put_uint32le(mbp, vcp->vc_sopt.sv_skey);
298 	mb_put_uint16le(mbp, plen);
299 	if (SMB_DIALECT(vcp) < SMB_DIALECT_NTLM0_12) {
300 		mb_put_uint32le(mbp, 0);
301 		smb_rq_wend(rqp);
302 		smb_rq_bstart(rqp);
303 		mb_put_mem(mbp, pp, plen, MB_MSYSTEM);
304 		smb_put_dstring(mbp, vcp, up, SMB_CS_NONE);
305 	} else {
306 		mb_put_uint16le(mbp, uniplen);
307 		mb_put_uint32le(mbp, 0);		/* reserved */
308 		mb_put_uint32le(mbp, vcp->obj.co_flags & SMBV_UNICODE ?
309 				     SMB_CAP_UNICODE : 0);
310 		smb_rq_wend(rqp);
311 		smb_rq_bstart(rqp);
312 		mb_put_mem(mbp, pp, plen, MB_MSYSTEM);
313 		mb_put_mem(mbp, (caddr_t)unipp, uniplen, MB_MSYSTEM);
314 		smb_put_dstring(mbp, vcp, up, SMB_CS_NONE);		/* AccountName */
315 		smb_put_dstring(mbp, vcp, vcp->vc_domain, SMB_CS_NONE);	/* PrimaryDomain */
316 		smb_put_dstring(mbp, vcp, "FreeBSD", SMB_CS_NONE);	/* Client's OS */
317 		smb_put_dstring(mbp, vcp, "NETSMB", SMB_CS_NONE);		/* Client name */
318 	}
319 	smb_rq_bend(rqp);
320 	if (ntencpass)
321 		kfree(ntencpass, M_SMBTEMP);
322 	error = smb_rq_simple(rqp);
323 	SMBSDEBUG("%d\n", error);
324 	if (error) {
325 		if (rqp->sr_errclass == ERRDOS && rqp->sr_serror == ERRnoaccess)
326 			error = EAUTH;
327 		goto bad;
328 	}
329 	vcp->vc_smbuid = rqp->sr_rpuid;
330 bad:
331 	kfree(encpass, M_SMBTEMP);
332 	kfree(pbuf, M_SMBTEMP);
333 	smb_rq_done(rqp);
334 	return error;
335 }
336 
337 int
338 smb_smb_ssnclose(struct smb_vc *vcp, struct smb_cred *scred)
339 {
340 	struct smb_rq *rqp;
341 	struct mbchain *mbp;
342 	int error;
343 
344 	if (vcp->vc_smbuid == SMB_UID_UNKNOWN)
345 		return 0;
346 
347 	if (smb_smb_nomux(vcp, scred, __func__) != 0)
348 		return EINVAL;
349 
350 	error = smb_rq_alloc(VCTOCP(vcp), SMB_COM_LOGOFF_ANDX, scred, &rqp);
351 	if (error)
352 		return error;
353 	mbp = &rqp->sr_rq;
354 	smb_rq_wstart(rqp);
355 	mb_put_uint8(mbp, 0xff);
356 	mb_put_uint8(mbp, 0);
357 	mb_put_uint16le(mbp, 0);
358 	smb_rq_wend(rqp);
359 	smb_rq_bstart(rqp);
360 	smb_rq_bend(rqp);
361 	error = smb_rq_simple(rqp);
362 	SMBSDEBUG("%d\n", error);
363 	smb_rq_done(rqp);
364 	return error;
365 }
366 
367 static char smb_any_share[] = "?????";
368 
369 static char *
370 smb_share_typename(int stype)
371 {
372 	char *pp;
373 
374 	switch (stype) {
375 	    case SMB_ST_DISK:
376 		pp = "A:";
377 		break;
378 	    case SMB_ST_PRINTER:
379 		pp = smb_any_share;		/* can't use LPT: here... */
380 		break;
381 	    case SMB_ST_PIPE:
382 		pp = "IPC";
383 		break;
384 	    case SMB_ST_COMM:
385 		pp = "COMM";
386 		break;
387 	    case SMB_ST_ANY:
388 	    default:
389 		pp = smb_any_share;
390 		break;
391 	}
392 	return pp;
393 }
394 
395 int
396 smb_smb_treeconnect(struct smb_share *ssp, struct smb_cred *scred)
397 {
398 	struct smb_vc *vcp;
399 	struct smb_rq rq, *rqp = &rq;
400 	struct mbchain *mbp;
401 	char *pp, *pbuf, *encpass;
402 	int error, plen, caseopt;
403 
404 	ssp->ss_tid = SMB_TID_UNKNOWN;
405 	error = smb_rq_alloc(SSTOCP(ssp), SMB_COM_TREE_CONNECT_ANDX, scred, &rqp);
406 	if (error)
407 		return error;
408 	vcp = rqp->sr_vc;
409 	caseopt = SMB_CS_NONE;
410 	if (vcp->vc_sopt.sv_sm & SMB_SM_USER) {
411 		plen = 1;
412 		pp = "";
413 		pbuf = NULL;
414 		encpass = NULL;
415 	} else {
416 		pbuf = kmalloc(SMB_MAXPASSWORDLEN + 1, M_SMBTEMP, M_WAITOK);
417 		encpass = kmalloc(24, M_SMBTEMP, M_WAITOK);
418 		iconv_convstr(vcp->vc_toupper, pbuf, smb_share_getpass(ssp));
419 		iconv_convstr(vcp->vc_toserver, pbuf, pbuf);
420 		if (vcp->vc_sopt.sv_sm & SMB_SM_ENCRYPT) {
421 			plen = 24;
422 			smb_encrypt(pbuf, vcp->vc_ch, encpass);
423 			pp = encpass;
424 		} else {
425 			plen = strlen(pbuf) + 1;
426 			pp = pbuf;
427 		}
428 	}
429 	mbp = &rqp->sr_rq;
430 	smb_rq_wstart(rqp);
431 	mb_put_uint8(mbp, 0xff);
432 	mb_put_uint8(mbp, 0);
433 	mb_put_uint16le(mbp, 0);
434 	mb_put_uint16le(mbp, 0);		/* Flags */
435 	mb_put_uint16le(mbp, plen);
436 	smb_rq_wend(rqp);
437 	smb_rq_bstart(rqp);
438 	mb_put_mem(mbp, pp, plen, MB_MSYSTEM);
439 	smb_put_dmem(mbp, vcp, "\\\\", 2, caseopt);
440 	pp = vcp->vc_srvname;
441 	smb_put_dmem(mbp, vcp, pp, strlen(pp), caseopt);
442 	smb_put_dmem(mbp, vcp, "\\", 1, caseopt);
443 	pp = ssp->ss_name;
444 	smb_put_dstring(mbp, vcp, pp, caseopt);
445 	pp = smb_share_typename(ssp->ss_type);
446 	smb_put_dstring(mbp, vcp, pp, caseopt);
447 	smb_rq_bend(rqp);
448 	error = smb_rq_simple(rqp);
449 	SMBSDEBUG("%d\n", error);
450 	if (error)
451 		goto bad;
452 	ssp->ss_tid = rqp->sr_rptid;
453 	ssp->ss_vcgenid = vcp->vc_genid;
454 	ssp->ss_flags |= SMBS_CONNECTED;
455 bad:
456 	if (encpass)
457 		kfree(encpass, M_SMBTEMP);
458 	if (pbuf)
459 		kfree(pbuf, M_SMBTEMP);
460 	smb_rq_done(rqp);
461 	return error;
462 }
463 
464 int
465 smb_smb_treedisconnect(struct smb_share *ssp, struct smb_cred *scred)
466 {
467 	struct smb_rq *rqp;
468 	int error;
469 
470 	if (ssp->ss_tid == SMB_TID_UNKNOWN)
471 		return 0;
472 	error = smb_rq_alloc(SSTOCP(ssp), SMB_COM_TREE_DISCONNECT, scred, &rqp);
473 	if (error)
474 		return error;
475 	smb_rq_wstart(rqp);
476 	smb_rq_wend(rqp);
477 	smb_rq_bstart(rqp);
478 	smb_rq_bend(rqp);
479 	error = smb_rq_simple(rqp);
480 	SMBSDEBUG("%d\n", error);
481 	smb_rq_done(rqp);
482 	ssp->ss_tid = SMB_TID_UNKNOWN;
483 	return error;
484 }
485 
486 static __inline int
487 smb_smb_read(struct smb_share *ssp, u_int16_t fid,
488 	int *len, int *rresid, struct uio *uio, struct smb_cred *scred)
489 {
490 	struct smb_rq *rqp;
491 	struct mbchain *mbp;
492 	struct mdchain *mdp;
493 	u_int16_t resid, bc;
494 	u_int8_t wc;
495 	int error, rlen, blksz;
496 
497 	error = smb_rq_alloc(SSTOCP(ssp), SMB_COM_READ, scred, &rqp);
498 	if (error)
499 		return error;
500 
501 	blksz = SSTOVC(ssp)->vc_txmax - SMB_HDRLEN - 16;
502 	rlen = *len = min(blksz, *len);
503 
504 	smb_rq_getrequest(rqp, &mbp);
505 	smb_rq_wstart(rqp);
506 	mb_put_mem(mbp, (caddr_t)&fid, sizeof(fid), MB_MSYSTEM);
507 	mb_put_uint16le(mbp, rlen);
508 	mb_put_uint32le(mbp, uio->uio_offset);
509 	mb_put_uint16le(mbp, (unsigned short)szmin(uio->uio_resid, 0xffff));
510 	smb_rq_wend(rqp);
511 	smb_rq_bstart(rqp);
512 	smb_rq_bend(rqp);
513 	do {
514 		error = smb_rq_simple(rqp);
515 		if (error)
516 			break;
517 		smb_rq_getreply(rqp, &mdp);
518 		md_get_uint8(mdp, &wc);
519 		if (wc != 5) {
520 			error = EBADRPC;
521 			break;
522 		}
523 		md_get_uint16le(mdp, &resid);
524 		md_get_mem(mdp, NULL, 4 * 2, MB_MSYSTEM);
525 		md_get_uint16le(mdp, &bc);
526 		md_get_uint8(mdp, NULL);		/* ignore buffer type */
527 		md_get_uint16le(mdp, &resid);
528 		if (resid == 0) {
529 			*rresid = resid;
530 			break;
531 		}
532 		error = md_get_uio(mdp, uio, resid);
533 		if (error)
534 			break;
535 		*rresid = resid;
536 	} while(0);
537 	smb_rq_done(rqp);
538 	return error;
539 }
540 
541 int
542 smb_read(struct smb_share *ssp, u_int16_t fid, struct uio *uio,
543 	struct smb_cred *scred)
544 {
545 	int len, resid;
546 	int error = 0;
547 
548 	while (uio->uio_resid > 0) {
549 		if (uio->uio_resid > INT_MAX)
550 			len = INT_MAX;
551 		else
552 			len = (int)uio->uio_resid;
553 		error = smb_smb_read(ssp, fid, &len, &resid, uio, scred);
554 		if (error)
555 			break;
556 		if (resid < len)
557 			break;
558 	}
559 	return error;
560 }
561 
562 static __inline int
563 smb_smb_write(struct smb_share *ssp, u_int16_t fid, int *len, int *rresid,
564 	struct uio *uio, struct smb_cred *scred)
565 {
566 	struct smb_rq *rqp;
567 	struct mbchain *mbp;
568 	struct mdchain *mdp;
569 	u_int16_t resid;
570 	u_int8_t wc;
571 	int error, blksz;
572 
573 	/* write data must be real */
574 	KKASSERT(uio->uio_segflg != UIO_NOCOPY);
575 
576 	blksz = SSTOVC(ssp)->vc_txmax - SMB_HDRLEN - 16;
577 	if (blksz > 0xffff)
578 		blksz = 0xffff;
579 
580 	resid = *len = min(blksz, *len);
581 
582 	error = smb_rq_alloc(SSTOCP(ssp), SMB_COM_WRITE, scred, &rqp);
583 	if (error)
584 		return error;
585 	smb_rq_getrequest(rqp, &mbp);
586 	smb_rq_wstart(rqp);
587 	mb_put_mem(mbp, (caddr_t)&fid, sizeof(fid), MB_MSYSTEM);
588 	mb_put_uint16le(mbp, resid);
589 	mb_put_uint32le(mbp, uio->uio_offset);
590 	mb_put_uint16le(mbp, (unsigned short)szmin(uio->uio_resid, 0xffff));
591 	smb_rq_wend(rqp);
592 	smb_rq_bstart(rqp);
593 	mb_put_uint8(mbp, SMB_DT_DATA);
594 	mb_put_uint16le(mbp, resid);
595 	do {
596 		error = mb_put_uio(mbp, uio, resid);
597 		if (error)
598 			break;
599 		smb_rq_bend(rqp);
600 		error = smb_rq_simple(rqp);
601 		if (error)
602 			break;
603 		smb_rq_getreply(rqp, &mdp);
604 		md_get_uint8(mdp, &wc);
605 		if (wc != 1) {
606 			error = EBADRPC;
607 			break;
608 		}
609 		md_get_uint16le(mdp, &resid);
610 		*rresid = resid;
611 	} while(0);
612 	smb_rq_done(rqp);
613 	return error;
614 }
615 
616 int
617 smb_write(struct smb_share *ssp, u_int16_t fid, struct uio *uio,
618 	struct smb_cred *scred)
619 {
620 	int error = 0, len, resid;
621 	struct uio olduio;
622 
623 	olduio = *uio;
624 	while (uio->uio_resid > 0) {
625 		if (uio->uio_resid > INT_MAX)
626 			len = INT_MAX;
627 		else
628 			len = (int)uio->uio_resid;
629 		error = smb_smb_write(ssp, fid, &len, &resid, uio, scred);
630 		if (error)
631 			break;
632 		if (resid < len) {
633 			error = EIO;
634 			break;
635 		}
636 	}
637 	if (error) {
638 		/*
639 		 * Errors can happen on the copyin, the rpc, etc.  So they
640 		 * imply resid is unreliable.  The only safe thing is
641 		 * to pretend zero bytes made it.  We needn't restore the
642 		 * iovs because callers don't depend on them in error
643 		 * paths - uio_resid and uio_offset are what matter.
644 		 */
645 		*uio = olduio;
646 	}
647 	return error;
648 }
649 
650 int
651 smb_smb_echo(struct smb_vc *vcp, struct smb_cred *scred)
652 {
653 	struct smb_rq *rqp;
654 	struct mbchain *mbp;
655 	int error;
656 
657 	error = smb_rq_alloc(VCTOCP(vcp), SMB_COM_ECHO, scred, &rqp);
658 	if (error)
659 		return error;
660 	mbp = &rqp->sr_rq;
661 	smb_rq_wstart(rqp);
662 	mb_put_uint16le(mbp, 1);
663 	smb_rq_wend(rqp);
664 	smb_rq_bstart(rqp);
665 	mb_put_uint32le(mbp, 0);
666 	smb_rq_bend(rqp);
667 	error = smb_rq_simple(rqp);
668 	SMBSDEBUG("%d\n", error);
669 	smb_rq_done(rqp);
670 	return error;
671 }
672