Subversion Repositories HelenOS

Rev

Rev 3425 | Rev 3597 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 3425 Rev 3536
Line 34... Line 34...
34
 * @file    fat_ops.c
34
 * @file    fat_ops.c
35
 * @brief   Implementation of VFS operations for the FAT file system server.
35
 * @brief   Implementation of VFS operations for the FAT file system server.
36
 */
36
 */
37
 
37
 
38
#include "fat.h"
38
#include "fat.h"
-
 
39
#include "fat_dentry.h"
-
 
40
#include "fat_fat.h"
39
#include "../../vfs/vfs.h"
41
#include "../../vfs/vfs.h"
40
#include <libfs.h>
42
#include <libfs.h>
-
 
43
#include <libblock.h>
41
#include <ipc/ipc.h>
44
#include <ipc/ipc.h>
42
#include <ipc/services.h>
45
#include <ipc/services.h>
43
#include <ipc/devmap.h>
46
#include <ipc/devmap.h>
44
#include <async.h>
47
#include <async.h>
45
#include <errno.h>
48
#include <errno.h>
Line 48... Line 51...
48
#include <libadt/hash_table.h>
51
#include <libadt/hash_table.h>
49
#include <libadt/list.h>
52
#include <libadt/list.h>
50
#include <assert.h>
53
#include <assert.h>
51
#include <futex.h>
54
#include <futex.h>
52
#include <sys/mman.h>
55
#include <sys/mman.h>
53
 
-
 
54
#define BS_BLOCK        0
56
#include <align.h>
55
#define BS_SIZE         512
-
 
56
 
57
 
57
/** Futex protecting the list of cached free FAT nodes. */
58
/** Futex protecting the list of cached free FAT nodes. */
58
static futex_t ffn_futex = FUTEX_INITIALIZER;
59
static futex_t ffn_futex = FUTEX_INITIALIZER;
59
 
60
 
60
/** List of cached free FAT nodes. */
61
/** List of cached free FAT nodes. */
61
static LIST_INITIALIZE(ffn_head);
62
static LIST_INITIALIZE(ffn_head);
62
 
63
 
63
#define FAT_NAME_LEN        8
-
 
64
#define FAT_EXT_LEN     3
-
 
65
 
-
 
66
#define FAT_PAD         ' ' 
-
 
67
 
-
 
68
#define FAT_DENTRY_UNUSED   0x00
-
 
69
#define FAT_DENTRY_E5_ESC   0x05
-
 
70
#define FAT_DENTRY_DOT      0x2e
-
 
71
#define FAT_DENTRY_ERASED   0xe5
-
 
72
 
-
 
73
#define min(a, b)       ((a) < (b) ? (a) : (b))
-
 
74
 
-
 
75
static void dentry_name_canonify(fat_dentry_t *d, char *buf)
-
 
76
{
-
 
77
    int i;
-
 
78
 
-
 
79
    for (i = 0; i < FAT_NAME_LEN; i++) {
-
 
80
        if (d->name[i] == FAT_PAD)
-
 
81
            break;
-
 
82
        if (d->name[i] == FAT_DENTRY_E5_ESC)
-
 
83
            *buf++ = 0xe5;
-
 
84
        else
-
 
85
            *buf++ = d->name[i];
-
 
86
    }
-
 
87
    if (d->ext[0] != FAT_PAD)
-
 
88
        *buf++ = '.';
-
 
89
    for (i = 0; i < FAT_EXT_LEN; i++) {
-
 
90
        if (d->ext[i] == FAT_PAD) {
-
 
91
            *buf = '\0';
-
 
92
            return;
-
 
93
        }
-
 
94
        if (d->ext[i] == FAT_DENTRY_E5_ESC)
-
 
95
            *buf++ = 0xe5;
-
 
96
        else
-
 
97
            *buf++ = d->ext[i];
-
 
98
    }
-
 
99
    *buf = '\0';
-
 
100
}
-
 
101
 
-
 
102
static int dev_phone = -1;      /* FIXME */
-
 
103
static void *dev_buffer = NULL;     /* FIXME */
-
 
104
 
-
 
105
/* TODO move somewhere else */
-
 
106
typedef struct {
-
 
107
    void *data;
-
 
108
    size_t size;
-
 
109
} block_t;
-
 
110
 
-
 
111
static block_t *block_get(dev_handle_t dev_handle, off_t offset, size_t bs)
-
 
112
{
-
 
113
    /* FIXME */
-
 
114
    block_t *b;
-
 
115
    off_t bufpos = 0;
-
 
116
    size_t buflen = 0;
-
 
117
    off_t pos = offset * bs;
-
 
118
 
-
 
119
    assert(dev_phone != -1);
-
 
120
    assert(dev_buffer);
-
 
121
 
-
 
122
    b = malloc(sizeof(block_t));
-
 
123
    if (!b)
-
 
124
        return NULL;
-
 
125
   
-
 
126
    b->data = malloc(bs);
-
 
127
    if (!b->data) {
-
 
128
        free(b);
-
 
129
        return NULL;
-
 
130
    }
-
 
131
    b->size = bs;
-
 
132
 
-
 
133
    if (!libfs_blockread(dev_phone, dev_buffer, &bufpos, &buflen, &pos,
-
 
134
        b->data, bs, bs)) {
-
 
135
        free(b->data);
-
 
136
        free(b);
-
 
137
        return NULL;
-
 
138
    }
-
 
139
 
-
 
140
    return b;
-
 
141
}
-
 
