Subversion Repositories HelenOS

Rev

Rev 3091 | Rev 3109 | Go to most recent revision | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 3091 Rev 3103
1
/*
1
/*
2
 * Copyright (c) 2008 Jakub Jermar
2
 * Copyright (c) 2008 Jakub Jermar
3
 * All rights reserved.
3
 * All rights reserved.
4
 *
4
 *
5
 * Redistribution and use in source and binary forms, with or without
5
 * Redistribution and use in source and binary forms, with or without
6
 * modification, are permitted provided that the following conditions
6
 * modification, are permitted provided that the following conditions
7
 * are met:
7
 * are met:
8
 *
8
 *
9
 * - Redistributions of source code must retain the above copyright
9
 * - Redistributions of source code must retain the above copyright
10
 *   notice, this list of conditions and the following disclaimer.
10
 *   notice, this list of conditions and the following disclaimer.
11
 * - Redistributions in binary form must reproduce the above copyright
11
 * - Redistributions in binary form must reproduce the above copyright
12
 *   notice, this list of conditions and the following disclaimer in the
12
 *   notice, this list of conditions and the following disclaimer in the
13
 *   documentation and/or other materials provided with the distribution.
13
 *   documentation and/or other materials provided with the distribution.
14
 * - The name of the author may not be used to endorse or promote products
14
 * - The name of the author may not be used to endorse or promote products
15
 *   derived from this software without specific prior written permission.
15
 *   derived from this software without specific prior written permission.
16
 *
16
 *
17
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
17
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
18
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
19
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
20
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
21
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
22
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
22
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
23
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
23
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
24
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
25
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
25
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
26
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27
 */
27
 */
28
 
28
 
29
/** @addtogroup fs
29
/** @addtogroup fs
30
 * @{
30
 * @{
31
 */
31
 */
32
 
32
 
33
/**
33
/**
34
 * @file    tmpfs_ops.c
34
 * @file    tmpfs_ops.c
35
 * @brief   Implementation of VFS operations for the TMPFS file system
35
 * @brief   Implementation of VFS operations for the TMPFS file system
36
 *      server.
36
 *      server.
37
 */
37
 */
38
 
38
 
39
#include "tmpfs.h"
39
#include "tmpfs.h"
40
#include "../../vfs/vfs.h"
40
#include "../../vfs/vfs.h"
41
#include <ipc/ipc.h>
41
#include <ipc/ipc.h>
42
#include <async.h>
42
#include <async.h>
43
#include <errno.h>
43
#include <errno.h>
44
#include <atomic.h>
44
#include <atomic.h>
45
#include <stdlib.h>
45
#include <stdlib.h>
46
#include <string.h>
46
#include <string.h>
47
#include <stdio.h>
47
#include <stdio.h>
48
#include <assert.h>
48
#include <assert.h>
49
#include <sys/types.h>
49
#include <sys/types.h>
50
#include <libadt/hash_table.h>
50
#include <libadt/hash_table.h>
51
#include <as.h>
51
#include <as.h>
52
#include <libfs.h>
52
#include <libfs.h>
53
#include <ipc/services.h>
-
 
54
#include <ipc/devmap.h>
-
 
55
#include <sys/mman.h>
-
 
56
#include <byteorder.h>
-
 
57
 
53
 
58
#define min(a, b)       ((a) < (b) ? (a) : (b))
54
#define min(a, b)       ((a) < (b) ? (a) : (b))
59
#define max(a, b)       ((a) > (b) ? (a) : (b))
55
#define max(a, b)       ((a) > (b) ? (a) : (b))
60
 
56
 
61
#define DENTRIES_BUCKETS    256
57
#define DENTRIES_BUCKETS    256
62
 
58
 
63
#define NAMES_BUCKETS       4
59
#define NAMES_BUCKETS       4
64
 
60
 
65
#define BLOCK_SIZE          1024    // FIXME
-
 
66
#define RD_BASE             1024    // FIXME
-
 
67
#define RD_READ_BLOCK   (RD_BASE + 1)
-
 
68
 
-
 
69
/*
61
/*
70
 * For now, we don't distinguish between different dev_handles/instances. All
62
 * For now, we don't distinguish between different dev_handles/instances. All
71
 * requests resolve to the only instance, rooted in the following variable.
63
 * requests resolve to the only instance, rooted in the following variable.
72
 */
64
 */
73
static tmpfs_dentry_t *root;
65
static tmpfs_dentry_t *root;
74
 
66
 
75
/*
67
/*
76
 * Implementation of the libfs interface.
68
 * Implementation of the libfs interface.
77
 */
69
 */
78
 
70
 
79
/* Forward declarations of static functions. */
71
/* Forward declarations of static functions. */
80
static void *tmpfs_match(void *, const char *);
72
static void *tmpfs_match(void *, const char *);
81
static void *tmpfs_node_get(dev_handle_t, fs_index_t);
73
static void *tmpfs_node_get(dev_handle_t, fs_index_t);
82
static void tmpfs_node_put(void *);
74
static void tmpfs_node_put(void *);
83
static void *tmpfs_create_node(int);
75
static void *tmpfs_create_node(int);
84
static bool tmpfs_link_node(void *, void *, const char *);
76
static bool tmpfs_link_node(void *, void *, const char *);
85
static int tmpfs_unlink_node(void *, void *);
77
static int tmpfs_unlink_node(void *, void *);
86
static int tmpfs_destroy_node(void *);
78
static int tmpfs_destroy_node(void *);
87
 
79
 
88
/* Implementation of helper functions. */
80
/* Implementation of helper functions. */
89
static fs_index_t tmpfs_index_get(void *nodep)
81
static fs_index_t tmpfs_index_get(void *nodep)
90
{
82
{
91
    return ((tmpfs_dentry_t *) nodep)->index;
83
    return ((tmpfs_dentry_t *) nodep)->index;
92
}
84
}
93
 
85
 
94
static size_t tmpfs_size_get(void *nodep)
86
static size_t tmpfs_size_get(void *nodep)
95
{
87
{
96
    return ((tmpfs_dentry_t *) nodep)->size;
88
    return ((tmpfs_dentry_t *) nodep)->size;
97
}
89
}
98
 
90
 
99
static unsigned tmpfs_lnkcnt_get(void *nodep)
91
static unsigned tmpfs_lnkcnt_get(void *nodep)
100
{
92
{
101
    return ((tmpfs_dentry_t *) nodep)->lnkcnt;
93
    return ((tmpfs_dentry_t *) nodep)->lnkcnt;
102
}
94
}
103
 
