Subversion Repositories freemyipod

Rev

Go to most recent revision | Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
69 theseven 1
/***************************************************************************
2
 *             __________               __   ___.
3
 *   Open      \______   \ ____   ____ |  | _\_ |__   _______  ___
4
 *   Source     |       _//  _ \_/ ___\|  |/ /| __ \ /  _ \  \/  /
5
 *   Jukebox    |    |   (  <_> )  \___|    < | \_\ (  <_> > <  <
6
 *   Firmware   |____|_  /\____/ \___  >__|_ \|___  /\____/__/\_ \
7
 *                     \/            \/     \/    \/            \/
8
 * $Id: file.c 26191 2010-05-20 12:59:12Z funman $
9
 *
10
 * Copyright (C) 2002 by Björn Stenberg
11
 *
12
 * This program is free software; you can redistribute it and/or
13
 * modify it under the terms of the GNU General Public License
14
 * as published by the Free Software Foundation; either version 2
15
 * of the License, or (at your option) any later version.
16
 *
17
 * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
18
 * KIND, either express or implied.
19
 *
20
 ****************************************************************************/
21
#include "global.h"
114 theseven 22
#include "libc/include/errno.h"
23
#include "libc/include/string.h"
69 theseven 24
#include "file.h"
25
#include "fat.h"
26
#include "dir.h"
27
#include "util.h"
429 theseven 28
#include "thread.h"
69 theseven 29
 
30
/*
31
  These functions provide a roughly POSIX-compatible file IO API.
32
 
33
  Since the fat32 driver only manages sectors, we maintain a one-sector
34
  cache for each open file. This way we can provide byte access without
35
  having to re-read the sector each time.
36
  The penalty is the RAM used for the cache and slightly more complex code.
37
*/
38
 
39
struct filedesc {
433 theseven 40
    unsigned char cache[SECTOR_SIZE];
69 theseven 41
    int cacheoffset; /* invariant: 0 <= cacheoffset <= SECTOR_SIZE */
42
    long fileoffset;
43
    long size;
44
    int attr;
45
    struct fat_file fatfile;
433 theseven 46
    struct filedesc* next;
47
    struct scheduler_thread* process;
69 theseven 48
    bool write;
49
    bool dirty;
50
    bool trunc;
433 theseven 51
};
69 theseven 52
 
433 theseven 53
static struct mutex file_mutex;
54
static struct filedesc* openfiles;
69 theseven 55
 
56
static int flush_cache(int fd);
57
 
58
int file_creat(const char *pathname)
59
{
60
    return open(pathname, O_WRONLY|O_CREAT|O_TRUNC, 0666);
61
}
62
 