142
 
-
 
143
static void block_put(block_t *block)
-
 
144
{
-
 
145
    /* FIXME */
-
 
146
    free(block->data);
-
 
147
    free(block);
-
 
148
}
-
 
149
 
-
 
150
#define FAT_BS(b)       ((fat_bs_t *)((b)->data))
-
 
151
 
-
 
152
#define FAT_CLST_RES0   0x0000
-
 
153
#define FAT_CLST_RES1   0x0001
-
 
154
#define FAT_CLST_FIRST  0x0002
-
 
155
#define FAT_CLST_BAD    0xfff7
-
 
156
#define FAT_CLST_LAST1  0xfff8
-
 
157
#define FAT_CLST_LAST8  0xffff
-
 
158
 
-
 
159
/* internally used to mark root directory's parent */
-
 
160
#define FAT_CLST_ROOTPAR    FAT_CLST_RES0
-
 
161
/* internally used to mark root directory */
-
 
162
#define FAT_CLST_ROOT       FAT_CLST_RES1
-
 
163
 
-
 
164
#define fat_block_get(np, off) \
-
 
165
    _fat_block_get((np)->idx->dev_handle, (np)->firstc, (off))
-
 
166
 
-
 
167
static block_t *
-
 
168
_fat_block_get(dev_handle_t dev_handle, fat_cluster_t firstc, off_t offset)
-
 
169
{
-
 
170
    block_t *bb;
-
 
171
    block_t *b;
-
 
172
    unsigned bps;
-
 
173
    unsigned spc;
-
 
174
    unsigned rscnt;     /* block address of the first FAT */
-
 
175
    unsigned fatcnt;
-
 
176
    unsigned rde;
-
 
177
    unsigned rds;       /* root directory size */
-
 
178
    unsigned sf;
-
 
179
    unsigned ssa;       /* size of the system area */
-
 
180
    unsigned clusters;
-
 
181
    fat_cluster_t clst = firstc;
-
 
182
    unsigned i;
-
 
183
 
-
 
184
    bb = block_get(dev_handle, BS_BLOCK, BS_SIZE);
-
 
185
    bps = uint16_t_le2host(FAT_BS(bb)->bps);
-
 
186
    spc = FAT_BS(bb)->spc;
-
 
187
    rscnt = uint16_t_le2host(FAT_BS(bb)->rscnt);
-
 
188
    fatcnt = FAT_BS(bb)->fatcnt;
-
 
189
    rde = uint16_t_le2host(FAT_BS(bb)->root_ent_max);
-
 
190
    sf = uint16_t_le2host(FAT_BS(bb)->sec_per_fat);
-
 
191
    block_put(bb);
-
 
192
 
-
 
193
    rds = (sizeof(fat_dentry_t) * rde) / bps;
-
 
194
    rds += ((sizeof(fat_dentry_t) * rde) % bps != 0);
-
 
195
    ssa = rscnt + fatcnt * sf + rds;
-
 
196
 
-
 
197
    if (firstc == FAT_CLST_ROOT) {
-
 
198
        /* root directory special case */
-
 
199
        assert(offset < rds);
-
 
200
        b = block_get(dev_handle, rscnt + fatcnt * sf + offset, bps);
-
 
201
        return b;
-
 
202
    }
-
 
203
 
-
 
204
    clusters = offset / spc;
-
 
205
    for (i = 0; i < clusters; i++) {
-
 
206
        unsigned fsec;  /* sector offset relative to FAT1 */
-
 
207
        unsigned fidx;  /* FAT1 entry index */
-
 
208
 
-
 
209
        assert(clst >= FAT_CLST_FIRST && clst < FAT_CLST_BAD);
-
 
210
        fsec = (clst * sizeof(fat_cluster_t)) / bps;
-
 
211
        fidx = clst % (bps / sizeof(fat_cluster_t));
-
 
212
        /* read FAT1 */
-
 
213
        b = block_get(dev_handle, rscnt + fsec, bps);
-
 
214
        clst = uint16_t_le2host(((fat_cluster_t *)b->data)[fidx]);
-
 
215
        assert(clst != FAT_CLST_BAD);
-
 
216
        assert(clst < FAT_CLST_LAST1);
-
 
217
        block_put(b);
-
 
218
    }
-
 
219
 
-
 
220
    b = block_get(dev_handle, ssa + (clst - FAT_CLST_FIRST) * spc +
-
 
221
        offset % spc, bps);
-
 
222
 
-
 
223
    return b;
-
 
224
}
-
 
225
 
-
 
226
/** Return number of blocks allocated to a file.
-
 
227
 *
-
 
228
 * @param dev_handle    Device handle of the device with the file.
-
 
229
 * @param firstc    First cluster of the file.
-
 
230
 *
-
 
231
 * @return      Number of blocks allocated to the file.
-
 
232
 */