95
 
104
static bool tmpfs_has_children(void *nodep)
96
static bool tmpfs_has_children(void *nodep)
105
{
97
{
106
    return ((tmpfs_dentry_t *) nodep)->child != NULL;
98
    return ((tmpfs_dentry_t *) nodep)->child != NULL;
107
}
99
}
108
 
100
 
109
static void *tmpfs_root_get(dev_handle_t dev_handle)
101
static void *tmpfs_root_get(dev_handle_t dev_handle)
110
{
102
{
111
    return root;
103
    return root;
112
}
104
}
113
 
105
 
114
static char tmpfs_plb_get_char(unsigned pos)
106
static char tmpfs_plb_get_char(unsigned pos)
115
{
107
{
116
    return tmpfs_reg.plb_ro[pos % PLB_SIZE];
108
    return tmpfs_reg.plb_ro[pos % PLB_SIZE];
117
}
109
}
118
 
110
 
119
static bool tmpfs_is_directory(void *nodep)
111
static bool tmpfs_is_directory(void *nodep)
120
{
112
{
121
    return ((tmpfs_dentry_t *) nodep)->type == TMPFS_DIRECTORY;
113
    return ((tmpfs_dentry_t *) nodep)->type == TMPFS_DIRECTORY;
122
}
114
}
123
 
115
 
124
static bool tmpfs_is_file(void *nodep)
116
static bool tmpfs_is_file(void *nodep)
125
{
117
{
126
    return ((tmpfs_dentry_t *) nodep)->type == TMPFS_FILE;
118
    return ((tmpfs_dentry_t *) nodep)->type == TMPFS_FILE;
127
}
119
}
128
 
120
 
129
/** libfs operations */
121
/** libfs operations */
130
libfs_ops_t tmpfs_libfs_ops = {
122
libfs_ops_t tmpfs_libfs_ops = {
131
    .match = tmpfs_match,
123
    .match = tmpfs_match,
132
    .node_get = tmpfs_node_get,
124
    .node_get = tmpfs_node_get,
133
    .node_put = tmpfs_node_put,
125
    .node_put = tmpfs_node_put,
134
    .create = tmpfs_create_node,
126
    .create = tmpfs_create_node,
135
    .destroy = tmpfs_destroy_node,
127
    .destroy = tmpfs_destroy_node,
136
    .link = tmpfs_link_node,
128
    .link = tmpfs_link_node,
137
    .unlink = tmpfs_unlink_node,
129
    .unlink = tmpfs_unlink_node,
138
    .index_get = tmpfs_index_get,
130
    .index_get = tmpfs_index_get,
139
    .size_get = tmpfs_size_get,
131
    .size_get = tmpfs_size_get,
140
    .lnkcnt_get = tmpfs_lnkcnt_get,
132
    .lnkcnt_get = tmpfs_lnkcnt_get,
141
    .has_children = tmpfs_has_children,
133
    .has_children = tmpfs_has_children,
142
    .root_get = tmpfs_root_get,
134
    .root_get = tmpfs_root_get,
143
    .plb_get_char = tmpfs_plb_get_char,
135
    .plb_get_char = tmpfs_plb_get_char,
144
    .is_directory = tmpfs_is_directory,
136
    .is_directory = tmpfs_is_directory,
145
    .is_file = tmpfs_is_file
137
    .is_file = tmpfs_is_file
146
};
138
};
147
 
139
 
148
/** Hash table of all directory entries. */
140
/** Hash table of all directory entries. */
149
hash_table_t dentries;
141
hash_table_t dentries;
150
 
142
 
151
struct rdentry {
-
 
152
    uint8_t type;
-
 
153
    uint32_t len;
-
 
154
} __attribute__((packed));
-
 
155
 
-
 
156
/* Implementation of hash table interface for the dentries hash table. */
143
/* Implementation of hash table interface for the dentries hash table. */
157
static hash_index_t dentries_hash(unsigned long *key)
144
static hash_index_t dentries_hash(unsigned long *key)
158
{
145
{
159
    return *key % DENTRIES_BUCKETS;
146
    return *key % DENTRIES_BUCKETS;
160
}
147
}
161
 
148
 
162
static int dentries_compare(unsigned long *key, hash_count_t keys,
149
static int dentries_compare(unsigned long *key, hash_count_t keys,
163
    link_t *item)
150
    link_t *item)
164
{
151
{
165
    tmpfs_dentry_t *dentry = hash_table_get_instance(item, tmpfs_dentry_t,
152
    tmpfs_dentry_t *dentry = hash_table_get_instance(item, tmpfs_dentry_t,
166
        dh_link);
153
        dh_link);
167
    return dentry->index == *key;
154
    return dentry->index == *key;
168
}
155
}
169
 
156
 
170
static void dentries_remove_callback(link_t *item)
157
static void dentries_remove_callback(link_t *item)
171
{
158
{
172
}
159
}
173
 
160
 
174
/** TMPFS dentries hash table operations. */
161
/** TMPFS dentries hash table operations. */
175
hash_table_operations_t dentries_ops = {
162
hash_table_operations_t dentries_ops = {
176
    .hash = dentries_hash,
163
    .hash = dentries_hash,
177
    .compare = dentries_compare,
164
    .compare = dentries_compare,
178
    .remove_callback = dentries_remove_callback
165
    .remove_callback = dentries_remove_callback
179
};
166
};
180
 
167
 
181
fs_index_t tmpfs_next_index = 1;
168
fs_index_t tmpfs_next_index = 1;
182
 
169
 
183
typedef struct {
170
typedef struct {
184
    char *name;
171
    char *name;
185
    tmpfs_dentry_t *parent;
172
    tmpfs_dentry_t *parent;
186
    link_t link;
173
    link_t link;
187
} tmpfs_name_t;
174
} tmpfs_name_t;
188
 
175
 
189
/* Implementation of hash table interface for the names hash table. */
176
/* Implementation of hash table interface for the names hash table. */
190
static hash_index_t names_hash(unsigned long *key)
177
static hash_index_t names_hash(unsigned long *key)
191
{
178
{
192
    tmpfs_dentry_t *dentry = (tmpfs_dentry_t *) *key;
179
    tmpfs_dentry_t *dentry = (tmpfs_dentry_t *) *key;
193
    return dentry->index % NAMES_BUCKETS;
180
    return dentry->index % NAMES_BUCKETS;
194
}
181
}
195
 
182
 