63
static int open_internal(const char* pathname, int flags, bool use_cache)
64
{
65
    DIR* dir;
66
    struct dirent* entry;
67
    char pathnamecopy[MAX_PATH];
68
    char* name;
433 theseven 69
    struct filedesc* file;
69 theseven 70
    int rc;
71
 
72
    DEBUGF("open(\"%s\",%d)",pathname,flags);
73
 
74
    if ( pathname[0] != '/' ) {
75
        DEBUGF("'%s' is not an absolute path.", pathname);
76
        DEBUGF("Only absolute pathnames supported at the moment");
77
        errno = EINVAL;
78
        return -1;
79
    }
80
 
433 theseven 81
    file = (struct filedesc*)memalign(0x10, sizeof(struct filedesc));
82
    if (!file)
83
    {
69 theseven 84
        errno = EMFILE;
85
        return -2;
86
    }
87
    memset(file, 0, sizeof(struct filedesc));
433 theseven 88
    file->process = current_thread;
69 theseven 89
    if (flags & (O_RDWR | O_WRONLY)) {
90
        file->write = true;
91
 
92
        if (flags & O_TRUNC)
93
            file->trunc = true;
94
    }
95
 
96
    strlcpy(pathnamecopy, pathname, sizeof(pathnamecopy));
97
 
98
    /* locate filename */
99
    name=strrchr(pathnamecopy+1,'/');
100
    if ( name ) {
101
        *name = 0; 
102
        dir = opendir(pathnamecopy);
103
        *name = '/';
104
        name++;
105
    }
106
    else {
107
        dir = opendir("/");
108
        name = pathnamecopy+1;
109
    }
110
    if (!dir) {
111
        DEBUGF("Failed opening dir");
112
        errno = EIO;
433 theseven 113
        free(file);
69 theseven 114
        return -4;
115
    }
116
 
117
    if(name[0] == 0) {
118
        DEBUGF("Empty file name");
119
        errno = EINVAL;
433 theseven 120
        free(file);
69 theseven 121
        closedir(dir);
122
        return -5;
123
    }
124
 
125
    /* scan dir for name */
126
    while ((entry = readdir(dir))) {
127
        if ( !strcasecmp(name, entry->d_name) ) {
128
            fat_open(IF_MV2(dir->fatdir.file.volume,)
129
                     entry->startcluster,
130
                     &(file->fatfile),
131
                     &(dir->fatdir));
132
            file->size = file->trunc ? 0 : entry->size;
133
            file->attr = entry->attribute;
134
            break;
135
        }
136
    }
137
 
138
    if ( !entry ) {
139
        DEBUGF("Didn't find file %s",name);
140
        if ( file->write && (flags & O_CREAT) ) {
141
            rc = fat_create_file(name,
142
                                 &(file->fatfile),
143
                                 &(dir->fatdir));
144
            if (rc < 0) {
145
                DEBUGF("Couldn't create %s in %s",name,pathnamecopy);
146
                errno = EIO;
433 theseven 147
                free(file);
69 theseven 148
                closedir(dir);
149
                return rc * 10 - 6;
150
            }
151
            file->size = 0;
152
            file->attr = 0;
153
        }
154
        else {
155
            DEBUGF("Couldn't find %s in %s",name,pathnamecopy);
156
            errno = ENOENT;
433 theseven 157
            free(file);
69 theseven 158
            closedir(dir);
159
            return -7;
160
        }
161
    } else {
162
        if(file->write && (file->attr & FAT_ATTR_DIRECTORY)) {
163
            errno = EISDIR;
433 theseven 164
            free(file);
69 theseven 165
            closedir(dir);
166
            return -8;
167
        }
168
    }
169
    closedir(dir);
170
 
171
    file->cacheoffset = -1;
172
    file->fileoffset = 0;
173
 
174
    if (file->write && (flags & O_APPEND)) {
433 theseven 175
        rc = lseek((int)file,0,SEEK_END);
69 theseven 176
        if (rc < 0 )
433 theseven 177
        {
178
            free(file);
69 theseven 179
            return rc * 10 - 9;
433 theseven 180
        }
69 theseven 181
    }
182
 
433 theseven 183
    mutex_lock(&file_mutex, TIMEOUT_BLOCK);
184
    file->next = openfiles;
185
    openfiles = file;
186
    mutex_unlock(&file_mutex);
187
 
188
    return (int)file;
69 theseven 189
}
190
 
191
int file_open(const char* pathname, int flags)
192
{
193
    /* By default, use the dircache if available. */
194
    return open_internal(pathname, flags, true);
195
}
196
 
197
int close(int fd)
198
{
199
    int rc = 0;
433 theseven 200
    struct filedesc* f = (struct filedesc*)fd;
69 theseven 201
    DEBUGF("close(%d)", fd);
433 theseven 202
    if (!f)
203
    {
69 theseven 204
        errno = EBADF;
205
        return -2;
206
    }
433 theseven 207
    if (f->write)
208
    {
69 theseven 209
        rc = fsync(fd);
210
        if (rc < 0)
211
            return rc * 10 - 3;
212
    }
433 theseven 213
    mutex_lock(&file_mutex, TIMEOUT_BLOCK);
214
    if (openfiles == f) openfiles = openfiles->next;
215
    else
216
        for (f = openfiles; f; f = f->next)
217
            if ((int)(f->next) == fd)
218
                f->next = f->next->next;
219
    mutex_unlock(&file_mutex);
220
    free((void*)fd);
69 theseven 221
    return 0;
222
}
223
 
224
int close_all_of_process(struct scheduler_thread* process)
225
{
433 theseven 226
    struct filedesc* f;
227
    struct filedesc* prev;
69 theseven 228
    int closed = 0;
433 theseven 229
    mutex_lock(&file_mutex, TIMEOUT_BLOCK);
230
    while (openfiles && openfiles->process == process)
69 theseven 231
    {
433 theseven 232
        prev = openfiles;
233
        openfiles = openfiles->next;
234
        if (openfiles->write) fsync((int)openfiles);
235
        free(prev);
236
        closed++;
237
    }
238
    for (f = openfiles; f; f = f->next)
460 theseven 239
        while (f->next && f->next->process == process)
69 theseven 240
        {
460 theseven 241
            prev = f->next;
242
            f->next = f->next->next;
243
            free(prev);
69 theseven 244
            closed++;
245
        }
433 theseven 246
    mutex_unlock(&file_mutex);
69 theseven 247
    return closed; /* return how many we did */
248
}
249
 