-
 
233
static uint16_t
-
 
234
_fat_blcks_get(dev_handle_t dev_handle, fat_cluster_t firstc)
-
 
235
{
-
 
236
    block_t *bb;
-
 
237
    block_t *b;
-
 
238
    unsigned bps;
-
 
239
    unsigned spc;
-
 
240
    unsigned rscnt;     /* block address of the first FAT */
-
 
241
    unsigned clusters = 0;
-
 
242
    fat_cluster_t clst = firstc;
-
 
243
 
-
 
244
    bb = block_get(dev_handle, BS_BLOCK, BS_SIZE);
-
 
245
    bps = uint16_t_le2host(FAT_BS(bb)->bps);
-
 
246
    spc = FAT_BS(bb)->spc;
-
 
247
    rscnt = uint16_t_le2host(FAT_BS(bb)->rscnt);
-
 
248
    block_put(bb);
-
 
249
 
-
 
250
    if (firstc == FAT_CLST_RES0) {
-
 
251
        /* No space allocated to the file. */
-
 
252
        return 0;
-
 
253
    }
-
 
254
 
-
 
255
    while (clst < FAT_CLST_LAST1) {
-
 
256
        unsigned fsec;  /* sector offset relative to FAT1 */
-
 
257
        unsigned fidx;  /* FAT1 entry index */
-
 
258
 
-
 
259
        assert(clst >= FAT_CLST_FIRST);
-
 
260
        fsec = (clst * sizeof(fat_cluster_t)) / bps;
-
 
261
        fidx = clst % (bps / sizeof(fat_cluster_t));
-
 
262
        /* read FAT1 */
-
 
263
        b = block_get(dev_handle, rscnt + fsec, bps);
-
 
264
        clst = uint16_t_le2host(((fat_cluster_t *)b->data)[fidx]);
-
 
265
        assert(clst != FAT_CLST_BAD);
-
 
266
        block_put(b);
-
 
267
        clusters++;
-
 
268
    }
-
 
269
 
-
 
270
    return clusters * spc;
-
 
271
}
-
 
272
 
-
 
273
static void fat_node_initialize(fat_node_t *node)
64
static void fat_node_initialize(fat_node_t *node)
274
{
65
{
275
    futex_initialize(&node->lock, 1);
66
    futex_initialize(&node->lock, 1);
276
    node->idx = NULL;
67
    node->idx = NULL;
277
    node->type = 0;
68
    node->type = 0;
Line 280... Line 71...
280
    node->lnkcnt = 0;
71
    node->lnkcnt = 0;
281
    node->refcnt = 0;
72
    node->refcnt = 0;
282
    node->dirty = false;
73
    node->dirty = false;
283
}
74
}
284
 
75
 
285
static uint16_t fat_bps_get(dev_handle_t dev_handle)
76
static void fat_node_sync(fat_node_t *node)
286
{
77
{
287
    block_t *bb;
78
    block_t *b;
-
 
79
    fat_bs_t *bs;
-
 
80
    fat_dentry_t *d;
288
    uint16_t bps;
81
    uint16_t bps;
-
 
82
    unsigned dps;
289
   
83
   
290
    bb = block_get(dev_handle, BS_BLOCK, BS_SIZE);
-
 
291
    assert(bb != NULL);
84
    assert(node->dirty);
292
    bps = uint16_t_le2host(FAT_BS(bb)->bps);
-
 
293
    block_put(bb);
-
 
294
 
85
 
-
 
86
    bs = block_bb_get(node->idx->dev_handle);
295
    return bps;
87
    bps = uint16_t_le2host(bs->bps);
-
 
88
    dps = bps / sizeof(fat_dentry_t);
296
}
89
   
-
 
90
    /* Read the block that contains the dentry of interest. */
-
 
91
    b = _fat_block_get(bs, node->idx->dev_handle, node->idx->pfc,
-
 
92
        (node->idx->pdi * sizeof(fat_dentry_t)) / bps);
297
 
93
 
298
typedef enum {
-
 
299
    FAT_DENTRY_SKIP,
-
 
300
    FAT_DENTRY_LAST,
-
 
301
    FAT_DENTRY_VALID
-
 
302
} fat_dentry_clsf_t;
94
    d = ((fat_dentry_t *)b->data) + (node->idx->pdi % dps);
303
 
95
 
304
static fat_dentry_clsf_t fat_classify_dentry(fat_dentry_t *d)
-
 
305
{
-
 
306
    if (d->attr & FAT_ATTR_VOLLABEL) {
-
 
307
        /* volume label entry */
-
 
308
        return FAT_DENTRY_SKIP;
-
 
309
    }
-
 
310
    if (d->name[0] == FAT_DENTRY_ERASED) {
-
 
311
        /* not-currently-used entry */
96
    d->firstc = host2uint16_t_le(node->firstc);
312
        return FAT_DENTRY_SKIP;
-
 
313
    }
-
 
314
    if (d->name[0] == FAT_DENTRY_UNUSED) {
-
 
315
        /* never used entry */
-
 
316
        return FAT_DENTRY_LAST;
-
 
317
    }
-
 
318
    if (d->name[0] == FAT_DENTRY_DOT) {
97
    if (node->type == FAT_FILE)
319
        /*
-
 
320
         * Most likely '.' or '..'.
98
        d->size = host2uint32_t_le(node->size);
321
         * It cannot occur in a regular file name.
99
    /* TODO: update other fields? (e.g time fields, attr field) */
322
         */
-
 
323
        return FAT_DENTRY_SKIP;
-
 
324
    }
100
   
325
    return FAT_DENTRY_VALID;
-
 
326
}
-
 
327
 
-
 
328
static void fat_node_sync(fat_node_t *node)
101
    b->dirty = true;        /* need to sync block */
329
{
-
 
330
    /* TODO */
102
    block_put(b);
331
}
103
}
332
 