196
static int names_compare(unsigned long *key, hash_count_t keys, link_t *item)
183
static int names_compare(unsigned long *key, hash_count_t keys, link_t *item)
197
{
184
{
198
    tmpfs_dentry_t *dentry = (tmpfs_dentry_t *) *key;
185
    tmpfs_dentry_t *dentry = (tmpfs_dentry_t *) *key;
199
    tmpfs_name_t *namep = hash_table_get_instance(item, tmpfs_name_t,
186
    tmpfs_name_t *namep = hash_table_get_instance(item, tmpfs_name_t,
200
        link);
187
        link);
201
    return dentry == namep->parent;
188
    return dentry == namep->parent;
202
}
189
}
203
 
190
 
204
static void names_remove_callback(link_t *item)
191
static void names_remove_callback(link_t *item)
205
{
192
{
206
    tmpfs_name_t *namep = hash_table_get_instance(item, tmpfs_name_t,
193
    tmpfs_name_t *namep = hash_table_get_instance(item, tmpfs_name_t,
207
        link);
194
        link);
208
    free(namep->name);
195
    free(namep->name);
209
    free(namep);
196
    free(namep);
210
}
197
}
211
 
198
 
212
/** TMPFS node names hash table operations. */
199
/** TMPFS node names hash table operations. */
213
static hash_table_operations_t names_ops = {
200
static hash_table_operations_t names_ops = {
214
    .hash = names_hash,
201
    .hash = names_hash,
215
    .compare = names_compare,
202
    .compare = names_compare,
216
    .remove_callback = names_remove_callback
203
    .remove_callback = names_remove_callback
217
};
204
};
218
 
205
 
219
static void tmpfs_name_initialize(tmpfs_name_t *namep)
206
static void tmpfs_name_initialize(tmpfs_name_t *namep)
220
{
207
{
221
    namep->name = NULL;
208
    namep->name = NULL;
222
    namep->parent = NULL;
209
    namep->parent = NULL;
223
    link_initialize(&namep->link);
210
    link_initialize(&namep->link);
224
}
211
}
225
 
212
 
226
static bool tmpfs_dentry_initialize(tmpfs_dentry_t *dentry)
213
static bool tmpfs_dentry_initialize(tmpfs_dentry_t *dentry)
227
{
214
{
228
    dentry->index = 0;
215
    dentry->index = 0;
229
    dentry->sibling = NULL;
216
    dentry->sibling = NULL;
230
    dentry->child = NULL;
217
    dentry->child = NULL;
231
    dentry->type = TMPFS_NONE;
218
    dentry->type = TMPFS_NONE;
232
    dentry->lnkcnt = 0;
219
    dentry->lnkcnt = 0;
233
    dentry->size = 0;
220
    dentry->size = 0;
234
    dentry->data = NULL;
221
    dentry->data = NULL;
235
    link_initialize(&dentry->dh_link);
222
    link_initialize(&dentry->dh_link);
236
    return (bool)hash_table_create(&dentry->names, NAMES_BUCKETS, 1,
223
    return (bool)hash_table_create(&dentry->names, NAMES_BUCKETS, 1,
237
        &names_ops);
224
        &names_ops);
238
}
225
}
239
 
226
 
240
static bool tmpfs_init(void)
227
static bool tmpfs_init(void)
241
{
228
{
242
    if (!hash_table_create(&dentries, DENTRIES_BUCKETS, 1, &dentries_ops))
229
    if (!hash_table_create(&dentries, DENTRIES_BUCKETS, 1, &dentries_ops))
243
        return false;
230
        return false;
244
    root = (tmpfs_dentry_t *) tmpfs_create_node(L_DIRECTORY);
231
    root = (tmpfs_dentry_t *) tmpfs_create_node(L_DIRECTORY);
245
    if (!root) {
232
    if (!root) {
246
        hash_table_destroy(&dentries);
233
        hash_table_destroy(&dentries);
247
        return false;
234
        return false;
248
    }
235
    }
249
    root->lnkcnt = 1;
236
    root->lnkcnt = 1;
250
    return true;
237
    return true;
251
}
238
}
252
 
-
 
253
static bool tmpfs_blockread(int phone, void *buffer, size_t *bufpos, size_t *buflen, size_t *pos, void *dst, size_t size)
-
 
254
{
-
 
255
    size_t offset = 0;
-
 
256
    size_t left = size;
-
 
257
   
-
 
258
    while (left > 0) {
-
 
259
        size_t rd;
-
 
260
       
-
 
261
        if (*bufpos + left < *buflen)
-
 
262
            rd = left;
-
 
263
        else
-
 
264
            rd = *buflen - *bufpos;
-
 
265
       
-
 
266
        if (rd > 0) {
-
 
267
            memcpy(dst + offset, buffer + *bufpos, rd);
-
 
268
            offset += rd;
-
 
269
            *bufpos += rd;
-
 
270
            *pos += rd;
-
 
271
            left -= rd;
-
 
272
        }
-
 
273
       
-
 
274
        if (*bufpos == *buflen) {
-
 
275
            ipcarg_t retval;
-
 
276
            int rc = ipc_call_sync_2_1(phone, RD_READ_BLOCK,
-
 
277
                *pos / BLOCK_SIZE, BLOCK_SIZE,
-
 
278
                &retval);
-
 
279
            if ((rc != EOK) || (retval != EOK))
-
 
280
                return false;
-
 
281
           
-
 
282
            *bufpos = 0;
-
 
283
            *buflen = BLOCK_SIZE;
-
 
284
        }
-
 
285
    }
-
 
286
   
-
 
287
    return true;
-
 
288
}
-
 
289
 
-
 
290
static bool tmpfs_restore_recursion(int phone, void *block, size_t *bufpos, size_t *buflen, size_t *pos, tmpfs_dentry_t *parent)
-
 
