This source file includes following definitions.
- msdos_prefetch
- msdos_file_read
- msdos_file_write
- msdos_truncate
1
2
3
4
5
6
7
8
9 #include <linux/module.h>
10
11 #include <linux/sched.h>
12 #include <linux/locks.h>
13 #include <linux/fs.h>
14 #include <linux/msdos_fs.h>
15 #include <linux/errno.h>
16 #include <linux/fcntl.h>
17 #include <linux/stat.h>
18 #include <linux/string.h>
19
20 #include <asm/segment.h>
21 #include <asm/system.h>
22
23 #include "msbuffer.h"
24
25 #define MIN(a,b) (((a) < (b)) ? (a) : (b))
26 #define MAX(a,b) (((a) > (b)) ? (a) : (b))
27
28 #define PRINTK(x)
29 #define Printk(x) printk x
30
31 static struct file_operations msdos_file_operations = {
32 NULL,
33 msdos_file_read,
34 msdos_file_write,
35 NULL,
36 NULL,
37 NULL,
38 generic_mmap,
39 NULL,
40 NULL,
41 file_fsync
42 };
43
44 struct inode_operations msdos_file_inode_operations = {
45 &msdos_file_operations,
46 NULL,
47 NULL,
48 NULL,
49 NULL,
50 NULL,
51 NULL,
52 NULL,
53 NULL,
54 NULL,
55 NULL,
56 NULL,
57 msdos_bmap,
58 msdos_truncate,
59 NULL,
60 NULL
61 };
62
63
64
65
66
67
68 static struct file_operations msdos_file_operations_1024 = {
69 NULL,
70 msdos_file_read,
71 msdos_file_write,
72 NULL,
73 NULL,
74 NULL,
75 msdos_mmap,
76 NULL,
77 NULL,
78 file_fsync
79 };
80
81
82
83
84
85
86
87
88
89
90 struct inode_operations msdos_file_inode_operations_1024 = {
91 &msdos_file_operations_1024,
92 NULL,
93 NULL,
94 NULL,
95 NULL,
96 NULL,
97 NULL,
98 NULL,
99 NULL,
100 NULL,
101 NULL,
102 NULL,
103 NULL,
104 msdos_truncate,
105 NULL,
106 NULL
107 };
108
109 #define MSDOS_PREFETCH 32
110 struct msdos_pre {
111 int file_sector;
112
113 struct buffer_head *bhlist[MSDOS_PREFETCH];
114 int nblist;
115 int nolist;
116 };
117
118
119
120 static void msdos_prefetch (
121 struct inode *inode,
122 struct msdos_pre *pre,
123 int nb)
124 {
125 struct super_block *sb = inode->i_sb;
126 struct buffer_head *bhreq[MSDOS_PREFETCH];
127
128 int nbreq=0;
129 int i;
130 for (i=0; i<nb; i++){
131 int sector = msdos_smap(inode,pre->file_sector);
132 if (sector != 0){
133 struct buffer_head *bh;
134 PRINTK (("fsector2 %d -> %d\n",pre->file_sector-1,sector));
135 pre->file_sector++;
136 bh = getblk(inode->i_dev,sector,SECTOR_SIZE);
137 if (bh == NULL) break;
138 pre->bhlist[pre->nblist++] = bh;
139 if (!msdos_is_uptodate(sb,bh)) bhreq[nbreq++] = bh;
140 }else{
141 break;
142 }
143 }
144 if (nbreq > 0) msdos_ll_rw_block (sb,READ,nbreq,bhreq);
145 for (i=pre->nblist; i<MSDOS_PREFETCH; i++) pre->bhlist[i] = NULL;
146 }
147
148
149
150
151 int msdos_file_read(
152 struct inode *inode,
153 struct file *filp,
154 char *buf,
155 int count)
156 {
157 struct super_block *sb = inode->i_sb;
158 char *start = buf;
159 char *end = buf + count;
160 int i;
161 int left_in_file;
162 struct msdos_pre pre;
163
164
165 if (!inode) {
166 printk("msdos_file_read: inode = NULL\n");
167 return -EINVAL;
168 }
169
170 if (!S_ISREG(inode->i_mode) && !S_ISLNK(inode->i_mode)) {
171 printk("msdos_file_read: mode = %07o\n",inode->i_mode);
172 return -EINVAL;
173 }
174 if (filp->f_pos >= inode->i_size || count <= 0) return 0;
175
176
177
178
179
180
181
182
183
184 PRINTK (("#### ino %ld pos %ld size %ld count %d\n",inode->i_ino,filp->f_pos,inode->i_size,count));
185 {
186
187
188
189
190 int count_max = (filp->f_pos & (SECTOR_SIZE-1)) + count;
191 int to_reada;
192 pre.file_sector = filp->f_pos >> SECTOR_BITS;
193 to_reada = count_max / SECTOR_SIZE;
194 if (count_max & (SECTOR_SIZE-1)) to_reada++;
195 if (filp->f_reada || !MSDOS_I(inode)->i_binary){
196
197
198
199 int ahead = read_ahead[MAJOR(inode->i_dev)];
200 PRINTK (("to_reada %d ahead %d\n",to_reada,ahead));
201 if (ahead == 0) ahead = 8;
202 to_reada += ahead;
203 }
204 if (to_reada > MSDOS_PREFETCH) to_reada = MSDOS_PREFETCH;
205 pre.nblist = 0;
206 msdos_prefetch (inode,&pre,to_reada);
207 }
208 pre.nolist = 0;
209 PRINTK (("count %d ahead %d nblist %d\n",count,read_ahead[MAJOR(inode->i_dev)],pre.nblist));
210 while ((left_in_file = inode->i_size - filp->f_pos) > 0
211 && buf < end){
212 struct buffer_head *bh = pre.bhlist[pre.nolist];
213 char *data;
214 int size,offset;
215 if (bh == NULL) break;
216 pre.bhlist[pre.nolist] = NULL;
217 pre.nolist++;
218 if (pre.nolist == MSDOS_PREFETCH/2){
219 memcpy (pre.bhlist,pre.bhlist+MSDOS_PREFETCH/2
220 ,(MSDOS_PREFETCH/2)*sizeof(pre.bhlist[0]));
221 pre.nblist -= MSDOS_PREFETCH/2;
222 msdos_prefetch (inode,&pre,MSDOS_PREFETCH/2);
223 pre.nolist = 0;
224 }
225 PRINTK (("file_read pos %ld nblist %d %d %d\n",filp->f_pos,pre.nblist,pre.fetched,count));
226 wait_on_buffer(bh);
227 if (!msdos_is_uptodate(sb,bh)){
228
229 brelse (bh);
230 break;
231 }
232 offset = filp->f_pos & (SECTOR_SIZE-1);
233 data = bh->b_data + offset;
234 size = MIN(SECTOR_SIZE-offset,left_in_file);
235 if (MSDOS_I(inode)->i_binary) {
236 size = MIN(size,end-buf);
237 memcpy_tofs(buf,data,size);
238 buf += size;
239 filp->f_pos += size;
240 }else{
241 for (; size && buf < end; size--) {
242 char ch = *data++;
243 filp->f_pos++;
244 if (ch == 26){
245 filp->f_pos = inode->i_size;
246 break;
247 }else if (ch != '\r'){
248 put_user(ch,buf++);
249 }
250 }
251 }
252 brelse(bh);
253 }
254 PRINTK (("--- %d -> %d\n",count,(int)(buf-start)));
255 for (i=0; i<pre.nblist; i++) brelse (pre.bhlist[i]);
256 if (start == buf) return -EIO;
257 if (!IS_RDONLY(inode)) inode->i_atime = CURRENT_TIME;
258 filp->f_reada = 1;
259 return buf-start;
260 }
261
262
263
264
265 int msdos_file_write(
266 struct inode *inode,
267 struct file *filp,
268 const char *buf,
269 int count)
270 {
271 struct super_block *sb = inode->i_sb;
272 int sector,offset,size,left,written;
273 int error,carry;
274 const char *start;
275 char *to,ch;
276 struct buffer_head *bh;
277 int binary_mode = MSDOS_I(inode)->i_binary;
278
279 if (!inode) {
280 printk("msdos_file_write: inode = NULL\n");
281 return -EINVAL;
282 }
283
284 if (!S_ISREG(inode->i_mode) && !S_ISLNK(inode->i_mode)) {
285 printk("msdos_file_write: mode = %07o\n",inode->i_mode);
286 return -EINVAL;
287 }
288
289
290
291
292 if (filp->f_flags & O_APPEND) filp->f_pos = inode->i_size;
293 if (count <= 0) return 0;
294 error = carry = 0;
295 for (start = buf; count || carry; count -= size) {
296 while (!(sector = msdos_smap(inode,filp->f_pos >> SECTOR_BITS)))
297 if ((error = msdos_add_cluster(inode)) < 0) break;
298 if (error) {
299 msdos_truncate(inode);
300 break;
301 }
302 offset = filp->f_pos & (SECTOR_SIZE-1);
303 size = MIN(SECTOR_SIZE-offset,MAX(carry,count));
304 if (binary_mode
305 && offset == 0
306 && (size == SECTOR_SIZE
307 || filp->f_pos + size >= inode->i_size)){
308
309
310
311 if (!(bh = getblk(inode->i_dev,sector,SECTOR_SIZE))){
312 error = -EIO;
313 break;
314 }
315 }else if (!(bh = bread(inode->i_dev,sector,SECTOR_SIZE))) {
316 error = -EIO;
317 break;
318 }
319 if (binary_mode) {
320 memcpy_fromfs(bh->b_data+offset,buf,written = size);
321 buf += size;
322 }
323 else {
324 written = left = SECTOR_SIZE-offset;
325 to = (char *) bh->b_data+(filp->f_pos & (SECTOR_SIZE-1));
326 if (carry) {
327 *to++ = '\n';
328 left--;
329 carry = 0;
330 }
331 for (size = 0; size < count && left; size++) {
332 if ((ch = get_user(buf++)) == '\n') {
333 *to++ = '\r';
334 left--;
335 }
336 if (!left) carry = 1;
337 else {
338 *to++ = ch;
339 left--;
340 }
341 }
342 written -= left;
343 }
344 filp->f_pos += written;
345 if (filp->f_pos > inode->i_size) {
346 inode->i_size = filp->f_pos;
347 inode->i_dirt = 1;
348 }
349 msdos_set_uptodate(sb,bh,1);
350 mark_buffer_dirty(bh, 0);
351 brelse(bh);
352 }
353 if (start == buf)
354 return error;
355 inode->i_mtime = inode->i_ctime = CURRENT_TIME;
356 MSDOS_I(inode)->i_attrs |= ATTR_ARCH;
357 inode->i_dirt = 1;
358 return buf-start;
359 }
360
361 void msdos_truncate(struct inode *inode)
362 {
363 int cluster;
364
365 cluster = SECTOR_SIZE*MSDOS_SB(inode->i_sb)->cluster_size;
366 (void) fat_free(inode,(inode->i_size+(cluster-1))/cluster);
367 MSDOS_I(inode)->i_attrs |= ATTR_ARCH;
368 inode->i_dirt = 1;
369 }