WebSVN – HelenOS – Diff – /branches/dd/uspace/lib/libc/generic/vfs/vfs.c


/*
 * Copyright (c) 2008 Jakub Jermar
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * - Redistributions of source code must retain the above copyright
 *   notice, this list of conditions and the following disclaimer.
 * - Redistributions in binary form must reproduce the above copyright
 *   notice, this list of conditions and the following disclaimer in the
 *   documentation and/or other materials provided with the distribution.
 * - The name of the author may not be used to endorse or promote products
 *   derived from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */
 
/** @addtogroup libc
 * @{
 */
/** @file
 */
 
#include <vfs/vfs.h>
#include <vfs/canonify.h>
#include <stdlib.h>
#include <unistd.h>
#include <dirent.h>
#include <fcntl.h>
#include <stdio.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <ipc/ipc.h>
#include <ipc/services.h>
#include <async.h>
#include <atomic.h>
#include <futex.h>
#include <errno.h>
#include <string.h>
#include <devmap.h>
#include <ipc/vfs.h>
#include <ipc/devmap.h>
 
static int vfs_phone = -1;
static futex_t vfs_phone_futex = FUTEX_INITIALIZER;
static futex_t cwd_futex = FUTEX_INITIALIZER;
 
DIR *cwd_dir = NULL;
char *cwd_path = NULL;
size_t cwd_size = 0;
 
char *absolutize(const char *path, size_t *retlen)
{
    char *ncwd_path;
    char *ncwd_path_nc;
 
    futex_down(&cwd_futex);
    size_t size = str_size(path);
    if (*path != '/') {
        if (!cwd_path) {
            futex_up(&cwd_futex);
            return NULL;
        }
        ncwd_path_nc = malloc(cwd_size + 1 + size + 1);
        if (!ncwd_path_nc) {
            futex_up(&cwd_futex);
            return NULL;
        }
        str_cpy(ncwd_path_nc, cwd_size + 1 + size + 1, cwd_path);
        ncwd_path_nc[cwd_size] = '/';
        ncwd_path_nc[cwd_size + 1] = '\0';
    } else {
        ncwd_path_nc = malloc(size + 1);
        if (!ncwd_path_nc) {
            futex_up(&cwd_futex);
            return NULL;
        }
        ncwd_path_nc[0] = '\0';
    }
    str_append(ncwd_path_nc, cwd_size + 1 + size + 1, path);
    ncwd_path = canonify(ncwd_path_nc, retlen);
    if (!ncwd_path) {
        futex_up(&cwd_futex);
        free(ncwd_path_nc);
        return NULL;
    }
    /*
     * We need to clone ncwd_path because canonify() works in-place and thus
     * the address in ncwd_path need not be the same as ncwd_path_nc, even
     * though they both point into the same dynamically allocated buffer.
     */
    ncwd_path = str_dup(ncwd_path);
    free(ncwd_path_nc);
    if (!ncwd_path) {
        futex_up(&cwd_futex);
        return NULL;
    }
    futex_up(&cwd_futex);
    return ncwd_path;
}
 
static void vfs_connect(void)
{
    while (vfs_phone < 0)
        vfs_phone = ipc_connect_me_to_blocking(PHONE_NS, SERVICE_VFS, 0, 0);
}
 
int mount(const char *fs_name, const char *mp, const char *dev,
    const char *opts, unsigned int flags)
{
    int res;
    ipcarg_t rc;
    aid_t req;
    dev_handle_t dev_handle;
   
    res = devmap_device_get_handle(dev, &dev_handle, flags);
    if (res != EOK)
        return res;
   
    size_t mpa_size;
    char *mpa = absolutize(mp, &mpa_size);
    if (!mpa)
        return ENOMEM;
   
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    req = async_send_2(vfs_phone, VFS_IN_MOUNT, dev_handle, flags, NULL);
    rc = ipc_data_write_start(vfs_phone, (void *) mpa, mpa_size);
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        free(mpa);
        return (int) rc;
    }
   
    rc = ipc_data_write_start(vfs_phone, (void *) opts, str_size(opts));
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        free(mpa);
        return (int) rc;
    }
 
    rc = ipc_data_write_start(vfs_phone, (void *) fs_name, str_size(fs_name));
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        free(mpa);
        return (int) rc;
    }
 
    /* Ask VFS whether it likes fs_name. */
    rc = async_req_0_0(vfs_phone, IPC_M_PING);
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        free(mpa);
        return (int) rc;
    }
   
    async_wait_for(req, &rc);
    async_serialize_end();
    futex_up(&vfs_phone_futex);
    free(mpa);
   
    return (int) rc;
}
 
static int _open(const char *path, int lflag, int oflag, ...)
{
    ipcarg_t rc;
    ipc_call_t answer;
    aid_t req;
   
    size_t pa_size;
    char *pa = absolutize(path, &pa_size);
    if (!pa)
        return ENOMEM;
   
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    req = async_send_3(vfs_phone, VFS_IN_OPEN, lflag, oflag, 0, &answer);
    rc = ipc_data_write_start(vfs_phone, pa, pa_size);
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        free(pa);
        return (int) rc;
    }
    async_wait_for(req, &rc);
    async_serialize_end();
    futex_up(&vfs_phone_futex);
    free(pa);
   
    if (rc != EOK)
        return (int) rc;
   
    return (int) IPC_GET_ARG1(answer);
}
 
int open(const char *path, int oflag, ...)
{
    return _open(path, L_FILE, oflag);
}
 