291
{
-
 
292
    struct rdentry entry;
-
 
293
   
-
 
294
    do {
-
 
295
        char *fname;
-
 
296
        tmpfs_dentry_t *node;
-
 
297
        uint32_t size;
-
 
298
       
-
 
299
        if (!tmpfs_blockread(phone, block, bufpos, buflen, pos, &entry, sizeof(entry)))
-
 
300
            return false;
-
 
301
       
-
 
302
        entry.len = uint32_t_le2host(entry.len);
-
 
303
       
-
 
304
        switch (entry.type) {
-
 
305
        case 0:
-
 
306
            break;
-
 
307
        case 1:
-
 
308
            fname = malloc(entry.len + 1);
-
 
309
            if (fname == NULL)
-
 
310
                return false;
-
 
311
           
-
 
312
            node = (tmpfs_dentry_t *) tmpfs_create_node(L_FILE);
-
 
313
            if (node == NULL) {
-
 
314
                free(fname);
-
 
315
                return false;
-
 
316
            }
-
 
317
           
-
 
318
            if (!tmpfs_blockread(phone, block, bufpos, buflen, pos, fname, entry.len)) {
-
 
319
                tmpfs_destroy_node((void *) node);
-
 
320
                free(fname);
-
 
321
                return false;
-
 
322
            }
-
 
323
            fname[entry.len] = 0;
-
 
324
           
-
 
325
            if (!tmpfs_link_node((void *) parent, (void *) node, fname)) {
-
 
326
                tmpfs_destroy_node((void *) node);
-
 
327
                free(fname);
-
 
328
                return false;
-
 
329
            }
-
 
330
            free(fname);
-
 
331
           
-
 
332
            if (!tmpfs_blockread(phone, block, bufpos, buflen, pos, &size, sizeof(size)))
-
 
333
                return false;
-
 
334
           
-
 
335
            size = uint32_t_le2host(size);
-
 
336
           
-
 
337
            node->data = malloc(size);
-
 
338
            if (node->data == NULL)
-
 
339
                return false;
-
 
340
           
-
 
341
            node->size = size;
-
 
342
            if (!tmpfs_blockread(phone, block, bufpos, buflen, pos, node->data, size))
-
 
343
                return false;
-
 
344
           
-
 
345
            break;
-
 
346
        case 2:
-
 
347
            fname = malloc(entry.len + 1);
-
 
348
            if (fname == NULL)
-
 
349
                return false;
-
 
350
           
-
 
351
            node = (tmpfs_dentry_t *) tmpfs_create_node(L_DIRECTORY);
-
 
352
            if (node == NULL) {
-
 
353
                free(fname);
-
 
354
                return false;
-
 
355
            }
-
 
356
           
-
 
357
            if (!tmpfs_blockread(phone, block, bufpos, buflen, pos, fname, entry.len)) {
-
 
358
                tmpfs_destroy_node((void *) node);
-
 
359
                free(fname);
-
 
360
                return false;
-
 
361
            }
-
 
362
            fname[entry.len] = 0;
-
 
363
           
-
 
364
            if (!tmpfs_link_node((void *) parent, (void *) node, fname)) {
-
 
365
                tmpfs_destroy_node((void *) node);
-
 
366
                free(fname);
-
 
367
                return false;
-
 
368
            }
-
 
369
            free(fname);
-
 
370
           
-
 
371
            if (!tmpfs_restore_recursion(phone, block, bufpos, buflen, pos, node))
-
 
372
                return false;
-
 
373
           
-
 
374
            break;
-
 
375
        default:
-
 
376
            return false;
-
 
377
        }
-
 
378
    } while (entry.type != 0);
-
 
379
   
-
 
380
    return true;
-
 
381
}
-
 
382
 
-
 
383
static bool tmpfs_restore(dev_handle_t dev)
-
 
384
{
-
 
385
    void *block = mmap(NULL, BLOCK_SIZE,
-
 
386
        PROTO_READ | PROTO_WRITE, MAP_ANONYMOUS | MAP_PRIVATE, 0, 0);
-
 
387
   
-
 
388
    if (block == NULL)
-
 
389
        return false;
-
 
390
   
-
 
391
    int phone = ipc_connect_me_to(PHONE_NS, SERVICE_DEVMAP, DEVMAP_CONNECT_TO_DEVICE, dev);
-
 
392
 
-
 
393
    if (phone < 0) {
-
 
394
        munmap(block, BLOCK_SIZE);
-
 
395
        return false;
-
 
396
    }
-
 
397
   
-
 
398
    if (ipc_share_out_start(phone, block, AS_AREA_READ | AS_AREA_WRITE) != EOK)
-
 
399
        goto error;
-
 
400
   
-
 
401
    size_t bufpos = 0;
-
 
402
    size_t buflen = 0;
-
 
403
    size_t pos = 0;
-
 
404
   
-
 
405
    char tag[6];
-
 
406
    if (!tmpfs_blockread(phone, block, &bufpos, &buflen, &pos, tag, 5))
-
 
407
        goto error;
-
 
408
   
-
 
409
    tag[5] = 0;
-
 
410
    if (strcmp(tag, "TMPFS") != 0)
-
 
411
        goto error;
-
 
412
   
-
 
413
    if (!tmpfs_restore_recursion(phone, block, &bufpos, &buflen, &pos, root))
-
 
414
        goto error;
-
 
415
       
-
 
416
    ipc_hangup(phone);
-
 
417
    munmap(block, BLOCK_SIZE);
-
 
418
    return true;
-
 
419
   
-
 
420
error:
-
 
421
    ipc_hangup(phone);
-
 
422
    munmap(block, BLOCK_SIZE);
-
 
423
    return false;
-
 
424
}
-
 
425
 
239
 
426
/** Compare one component of path to a directory entry.
240
/** Compare one component of path to a directory entry.
427
 *
241
 *
428
 * @param parentp   Pointer to node from which we descended.
242
 * @param parentp   Pointer to node from which we descended.
429
 * @param childp    Pointer to node to compare the path component with.
243
 * @param childp    Pointer to node to compare the path component with.
430
 * @param component Array of characters holding component name.
244
 * @param component Array of characters holding component name.
431
 *
245
 *
432
 * @return      True on match, false otherwise.
246
 * @return      True on match, false otherwise.
433
 */
247
 */
434
static bool
248
static bool
435
tmpfs_match_one(tmpfs_dentry_t *parentp, tmpfs_dentry_t *childp,
249
tmpfs_match_one(tmpfs_dentry_t *parentp, tmpfs_dentry_t *childp,
436
    const char *component)
250
    const char *component)
437
{
251
{
438
    unsigned long key = (unsigned long) parentp;
252
    unsigned long key = (unsigned long) parentp;
439
    link_t *hlp = hash_table_find(&childp->names, &key);
253
    link_t *hlp = hash_table_find(&childp->names, &key);
440
    assert(hlp);
254
    assert(hlp);
441
    tmpfs_name_t *namep = hash_table_get_instance(hlp, tmpfs_name_t, link);
255
    tmpfs_name_t *namep = hash_table_get_instance(hlp, tmpfs_name_t, link);
442
    return !strcmp(namep->name, component);
256
    return !strcmp(namep->name, component);
443
}
257
}
444
 
258
 
