Subversion Repositories HelenOS

Rev

Rev 4492 | Rev 4584 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
2671 jermar 1
/*
2684 jermar 2
 * Copyright (c) 2008 Jakub Jermar
2671 jermar 3
 * All rights reserved.
4
 *
5
 * Redistribution and use in source and binary forms, with or without
6
 * modification, are permitted provided that the following conditions
7
 * are met:
8
 *
9
 * - Redistributions of source code must retain the above copyright
10
 *   notice, this list of conditions and the following disclaimer.
11
 * - Redistributions in binary form must reproduce the above copyright
12
 *   notice, this list of conditions and the following disclaimer in the
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
15
 *   derived from this software without specific prior written permission.
16
 *
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
19
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
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
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
26
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27
 */
28
 
29
/** @addtogroup libc
30
 * @{
31
 */
32
/** @file
33
 */
4002 decky 34
 
2755 jermar 35
#include <vfs/vfs.h>
36
#include <vfs/canonify.h>
2694 jermar 37
#include <stdlib.h>
2674 jermar 38
#include <unistd.h>
2694 jermar 39
#include <dirent.h>
2674 jermar 40
#include <fcntl.h>
2707 jermar 41
#include <sys/stat.h>
2771 jermar 42
#include <stdio.h>
2707 jermar 43
#include <sys/types.h>
2671 jermar 44
#include <ipc/ipc.h>
45
#include <ipc/services.h>
46
#include <async.h>
47
#include <atomic.h>
48
#include <futex.h>
49
#include <errno.h>
50
#include <string.h>
4401 svoboda 51
#include <devmap.h>
4482 decky 52
#include <ipc/vfs.h>
53
#include <ipc/devmap.h>
2671 jermar 54
 
4482 decky 55
static int vfs_phone = -1;
56
static futex_t vfs_phone_futex = FUTEX_INITIALIZER;
57
static futex_t cwd_futex = FUTEX_INITIALIZER;
2671 jermar 58
 
2755 jermar 59
DIR *cwd_dir = NULL;
60
char *cwd_path = NULL;
4256 svoboda 61
size_t cwd_size = 0;
2755 jermar 62
 
3306 jermar 63
char *absolutize(const char *path, size_t *retlen)
2755 jermar 64
{
65
    char *ncwd_path;
3292 jermar 66
    char *ncwd_path_nc;
2755 jermar 67
 
68
    futex_down(&cwd_futex);
4256 svoboda 69
    size_t size = str_size(path);
2755 jermar 70
    if (*path != '/') {
71
        if (!cwd_path) {
72
            futex_up(&cwd_futex);
73
            return NULL;
74
        }
4256 svoboda 75
        ncwd_path_nc = malloc(cwd_size + 1 + size + 1);
3292 jermar 76
        if (!ncwd_path_nc) {
2755 jermar 77
            futex_up(&cwd_futex);
78
            return NULL;
79
        }
4268 svoboda 80
        str_cpy(ncwd_path_nc, cwd_size + 1 + size + 1, cwd_path);
4256 svoboda 81
        ncwd_path_nc[cwd_size] = '/';
82
        ncwd_path_nc[cwd_size + 1] = '\0';
2755 jermar 83
    } else {
4256 svoboda 84
        ncwd_path_nc = malloc(size + 1);
3292 jermar 85
        if (!ncwd_path_nc) {
2755 jermar 86
            futex_up(&cwd_futex);
87
            return NULL;
88
        }
3292 jermar 89
        ncwd_path_nc[0] = '\0';
2755 jermar 90
    }
4280 svoboda 91
    str_append(ncwd_path_nc, cwd_size + 1 + size + 1, path);
3292 jermar 92
    ncwd_path = canonify(ncwd_path_nc, retlen);
93
    if (!ncwd_path) {
2771 jermar 94
        futex_up(&cwd_futex);
3292 jermar 95
        free(ncwd_path_nc);
2771 jermar 96
        return NULL;
97
    }
3292 jermar 98
    /*
99
     * We need to clone ncwd_path because canonify() works in-place and thus
100
     * the address in ncwd_path need not be the same as ncwd_path_nc, even
101
     * though they both point into the same dynamically allocated buffer.
102
     */
4266 svoboda 103
    ncwd_path = str_dup(ncwd_path);
3292 jermar 104
    free(ncwd_path_nc);
105
    if (!ncwd_path) {
106
        futex_up(&cwd_futex);
107
        return NULL;
108
    }
2755 jermar 109
    futex_up(&cwd_futex);
110
    return ncwd_path;
111
}
112
 