250
int fsync(int fd)
251
{
433 theseven 252
    struct filedesc* file = (struct filedesc*)fd;
69 theseven 253
    int rc = 0;
254
 
255
    DEBUGF("fsync(%d)", fd);
256
 
433 theseven 257
    if (!file) {
69 theseven 258
        errno = EBADF;
259
        return -2;
260
    }
261
    if (file->write) {
262
        /* flush sector cache */
263
        if ( file->dirty ) {
264
            rc = flush_cache(fd);
265
            if (rc < 0)
266
            {
267
                /* when failing, try to close the file anyway */
268
                fat_closewrite(&(file->fatfile), file->size, file->attr);
269
                return rc * 10 - 3;
270
            }
271
        }
272
 
273
        /* truncate? */
274
        if (file->trunc) {
275
            rc = ftruncate(fd, file->size);
276
            if (rc < 0)
277
            {
278
                /* when failing, try to close the file anyway */
279
                fat_closewrite(&(file->fatfile), file->size, file->attr);
280
                return rc * 10 - 4;
281
            }
282
        }
283
 
284
        /* tie up all loose ends */
285
        rc = fat_closewrite(&(file->fatfile), file->size, file->attr);
286
        if (rc < 0)
287
            return rc * 10 - 5;
288
    }
289
    return 0;
290
}
291
 
292
int remove(const char* name)
293
{
294
    int rc;
295
    struct filedesc* file;
296
    /* Can't use dircache now, because we need to access the fat structures. */
297
    int fd = open_internal(name, O_WRONLY, false);
298
    if ( fd < 0 )
299
        return fd * 10 - 1;
300
 
301
    file = &openfiles[fd];
302
    rc = fat_remove(&(file->fatfile));
303
    if ( rc < 0 ) {
304
        DEBUGF("Failed removing file: %d", rc);
305
        errno = EIO;
306
        return rc * 10 - 3;
307
    }
308
 
309
    file->size = 0;
310
 
311
    rc = close(fd);
312
    if (rc<0)
313
        return rc * 10 - 4;
314
 
315
    return 0;
316
}
317
 
318
int rename(const char* path, const char* newpath)
319
{
320
    int rc, fd;
321
    DIR* dir;
322
    char* nameptr;
323
    char* dirptr;
324
    struct filedesc* file;
325
    char newpath2[MAX_PATH];
326
 
327
    /* verify new path does not already exist */
328
    /* If it is a directory, errno == EISDIR if the name exists */
329
    fd = open(newpath, O_RDONLY);
330
    if ( fd >= 0 || errno == EISDIR) {
331
        close(fd);
332
        errno = EBUSY;
333
        return -1;
334
    }
335
    close(fd);
336
 
337
    fd = open_internal(path, O_RDONLY, false);
338
    if ( fd < 0 ) {
339
        errno = EIO;
340
        return fd * 10 - 2;
341
    }
342
 
343
    /* extract new file name */
344
    nameptr = strrchr(newpath,'/');
345
    if (nameptr)
346
        nameptr++;
347
    else {
348
        close(fd);
349
        return - 3;
350
    }
351
 
352
    /* Extract new path */
353
    strcpy(newpath2, newpath);
354
 
355
    dirptr = strrchr(newpath2,'/');
356
    if(dirptr)
357
        *dirptr = 0;
358
    else {
359
        close(fd);
360
        return - 4;
361
    }
362
 
363
    dirptr = newpath2;
364
 
365
    if(strlen(dirptr) == 0) {
366
        dirptr = "/";
367
    }
368
 
369
    dir = opendir(dirptr);
370
    if(!dir) {
371
        close(fd);
372
        return - 5;
373
    }
374
 
433 theseven 375
    file = (struct filedesc*)fd;
69 theseven 376
 
377
    rc = fat_rename(&file->fatfile, &dir->fatdir, nameptr,
378
                    file->size, file->attr);
379
#ifdef HAVE_MULTIVOLUME
380
    if ( rc == -1) {
381
        close(fd);
382
        closedir(dir);
383
        DEBUGF("Failed renaming file across volumnes: %d", rc);
384
        errno = EXDEV;
385
        return -6;
386
    }
387
#endif
388
    if ( rc < 0 ) {
389
        close(fd);
390
        closedir(dir);
391
        DEBUGF("Failed renaming file: %d", rc);
392
        errno = EIO;
393
        return rc * 10 - 7;
394
    }
395
 
396
    rc = close(fd);
397
    if (rc<0) {
398
        closedir(dir);
399
        errno = EIO;
400
        return rc * 10 - 8;
401
    }
402
 
403
    rc = closedir(dir);
404
    if (rc<0) {
405
        errno = EIO;
406
        return rc * 10 - 9;
407
    }
408
 
409
    return 0;
410
}
411
 
