1 46f79934 2005-01-04 devnull /* Copyright (C) 2003 Russ Cox, Massachusetts Institute of Technology */
 2 46f79934 2005-01-04 devnull /* See COPYRIGHT */
 3 46f79934 2005-01-04 devnull 
 4 46f79934 2005-01-04 devnull #include <u.h>
 5 46f79934 2005-01-04 devnull #include <libc.h>
 6 46f79934 2005-01-04 devnull #include <fcall.h>
 7 46f79934 2005-01-04 devnull #include <9pclient.h>
 8 46f79934 2005-01-04 devnull #include "fsimpl.h"
 9 46f79934 2005-01-04 devnull 
10 46f79934 2005-01-04 devnull long
11 46f79934 2005-01-04 devnull fspread(CFid *fid, void *buf, long n, vlong offset)
12 46f79934 2005-01-04 devnull {
13 46f79934 2005-01-04 devnull 	Fcall tx, rx;
14 46f79934 2005-01-04 devnull 	void *freep;
15 46f79934 2005-01-04 devnull 	uint msize;
16 46f79934 2005-01-04 devnull 
17 46f79934 2005-01-04 devnull 	msize = fid->fs->msize - IOHDRSZ;
18 46f79934 2005-01-04 devnull 	if(n > msize)
19 46f79934 2005-01-04 devnull 		n = msize;
20 46f79934 2005-01-04 devnull 	tx.type = Tread;
21 46f79934 2005-01-04 devnull 	tx.fid = fid->fid;
22 46f79934 2005-01-04 devnull 	if(offset == -1){
23 46f79934 2005-01-04 devnull 		qlock(&fid->lk);
24 46f79934 2005-01-04 devnull 		tx.offset = fid->offset;
25 46f79934 2005-01-04 devnull 		qunlock(&fid->lk);
26 46f79934 2005-01-04 devnull 	}else
27 46f79934 2005-01-04 devnull 		tx.offset = offset;
28 46f79934 2005-01-04 devnull 	tx.count = n;
29 46f79934 2005-01-04 devnull 
30 46f79934 2005-01-04 devnull 	if(_fsrpc(fid->fs, &tx, &rx, &freep) < 0)
31 46f79934 2005-01-04 devnull 		return -1;
32 46f79934 2005-01-04 devnull 	if(rx.type == Rerror){
33 46f79934 2005-01-04 devnull 		werrstr("%s", rx.ename);
34 46f79934 2005-01-04 devnull 		free(freep);
35 46f79934 2005-01-04 devnull 		return -1;
36 46f79934 2005-01-04 devnull 	}
37 46f79934 2005-01-04 devnull 	if(rx.count){
38 46f79934 2005-01-04 devnull 		memmove(buf, rx.data, rx.count);
39 46f79934 2005-01-04 devnull 		if(offset == -1){
40 46f79934 2005-01-04 devnull 			qlock(&fid->lk);
41 46f79934 2005-01-04 devnull 			fid->offset += rx.count;
42 46f79934 2005-01-04 devnull 			qunlock(&fid->lk);
43 46f79934 2005-01-04 devnull 		}
44 46f79934 2005-01-04 devnull 	}
45 46f79934 2005-01-04 devnull 	free(freep);
46 46f79934 2005-01-04 devnull 	
47 46f79934 2005-01-04 devnull 	return rx.count;
48 46f79934 2005-01-04 devnull }
49 46f79934 2005-01-04 devnull 
50 46f79934 2005-01-04 devnull long
51 46f79934 2005-01-04 devnull fsread(CFid *fid, void *buf, long n)
52 46f79934 2005-01-04 devnull {
53 46f79934 2005-01-04 devnull 	return fspread(fid, buf, n, -1);
54 46f79934 2005-01-04 devnull }
55 46f79934 2005-01-04 devnull 
56 46f79934 2005-01-04 devnull long
57 46f79934 2005-01-04 devnull fsreadn(CFid *fid, void *buf, long n)
58 46f79934 2005-01-04 devnull {
59 46f79934 2005-01-04 devnull 	long tot, nn;
60 46f79934 2005-01-04 devnull 
61 46f79934 2005-01-04 devnull 	for(tot=0; tot<n; tot+=nn){
62 46f79934 2005-01-04 devnull 		nn = fsread(fid, (char*)buf+tot, n-tot);
63 46f79934 2005-01-04 devnull 		if(nn <= 0){
64 46f79934 2005-01-04 devnull 			if(tot == 0)
65 46f79934 2005-01-04 devnull 				return nn;
66 46f79934 2005-01-04 devnull 			break;
67 46f79934 2005-01-04 devnull 		}
68 46f79934 2005-01-04 devnull 	}
69 46f79934 2005-01-04 devnull 	return tot;
70 46f79934 2005-01-04 devnull }
71 46f79934 2005-01-04 devnull 			
72 46f79934 2005-01-04 devnull