445
void *tmpfs_match(void *prnt, const char *component)
259
void *tmpfs_match(void *prnt, const char *component)
446
{
260
{
447
    tmpfs_dentry_t *parentp = (tmpfs_dentry_t *) prnt;
261
    tmpfs_dentry_t *parentp = (tmpfs_dentry_t *) prnt;
448
    tmpfs_dentry_t *childp = parentp->child;
262
    tmpfs_dentry_t *childp = parentp->child;
449
 
263
 
450
    while (childp && !tmpfs_match_one(parentp, childp, component))
264
    while (childp && !tmpfs_match_one(parentp, childp, component))
451
        childp = childp->sibling;
265
        childp = childp->sibling;
452
 
266
 
453
    return (void *) childp;
267
    return (void *) childp;
454
}
268
}
455
 
269
 
456
void *
270
void *
457
tmpfs_node_get(dev_handle_t dev_handle, fs_index_t index)
271
tmpfs_node_get(dev_handle_t dev_handle, fs_index_t index)
458
{
272
{
459
    unsigned long key = index;
273
    unsigned long key = index;
460
    link_t *lnk = hash_table_find(&dentries, &key);
274
    link_t *lnk = hash_table_find(&dentries, &key);
461
    if (!lnk)
275
    if (!lnk)
462
        return NULL;
276
        return NULL;
463
    return hash_table_get_instance(lnk, tmpfs_dentry_t, dh_link);
277
    return hash_table_get_instance(lnk, tmpfs_dentry_t, dh_link);
464
}
278
}
465
 
279
 
466
void tmpfs_node_put(void *node)
280
void tmpfs_node_put(void *node)
467
{
281
{
468
    /* nothing to do */
282
    /* nothing to do */
469
}
283
}
470
 
284
 
471
void *tmpfs_create_node(int lflag)
285
void *tmpfs_create_node(int lflag)
472
{
286
{
473
    assert((lflag & L_FILE) ^ (lflag & L_DIRECTORY));
287
    assert((lflag & L_FILE) ^ (lflag & L_DIRECTORY));
474
 
288
 
475
    tmpfs_dentry_t *node = malloc(sizeof(tmpfs_dentry_t));
289
    tmpfs_dentry_t *node = malloc(sizeof(tmpfs_dentry_t));
476
    if (!node)
290
    if (!node)
477
        return NULL;
291
        return NULL;
478
 
292
 
479
    if (!tmpfs_dentry_initialize(node)) {
293
    if (!tmpfs_dentry_initialize(node)) {
480
        free(node);
294
        free(node);
481
        return NULL;
295
        return NULL;
482
    }
296
    }
483
    node->index = tmpfs_next_index++;
297
    node->index = tmpfs_next_index++;
484
    if (lflag & L_DIRECTORY)
298
    if (lflag & L_DIRECTORY)
485
        node->type = TMPFS_DIRECTORY;
299
        node->type = TMPFS_DIRECTORY;
486
    else
300
    else
487
        node->type = TMPFS_FILE;
301
        node->type = TMPFS_FILE;
488
 
302
 
489
    /* Insert the new node into the dentry hash table. */
303
    /* Insert the new node into the dentry hash table. */
490
    unsigned long key = node->index;
304
    unsigned long key = node->index;
491
    hash_table_insert(&dentries, &key, &node->dh_link);
305
    hash_table_insert(&dentries, &key, &node->dh_link);
492
    return (void *) node;
306
    return (void *) node;
493
}
307
}
494
 
308
 
495
bool tmpfs_link_node(void *prnt, void *chld, const char *nm)
309
bool tmpfs_link_node(void *prnt, void *chld, const char *nm)
496
{
310
{
497
    tmpfs_dentry_t *parentp = (tmpfs_dentry_t *) prnt;
311
    tmpfs_dentry_t *parentp = (tmpfs_dentry_t *) prnt;
498
    tmpfs_dentry_t *childp = (tmpfs_dentry_t *) chld;
312
    tmpfs_dentry_t *childp = (tmpfs_dentry_t *) chld;
499
 
313
 
500
    assert(parentp->type == TMPFS_DIRECTORY);
314
    assert(parentp->type == TMPFS_DIRECTORY);
501
 
315
 
502
    tmpfs_name_t *namep = malloc(sizeof(tmpfs_name_t));
316
    tmpfs_name_t *namep = malloc(sizeof(tmpfs_name_t));
503
    if (!namep)
317
    if (!namep)
504
        return false;
318
        return false;
505
    tmpfs_name_initialize(namep);
319
    tmpfs_name_initialize(namep);
506
    size_t len = strlen(nm);
320
    size_t len = strlen(nm);
507
    namep->name = malloc(len + 1);
321
    namep->name = malloc(len + 1);
508
    if (!namep->name) {
322
    if (!namep->name) {
509
        free(namep);
323
        free(namep);
510
        return false;
324
        return false;
511
    }
325
    }
512
    strcpy(namep->name, nm);
326
    strcpy(namep->name, nm);
513
    namep->parent = parentp;
327
    namep->parent = parentp;
514
   
328
   
515
    childp->lnkcnt++;
329
    childp->lnkcnt++;
516
 
330
 
517
    unsigned long key = (unsigned long) parentp;
331
    unsigned long key = (unsigned long) parentp;
518
    hash_table_insert(&childp->names, &key, &namep->link);
332
    hash_table_insert(&childp->names, &key, &namep->link);
519
 
333
 
520
    /* Insert the new node into the namespace. */
334
    /* Insert the new node into the namespace. */
521
    if (parentp->child) {
335
    if (parentp->child) {
522
        tmpfs_dentry_t *tmp = parentp->child;
336
        tmpfs_dentry_t *tmp = parentp->child;
523
        while (tmp->sibling)
337
        while (tmp->sibling)
524
            tmp = tmp->sibling;
338
            tmp = tmp->sibling;
525
        tmp->sibling = childp;
339
        tmp->sibling = childp;
526
    } else {
340
    } else {
527
        parentp->child = childp;
341
        parentp->child = childp;
528
    }
342
    }
529
 
343
 
530
    return true;
344
    return true;
531
}
345
}
532
 
346
 