4002 decky 113
static void vfs_connect(void)
2671 jermar 114
{
4002 decky 115
    while (vfs_phone < 0)
116
        vfs_phone = ipc_connect_me_to_blocking(PHONE_NS, SERVICE_VFS, 0, 0);
2671 jermar 117
}
118
 
4002 decky 119
int mount(const char *fs_name, const char *mp, const char *dev,
4401 svoboda 120
    const char *opts, unsigned int flags)
2671 jermar 121
{
122
    int res;
123
    ipcarg_t rc;
124
    aid_t req;
3077 decky 125
    dev_handle_t dev_handle;
126
 
4401 svoboda 127
    res = devmap_device_get_handle(dev, &dev_handle, flags);
3077 decky 128
    if (res != EOK)
129
        return res;
130
 
4256 svoboda 131
    size_t mpa_size;
132
    char *mpa = absolutize(mp, &mpa_size);
2755 jermar 133
    if (!mpa)
134
        return ENOMEM;
4002 decky 135
 
2671 jermar 136
    futex_down(&vfs_phone_futex);
137
    async_serialize_start();
4002 decky 138
    vfs_connect();
139
 
140
    req = async_send_2(vfs_phone, VFS_MOUNT, dev_handle, flags, NULL);
4256 svoboda 141
    rc = ipc_data_write_start(vfs_phone, (void *) mpa, mpa_size);
2671 jermar 142
    if (rc != EOK) {
143
        async_wait_for(req, NULL);
144
        async_serialize_end();
145
        futex_up(&vfs_phone_futex);
2755 jermar 146
        free(mpa);
2671 jermar 147
        return (int) rc;
148
    }
4002 decky 149
 
4305 jermar 150
    rc = ipc_data_write_start(vfs_phone, (void *) opts, str_size(opts));
151
    if (rc != EOK) {
152
        async_wait_for(req, NULL);
153
        async_serialize_end();
154
        futex_up(&vfs_phone_futex);
155
        free(mpa);
156
        return (int) rc;
157
    }
158
 
4256 svoboda 159
    rc = ipc_data_write_start(vfs_phone, (void *) fs_name, str_size(fs_name));
3255 jermar 160
    if (rc != EOK) {
161
        async_wait_for(req, NULL);
162
        async_serialize_end();
163
        futex_up(&vfs_phone_futex);
164
        free(mpa);
165
        return (int) rc;
166
    }
4302 jermar 167
 
168
    /* Ask VFS whether it likes fs_name. */
169
    rc = async_req_0_0(vfs_phone, IPC_M_PING);
170
    if (rc != EOK) {
171
        async_wait_for(req, NULL);
172
        async_serialize_end();
173
        futex_up(&vfs_phone_futex);
174
        free(mpa);
175
        return (int) rc;
176
    }
4002 decky 177
 
2671 jermar 178
    async_wait_for(req, &rc);
179
    async_serialize_end();
180
    futex_up(&vfs_phone_futex);
2755 jermar 181
    free(mpa);
4002 decky 182
 
2671 jermar 183
    return (int) rc;
184
}
185
 
2700 jermar 186
static int _open(const char *path, int lflag, int oflag, ...)
2671 jermar 187
{
188
    ipcarg_t rc;
189
    ipc_call_t answer;
190
    aid_t req;
191
 
4256 svoboda 192
    size_t pa_size;
193
    char *pa = absolutize(path, &pa_size);
2755 jermar 194
    if (!pa)
195
        return ENOMEM;
196
 
2671 jermar 197
    futex_down(&vfs_phone_futex);
198
    async_serialize_start();
4002 decky 199
    vfs_connect();
200
 
2700 jermar 201
    req = async_send_3(vfs_phone, VFS_OPEN, lflag, oflag, 0, &answer);
4256 svoboda 202
    rc = ipc_data_write_start(vfs_phone, pa, pa_size);
2671 jermar 203
    if (rc != EOK) {
204
        async_wait_for(req, NULL);
205
        async_serialize_end();
206
        futex_up(&vfs_phone_futex);
2755 jermar 207
        free(pa);
2671 jermar 208
        return (int) rc;
209
    }
210
    async_wait_for(req, &rc);
211
    async_serialize_end();
212
    futex_up(&vfs_phone_futex);
2755 jermar 213
    free(pa);
4482 decky 214
 
3246 jermar 215
    if (rc != EOK)
216
        return (int) rc;
4482 decky 217
 
2671 jermar 218
    return (int) IPC_GET_ARG1(answer);
219
}
220
 
2700 jermar 221
int open(const char *path, int oflag, ...)
222
{
223
    return _open(path, L_FILE, oflag);
224
}
225
 