104
 
333
/** Internal version of fat_node_get().
105
/** Internal version of fat_node_get().
334
 *
106
 *
335
 * @param idxp      Locked index structure.
107
 * @param idxp      Locked index structure.
336
 */
108
 */
337
static void *fat_node_get_core(fat_idx_t *idxp)
109
static void *fat_node_get_core(fat_idx_t *idxp)
338
{
110
{
339
    block_t *b;
111
    block_t *b;
-
 
112
    fat_bs_t *bs;
340
    fat_dentry_t *d;
113
    fat_dentry_t *d;
341
    fat_node_t *nodep = NULL;
114
    fat_node_t *nodep = NULL;
342
    unsigned bps;
115
    unsigned bps;
343
    unsigned dps;
116
    unsigned dps;
344
 
117
 
Line 387... Line 160...
387
        if (!nodep)
160
        if (!nodep)
388
            return NULL;
161
            return NULL;
389
    }
162
    }
390
    fat_node_initialize(nodep);
163
    fat_node_initialize(nodep);
391
 
164
 
392
    bps = fat_bps_get(idxp->dev_handle);
165
    bs = block_bb_get(idxp->dev_handle);
-
 
166
    bps = uint16_t_le2host(bs->bps);
393
    dps = bps / sizeof(fat_dentry_t);
167
    dps = bps / sizeof(fat_dentry_t);
394
 
168
 
395
    /* Read the block that contains the dentry of interest. */
169
    /* Read the block that contains the dentry of interest. */
396
    b = _fat_block_get(idxp->dev_handle, idxp->pfc,
170
    b = _fat_block_get(bs, idxp->dev_handle, idxp->pfc,
397
        (idxp->pdi * sizeof(fat_dentry_t)) / bps);
171
        (idxp->pdi * sizeof(fat_dentry_t)) / bps);
398
    assert(b);
172
    assert(b);
399
 
173
 
400
    d = ((fat_dentry_t *)b->data) + (idxp->pdi % dps);
174
    d = ((fat_dentry_t *)b->data) + (idxp->pdi % dps);
401
    if (d->attr & FAT_ATTR_SUBDIR) {
175
    if (d->attr & FAT_ATTR_SUBDIR) {
Line 408... Line 182...
408
        /*
182
        /*
409
         * Unfortunately, the 'size' field of the FAT dentry is not
183
         * Unfortunately, the 'size' field of the FAT dentry is not
410
         * defined for the directory entry type. We must determine the
184
         * defined for the directory entry type. We must determine the
411
         * size of the directory by walking the FAT.
185
         * size of the directory by walking the FAT.
412
         */
186
         */
413
        nodep->size = bps * _fat_blcks_get(idxp->dev_handle,
187
        nodep->size = bps * _fat_blcks_get(bs, idxp->dev_handle,
414
            uint16_t_le2host(d->firstc));
188
            uint16_t_le2host(d->firstc), NULL);
415
    } else {
189
    } else {
416
        nodep->type = FAT_FILE;
190
        nodep->type = FAT_FILE;
417
        nodep->size = uint32_t_le2host(d->size);
191
        nodep->size = uint32_t_le2host(d->size);
418
    }
192
    }
419
    nodep->firstc = uint16_t_le2host(d->firstc);
193
    nodep->firstc = uint16_t_le2host(d->firstc);
Line 477... Line 251...
477
    return ENOTSUP; /* not supported at the moment */
251
    return ENOTSUP; /* not supported at the moment */
478
}
252
}
479
 
253
 