533
int tmpfs_unlink_node(void *prnt, void *chld)
347
int tmpfs_unlink_node(void *prnt, void *chld)
534
{
348
{
535
    tmpfs_dentry_t *parentp = (tmpfs_dentry_t *)prnt;
349
    tmpfs_dentry_t *parentp = (tmpfs_dentry_t *)prnt;
536
    tmpfs_dentry_t *childp = (tmpfs_dentry_t *)chld;
350
    tmpfs_dentry_t *childp = (tmpfs_dentry_t *)chld;
537
 
351
 
538
    if (!parentp)
352
    if (!parentp)
539
        return EBUSY;
353
        return EBUSY;
540
 
354
 
541
    if (childp->child)
355
    if (childp->child)
542
        return ENOTEMPTY;
356
        return ENOTEMPTY;
543
 
357
 
544
    if (parentp->child == childp) {
358
    if (parentp->child == childp) {
545
        parentp->child = childp->sibling;
359
        parentp->child = childp->sibling;
546
    } else {
360
    } else {
547
        /* TODO: consider doubly linked list for organizing siblings. */
361
        /* TODO: consider doubly linked list for organizing siblings. */
548
        tmpfs_dentry_t *tmp = parentp->child;
362
        tmpfs_dentry_t *tmp = parentp->child;
549
        while (tmp->sibling != childp)
363
        while (tmp->sibling != childp)
550
            tmp = tmp->sibling;
364
            tmp = tmp->sibling;
551
        tmp->sibling = childp->sibling;
365
        tmp->sibling = childp->sibling;
552
    }
366
    }
553
    childp->sibling = NULL;
367
    childp->sibling = NULL;
554
 
368
 
555
    unsigned long key = (unsigned long) parentp;
369
    unsigned long key = (unsigned long) parentp;
556
    hash_table_remove(&childp->names, &key, 1);
370
    hash_table_remove(&childp->names, &key, 1);
557
 
371
 
558
    childp->lnkcnt--;
372
    childp->lnkcnt--;
559
 
373
 
560
    return EOK;
374
    return EOK;
561
}
375
}
562
 
376
 
563
int tmpfs_destroy_node(void *nodep)
377
int tmpfs_destroy_node(void *nodep)
564
{
378
{
565
    tmpfs_dentry_t *dentry = (tmpfs_dentry_t *) nodep;
379
    tmpfs_dentry_t *dentry = (tmpfs_dentry_t *) nodep;
566
   
380
   
567
    assert(!dentry->lnkcnt);
381
    assert(!dentry->lnkcnt);
568
    assert(!dentry->child);
382
    assert(!dentry->child);
569
    assert(!dentry->sibling);
383
    assert(!dentry->sibling);
570
 
384
 
571
    unsigned long key = dentry->index;
385
    unsigned long key = dentry->index;
572
    hash_table_remove(&dentries, &key, 1);
386
    hash_table_remove(&dentries, &key, 1);
573
 
387
 
574
    hash_table_destroy(&dentry->names);
388
    hash_table_destroy(&dentry->names);
575
 
389
 
576
    if (dentry->type == TMPFS_FILE)
390
    if (dentry->type == TMPFS_FILE)
577
        free(dentry->data);
391
        free(dentry->data);
578
    free(dentry);
392
    free(dentry);
579
    return EOK;
393
    return EOK;
580
}
394
}
581
 
395
 
582
void tmpfs_mount(ipc_callid_t rid, ipc_call_t *request)
396
void tmpfs_mount(ipc_callid_t rid, ipc_call_t *request)
583
{
397
{
584
    dev_handle_t mr_dev_handle = (dev_handle_t) IPC_GET_ARG1(*request);
398
    dev_handle_t mr_dev_handle = (dev_handle_t) IPC_GET_ARG1(*request);
585
    fs_index_t mr_index = (fs_index_t) IPC_GET_ARG2(*request);
399
    fs_index_t mr_index = (fs_index_t) IPC_GET_ARG2(*request);
586
    fs_handle_t mp_fs_handle = (fs_handle_t) IPC_GET_ARG3(*request);
400
    fs_handle_t mp_fs_handle = (fs_handle_t) IPC_GET_ARG3(*request);
587
    dev_handle_t mp_dev_handle = (dev_handle_t) IPC_GET_ARG4(*request);
401
    dev_handle_t mp_dev_handle = (dev_handle_t) IPC_GET_ARG4(*request);
588
    fs_index_t mp_index = (fs_index_t) IPC_GET_ARG5(*request);
402
    fs_index_t mp_index = (fs_index_t) IPC_GET_ARG5(*request);
589
   
403
   
590
    if ((mr_index == root->index) &&
404
    if ((mr_index == root->index) &&
591
        (mp_fs_handle == tmpfs_reg.fs_handle) &&
405
        (mp_fs_handle == tmpfs_reg.fs_handle) &&
592
        (mp_index == mr_index)) {
406
        (mp_index == mr_index)) {
593
       
407
       
594
        if (mr_dev_handle >= 0) {
408
        if (mr_dev_handle >= 0) {
595
            if (tmpfs_restore(mr_dev_handle))
409
            if (tmpfs_restore(mr_dev_handle))
596
                ipc_answer_0(rid, EOK);
410
                ipc_answer_0(rid, EOK);
597
            else
411
            else
598
                ipc_answer_0(rid, ELIMIT);
412
                ipc_answer_0(rid, ELIMIT);
599
        } else
413
        } else
600
            ipc_answer_0(rid, EOK);
414
            ipc_answer_0(rid, EOK);
601
    } else
415
    } else
602
        ipc_answer_0(rid, ENOTSUP);
416
        ipc_answer_0(rid, ENOTSUP);
603
}
417
}
604
 
418
 
605
void tmpfs_lookup(ipc_callid_t rid, ipc_call_t *request)
419
void tmpfs_lookup(ipc_callid_t rid, ipc_call_t *request)
606
{
420
{
607
    /* Initialize TMPFS. */
421
    /* Initialize TMPFS. */
608
    if (!root && !tmpfs_init()) {
422
    if (!root && !tmpfs_init()) {
609
        ipc_answer_0(rid, ENOMEM);
423
        ipc_answer_0(rid, ENOMEM);
610
        return;
424
        return;
611
    }
425
    }
612
    libfs_lookup(&tmpfs_libfs_ops, tmpfs_reg.fs_handle, rid, request);
426
    libfs_lookup(&tmpfs_libfs_ops, tmpfs_reg.fs_handle, rid, request);
613
}
427
}
614
 
428
 
615
void tmpfs_read(ipc_callid_t rid, ipc_call_t *request)
429
void tmpfs_read(ipc_callid_t rid, ipc_call_t *request)
616
{
430
{
617
    dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request);
431
    dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request);
618
    fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request);
432
    fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request);
619
    off_t pos = (off_t)IPC_GET_ARG3(*request);
433
    off_t pos = (off_t)IPC_GET_ARG3(*request);
620
 
434
 