4492 jermar 226
int open_node(fdi_node_t *node, int oflag)
4482 decky 227
{
228
    futex_down(&vfs_phone_futex);
229
    async_serialize_start();
230
    vfs_connect();
231
 
232
    ipc_call_t answer;
233
    aid_t req = async_send_4(vfs_phone, VFS_OPEN_NODE, node->fs_handle,
234
        node->dev_handle, node->index, oflag, &answer);
235
 
236
    ipcarg_t rc;
237
    async_wait_for(req, &rc);
238
    async_serialize_end();
239
    futex_up(&vfs_phone_futex);
240
 
241
    if (rc != EOK)
242
        return (int) rc;
243
 
244
    return (int) IPC_GET_ARG1(answer);
245
}
246
 
2707 jermar 247
int close(int fildes)
248
{
2734 jermar 249
    ipcarg_t rc;
4002 decky 250
 
2734 jermar 251
    futex_down(&vfs_phone_futex);
252
    async_serialize_start();
4002 decky 253
    vfs_connect();
254
 
2734 jermar 255
    rc = async_req_1_0(vfs_phone, VFS_CLOSE, fildes);
4002 decky 256
 
2734 jermar 257
    async_serialize_end();
258
    futex_up(&vfs_phone_futex);
259
 
260
    return (int)rc;
2707 jermar 261
}
262
 
2671 jermar 263
ssize_t read(int fildes, void *buf, size_t nbyte)
264
{
265
    ipcarg_t rc;
266
    ipc_call_t answer;
267
    aid_t req;
268
 
269
    futex_down(&vfs_phone_futex);
270
    async_serialize_start();
4002 decky 271
    vfs_connect();
272
 
2674 jermar 273
    req = async_send_1(vfs_phone, VFS_READ, fildes, &answer);
2741 jermar 274
    rc = ipc_data_read_start(vfs_phone, (void *)buf, nbyte);
275
    if (rc != EOK) {
2671 jermar 276
        async_wait_for(req, NULL);
277
        async_serialize_end();
278
        futex_up(&vfs_phone_futex);
279
        return (ssize_t) rc;
280
    }
281
    async_wait_for(req, &rc);
282
    async_serialize_end();
283
    futex_up(&vfs_phone_futex);
2710 jermar 284
    if (rc == EOK)
285
        return (ssize_t) IPC_GET_ARG1(answer);
286
    else
3313 jermar 287
        return rc;
2671 jermar 288
}
289
 
2674 jermar 290
ssize_t write(int fildes, const void *buf, size_t nbyte)
291
{
292
    ipcarg_t rc;
293
    ipc_call_t answer;
294
    aid_t req;
295
 
296
    futex_down(&vfs_phone_futex);
297
    async_serialize_start();
4002 decky 298
    vfs_connect();
299
 
2674 jermar 300
    req = async_send_1(vfs_phone, VFS_WRITE, fildes, &answer);
2741 jermar 301
    rc = ipc_data_write_start(vfs_phone, (void *)buf, nbyte);
302
    if (rc != EOK) {
2674 jermar 303
        async_wait_for(req, NULL);
304
        async_serialize_end();
305
        futex_up(&vfs_phone_futex);
306
        return (ssize_t) rc;
307
    }
308
    async_wait_for(req, &rc);
309
    async_serialize_end();
310
    futex_up(&vfs_phone_futex);
2710 jermar 311
    if (rc == EOK)
312
        return (ssize_t) IPC_GET_ARG1(answer);
313
    else
314
        return -1;
2674 jermar 315
}
2684 jermar 316
 
4482 decky 317
int fd_phone(int fildes)
318
{
319
    futex_down(&vfs_phone_futex);
320
    async_serialize_start();
321
    vfs_connect();
322
 
323
    ipcarg_t device;
324
    ipcarg_t rc = async_req_1_1(vfs_phone, VFS_DEVICE, fildes, &device);
325
 
326
    async_serialize_end();
327
    futex_up(&vfs_phone_futex);
328
 
329
    if (rc != EOK)
330
        return -1;
331
 
332
    return devmap_device_connect((dev_handle_t) device, 0);
333
}
334
 
4508 decky 335
int fd_node(int fildes, fdi_node_t *node)
4482 decky 336
{
337
    futex_down(&vfs_phone_futex);
338
    async_serialize_start();
339
    vfs_connect();
340
 
341
    ipcarg_t fs_handle;
342
    ipcarg_t dev_handle;
343
    ipcarg_t index;
344
    ipcarg_t rc = async_req_1_3(vfs_phone, VFS_NODE, fildes, &fs_handle,
345
        &dev_handle, &index);
346
 
347
    async_serialize_end();
348
    futex_up(&vfs_phone_futex);
349
 
350
    if (rc == EOK) {
351
        node->fs_handle = (fs_handle_t) fs_handle;
352
        node->dev_handle = (dev_handle_t) dev_handle;
353
        node->index = (fs_index_t) index;
354
    }
4508 decky 355
 
356
    return rc;
4482 decky 357
}
358
 