412
int ftruncate(int fd, off_t size)
413
{
414
    int rc, sector;
433 theseven 415
    struct filedesc* file = (struct filedesc*)fd;
69 theseven 416
 
417
    sector = size / SECTOR_SIZE;
418
    if (size % SECTOR_SIZE)
419
        sector++;
420
 
421
    rc = fat_seek(&(file->fatfile), sector);
422
    if (rc < 0) {
423
        errno = EIO;
424
        return rc * 10 - 1;
425
    }
426
 
427
    rc = fat_truncate(&(file->fatfile));
428
    if (rc < 0) {
429
        errno = EIO;
430
        return rc * 10 - 2;
431
    }
432
 
433
    file->size = size;
434
 
435
    return 0;
436
}
437
 
438
static int flush_cache(int fd)
439
{
440
    int rc;
433 theseven 441
    struct filedesc* file = (struct filedesc*)fd;
69 theseven 442
    long sector = file->fileoffset / SECTOR_SIZE;
443
 
444
    DEBUGF("Flushing dirty sector cache");
445
 
446
    /* make sure we are on correct sector */
447
    rc = fat_seek(&(file->fatfile), sector);
448
    if ( rc < 0 )
449
        return rc * 10 - 3;
450
 
451
    rc = fat_readwrite(&(file->fatfile), 1, file->cache, true );
452
 
453
    if ( rc < 0 ) {
454
        if(file->fatfile.eof)
455
            errno = ENOSPC;
456
 
457
        return rc * 10 - 2;
458
    }
459
 
460
    file->dirty = false;
461
 
462
    return 0;
463
}
464
 