621
    /*
435
    /*
622
     * Lookup the respective dentry.
436
     * Lookup the respective dentry.
623
     */
437
     */
624
    link_t *hlp;
438
    link_t *hlp;
625
    unsigned long key = index;
439
    unsigned long key = index;
626
    hlp = hash_table_find(&dentries, &key);
440
    hlp = hash_table_find(&dentries, &key);
627
    if (!hlp) {
441
    if (!hlp) {
628
        ipc_answer_0(rid, ENOENT);
442
        ipc_answer_0(rid, ENOENT);
629
        return;
443
        return;
630
    }
444
    }
631
    tmpfs_dentry_t *dentry = hash_table_get_instance(hlp, tmpfs_dentry_t,
445
    tmpfs_dentry_t *dentry = hash_table_get_instance(hlp, tmpfs_dentry_t,
632
        dh_link);
446
        dh_link);
633
 
447
 
634
    /*
448
    /*
635
     * Receive the read request.
449
     * Receive the read request.
636
     */
450
     */
637
    ipc_callid_t callid;
451
    ipc_callid_t callid;
638
    size_t len;
452
    size_t len;
639
    if (!ipc_data_read_receive(&callid, &len)) {
453
    if (!ipc_data_read_receive(&callid, &len)) {
640
        ipc_answer_0(callid, EINVAL);  
454
        ipc_answer_0(callid, EINVAL);  
641
        ipc_answer_0(rid, EINVAL);
455
        ipc_answer_0(rid, EINVAL);
642
        return;
456
        return;
643
    }
457
    }
644
 
458
 
645
    size_t bytes;
459
    size_t bytes;
646
    if (dentry->type == TMPFS_FILE) {
460
    if (dentry->type == TMPFS_FILE) {
647
        bytes = max(0, min(dentry->size - pos, len));
461
        bytes = max(0, min(dentry->size - pos, len));
648
        (void) ipc_data_read_finalize(callid, dentry->data + pos,
462
        (void) ipc_data_read_finalize(callid, dentry->data + pos,
649
            bytes);
463
            bytes);
650
    } else {
464
    } else {
651
        int i;
465
        int i;
652
        tmpfs_dentry_t *cur;
466
        tmpfs_dentry_t *cur;
653
       
467
       
654
        assert(dentry->type == TMPFS_DIRECTORY);
468
        assert(dentry->type == TMPFS_DIRECTORY);
655
       
469
       
656
        /*
470
        /*
657
         * Yes, we really use O(n) algorithm here.
471
         * Yes, we really use O(n) algorithm here.
658
         * If it bothers someone, it could be fixed by introducing a
472
         * If it bothers someone, it could be fixed by introducing a
659
         * hash table.
473
         * hash table.
660
         */
474
         */
661
        for (i = 0, cur = dentry->child; i < pos && cur; i++,
475
        for (i = 0, cur = dentry->child; i < pos && cur; i++,
662
            cur = cur->sibling)
476
            cur = cur->sibling)
663
            ;
477
            ;
664
 
478
 
665
        if (!cur) {
479
        if (!cur) {
666
            ipc_answer_0(callid, ENOENT);
480
            ipc_answer_0(callid, ENOENT);
667
            ipc_answer_1(rid, ENOENT, 0);
481
            ipc_answer_1(rid, ENOENT, 0);
668
            return;
482
            return;
669
        }
483
        }
670
 
484
 
671
        unsigned long key = (unsigned long) dentry;
485
        unsigned long key = (unsigned long) dentry;
672
        link_t *hlp = hash_table_find(&cur->names, &key);
486
        link_t *hlp = hash_table_find(&cur->names, &key);
673
        assert(hlp);
487
        assert(hlp);
674
        tmpfs_name_t *namep = hash_table_get_instance(hlp, tmpfs_name_t,
488
        tmpfs_name_t *namep = hash_table_get_instance(hlp, tmpfs_name_t,
675
            link);
489
            link);
676
 
490
 
677
        (void) ipc_data_read_finalize(callid, namep->name,
491
        (void) ipc_data_read_finalize(callid, namep->name,
678
            strlen(namep->name) + 1);
492
            strlen(namep->name) + 1);
679
        bytes = 1;
493
        bytes = 1;
680
    }
494
    }
681
 
495
 
682
    /*
496
    /*
683
     * Answer the VFS_READ call.
497
     * Answer the VFS_READ call.
684
     */
498
     */
685
    ipc_answer_1(rid, EOK, bytes);
499
    ipc_answer_1(rid, EOK, bytes);
686
}
500
}
687
 
501
 
688
void tmpfs_write(ipc_callid_t rid, ipc_call_t *request)
502
void tmpfs_write(ipc_callid_t rid, ipc_call_t *request)
689
{
503
{
690
    dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request);
504
    dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request);
691
    fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request);
505
    fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request);
692
    off_t pos = (off_t)IPC_GET_ARG3(*request);
506
    off_t pos = (off_t)IPC_GET_ARG3(*request);
693
 
507
 
694
    /*
508
    /*
695
     * Lookup the respective dentry.
509
     * Lookup the respective dentry.
696
     */
510
     */
697
    link_t *hlp;
511
    link_t *hlp;
698
    unsigned long key = index;
512
    unsigned long key = index;
699
    hlp = hash_table_find(&dentries, &key);
513
    hlp = hash_table_find(&dentries, &key);
700
    if (!hlp) {
514
    if (!hlp) {
701
        ipc_answer_0(rid, ENOENT);
515
        ipc_answer_0(rid, ENOENT);
702
        return;
516
        return;
703
    }
517
    }
704
    tmpfs_dentry_t *dentry = hash_table_get_instance(hlp, tmpfs_dentry_t,
518
    tmpfs_dentry_t *dentry = hash_table_get_instance(hlp, tmpfs_dentry_t,
705
        dh_link);
519
        dh_link);
706
 
520
 
707
    /*
521
    /*
708
     * Receive the write request.
522
     * Receive the write request.
709
     */
523
     */
710
    ipc_callid_t callid;
524
    ipc_callid_t callid;
711
    size_t len;
525
    size_t len;
712
    if (!ipc_data_write_receive(&callid, &len)) {
526
    if (!ipc_data_write_receive(&callid, &len)) {
713
        ipc_answer_0(callid, EINVAL);  
527
        ipc_answer_0(callid, EINVAL);  
714
        ipc_answer_0(rid, EINVAL);
528
        ipc_answer_0(rid, EINVAL);
715
        return;
529
        return;
716
    }
530
    }
717
 