480
static void *fat_match(void *prnt, const char *component)
254
static void *fat_match(void *prnt, const char *component)
481
{
255
{
-
 
256
    fat_bs_t *bs;
482
    fat_node_t *parentp = (fat_node_t *)prnt;
257
    fat_node_t *parentp = (fat_node_t *)prnt;
483
    char name[FAT_NAME_LEN + 1 + FAT_EXT_LEN + 1];
258
    char name[FAT_NAME_LEN + 1 + FAT_EXT_LEN + 1];
484
    unsigned i, j;
259
    unsigned i, j;
485
    unsigned bps;       /* bytes per sector */
260
    unsigned bps;       /* bytes per sector */
486
    unsigned dps;       /* dentries per sector */
261
    unsigned dps;       /* dentries per sector */
487
    unsigned blocks;
262
    unsigned blocks;
488
    fat_dentry_t *d;
263
    fat_dentry_t *d;
489
    block_t *b;
264
    block_t *b;
490
 
265
 
491
    futex_down(&parentp->idx->lock);
266
    futex_down(&parentp->idx->lock);
492
    bps = fat_bps_get(parentp->idx->dev_handle);
267
    bs = block_bb_get(parentp->idx->dev_handle);
-
 
268
    bps = uint16_t_le2host(bs->bps);
493
    dps = bps / sizeof(fat_dentry_t);
269
    dps = bps / sizeof(fat_dentry_t);
494
    blocks = parentp->size / bps + (parentp->size % bps != 0);
270
    blocks = parentp->size / bps;
495
    for (i = 0; i < blocks; i++) {
271
    for (i = 0; i < blocks; i++) {
496
        unsigned dentries;
-
 
497
       
-
 
498
        b = fat_block_get(parentp, i);
272
        b = fat_block_get(bs, parentp, i);
499
        dentries = (i == blocks - 1) ?
-
 
500
            parentp->size % sizeof(fat_dentry_t) :
-
 
501
            dps;
-
 
502
        for (j = 0; j < dentries; j++) {
273
        for (j = 0; j < dps; j++) {
503
            d = ((fat_dentry_t *)b->data) + j;
274
            d = ((fat_dentry_t *)b->data) + j;
504
            switch (fat_classify_dentry(d)) {
275
            switch (fat_classify_dentry(d)) {
505
            case FAT_DENTRY_SKIP:
276
            case FAT_DENTRY_SKIP:
506
                continue;
277
                continue;
507
            case FAT_DENTRY_LAST:
278
            case FAT_DENTRY_LAST:
Line 540... Line 311...
540
                return node;
311
                return node;
541
            }
312
            }
542
        }
313
        }
543
        block_put(b);
314
        block_put(b);
544
    }
315
    }
-
 
316
 
545
    futex_up(&parentp->idx->lock);
317
    futex_up(&parentp->idx->lock);
546
    return NULL;
318
    return NULL;
547
}
319
}
548
 
320
 
549
static fs_index_t fat_index_get(void *node)
321
static fs_index_t fat_index_get(void *node)
Line 564... Line 336...
564
    return ((fat_node_t *)node)->lnkcnt;
336
    return ((fat_node_t *)node)->lnkcnt;
565
}
337
}
566
 
338
 