465
static int readwrite(int fd, void* buf, long count, bool write)
466
{
467
    long sectors;
120 theseven 468
    long i;
69 theseven 469
    long nread=0;
470
    struct filedesc* file;
120 theseven 471
    int rc, rc2;
69 theseven 472
 
433 theseven 473
    file = (struct filedesc*)fd;
69 theseven 474
 
433 theseven 475
    if (!file) {
69 theseven 476
        errno = EBADF;
477
        return -1;
478
    }
479
 
480
    if(file->attr & FAT_ATTR_DIRECTORY) {
481
        errno = EISDIR;
482
        return -1;
483
    }
484
 
485
    DEBUGF( "readwrite(%d,%lx,%ld,%s)",
486
             fd,(long)buf,count,write?"write":"read");
487
 
488
    /* attempt to read past EOF? */
489
    if (!write && count > file->size - file->fileoffset)
490
        count = file->size - file->fileoffset;
491
 
492
    /* any head bytes? */
493
    if ( file->cacheoffset != -1 ) {
494
        int offs = file->cacheoffset;
495
        int headbytes = MIN(count, SECTOR_SIZE - offs);
496
 
497
        if (write) {
498
            memcpy( file->cache + offs, buf, headbytes );
499
            file->dirty = true;
500
        }
501
        else {
502
            memcpy( buf, file->cache + offs, headbytes );
503
        }
504
 
505
        if (offs + headbytes == SECTOR_SIZE) {
506
            if (file->dirty) {
507
                rc = flush_cache(fd);
508
                if ( rc < 0 ) {
509
                    errno = EIO;
510
                    return rc * 10 - 2;
511
                }
512
            }
513
            file->cacheoffset = -1;
514
        }
515
        else {
516
            file->cacheoffset += headbytes;
517
        }
518
 
519
        nread = headbytes;
520
        count -= headbytes;
521
    }
522
 
523
    /* If the buffer has been modified, either it has been flushed already
524
     * (if (offs+headbytes == SECTOR_SIZE)...) or does not need to be (no
525
     * more data to follow in this call). Do NOT flush here. */
526
 
527
    /* read/write whole sectors right into/from the supplied buffer */
528
    sectors = count / SECTOR_SIZE;
120 theseven 529
    rc = 0;
69 theseven 530
    if ( sectors ) {
70 theseven 531
        if (((uint32_t)buf + nread) & (CACHEALIGN_SIZE - 1))
120 theseven 532
            for (i = 0; i < sectors; i++)
533
            {
534
                if (write) memcpy(file->cache, buf+nread+i*SECTOR_SIZE, SECTOR_SIZE);
535
                rc2 = fat_readwrite(&(file->fatfile), 1, file->cache, write );
536
                if (rc2 < 0)
537
                {
538
                    rc = rc2;
539
                    break;
540
                }
541
                else rc += rc2;
542
                if (!write) memcpy(buf+nread+i*SECTOR_SIZE, file->cache, SECTOR_SIZE);
543
            }
69 theseven 544
        else rc = fat_readwrite(&(file->fatfile), sectors, (unsigned char*)buf+nread, write );
545
        if ( rc < 0 ) {
546
            DEBUGF("Failed read/writing %ld sectors",sectors);
547
            errno = EIO;
548
            if(write && file->fatfile.eof) {
549
                DEBUGF("No space left on device");
550
                errno = ENOSPC;
551
            } else {
552
                file->fileoffset += nread;
553
            }
554
            file->cacheoffset = -1;
555
            /* adjust file size to length written */
556
            if ( write && file->fileoffset > file->size )
557
            {
558
                file->size = file->fileoffset;
559
            }
560
            return nread ? nread : rc * 10 - 4;
561
        }
562
        else {
563
            if ( rc > 0 ) {
564
                nread += rc * SECTOR_SIZE;
565
                count -= sectors * SECTOR_SIZE;
566
 
567
                /* if eof, skip tail bytes */
568
                if ( rc < sectors )
569
                    count = 0;
570
            }
571
            else {
572
                /* eof */
573
                count=0;
574
            }
575
 
576
            file->cacheoffset = -1;
577
        }
578
    }
579
 
580
    /* any tail bytes? */
581
    if ( count ) {
582
        if (write) {
583
            if ( file->fileoffset + nread < file->size ) {
584
                /* sector is only partially filled. copy-back from disk */
585
                DEBUGF("Copy-back tail cache");
586
                rc = fat_readwrite(&(file->fatfile), 1, file->cache, false );
587
                if ( rc < 0 ) {
588
                    DEBUGF("Failed writing");
589
                    errno = EIO;
590
                    file->fileoffset += nread;
591
                    file->cacheoffset = -1;
592
                    /* adjust file size to length written */
593
                    if ( file->fileoffset > file->size )
594
                    {
595
                        file->size = file->fileoffset;
596
                    }
597
                    return nread ? nread : rc * 10 - 5;
598
                }
599
                /* seek back one sector to put file position right */
600
                rc = fat_seek(&(file->fatfile), 
601
                              (file->fileoffset + nread) /
602
                              SECTOR_SIZE);
603
                if ( rc < 0 ) {
604
                    DEBUGF("fat_seek() failed");
605
                    errno = EIO;
606
                    file->fileoffset += nread;
607
                    file->cacheoffset = -1;
608
                    /* adjust file size to length written */
609
                    if ( file->fileoffset > file->size )
610
                    {
611
                        file->size = file->fileoffset;
612
                    }
613
                    return nread ? nread : rc * 10 - 6;
614
                }
615
            }
616
            memcpy( file->cache, (unsigned char*)buf + nread, count );
617
            file->dirty = true;
618
        }
619
        else {
620
            rc = fat_readwrite(&(file->fatfile), 1, file->cache,false);
621
            if (rc < 1 ) {
622
                DEBUGF("Failed caching sector");
623
                errno = EIO;
624
                file->fileoffset += nread;
625
                file->cacheoffset = -1;
626
                return nread ? nread : rc * 10 - 7;
627
            }
628
            memcpy( (unsigned char*)buf + nread, file->cache, count );
629
        }
630
 
631
        nread += count;
632
        file->cacheoffset = count;
633
    }
634
 
635
    file->fileoffset += nread;
636
    DEBUGF("fileoffset: %ld", file->fileoffset);
637
 
638
    /* adjust file size to length written */
639
    if ( write && file->fileoffset > file->size )
640
    {
641
        file->size = file->fileoffset;
642
    }
643
 
644
    return nread;
645
}
646
 