int open_node(fdi_node_t *node, int oflag)
{
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    ipc_call_t answer;
    aid_t req = async_send_4(vfs_phone, VFS_IN_OPEN_NODE, node->fs_handle,
        node->dev_handle, node->index, oflag, &answer);
   
    ipcarg_t rc;
    async_wait_for(req, &rc);
    async_serialize_end();
    futex_up(&vfs_phone_futex);
   
    if (rc != EOK)
        return (int) rc;
   
    return (int) IPC_GET_ARG1(answer);
}
 
int close(int fildes)
{
    ipcarg_t rc;
   
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    rc = async_req_1_0(vfs_phone, VFS_IN_CLOSE, fildes);
   
    async_serialize_end();
    futex_up(&vfs_phone_futex);
   
    return (int)rc;
}
 
ssize_t read(int fildes, void *buf, size_t nbyte)
{
    ipcarg_t rc;
    ipc_call_t answer;
    aid_t req;
 
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    req = async_send_1(vfs_phone, VFS_IN_READ, fildes, &answer);
    rc = ipc_data_read_start(vfs_phone, (void *)buf, nbyte);
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        return (ssize_t) rc;
    }
    async_wait_for(req, &rc);
    async_serialize_end();
    futex_up(&vfs_phone_futex);
    if (rc == EOK)
        return (ssize_t) IPC_GET_ARG1(answer);
    else
        return rc;
}
 
ssize_t write(int fildes, const void *buf, size_t nbyte)
{
    ipcarg_t rc;
    ipc_call_t answer;
    aid_t req;
 
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    req = async_send_1(vfs_phone, VFS_IN_WRITE, fildes, &answer);
    rc = ipc_data_write_start(vfs_phone, (void *)buf, nbyte);
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        return (ssize_t) rc;
    }
    async_wait_for(req, &rc);
    async_serialize_end();
    futex_up(&vfs_phone_futex);
    if (rc == EOK)
        return (ssize_t) IPC_GET_ARG1(answer);
    else
        return -1;
}
 
int fsync(int fildes)
{
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    ipcarg_t rc = async_req_1_0(vfs_phone, VFS_IN_SYNC, fildes);
   
    async_serialize_end();
    futex_up(&vfs_phone_futex);
   
    return (int) rc;
}
 
off_t lseek(int fildes, off_t offset, int whence)
{
    ipcarg_t rc;
 
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    ipcarg_t newoffs;
    rc = async_req_3_1(vfs_phone, VFS_IN_SEEK, fildes, offset, whence,
        &newoffs);
 
    async_serialize_end();
    futex_up(&vfs_phone_futex);
 
    if (rc != EOK)
        return (off_t) -1;
   
    return (off_t) newoffs;
}
 
int ftruncate(int fildes, off_t length)
{
    ipcarg_t rc;
   
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    rc = async_req_2_0(vfs_phone, VFS_IN_TRUNCATE, fildes, length);
    async_serialize_end();
    futex_up(&vfs_phone_futex);
    return (int) rc;
}
 
int fstat(int fildes, struct stat *stat)
{
    ipcarg_t rc;
 
    aid_t req;
 
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    req = async_send_1(vfs_phone, VFS_IN_FSTAT, fildes, NULL);
    rc = ipc_data_read_start(vfs_phone, (void *)stat, sizeof(struct stat));
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        return (ssize_t) rc;
    }
    async_wait_for(req, &rc);
    async_serialize_end();
    futex_up(&vfs_phone_futex);
 
    return rc;
}
 
int stat(const char *path, struct stat *stat)
{
    ipcarg_t rc;
    aid_t req;
   
    size_t pa_size;
    char *pa = absolutize(path, &pa_size);
    if (!pa)
        return ENOMEM;
   
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    req = async_send_0(vfs_phone, VFS_IN_STAT, NULL);
    rc = ipc_data_write_start(vfs_phone, pa, pa_size);
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        free(pa);
        return (int) rc;
    }
    rc = ipc_data_read_start(vfs_phone, stat, sizeof(struct stat));
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        free(pa);
        return (int) rc;
    }
    async_wait_for(req, &rc);
    async_serialize_end();
    futex_up(&vfs_phone_futex);
    free(pa);
    return rc;
}
 
DIR *opendir(const char *dirname)
{
    DIR *dirp = malloc(sizeof(DIR));
    if (!dirp)
        return NULL;
    dirp->fd = _open(dirname, L_DIRECTORY, 0);
    if (dirp->fd < 0) {
        free(dirp);
        return NULL;
    }
    return dirp;
}
 
struct dirent *readdir(DIR *dirp)
{
    ssize_t len = read(dirp->fd, &dirp->res.d_name[0], NAME_MAX + 1);
    if (len <= 0)
        return NULL;
    return &dirp->res;
}
 
void rewinddir(DIR *dirp)
{
    (void) lseek(dirp->fd, 0, SEEK_SET);
}
 
int closedir(DIR *dirp)
{
    (void) close(dirp->fd);
    free(dirp);
    return 0;
}
 
int mkdir(const char *path, mode_t mode)
{
    ipcarg_t rc;
    aid_t req;
   
    size_t pa_size;
    char *pa = absolutize(path, &pa_size);
    if (!pa)
        return ENOMEM;
   
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    req = async_send_1(vfs_phone, VFS_IN_MKDIR, mode, NULL);
    rc = ipc_data_write_start(vfs_phone, pa, pa_size);
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        free(pa);
        return (int) rc;
    }
    async_wait_for(req, &rc);
    async_serialize_end();
    futex_up(&vfs_phone_futex);
    free(pa);
    return rc;
}
 