567
static bool fat_has_children(void *node)
339
static bool fat_has_children(void *node)
568
{
340
{
-
 
341
    fat_bs_t *bs;
569
    fat_node_t *nodep = (fat_node_t *)node;
342
    fat_node_t *nodep = (fat_node_t *)node;
570
    unsigned bps;
343
    unsigned bps;
571
    unsigned dps;
344
    unsigned dps;
572
    unsigned blocks;
345
    unsigned blocks;
573
    block_t *b;
346
    block_t *b;
574
    unsigned i, j;
347
    unsigned i, j;
575
 
348
 
576
    if (nodep->type != FAT_DIRECTORY)
349
    if (nodep->type != FAT_DIRECTORY)
577
        return false;
350
        return false;
578
 
351
   
579
    futex_down(&nodep->idx->lock);
352
    futex_down(&nodep->idx->lock);
580
    bps = fat_bps_get(nodep->idx->dev_handle);
353
    bs = block_bb_get(nodep->idx->dev_handle);
-
 
354
    bps = uint16_t_le2host(bs->bps);
581
    dps = bps / sizeof(fat_dentry_t);
355
    dps = bps / sizeof(fat_dentry_t);
582
 
356
 
583
    blocks = nodep->size / bps + (nodep->size % bps != 0);
357
    blocks = nodep->size / bps;
584
 
358
 
585
    for (i = 0; i < blocks; i++) {
359
    for (i = 0; i < blocks; i++) {
586
        unsigned dentries;
-
 
587
        fat_dentry_t *d;
360
        fat_dentry_t *d;
588
   
361
   
589
        b = fat_block_get(nodep, i);
362
        b = fat_block_get(bs, nodep, i);
590
        dentries = (i == blocks - 1) ?
-
 
591
            nodep->size % sizeof(fat_dentry_t) :
-
 
592
            dps;
-
 
593
        for (j = 0; j < dentries; j++) {
363
        for (j = 0; j < dps; j++) {
594
            d = ((fat_dentry_t *)b->data) + j;
364
            d = ((fat_dentry_t *)b->data) + j;
595
            switch (fat_classify_dentry(d)) {
365
            switch (fat_classify_dentry(d)) {
596
            case FAT_DENTRY_SKIP:
366
            case FAT_DENTRY_SKIP:
597
                continue;
367
                continue;
598
            case FAT_DENTRY_LAST:
368
            case FAT_DENTRY_LAST:
Line 656... Line 426...
656
};
426
};
657
 
427
 
658
void fat_mounted(ipc_callid_t rid, ipc_call_t *request)
428
void fat_mounted(ipc_callid_t rid, ipc_call_t *request)
659
{
429
{
660
    dev_handle_t dev_handle = (dev_handle_t) IPC_GET_ARG1(*request);
430
    dev_handle_t dev_handle = (dev_handle_t) IPC_GET_ARG1(*request);
661
    block_t *bb;
431
    fat_bs_t *bs;
662
    uint16_t bps;
432
    uint16_t bps;
663
    uint16_t rde;
433
    uint16_t rde;
664
    int rc;
434
    int rc;
665
 
435
 
666
    /*
-
 
667
     * For now, we don't bother to remember dev_handle, dev_phone or
-
 
668
     * dev_buffer in some data structure. We use global variables because we
-
 
669
     * know there will be at most one mount on this file system.
-
 
670
     * Of course, this is a huge TODO item.
436
    /* initialize libblock */
671
     */
-
 
672
    dev_buffer = mmap(NULL, BS_SIZE, PROTO_READ | PROTO_WRITE,
437
    rc = block_init(dev_handle, BS_SIZE, BS_BLOCK * BS_SIZE, BS_SIZE);
673
        MAP_ANONYMOUS | MAP_PRIVATE, 0, 0);
-
 
674
   
-
 
675
    if (!dev_buffer) {
-
 
676
        ipc_answer_0(rid, ENOMEM);
-
 
677
        return;
-
 
678
    }
-
 
679
 
-
 
680
    dev_phone = ipc_connect_me_to(PHONE_NS, SERVICE_DEVMAP,
-
 
681
        DEVMAP_CONNECT_TO_DEVICE, dev_handle);
-
 
682
 
-
 
683
    if (dev_phone < 0) {
-
 
684
        munmap(dev_buffer, BS_SIZE);
-
 
685
        ipc_answer_0(rid, dev_phone);
-
 
686
        return;
-
 
687
    }
-
 
688
 
-
 
689
    rc = ipc_share_out_start(dev_phone, dev_buffer,
-
 
690
        AS_AREA_READ | AS_AREA_WRITE);
-
 
691
    if (rc != EOK) {
438
    if (rc != EOK) {
692
            munmap(dev_buffer, BS_SIZE);
-
 
693
        ipc_answer_0(rid, rc);
439
        ipc_answer_0(rid, 0);
694
        return;
440
        return;
695
    }
441
    }
696
 
442
 
-
 
443
    /* get the buffer with the boot sector */
-
 
444
    bs = block_bb_get(dev_handle);
-
 
445
   
697
    /* Read the number of root directory entries. */
446
    /* Read the number of root directory entries. */
698
    bb = block_get(dev_handle, BS_BLOCK, BS_SIZE);
-
 
699
    bps = uint16_t_le2host(FAT_BS(bb)->bps);
447
    bps = uint16_t_le2host(bs->bps);
700
    rde = uint16_t_le2host(FAT_BS(bb)->root_ent_max);
448
    rde = uint16_t_le2host(bs->root_ent_max);
701
    block_put(bb);
-
 
702
 
449
 
703
    if (bps != BS_SIZE) {
450
    if (bps != BS_SIZE) {
704
        munmap(dev_buffer, BS_SIZE);
451
        block_fini(dev_handle);
705
        ipc_answer_0(rid, ENOTSUP);
452
        ipc_answer_0(rid, ENOTSUP);
706
        return;
453
        return;
707
    }
454
    }
708
 
455
 
709
    rc = fat_idx_init_by_dev_handle(dev_handle);
456
    rc = fat_idx_init_by_dev_handle(dev_handle);
710
    if (rc != EOK) {
457
    if (rc != EOK) {
711
            munmap(dev_buffer, BS_SIZE);
458
        block_fini(dev_handle);
712
        ipc_answer_0(rid, rc);
459
        ipc_answer_0(rid, rc);
713
        return;
460
        return;
714
    }
461
    }
715
 
462
 
716
    /* Initialize the root node. */
463
    /* Initialize the root node. */
717
    fat_node_t *rootp = (fat_node_t *)malloc(sizeof(fat_node_t));
464
    fat_node_t *rootp = (fat_node_t *)malloc(sizeof(fat_node_t));
718
    if (!rootp) {
465
    if (!rootp) {
719
            munmap(dev_buffer, BS_SIZE);
466
        block_fini(dev_handle);
720
        fat_idx_fini_by_dev_handle(dev_handle);
467
        fat_idx_fini_by_dev_handle(dev_handle);
721
        ipc_answer_0(rid, ENOMEM);
468
        ipc_answer_0(rid, ENOMEM);
722
        return;
469
        return;
723
    }
470
    }
724
    fat_node_initialize(rootp);
471
    fat_node_initialize(rootp);
725
 
472
 
726
    fat_idx_t *ridxp = fat_idx_get_by_pos(dev_handle, FAT_CLST_ROOTPAR, 0);
473
    fat_idx_t *ridxp = fat_idx_get_by_pos(dev_handle, FAT_CLST_ROOTPAR, 0);
727
    if (!ridxp) {
474
    if (!ridxp) {
728
            munmap(dev_buffer, BS_SIZE);
475
        block_fini(dev_handle);
729
        free(rootp);
476
        free(rootp);
730
        fat_idx_fini_by_dev_handle(dev_handle);
477
        fat_idx_fini_by_dev_handle(dev_handle);
731
        ipc_answer_0(rid, ENOMEM);
478
        ipc_answer_0(rid, ENOMEM);
732
        return;
479
        return;
733
    }
480
    }
Line 761... Line 508...
761
{
508
{
762
    dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request);
509
    dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request);
763
    fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request);
510
    fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request);
764
    off_t pos = (off_t)IPC_GET_ARG3(*request);
511
    off_t pos = (off_t)IPC_GET_ARG3(*request);
765
    fat_node_t *nodep = (fat_node_t *)fat_node_get(dev_handle, index);
512
    fat_node_t *nodep = (fat_node_t *)fat_node_get(dev_handle, index);
-
 
513
    fat_bs_t *bs;
766
    uint16_t bps = fat_bps_get(dev_handle);
514
    uint16_t bps;
767
    size_t bytes;
515
    size_t bytes;
768
    block_t *b;
516
    block_t *b;
769
 
517
 
770
    if (!nodep) {
518
    if (!nodep) {
771
        ipc_answer_0(rid, ENOENT);
519
        ipc_answer_0(rid, ENOENT);
Line 779... Line 527...
779
        ipc_answer_0(callid, EINVAL);
527
        ipc_answer_0(callid, EINVAL);
780
        ipc_answer_0(rid, EINVAL);
528
        ipc_answer_0(rid, EINVAL);
781
        return;
529
        return;
782
    }
530
    }
783
 
531
 
-
 
532
    bs = block_bb_get(dev_handle);
-
 
533
    bps = uint16_t_le2host(bs->bps);
-
 
534
 
784
    if (nodep->type == FAT_FILE) {
535
    if (nodep->type == FAT_FILE) {
785
        /*
536
        /*
786
         * Our strategy for regular file reads is to read one block at
537
         * Our strategy for regular file reads is to read one block at
787
         * most and make use of the possibility to return less data than
538
         * most and make use of the possibility to return less data than
788
         * requested. This keeps the code very simple.
539
         * requested. This keeps the code very simple.
789
         */
540
         */
-
 
541
        if (pos >= nodep->size) {
-
 
542
            /* reading beyond the EOF */
-
 
543
            bytes = 0;
-
 
544
            (void) ipc_data_read_finalize(callid, NULL, 0);
-
 
545
        } else {
790
        bytes = min(len, bps - pos % bps);
546
            bytes = min(len, bps - pos % bps);
-
 
547
            bytes = min(bytes, nodep->size - pos);
791
        b = fat_block_get(nodep, pos / bps);
548
            b = fat_block_get(bs, nodep, pos / bps);
792
        (void) ipc_data_read_finalize(callid, b->data + pos % bps,
549
            (void) ipc_data_read_finalize(callid, b->data + pos % bps,
793
            bytes);
550
                bytes);
794
        block_put(b);
551
            block_put(b);
-
 
552
        }
795
    } else {
553
    } else {
796
        unsigned bnum;
554
        unsigned bnum;
797
        off_t spos = pos;
555
        off_t spos = pos;
798
        char name[FAT_NAME_LEN + 1 + FAT_EXT_LEN + 1];
556
        char name[FAT_NAME_LEN + 1 + FAT_EXT_LEN + 1];
799
        fat_dentry_t *d;
557
        fat_dentry_t *d;
Line 810... Line 568...
810
         */
568
         */
811
        bnum = (pos * sizeof(fat_dentry_t)) / bps;
569
        bnum = (pos * sizeof(fat_dentry_t)) / bps;
812
        while (bnum < nodep->size / bps) {
570
        while (bnum < nodep->size / bps) {
813
            off_t o;
571
            off_t o;
814
 
572
 
815
            b = fat_block_get(nodep, bnum);
573
            b = fat_block_get(bs, nodep, bnum);
816
            for (o = pos % (bps / sizeof(fat_dentry_t));
574
            for (o = pos % (bps / sizeof(fat_dentry_t));
817
                o < bps / sizeof(fat_dentry_t);
575
                o < bps / sizeof(fat_dentry_t);
818
                o++, pos++) {
576
                o++, pos++) {
819
                d = ((fat_dentry_t *)b->data) + o;
577
                d = ((fat_dentry_t *)b->data) + o;
820
                switch (fat_classify_dentry(d)) {
578
                switch (fat_classify_dentry(d)) {
Line 845... Line 603...
845
 
603
 
846
    fat_node_put(nodep);
604
    fat_node_put(nodep);
847
    ipc_answer_1(rid, EOK, (ipcarg_t)bytes);
605
    ipc_answer_1(rid, EOK, (ipcarg_t)bytes);
848
}
606
}
849
 
607
 
-
 
608
void fat_write(ipc_callid_t rid, ipc_call_t *request)
-
 
609
{
-
 
610
    dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request);
-
 
611
    fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request);
-
 
612
    off_t pos = (off_t)IPC_GET_ARG3(*request);
-
 
613
    fat_node_t *nodep = (fat_node_t *)fat_node_get(dev_handle, index);
-
 
614
    fat_bs_t *bs;
-
 
615
    size_t bytes;
-
 
616
    block_t *b;
-
 
617
    uint16_t bps;
-
 
618
    unsigned spc;
-
 
619
    off_t boundary;
-
 
620
   
-
 
621
    if (!nodep) {
-
 
622
        ipc_answer_0(rid, ENOENT);
-
 
623
        return;
-
 
624
    }
-
 
625
   
-
 
626
    /* XXX remove me when you are ready */
-
 
627
    {
-
 
628
        ipc_answer_0(rid, ENOTSUP);
-
 
629
        fat_node_put(nodep);
-
 
630
        return;
-
 
631
    }
-
 
632
 
-
 
633
    ipc_callid_t callid;
-
 
634
    size_t len;
-
 
635
    if (!ipc_data_write_receive(&callid, &len)) {
-
 
636
        fat_node_put(nodep);
-
 
637
        ipc_answer_0(callid, EINVAL);
-
 
638
        ipc_answer_0(rid, EINVAL);
-
 
639
        return;
-
 
640
    }
-
 
641
 
-
 
642
    /*
-
 
643
     * In all scenarios, we will attempt to write out only one block worth
-
 
644
     * of data at maximum. There might be some more efficient approaches,
-
 
645
     * but this one greatly simplifies fat_write(). Note that we can afford
-
 
646
     * to do this because the client must be ready to handle the return
-
 
647
     * value signalizing a smaller number of bytes written.
-
 
648
     */
-
 
649
    bytes = min(len, bps - pos % bps);
-
 
650
 
-
 
651
    bs = block_bb_get(dev_handle);
-
 
652
    bps = uint16_t_le2host(bs->bps);
-
 
653
    spc = bs->spc;
-
 
654
   
-
 
655
    boundary = ROUND_UP(nodep->size, bps * spc);
-
 
656
    if (pos < boundary) {
-
 
657
        /*
-
 
658
         * This is the easier case - we are either overwriting already
-
 
659
         * existing contents or writing behind the EOF, but still within
-
 
660
         * the limits of the last cluster. The node size may grow to the
-
 
661
         * next block size boundary.
-
 
662
         */
-
 
663
        fat_fill_gap(bs, nodep, FAT_CLST_RES0, pos);
-
 
664
        b = fat_block_get(bs, nodep, pos / bps);
-
 
665
        (void) ipc_data_write_finalize(callid, b->data + pos % bps,
-
 
666
            bytes);
-
 
667
        b->dirty = true;        /* need to sync block */
-
 
668
        block_put(b);
-
 
669
        if (pos + bytes > nodep->size) {
-
 
670
            nodep->size = pos + bytes;
-
 
671
            nodep->dirty = true;    /* need to sync node */
-
 
672
        }
-
 
673
        fat_node_put(nodep);
-
 
674
        ipc_answer_1(rid, EOK, bytes); 
-
 
675
        return;
-
 
676
    } else {
-
 
677
        /*
-
 
678
         * This is the more difficult case. We must allocate new
-
 
679
         * clusters for the node and zero them out.
-
 
680
         */
-
 
681
        int status;
-
 
682
        unsigned nclsts;
-
 
683
        fat_cluster_t mcl, lcl;
-
 
684
   
-
 
685
        nclsts = (ROUND_UP(pos + bytes, bps * spc) - boundary) /
-
 
686
            bps * spc;
-
 
687
        /* create an independent chain of nclsts clusters in all FATs */
-
 
688
        status = fat_alloc_clusters(bs, dev_handle, nclsts, &mcl,
-
 
689
            &lcl);
-
 
690
        if (status != EOK) {
-
 
691
            /* could not allocate a chain of nclsts clusters */
-
 
692
            fat_node_put(nodep);
-
 
693
            ipc_answer_0(callid, status);
-
 
694
            ipc_answer_0(rid, status);
-
 
695
            return;
-
 
696
        }
-
 
697
        /* zero fill any gaps */
-
 
698
        fat_fill_gap(bs, nodep, mcl, pos);
-
 
699
        b = _fat_block_get(bs, dev_handle, lcl,
-
 
700
            (pos / bps) % spc);
-
 
701
        (void) ipc_data_write_finalize(callid, b->data + pos % bps,
-
 
702
            bytes);
-
 
703
        b->dirty = true;        /* need to sync block */
-
 
704
        block_put(b);
-
 
705
        /*
-
 
706
         * Append the cluster chain starting in mcl to the end of the
-
 
707
         * node's cluster chain.
-
 
708
         */
-
 
709
        fat_append_clusters(bs, nodep, mcl);
-
 
710
        nodep->size = pos + bytes;
-
 
711
        nodep->dirty = true;        /* need to sync node */
-
 
712
        fat_node_put(nodep);
-
 
713
        ipc_answer_1(rid, EOK, bytes);
-
 
714
        return;
-
 
715
    }
-
 
716
}
-
 
717
 
850
/**
718
/**
851
 * @}
719
 * @}
852
 */
720
 */