647
ssize_t write(int fd, const void* buf, size_t count)
648
{
433 theseven 649
    if (!((struct filedesc*)fd)->write) {
69 theseven 650
        errno = EACCES;
651
        return -1;
652
    }
653
    return readwrite(fd, (void *)buf, count, true);
654
}
655
 
656
ssize_t read(int fd, void* buf, size_t count)
657
{
658
    return readwrite(fd, buf, count, false);
659
}
660
 
661
 
662
off_t lseek(int fd, off_t offset, int whence)
663
{
664
    off_t pos;
665
    long newsector;
666
    long oldsector;
667
    int sectoroffset;
668
    int rc;
433 theseven 669
    struct filedesc* file = (struct filedesc*)fd;
69 theseven 670
 
671
    DEBUGF("lseek(%d,%ld,%d)",fd,offset,whence);
672
 
433 theseven 673
    if (!file) {
69 theseven 674
        errno = EBADF;
675
        return -1;
676
    }
677
 
678
    switch ( whence ) {
679
        case SEEK_SET:
680
            pos = offset;
681
            break;
682
 
683
        case SEEK_CUR:
684
            pos = file->fileoffset + offset;
685
            break;
686
 
687
        case SEEK_END:
688
            pos = file->size + offset;
689
            break;
690
 
691
        default:
692
            errno = EINVAL;
693
            return -2;
694
    }
695
    if ((pos < 0) || (pos > file->size)) {
696
        errno = EINVAL;
697
        return -3;
698
    }
699
 
700
    /* new sector? */
701
    newsector = pos / SECTOR_SIZE;
702
    oldsector = file->fileoffset / SECTOR_SIZE;
703
    sectoroffset = pos % SECTOR_SIZE;
704
 
705
    if ( (newsector != oldsector) ||
706
         ((file->cacheoffset==-1) && sectoroffset) ) {
707
 
708
        if ( newsector != oldsector ) {
709
            if (file->dirty) {
710
                rc = flush_cache(fd);
711
                if (rc < 0)
712
                    return rc * 10 - 5;
713
            }
714
 
715
            rc = fat_seek(&(file->fatfile), newsector);
716
            if ( rc < 0 ) {
717
                errno = EIO;
718
                return rc * 10 - 4;
719
            }
720
        }
721
        if ( sectoroffset ) {
722
            rc = fat_readwrite(&(file->fatfile), 1, file->cache ,false);
723
            if ( rc < 0 ) {
724
                errno = EIO;
725
                return rc * 10 - 6;
726
            }
727
            file->cacheoffset = sectoroffset;
728
        }
729
        else
730
            file->cacheoffset = -1;
731
    }
732
    else
733
        if ( file->cacheoffset != -1 )
734
            file->cacheoffset = sectoroffset;
735
 
736
    file->fileoffset = pos;
737
 
738
    return pos;
739
}
740
 
741
off_t filesize(int fd)
742
{
433 theseven 743
    struct filedesc* file = (struct filedesc*)fd;
69 theseven 744
 
433 theseven 745
    if (!file) {
69 theseven 746
        errno = EBADF;
747
        return -1;
748
    }
749
 
750
    return file->size;
751
}
752
 
753
 
754
#ifdef HAVE_HOTSWAP
755
/* release all file handles on a given volume "by force", to avoid leaks */
756
int release_files(int volume)
757
{
433 theseven 758
    struct filedesc* prev;
69 theseven 759
    int closed = 0;
433 theseven 760
    mutex_lock(&file_mutex, TIMEOUT_BLOCK);
761
#ifdef HAVE_MULTIVOLUME
762
    struct filedesc* f;
763
    while (openfiles && openfiles->fatfile.volume == volume)
69 theseven 764
    {
433 theseven 765
        prev = openfiles;
766
        openfiles = openfiles->next;
767
        free(prev);
768
        closed++;
769
    }
770
    for (f = openfiles; f; f = f->next)
460 theseven 771
        while (f->next && f->next->fatfile.volume == volume)
69 theseven 772
        {
460 theseven 773
            prev = f->next;
774
            f->next = f->next->next;
775
            free(prev);
69 theseven 776
            closed++;
777
        }
433 theseven 778
#else
779
    (void)volume;
780
    while (openfiles)
781
    {
782
        prev = openfiles;
783
        openfiles = openfiles->next;
784
        free(prev);
785
        closed++;
786
    }
787
#endif
788
    mutex_unlock(&file_mutex);
69 theseven 789
    return closed; /* return how many we did */
790
}
791
#endif /* #ifdef HAVE_HOTSWAP */