static int _unlink(const char *path, int lflag)
{
    ipcarg_t rc;
    aid_t req;
   
    size_t pa_size;
    char *pa = absolutize(path, &pa_size);
    if (!pa)
        return ENOMEM;
 
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    req = async_send_0(vfs_phone, VFS_IN_UNLINK, NULL);
    rc = ipc_data_write_start(vfs_phone, pa, pa_size);
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        free(pa);
        return (int) rc;
    }
    async_wait_for(req, &rc);
    async_serialize_end();
    futex_up(&vfs_phone_futex);
    free(pa);
    return rc;
}
 
int unlink(const char *path)
{
    return _unlink(path, L_NONE);
}
 
int rmdir(const char *path)
{
    return _unlink(path, L_DIRECTORY);
}
 
int rename(const char *old, const char *new)
{
    ipcarg_t rc;
    aid_t req;
   
    size_t olda_size;
    char *olda = absolutize(old, &olda_size);
    if (!olda)
        return ENOMEM;
 
    size_t newa_size;
    char *newa = absolutize(new, &newa_size);
    if (!newa) {
        free(olda);
        return ENOMEM;
    }
 
    futex_down(&vfs_phone_futex);
    async_serialize_start();
    vfs_connect();
   
    req = async_send_0(vfs_phone, VFS_IN_RENAME, NULL);
    rc = ipc_data_write_start(vfs_phone, olda, olda_size);
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        free(olda);
        free(newa);
        return (int) rc;
    }
    rc = ipc_data_write_start(vfs_phone, newa, newa_size);
    if (rc != EOK) {
        async_wait_for(req, NULL);
        async_serialize_end();
        futex_up(&vfs_phone_futex);
        free(olda);
        free(newa);
        return (int) rc;
    }
    async_wait_for(req, &rc);
    async_serialize_end();
    futex_up(&vfs_phone_futex);
    free(olda);
    free(newa);
    return rc;
}
 
int chdir(const char *path)
{
    size_t pa_size;
    char *pa = absolutize(path, &pa_size);
    if (!pa)
        return ENOMEM;
 
    DIR *d = opendir(pa);
    if (!d) {
        free(pa);
        return ENOENT;
    }
 
    futex_down(&cwd_futex);
    if (cwd_dir) {
        closedir(cwd_dir);
        cwd_dir = NULL;
        free(cwd_path);
        cwd_path = NULL;
        cwd_size = 0;
    }
    cwd_dir = d;
    cwd_path = pa;
    cwd_size = pa_size;
    futex_up(&cwd_futex);
    return EOK;
}
 
char *getcwd(char *buf, size_t size)
{
    if (!size)
        return NULL;
    futex_down(&cwd_futex);
    if (size < cwd_size + 1) {
        futex_up(&cwd_futex);
        return NULL;
    }
    str_cpy(buf, size, cwd_path);
    futex_up(&cwd_futex);
    return buf;
}
 
int fd_phone(int fildes)
{
    struct stat stat;
    int rc;
 
    rc = fstat(fildes, &stat);
 
    if (!stat.devfs_stat.device)
        return -1;
   
    return devmap_device_connect(stat.devfs_stat.device, 0);
}
 
int fd_node(int fildes, fdi_node_t *node)
{
    struct stat stat;
    int rc;
 
    rc = fstat(fildes, &stat);
   
    if (rc == EOK) {
        node->fs_handle = stat.fs_handle;
        node->dev_handle = stat.dev_handle;
        node->index = stat.index;
    }
   
    return rc;
}
 
/** @}
 */
 