359
int fsync(int fildes)
360
{
361
    futex_down(&vfs_phone_futex);
362
    async_serialize_start();
363
    vfs_connect();
364
 
365
    ipcarg_t rc = async_req_1_0(vfs_phone, VFS_SYNC, fildes);
366
 
367
    async_serialize_end();
368
    futex_up(&vfs_phone_futex);
369
 
370
    return (int) rc;
371
}
372
 
2684 jermar 373
off_t lseek(int fildes, off_t offset, int whence)
374
{
375
    ipcarg_t rc;
376
 
377
    futex_down(&vfs_phone_futex);
378
    async_serialize_start();
4002 decky 379
    vfs_connect();
380
 
3488 svoboda 381
    ipcarg_t newoffs;
2684 jermar 382
    rc = async_req_3_1(vfs_phone, VFS_SEEK, fildes, offset, whence,
3488 svoboda 383
        &newoffs);
2684 jermar 384
 
385
    async_serialize_end();
386
    futex_up(&vfs_phone_futex);
387
 
388
    if (rc != EOK)
389
        return (off_t) -1;
390
 
3488 svoboda 391
    return (off_t) newoffs;
2684 jermar 392
}
393
 
2693 jermar 394
int ftruncate(int fildes, off_t length)
395
{
396
    ipcarg_t rc;
397
 
398
    futex_down(&vfs_phone_futex);
399
    async_serialize_start();
4002 decky 400
    vfs_connect();
401
 
2693 jermar 402
    rc = async_req_2_0(vfs_phone, VFS_TRUNCATE, fildes, length);
403
    async_serialize_end();
404
    futex_up(&vfs_phone_futex);
405
    return (int) rc;
406
}
407
 
2694 jermar 408
DIR *opendir(const char *dirname)
409
{
410
    DIR *dirp = malloc(sizeof(DIR));
411
    if (!dirp)
412
        return NULL;
2700 jermar 413
    dirp->fd = _open(dirname, L_DIRECTORY, 0);
2699 jermar 414
    if (dirp->fd < 0) {
2694 jermar 415
        free(dirp);
416
        return NULL;
417
    }
418
    return dirp;
419
}
420
 
421
struct dirent *readdir(DIR *dirp)
422
{
2699 jermar 423
    ssize_t len = read(dirp->fd, &dirp->res.d_name[0], NAME_MAX + 1);
424
    if (len <= 0)
425
        return NULL;
426
    return &dirp->res;
2694 jermar 427
}
428
 
429
void rewinddir(DIR *dirp)
430
{
2699 jermar 431
    (void) lseek(dirp->fd, 0, SEEK_SET);
2694 jermar 432
}
433
 
434
int closedir(DIR *dirp)
435
{
436
    (void) close(dirp->fd);
437
    free(dirp);
438
    return 0;
439
}
440
 
2707 jermar 441
int mkdir(const char *path, mode_t mode)
2694 jermar 442
{
2707 jermar 443
    ipcarg_t rc;
444
    aid_t req;
445
 
4256 svoboda 446
    size_t pa_size;
447
    char *pa = absolutize(path, &pa_size);
2755 jermar 448
    if (!pa)
449
        return ENOMEM;
4002 decky 450
 
2707 jermar 451
    futex_down(&vfs_phone_futex);
452
    async_serialize_start();
4002 decky 453
    vfs_connect();
454
 
2735 jermar 455
    req = async_send_1(vfs_phone, VFS_MKDIR, mode, NULL);
4256 svoboda 456
    rc = ipc_data_write_start(vfs_phone, pa, pa_size);
2707 jermar 457
    if (rc != EOK) {
458
        async_wait_for(req, NULL);
459
        async_serialize_end();
460
        futex_up(&vfs_phone_futex);
2755 jermar 461
        free(pa);
2707 jermar 462
        return (int) rc;
463
    }
464
    async_wait_for(req, &rc);
465
    async_serialize_end();
466
    futex_up(&vfs_phone_futex);
2755 jermar 467
    free(pa);
4482 decky 468
    return rc;
2694 jermar 469
}
470
 