531
 
718
    /*
532
    /*
719
     * Check whether the file needs to grow.
533
     * Check whether the file needs to grow.
720
     */
534
     */
721
    if (pos + len <= dentry->size) {
535
    if (pos + len <= dentry->size) {
722
        /* The file size is not changing. */
536
        /* The file size is not changing. */
723
        (void) ipc_data_write_finalize(callid, dentry->data + pos, len);
537
        (void) ipc_data_write_finalize(callid, dentry->data + pos, len);
724
        ipc_answer_2(rid, EOK, len, dentry->size);
538
        ipc_answer_2(rid, EOK, len, dentry->size);
725
        return;
539
        return;
726
    }
540
    }
727
    size_t delta = (pos + len) - dentry->size;
541
    size_t delta = (pos + len) - dentry->size;
728
    /*
542
    /*
729
     * At this point, we are deliberately extremely straightforward and
543
     * At this point, we are deliberately extremely straightforward and
730
     * simply realloc the contents of the file on every write that grows the
544
     * simply realloc the contents of the file on every write that grows the
731
     * file. In the end, the situation might not be as bad as it may look:
545
     * file. In the end, the situation might not be as bad as it may look:
732
     * our heap allocator can save us and just grow the block whenever
546
     * our heap allocator can save us and just grow the block whenever
733
     * possible.
547
     * possible.
734
     */
548
     */
735
    void *newdata = realloc(dentry->data, dentry->size + delta);
549
    void *newdata = realloc(dentry->data, dentry->size + delta);
736
    if (!newdata) {
550
    if (!newdata) {
737
        ipc_answer_0(callid, ENOMEM);
551
        ipc_answer_0(callid, ENOMEM);
738
        ipc_answer_2(rid, EOK, 0, dentry->size);
552
        ipc_answer_2(rid, EOK, 0, dentry->size);
739
        return;
553
        return;
740
    }
554
    }
741
    /* Clear any newly allocated memory in order to emulate gaps. */
555
    /* Clear any newly allocated memory in order to emulate gaps. */
742
    memset(newdata + dentry->size, 0, delta);
556
    memset(newdata + dentry->size, 0, delta);
743
    dentry->size += delta;
557
    dentry->size += delta;
744
    dentry->data = newdata;
558
    dentry->data = newdata;
745
    (void) ipc_data_write_finalize(callid, dentry->data + pos, len);
559
    (void) ipc_data_write_finalize(callid, dentry->data + pos, len);
746
    ipc_answer_2(rid, EOK, len, dentry->size);
560
    ipc_answer_2(rid, EOK, len, dentry->size);
747
}
561
}
748
 
562
 
749
void tmpfs_truncate(ipc_callid_t rid, ipc_call_t *request)
563
void tmpfs_truncate(ipc_callid_t rid, ipc_call_t *request)
750
{
564
{
751
    dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request);
565
    dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request);
752
    fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request);
566
    fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request);
753
    size_t size = (off_t)IPC_GET_ARG3(*request);
567
    size_t size = (off_t)IPC_GET_ARG3(*request);
754
 
568
 
755
    /*
569
    /*
756
     * Lookup the respective dentry.
570
     * Lookup the respective dentry.
757
     */
571
     */
758
    link_t *hlp;
572
    link_t *hlp;
759
    unsigned long key = index;
573
    unsigned long key = index;
760
    hlp = hash_table_find(&dentries, &key);
574
    hlp = hash_table_find(&dentries, &key);
761
    if (!hlp) {
575
    if (!hlp) {
762
        ipc_answer_0(rid, ENOENT);
576
        ipc_answer_0(rid, ENOENT);
763
        return;
577
        return;
764
    }
578
    }
765
    tmpfs_dentry_t *dentry = hash_table_get_instance(hlp, tmpfs_dentry_t,
579
    tmpfs_dentry_t *dentry = hash_table_get_instance(hlp, tmpfs_dentry_t,
766
        dh_link);
580
        dh_link);
767
 
581
 
768
    if (size == dentry->size) {
582
    if (size == dentry->size) {
769
        ipc_answer_0(rid, EOK);
583
        ipc_answer_0(rid, EOK);
770
        return;
584
        return;
771
    }
585
    }
772
 
586
 
773
    void *newdata = realloc(dentry->data, size);
587
    void *newdata = realloc(dentry->data, size);
774
    if (!newdata) {
588
    if (!newdata) {
775
        ipc_answer_0(rid, ENOMEM);
589
        ipc_answer_0(rid, ENOMEM);
776
        return;
590
        return;
777
    }
591
    }
778
    if (size > dentry->size) {
592
    if (size > dentry->size) {
779
        size_t delta = size - dentry->size;
593
        size_t delta = size - dentry->size;
780
        memset(newdata + dentry->size, 0, delta);
594
        memset(newdata + dentry->size, 0, delta);
781
    }
595
    }
782
    dentry->size = size;
596
    dentry->size = size;
783
    dentry->data = newdata;
597
    dentry->data = newdata;
784
    ipc_answer_0(rid, EOK);
598
    ipc_answer_0(rid, EOK);
785
}
599
}
786
 
600
 
787
void tmpfs_destroy(ipc_callid_t rid, ipc_call_t *request)
601
void tmpfs_destroy(ipc_callid_t rid, ipc_call_t *request)
788
{
602
{
789
    dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request);
603
    dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request);
790
    fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request);
604
    fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request);
791
    int rc;
605
    int rc;
792
 
606
 
793
    link_t *hlp;
607
    link_t *hlp;
794
    unsigned long key = index;
608
    unsigned long key = index;
795
    hlp = hash_table_find(&dentries, &key);
609
    hlp = hash_table_find(&dentries, &key);
796
    if (!hlp) {
610
    if (!hlp) {
797
        ipc_answer_0(rid, ENOENT);
611
        ipc_answer_0(rid, ENOENT);
798
        return;
612
        return;
799
    }
613
    }
800
    tmpfs_dentry_t *dentry = hash_table_get_instance(hlp, tmpfs_dentry_t,
614
    tmpfs_dentry_t *dentry = hash_table_get_instance(hlp, tmpfs_dentry_t,
801
        dh_link);
615
        dh_link);
802
    rc = tmpfs_destroy_node(dentry);
616
    rc = tmpfs_destroy_node(dentry);
803
    ipc_answer_0(rid, rc);
617
    ipc_answer_0(rid, rc);
804
}
618
}
805
 
619
 
806
/**
620
/**
807
 * @}
621
 * @}
808
 */
622
 */
809
 
623