Rev 4668	Rev 4688
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 libc	29	/** @addtogroup libc
30	* @{	30	* @{
31	*/	31	*/
32	/** @file	32	/** @file
33	*/	33	*/
34		34
35	#include <vfs/vfs.h>	35	#include <vfs/vfs.h>
36	#include <vfs/canonify.h>	36	#include <vfs/canonify.h>
37	#include <stdlib.h>	37	#include <stdlib.h>
38	#include <unistd.h>	38	#include <unistd.h>
39	#include <dirent.h>	39	#include <dirent.h>
40	#include <fcntl.h>	40	#include <fcntl.h>
41	#include <stdio.h>	41	#include <stdio.h>
42	#include <sys/stat.h>	42	#include <sys/stat.h>
43	#include <sys/types.h>	43	#include <sys/types.h>
44	#include <ipc/ipc.h>	44	#include <ipc/ipc.h>
45	#include <ipc/services.h>	45	#include <ipc/services.h>
46	#include <async.h>	46	#include <async.h>
47	#include <atomic.h>	47	#include <atomic.h>
48	#include <futex.h>	48	#include <futex.h>
49	#include <errno.h>	49	#include <errno.h>
50	#include <string.h>	50	#include <string.h>
51	#include <devmap.h>	51	#include <devmap.h>
52	#include <ipc/vfs.h>	52	#include <ipc/vfs.h>
53	#include <ipc/devmap.h>	53	#include <ipc/devmap.h>
54		54
55	static int vfs_phone = -1;	55	static int vfs_phone = -1;
56	static futex_t vfs_phone_futex = FUTEX_INITIALIZER;	56	static futex_t vfs_phone_futex = FUTEX_INITIALIZER;
57	static futex_t cwd_futex = FUTEX_INITIALIZER;	57	static futex_t cwd_futex = FUTEX_INITIALIZER;
58		58
59	DIR *cwd_dir = NULL;	59	DIR *cwd_dir = NULL;
60	char *cwd_path = NULL;	60	char *cwd_path = NULL;
61	size_t cwd_size = 0;	61	size_t cwd_size = 0;
62		62
63	char absolutize(const char path, size_t *retlen)	63	char absolutize(const char path, size_t *retlen)
64	{	64	{
65	char *ncwd_path;	65	char *ncwd_path;
66	char *ncwd_path_nc;	66	char *ncwd_path_nc;
67		67
68	futex_down(&cwd_futex);	68	futex_down(&cwd_futex);
69	size_t size = str_size(path);	69	size_t size = str_size(path);
70	if (*path != '/') {	70	if (*path != '/') {
71	if (!cwd_path) {	71	if (!cwd_path) {
72	futex_up(&cwd_futex);	72	futex_up(&cwd_futex);
73	return NULL;	73	return NULL;
74	}	74	}
75	ncwd_path_nc = malloc(cwd_size + 1 + size + 1);	75	ncwd_path_nc = malloc(cwd_size + 1 + size + 1);
76	if (!ncwd_path_nc) {	76	if (!ncwd_path_nc) {
77	futex_up(&cwd_futex);	77	futex_up(&cwd_futex);
78	return NULL;	78	return NULL;
79	}	79	}
80	str_cpy(ncwd_path_nc, cwd_size + 1 + size + 1, cwd_path);	80	str_cpy(ncwd_path_nc, cwd_size + 1 + size + 1, cwd_path);
81	ncwd_path_nc[cwd_size] = '/';	81	ncwd_path_nc[cwd_size] = '/';
82	ncwd_path_nc[cwd_size + 1] = '\0';	82	ncwd_path_nc[cwd_size + 1] = '\0';
83	} else {	83	} else {
84	ncwd_path_nc = malloc(size + 1);	84	ncwd_path_nc = malloc(size + 1);
85	if (!ncwd_path_nc) {	85	if (!ncwd_path_nc) {
86	futex_up(&cwd_futex);	86	futex_up(&cwd_futex);
87	return NULL;	87	return NULL;
88	}	88	}
89	ncwd_path_nc[0] = '\0';	89	ncwd_path_nc[0] = '\0';
90	}	90	}
91	str_append(ncwd_path_nc, cwd_size + 1 + size + 1, path);	91	str_append(ncwd_path_nc, cwd_size + 1 + size + 1, path);
92	ncwd_path = canonify(ncwd_path_nc, retlen);	92	ncwd_path = canonify(ncwd_path_nc, retlen);
93	if (!ncwd_path) {	93	if (!ncwd_path) {
94	futex_up(&cwd_futex);	94	futex_up(&cwd_futex);
95	free(ncwd_path_nc);	95	free(ncwd_path_nc);
96	return NULL;	96	return NULL;
97	}	97	}
98	/*	98	/*
99	* We need to clone ncwd_path because canonify() works in-place and thus	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	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.	101	* though they both point into the same dynamically allocated buffer.
102	*/	102	*/
103	ncwd_path = str_dup(ncwd_path);	103	ncwd_path = str_dup(ncwd_path);
104	free(ncwd_path_nc);	104	free(ncwd_path_nc);
105	if (!ncwd_path) {	105	if (!ncwd_path) {
106	futex_up(&cwd_futex);	106	futex_up(&cwd_futex);
107	return NULL;	107	return NULL;
108	}	108	}
109	futex_up(&cwd_futex);	109	futex_up(&cwd_futex);
110	return ncwd_path;	110	return ncwd_path;
111	}	111	}
112		112
113	static void vfs_connect(void)	113	static void vfs_connect(void)
114	{	114	{
115	while (vfs_phone < 0)	115	while (vfs_phone < 0)
116	vfs_phone = ipc_connect_me_to_blocking(PHONE_NS, SERVICE_VFS, 0, 0);	116	vfs_phone = ipc_connect_me_to_blocking(PHONE_NS, SERVICE_VFS, 0, 0);
117	}	117	}
118		118
119	int mount(const char fs_name, const char mp, const char *dev,	119	int mount(const char fs_name, const char mp, const char *dev,
120	const char *opts, unsigned int flags)	120	const char *opts, unsigned int flags)
121	{	121	{
122	int res;	122	int res;
123	ipcarg_t rc;	123	ipcarg_t rc;
124	aid_t req;	124	aid_t req;
125	dev_handle_t dev_handle;	125	dev_handle_t dev_handle;
126		126
127	res = devmap_device_get_handle(dev, &dev_handle, flags);	127	res = devmap_device_get_handle(dev, &dev_handle, flags);
128	if (res != EOK)	128	if (res != EOK)
129	return res;	129	return res;
130		130
131	size_t mpa_size;	131	size_t mpa_size;
132	char *mpa = absolutize(mp, &mpa_size);	132	char *mpa = absolutize(mp, &mpa_size);
133	if (!mpa)	133	if (!mpa)
134	return ENOMEM;	134	return ENOMEM;
135		135
136	futex_down(&vfs_phone_futex);	136	futex_down(&vfs_phone_futex);
137	async_serialize_start();	137	async_serialize_start();
138	vfs_connect();	138	vfs_connect();
139		139
140	req = async_send_2(vfs_phone, VFS_IN_MOUNT, dev_handle, flags, NULL);	140	req = async_send_2(vfs_phone, VFS_IN_MOUNT, dev_handle, flags, NULL);
141	rc = ipc_data_write_start(vfs_phone, (void *) mpa, mpa_size);	141	rc = ipc_data_write_start(vfs_phone, (void *) mpa, mpa_size);
142	if (rc != EOK) {	142	if (rc != EOK) {
143	async_wait_for(req, NULL);	143	async_wait_for(req, NULL);
144	async_serialize_end();	144	async_serialize_end();
145	futex_up(&vfs_phone_futex);	145	futex_up(&vfs_phone_futex);
146	free(mpa);	146	free(mpa);
147	return (int) rc;	147	return (int) rc;
148	}	148	}
149		149
150	rc = ipc_data_write_start(vfs_phone, (void *) opts, str_size(opts));	150	rc = ipc_data_write_start(vfs_phone, (void *) opts, str_size(opts));
151	if (rc != EOK) {	151	if (rc != EOK) {
152	async_wait_for(req, NULL);	152	async_wait_for(req, NULL);
153	async_serialize_end();	153	async_serialize_end();
154	futex_up(&vfs_phone_futex);	154	futex_up(&vfs_phone_futex);
155	free(mpa);	155	free(mpa);
156	return (int) rc;	156	return (int) rc;
157	}	157	}
158		158
159	rc = ipc_data_write_start(vfs_phone, (void *) fs_name, str_size(fs_name));	159	rc = ipc_data_write_start(vfs_phone, (void *) fs_name, str_size(fs_name));
160	if (rc != EOK) {	160	if (rc != EOK) {
161	async_wait_for(req, NULL);	161	async_wait_for(req, NULL);
162	async_serialize_end();	162	async_serialize_end();
163	futex_up(&vfs_phone_futex);	163	futex_up(&vfs_phone_futex);
164	free(mpa);	164	free(mpa);
165	return (int) rc;	165	return (int) rc;
166	}	166	}
167		167
168	/* Ask VFS whether it likes fs_name. */	168	/* Ask VFS whether it likes fs_name. */
169	rc = async_req_0_0(vfs_phone, IPC_M_PING);	169	rc = async_req_0_0(vfs_phone, IPC_M_PING);
170	if (rc != EOK) {	170	if (rc != EOK) {
171	async_wait_for(req, NULL);	171	async_wait_for(req, NULL);
172	async_serialize_end();	172	async_serialize_end();
173	futex_up(&vfs_phone_futex);	173	futex_up(&vfs_phone_futex);
174	free(mpa);	174	free(mpa);
175	return (int) rc;	175	return (int) rc;
176	}	176	}
177		177
178	async_wait_for(req, &rc);	178	async_wait_for(req, &rc);
179	async_serialize_end();	179	async_serialize_end();
180	futex_up(&vfs_phone_futex);	180	futex_up(&vfs_phone_futex);
181	free(mpa);	181	free(mpa);
182		182
183	return (int) rc;	183	return (int) rc;
184	}	184	}
185		185
186	static int _open(const char *path, int lflag, int oflag, ...)	186	static int _open(const char *path, int lflag, int oflag, ...)
187	{	187	{
188	ipcarg_t rc;	188	ipcarg_t rc;
189	ipc_call_t answer;	189	ipc_call_t answer;
190	aid_t req;	190	aid_t req;
191		191
192	size_t pa_size;	192	size_t pa_size;
193	char *pa = absolutize(path, &pa_size);	193	char *pa = absolutize(path, &pa_size);
194	if (!pa)	194	if (!pa)
195	return ENOMEM;	195	return ENOMEM;
196		196
197	futex_down(&vfs_phone_futex);	197	futex_down(&vfs_phone_futex);
198	async_serialize_start();	198	async_serialize_start();
199	vfs_connect();	199	vfs_connect();
200		200
201	req = async_send_3(vfs_phone, VFS_IN_OPEN, lflag, oflag, 0, &answer);	201	req = async_send_3(vfs_phone, VFS_IN_OPEN, lflag, oflag, 0, &answer);
202	rc = ipc_data_write_start(vfs_phone, pa, pa_size);	202	rc = ipc_data_write_start(vfs_phone, pa, pa_size);
203	if (rc != EOK) {	203	if (rc != EOK) {
204	async_wait_for(req, NULL);	204	async_wait_for(req, NULL);
205	async_serialize_end();	205	async_serialize_end();
206	futex_up(&vfs_phone_futex);	206	futex_up(&vfs_phone_futex);
207	free(pa);	207	free(pa);
208	return (int) rc;	208	return (int) rc;
209	}	209	}
210	async_wait_for(req, &rc);	210	async_wait_for(req, &rc);
211	async_serialize_end();	211	async_serialize_end();
212	futex_up(&vfs_phone_futex);	212	futex_up(&vfs_phone_futex);
213	free(pa);	213	free(pa);
214		214
215	if (rc != EOK)	215	if (rc != EOK)
216	return (int) rc;	216	return (int) rc;
217		217
218	return (int) IPC_GET_ARG1(answer);	218	return (int) IPC_GET_ARG1(answer);
219	}	219	}
220		220
221	int open(const char *path, int oflag, ...)	221	int open(const char *path, int oflag, ...)
222	{	222	{
223	return _open(path, L_FILE, oflag);	223	return _open(path, L_FILE, oflag);
224	}	224	}
225		225
226	int open_node(fdi_node_t *node, int oflag)	226	int open_node(fdi_node_t *node, int oflag)
227	{	227	{
228	futex_down(&vfs_phone_futex);	228	futex_down(&vfs_phone_futex);
229	async_serialize_start();	229	async_serialize_start();
230	vfs_connect();	230	vfs_connect();
231		231
232	ipc_call_t answer;	232	ipc_call_t answer;
233	aid_t req = async_send_4(vfs_phone, VFS_IN_OPEN_NODE, node->fs_handle,	233	aid_t req = async_send_4(vfs_phone, VFS_IN_OPEN_NODE, node->fs_handle,
234	node->dev_handle, node->index, oflag, &answer);	234	node->dev_handle, node->index, oflag, &answer);
235		235
236	ipcarg_t rc;	236	ipcarg_t rc;
237	async_wait_for(req, &rc);	237	async_wait_for(req, &rc);
238	async_serialize_end();	238	async_serialize_end();
239	futex_up(&vfs_phone_futex);	239	futex_up(&vfs_phone_futex);
240		240
241	if (rc != EOK)	241	if (rc != EOK)
242	return (int) rc;	242	return (int) rc;
243		243
244	return (int) IPC_GET_ARG1(answer);	244	return (int) IPC_GET_ARG1(answer);
245	}	245	}
246		246
247	int close(int fildes)	247	int close(int fildes)
248	{	248	{
249	ipcarg_t rc;	249	ipcarg_t rc;
250		250
251	futex_down(&vfs_phone_futex);	251	futex_down(&vfs_phone_futex);
252	async_serialize_start();	252	async_serialize_start();
253	vfs_connect();	253	vfs_connect();
254		254
255	rc = async_req_1_0(vfs_phone, VFS_IN_CLOSE, fildes);	255	rc = async_req_1_0(vfs_phone, VFS_IN_CLOSE, fildes);
256		256
257	async_serialize_end();	257	async_serialize_end();
258	futex_up(&vfs_phone_futex);	258	futex_up(&vfs_phone_futex);
259		259
260	return (int)rc;	260	return (int)rc;
261	}	261	}
262		262
263	ssize_t read(int fildes, void *buf, size_t nbyte)	263	ssize_t read(int fildes, void *buf, size_t nbyte)
264	{	264	{
265	ipcarg_t rc;	265	ipcarg_t rc;
266	ipc_call_t answer;	266	ipc_call_t answer;
267	aid_t req;	267	aid_t req;
268		268
269	futex_down(&vfs_phone_futex);	269	futex_down(&vfs_phone_futex);
270	async_serialize_start();	270	async_serialize_start();
271	vfs_connect();	271	vfs_connect();
272		272
273	req = async_send_1(vfs_phone, VFS_IN_READ, fildes, &answer);	273	req = async_send_1(vfs_phone, VFS_IN_READ, fildes, &answer);
274	rc = ipc_data_read_start(vfs_phone, (void *)buf, nbyte);	274	rc = ipc_data_read_start(vfs_phone, (void *)buf, nbyte);
275	if (rc != EOK) {	275	if (rc != EOK) {
276	async_wait_for(req, NULL);	276	async_wait_for(req, NULL);
277	async_serialize_end();	277	async_serialize_end();
278	futex_up(&vfs_phone_futex);	278	futex_up(&vfs_phone_futex);
279	return (ssize_t) rc;	279	return (ssize_t) rc;
280	}	280	}
281	async_wait_for(req, &rc);	281	async_wait_for(req, &rc);
282	async_serialize_end();	282	async_serialize_end();
283	futex_up(&vfs_phone_futex);	283	futex_up(&vfs_phone_futex);
284	if (rc == EOK)	284	if (rc == EOK)
285	return (ssize_t) IPC_GET_ARG1(answer);	285	return (ssize_t) IPC_GET_ARG1(answer);
286	else	286	else
287	return rc;	287	return rc;
288	}	288	}
289		289
290	ssize_t write(int fildes, const void *buf, size_t nbyte)	290	ssize_t write(int fildes, const void *buf, size_t nbyte)
291	{	291	{
292	ipcarg_t rc;	292	ipcarg_t rc;
293	ipc_call_t answer;	293	ipc_call_t answer;
294	aid_t req;	294	aid_t req;
295		295
296	futex_down(&vfs_phone_futex);	296	futex_down(&vfs_phone_futex);
297	async_serialize_start();	297	async_serialize_start();
298	vfs_connect();	298	vfs_connect();
299		299
300	req = async_send_1(vfs_phone, VFS_IN_WRITE, fildes, &answer);	300	req = async_send_1(vfs_phone, VFS_IN_WRITE, fildes, &answer);
301	rc = ipc_data_write_start(vfs_phone, (void *)buf, nbyte);	301	rc = ipc_data_write_start(vfs_phone, (void *)buf, nbyte);
302	if (rc != EOK) {	302	if (rc != EOK) {
303	async_wait_for(req, NULL);	303	async_wait_for(req, NULL);
304	async_serialize_end();	304	async_serialize_end();
305	futex_up(&vfs_phone_futex);	305	futex_up(&vfs_phone_futex);
306	return (ssize_t) rc;	306	return (ssize_t) rc;
307	}	307	}
308	async_wait_for(req, &rc);	308	async_wait_for(req, &rc);
309	async_serialize_end();	309	async_serialize_end();
310	futex_up(&vfs_phone_futex);	310	futex_up(&vfs_phone_futex);
311	if (rc == EOK)	311	if (rc == EOK)
312	return (ssize_t) IPC_GET_ARG1(answer);	312	return (ssize_t) IPC_GET_ARG1(answer);
313	else	313	else
314	return -1;	314	return -1;
315	}	315	}
316		316
317	int fsync(int fildes)	317	int fsync(int fildes)
318	{	318	{
319	futex_down(&vfs_phone_futex);	319	futex_down(&vfs_phone_futex);
320	async_serialize_start();	320	async_serialize_start();
321	vfs_connect();	321	vfs_connect();
322		322
323	ipcarg_t rc = async_req_1_0(vfs_phone, VFS_IN_SYNC, fildes);	323	ipcarg_t rc = async_req_1_0(vfs_phone, VFS_IN_SYNC, fildes);
324		324
325	async_serialize_end();	325	async_serialize_end();
326	futex_up(&vfs_phone_futex);	326	futex_up(&vfs_phone_futex);
327		327
328	return (int) rc;	328	return (int) rc;
329	}	329	}
330		330
331	off_t lseek(int fildes, off_t offset, int whence)	331	off_t lseek(int fildes, off_t offset, int whence)
332	{	332	{
333	ipcarg_t rc;	333	ipcarg_t rc;
334		334
335	futex_down(&vfs_phone_futex);	335	futex_down(&vfs_phone_futex);
336	async_serialize_start();	336	async_serialize_start();
337	vfs_connect();	337	vfs_connect();
338		338
339	ipcarg_t newoffs;	339	ipcarg_t newoffs;
340	rc = async_req_3_1(vfs_phone, VFS_IN_SEEK, fildes, offset, whence,	340	rc = async_req_3_1(vfs_phone, VFS_IN_SEEK, fildes, offset, whence,
341	&newoffs);	341	&newoffs);
342		342
343	async_serialize_end();	343	async_serialize_end();
344	futex_up(&vfs_phone_futex);	344	futex_up(&vfs_phone_futex);
345		345
346	if (rc != EOK)	346	if (rc != EOK)
347	return (off_t) -1;	347	return (off_t) -1;
348		348
349	return (off_t) newoffs;	349	return (off_t) newoffs;
350	}	350	}
351		351
352	int ftruncate(int fildes, off_t length)	352	int ftruncate(int fildes, off_t length)
353	{	353	{
354	ipcarg_t rc;	354	ipcarg_t rc;
355		355
356	futex_down(&vfs_phone_futex);	356	futex_down(&vfs_phone_futex);
357	async_serialize_start();	357	async_serialize_start();
358	vfs_connect();	358	vfs_connect();
359		359
360	rc = async_req_2_0(vfs_phone, VFS_IN_TRUNCATE, fildes, length);	360	rc = async_req_2_0(vfs_phone, VFS_IN_TRUNCATE, fildes, length);
361	async_serialize_end();	361	async_serialize_end();
362	futex_up(&vfs_phone_futex);	362	futex_up(&vfs_phone_futex);
363	return (int) rc;	363	return (int) rc;
364	}	364	}
365		365
366	int fstat(int fildes, struct stat *stat)	366	int fstat(int fildes, struct stat *stat)
367	{	367	{
368	ipcarg_t rc;	368	ipcarg_t rc;
369	ipc_call_t answer;	-
370	aid_t req;	369	aid_t req;
371		370
372	futex_down(&vfs_phone_futex);	371	futex_down(&vfs_phone_futex);
373	async_serialize_start();	372	async_serialize_start();
374	vfs_connect();	373	vfs_connect();
375		374
376	req = async_send_1(vfs_phone, VFS_IN_FSTAT, fildes, NULL);	375	req = async_send_1(vfs_phone, VFS_IN_FSTAT, fildes, NULL);
377	rc = ipc_data_read_start(vfs_phone, (void *)stat, sizeof(struct stat));	376	rc = ipc_data_read_start(vfs_phone, (void *)stat, sizeof(struct stat));
378	if (rc != EOK) {	377	if (rc != EOK) {
379	async_wait_for(req, NULL);	378	async_wait_for(req, NULL);
380	async_serialize_end();	379	async_serialize_end();
381	futex_up(&vfs_phone_futex);	380	futex_up(&vfs_phone_futex);
382	return (ssize_t) rc;	381	return (ssize_t) rc;
383	}	382	}
384	async_wait_for(req, &rc);	383	async_wait_for(req, &rc);
385	async_serialize_end();	384	async_serialize_end();
386	futex_up(&vfs_phone_futex);	385	futex_up(&vfs_phone_futex);
387		386
388	return rc;	387	return rc;
389	}	388	}
390		389
391	int stat(const char path, struct stat stat)	390	int stat(const char path, struct stat stat)
392	{	391	{
393	ipcarg_t rc;	392	ipcarg_t rc;
394	aid_t req;	393	aid_t req;
395		394
396	size_t pa_size;	395	size_t pa_size;
397	char *pa = absolutize(path, &pa_size);	396	char *pa = absolutize(path, &pa_size);
398	if (!pa)	397	if (!pa)
399	return ENOMEM;	398	return ENOMEM;
400		399
401	futex_down(&vfs_phone_futex);	400	futex_down(&vfs_phone_futex);
402	async_serialize_start();	401	async_serialize_start();
403	vfs_connect();	402	vfs_connect();
404		403
405	req = async_send_0(vfs_phone, VFS_IN_STAT, NULL);	404	req = async_send_0(vfs_phone, VFS_IN_STAT, NULL);
406	rc = ipc_data_write_start(vfs_phone, pa, pa_size);	405	rc = ipc_data_write_start(vfs_phone, pa, pa_size);
407	if (rc != EOK) {	406	if (rc != EOK) {
408	async_wait_for(req, NULL);	407	async_wait_for(req, NULL);
409	async_serialize_end();	408	async_serialize_end();
410	futex_up(&vfs_phone_futex);	409	futex_up(&vfs_phone_futex);
411	free(pa);	410	free(pa);
412	return (int) rc;	411	return (int) rc;
413	}	412	}
414	rc = ipc_data_read_start(vfs_phone, stat, sizeof(struct stat));	413	rc = ipc_data_read_start(vfs_phone, stat, sizeof(struct stat));
415	if (rc != EOK) {	414	if (rc != EOK) {
416	async_wait_for(req, NULL);	415	async_wait_for(req, NULL);
417	async_serialize_end();	416	async_serialize_end();
418	futex_up(&vfs_phone_futex);	417	futex_up(&vfs_phone_futex);
419	free(pa);	418	free(pa);
420	return (int) rc;	419	return (int) rc;
421	}	420	}
422	async_wait_for(req, &rc);	421	async_wait_for(req, &rc);
423	async_serialize_end();	422	async_serialize_end();
424	futex_up(&vfs_phone_futex);	423	futex_up(&vfs_phone_futex);
425	free(pa);	424	free(pa);
426	return rc;	425	return rc;
427	}	426	}
428		427
429	DIR opendir(const char dirname)	428	DIR opendir(const char dirname)
430	{	429	{
431	DIR *dirp = malloc(sizeof(DIR));	430	DIR *dirp = malloc(sizeof(DIR));
432	if (!dirp)	431	if (!dirp)
433	return NULL;	432	return NULL;
434	dirp->fd = _open(dirname, L_DIRECTORY, 0);	433	dirp->fd = _open(dirname, L_DIRECTORY, 0);
435	if (dirp->fd < 0) {	434	if (dirp->fd < 0) {
436	free(dirp);	435	free(dirp);
437	return NULL;	436	return NULL;
438	}	437	}
439	return dirp;	438	return dirp;
440	}	439	}
441		440
442	struct dirent readdir(DIR dirp)	441	struct dirent readdir(DIR dirp)
443	{	442	{
444	ssize_t len = read(dirp->fd, &dirp->res.d_name[0], NAME_MAX + 1);	443	ssize_t len = read(dirp->fd, &dirp->res.d_name[0], NAME_MAX + 1);
445	if (len <= 0)	444	if (len <= 0)
446	return NULL;	445	return NULL;
447	return &dirp->res;	446	return &dirp->res;
448	}	447	}
449		448
450	void rewinddir(DIR *dirp)	449	void rewinddir(DIR *dirp)
451	{	450	{
452	(void) lseek(dirp->fd, 0, SEEK_SET);	451	(void) lseek(dirp->fd, 0, SEEK_SET);
453	}	452	}
454		453
455	int closedir(DIR *dirp)	454	int closedir(DIR *dirp)
456	{	455	{
457	(void) close(dirp->fd);	456	(void) close(dirp->fd);
458	free(dirp);	457	free(dirp);
459	return 0;	458	return 0;
460	}	459	}
461		460
462	int mkdir(const char *path, mode_t mode)	461	int mkdir(const char *path, mode_t mode)
463	{	462	{
464	ipcarg_t rc;	463	ipcarg_t rc;
465	aid_t req;	464	aid_t req;
466		465
467	size_t pa_size;	466	size_t pa_size;
468	char *pa = absolutize(path, &pa_size);	467	char *pa = absolutize(path, &pa_size);
469	if (!pa)	468	if (!pa)
470	return ENOMEM;	469	return ENOMEM;
471		470
472	futex_down(&vfs_phone_futex);	471	futex_down(&vfs_phone_futex);
473	async_serialize_start();	472	async_serialize_start();
474	vfs_connect();	473	vfs_connect();
475		474
476	req = async_send_1(vfs_phone, VFS_IN_MKDIR, mode, NULL);	475	req = async_send_1(vfs_phone, VFS_IN_MKDIR, mode, NULL);
477	rc = ipc_data_write_start(vfs_phone, pa, pa_size);	476	rc = ipc_data_write_start(vfs_phone, pa, pa_size);
478	if (rc != EOK) {	477	if (rc != EOK) {
479	async_wait_for(req, NULL);	478	async_wait_for(req, NULL);
480	async_serialize_end();	479	async_serialize_end();
481	futex_up(&vfs_phone_futex);	480	futex_up(&vfs_phone_futex);
482	free(pa);	481	free(pa);
483	return (int) rc;	482	return (int) rc;
484	}	483	}
485	async_wait_for(req, &rc);	484	async_wait_for(req, &rc);
486	async_serialize_end();	485	async_serialize_end();
487	futex_up(&vfs_phone_futex);	486	futex_up(&vfs_phone_futex);
488	free(pa);	487	free(pa);
489	return rc;	488	return rc;
490	}	489	}
491		490
492	static int _unlink(const char *path, int lflag)	491	static int _unlink(const char *path, int lflag)
493	{	492	{
494	ipcarg_t rc;	493	ipcarg_t rc;
495	aid_t req;	494	aid_t req;
496		495
497	size_t pa_size;	496	size_t pa_size;
498	char *pa = absolutize(path, &pa_size);	497	char *pa = absolutize(path, &pa_size);
499	if (!pa)	498	if (!pa)
500	return ENOMEM;	499	return ENOMEM;

Subversion Repositories HelenOS

(root)/branches/dd/uspace/lib/libc/generic/vfs/vfs.c – Rev 4668 → 4688