2735 jermar 471
static int _unlink(const char *path, int lflag)
472
{
473
    ipcarg_t rc;
474
    aid_t req;
475
 
4256 svoboda 476
    size_t pa_size;
477
    char *pa = absolutize(path, &pa_size);
2755 jermar 478
    if (!pa)
479
        return ENOMEM;
2771 jermar 480
 
2735 jermar 481
    futex_down(&vfs_phone_futex);
482
    async_serialize_start();
4002 decky 483
    vfs_connect();
484
 
2735 jermar 485
    req = async_send_0(vfs_phone, VFS_UNLINK, NULL);
4256 svoboda 486
    rc = ipc_data_write_start(vfs_phone, pa, pa_size);
2735 jermar 487
    if (rc != EOK) {
488
        async_wait_for(req, NULL);
489
        async_serialize_end();
490
        futex_up(&vfs_phone_futex);
2755 jermar 491
        free(pa);
2735 jermar 492
        return (int) rc;
493
    }
494
    async_wait_for(req, &rc);
495
    async_serialize_end();
496
    futex_up(&vfs_phone_futex);
2755 jermar 497
    free(pa);
4482 decky 498
    return rc;
2735 jermar 499
}
500
 
501
int unlink(const char *path)
502
{
503
    return _unlink(path, L_NONE);
504
}
505
 
506
int rmdir(const char *path)
507
{
508
    return _unlink(path, L_DIRECTORY);
509
}
510
 
2763 jermar 511
int rename(const char *old, const char *new)
512
{
513
    ipcarg_t rc;
514
    aid_t req;
515
 
4256 svoboda 516
    size_t olda_size;
517
    char *olda = absolutize(old, &olda_size);
2763 jermar 518
    if (!olda)
519
        return ENOMEM;
2771 jermar 520
 
4256 svoboda 521
    size_t newa_size;
522
    char *newa = absolutize(new, &newa_size);
2763 jermar 523
    if (!newa) {
524
        free(olda);
525
        return ENOMEM;
526
    }
527
 
528
    futex_down(&vfs_phone_futex);
529
    async_serialize_start();
4002 decky 530
    vfs_connect();
531
 
2763 jermar 532
    req = async_send_0(vfs_phone, VFS_RENAME, NULL);
4256 svoboda 533
    rc = ipc_data_write_start(vfs_phone, olda, olda_size);
2763 jermar 534
    if (rc != EOK) {
535
        async_wait_for(req, NULL);
536
        async_serialize_end();
537
        futex_up(&vfs_phone_futex);
538
        free(olda);
539
        free(newa);
540
        return (int) rc;
541
    }
4256 svoboda 542
    rc = ipc_data_write_start(vfs_phone, newa, newa_size);
2763 jermar 543
    if (rc != EOK) {
544
        async_wait_for(req, NULL);
545
        async_serialize_end();
546
        futex_up(&vfs_phone_futex);
547
        free(olda);
548
        free(newa);
549
        return (int) rc;
550
    }
551
    async_wait_for(req, &rc);
552
    async_serialize_end();
553
    futex_up(&vfs_phone_futex);
554
    free(olda);
555
    free(newa);
556
    return rc;
557
}
558
 
2755 jermar 559
int chdir(const char *path)
560
{
4256 svoboda 561
    size_t pa_size;
562
    char *pa = absolutize(path, &pa_size);
2755 jermar 563
    if (!pa)
564
        return ENOMEM;
565
 
2771 jermar 566
    DIR *d = opendir(pa);
2755 jermar 567
    if (!d) {
568
        free(pa);
569
        return ENOENT;
570
    }
571
 
572
    futex_down(&cwd_futex);
573
    if (cwd_dir) {
574
        closedir(cwd_dir);
575
        cwd_dir = NULL;
576
        free(cwd_path);
577
        cwd_path = NULL;
4256 svoboda 578
        cwd_size = 0;
2755 jermar 579
    }
580
    cwd_dir = d;
2771 jermar 581
    cwd_path = pa;
4256 svoboda 582
    cwd_size = pa_size;
2755 jermar 583
    futex_up(&cwd_futex);
3464 jermar 584
    return EOK;
2755 jermar 585
}
586
 
587
char *getcwd(char *buf, size_t size)
588
{
589
    if (!size)
590
        return NULL;
591
    futex_down(&cwd_futex);
4256 svoboda 592
    if (size < cwd_size + 1) {
2755 jermar 593
        futex_up(&cwd_futex);
594
        return NULL;
595
    }
4268 svoboda 596
    str_cpy(buf, size, cwd_path);
2755 jermar 597
    futex_up(&cwd_futex);
598
    return buf;
599
}
600
 
2671 jermar 601
/** @}
602
 */