Index: uspace/lib/libc/generic/devmap.c =================================================================== --- uspace/lib/libc/generic/devmap.c (revision fc6dd18feebbc66893aec4d86827b7c815dbbfe7) +++ uspace/lib/libc/generic/devmap.c (revision 1313ee92979dd133fd0dd0717213410aada3df10) @@ -35,4 +35,6 @@ #include #include +#include +#include static int devmap_phone_driver = -1; @@ -105,6 +107,5 @@ aid_t req = async_send_2(phone, DEVMAP_DRIVER_REGISTER, 0, 0, &answer); - ipcarg_t retval = async_data_write_start(phone, name, str_size(name) + 1); - + ipcarg_t retval = async_data_write_start(phone, name, str_size(name)); if (retval != EOK) { async_wait_for(req, NULL); @@ -126,9 +127,10 @@ /** Register new device. * - * @param name Device name. - * @param handle Output: Handle to the created instance of device. + * @param namespace Namespace name. + * @param fqdn Fully qualified device name. + * @param handle Output: Handle to the created instance of device. * */ -int devmap_device_register(const char *name, dev_handle_t *handle) +int devmap_device_register(const char *fqdn, dev_handle_t *handle) { int phone = devmap_get_phone(DEVMAP_DRIVER, IPC_FLAG_BLOCKING); @@ -143,6 +145,5 @@ &answer); - ipcarg_t retval = async_data_write_start(phone, name, str_size(name) + 1); - + ipcarg_t retval = async_data_write_start(phone, fqdn, str_size(fqdn)); if (retval != EOK) { async_wait_for(req, NULL); @@ -167,5 +168,5 @@ } -int devmap_device_get_handle(const char *name, dev_handle_t *handle, unsigned int flags) +int devmap_device_get_handle(const char *fqdn, dev_handle_t *handle, unsigned int flags) { int phone = devmap_get_phone(DEVMAP_CLIENT, flags); @@ -180,6 +181,5 @@ &answer); - ipcarg_t retval = async_data_write_start(phone, name, str_size(name) + 1); - + ipcarg_t retval = async_data_write_start(phone, fqdn, str_size(fqdn)); if (retval != EOK) { async_wait_for(req, NULL); @@ -202,4 +202,55 @@ return retval; +} + +int devmap_namespace_get_handle(const char *name, dev_handle_t *handle, unsigned int flags) +{ + int phone = devmap_get_phone(DEVMAP_CLIENT, flags); + + if (phone < 0) + return phone; + + async_serialize_start(); + + ipc_call_t answer; + aid_t req = async_send_2(phone, DEVMAP_NAMESPACE_GET_HANDLE, flags, 0, + &answer); + + ipcarg_t retval = async_data_write_start(phone, name, str_size(name)); + if (retval != EOK) { + async_wait_for(req, NULL); + async_serialize_end(); + return retval; + } + + async_wait_for(req, &retval); + + async_serialize_end(); + + if (retval != EOK) { + if (handle != NULL) + *handle = (dev_handle_t) -1; + return retval; + } + + if (handle != NULL) + *handle = (dev_handle_t) IPC_GET_ARG1(answer); + + return retval; +} + +devmap_handle_type_t devmap_handle_probe(dev_handle_t handle) +{ + int phone = devmap_get_phone(DEVMAP_CLIENT, IPC_FLAG_BLOCKING); + + if (phone < 0) + return phone; + + ipcarg_t type; + int retval = async_req_1_1(phone, DEVMAP_HANDLE_PROBE, handle, &type); + if (retval != EOK) + return DEV_HANDLE_NONE; + + return (devmap_handle_type_t) type; } @@ -227,5 +278,5 @@ ipcarg_t null_id; - int retval = async_req_0_1(phone, DEVMAP_DEVICE_NULL_CREATE, &null_id); + int retval = async_req_0_1(phone, DEVMAP_NULL_CREATE, &null_id); if (retval != EOK) return -1; @@ -241,16 +292,11 @@ return; - async_req_1_0(phone, DEVMAP_DEVICE_NULL_DESTROY, (ipcarg_t) null_id); -} - -ipcarg_t devmap_device_get_count(void) -{ - int phone = devmap_get_phone(DEVMAP_CLIENT, IPC_FLAG_BLOCKING); - - if (phone < 0) - return 0; - + async_req_1_0(phone, DEVMAP_NULL_DESTROY, (ipcarg_t) null_id); +} + +static size_t devmap_count_namespaces_internal(int phone) +{ ipcarg_t count; - int retval = async_req_0_1(phone, DEVMAP_DEVICE_GET_COUNT, &count); + int retval = async_req_0_1(phone, DEVMAP_GET_NAMESPACE_COUNT, &count); if (retval != EOK) return 0; @@ -259,31 +305,135 @@ } -ipcarg_t devmap_device_get_devices(ipcarg_t count, dev_desc_t *data) -{ - int phone = devmap_get_phone(DEVMAP_CLIENT, IPC_FLAG_BLOCKING); - - if (phone < 0) - return 0; - - async_serialize_start(); - - ipc_call_t answer; - aid_t req = async_send_0(phone, DEVMAP_DEVICE_GET_DEVICES, &answer); - - ipcarg_t retval = async_data_read_start(phone, data, count * sizeof(dev_desc_t)); - - if (retval != EOK) { - async_wait_for(req, NULL); - async_serialize_end(); - return 0; - } - - async_wait_for(req, &retval); - - async_serialize_end(); - +static size_t devmap_count_devices_internal(int phone, dev_handle_t ns_handle) +{ + ipcarg_t count; + int retval = async_req_1_1(phone, DEVMAP_GET_DEVICE_COUNT, ns_handle, &count); if (retval != EOK) return 0; - return IPC_GET_ARG1(answer); -} + return count; +} + +size_t devmap_count_namespaces(void) +{ + int phone = devmap_get_phone(DEVMAP_CLIENT, IPC_FLAG_BLOCKING); + + if (phone < 0) + return 0; + + return devmap_count_namespaces_internal(phone); +} + +size_t devmap_count_devices(dev_handle_t ns_handle) +{ + int phone = devmap_get_phone(DEVMAP_CLIENT, IPC_FLAG_BLOCKING); + + if (phone < 0) + return 0; + + return devmap_count_devices_internal(phone, ns_handle); +} + +size_t devmap_get_namespaces(dev_desc_t **data) +{ + int phone = devmap_get_phone(DEVMAP_CLIENT, IPC_FLAG_BLOCKING); + + if (phone < 0) + return 0; + + /* Loop until namespaces read succesful */ + while (true) { + size_t count = devmap_count_namespaces_internal(phone); + if (count == 0) + return 0; + + dev_desc_t *devs = (dev_desc_t *) calloc(count, sizeof(dev_desc_t)); + if (devs == NULL) + return 0; + + async_serialize_start(); + + ipc_call_t answer; + aid_t req = async_send_0(phone, DEVMAP_GET_NAMESPACES, &answer); + + int rc = async_data_read_start(phone, devs, count * sizeof(dev_desc_t)); + if (rc == EOVERFLOW) { + /* + * Number of namespaces has changed since + * the last call of DEVMAP_DEVICE_GET_NAMESPACE_COUNT + */ + async_serialize_end(); + free(devs); + continue; + } + + if (rc != EOK) { + async_wait_for(req, NULL); + async_serialize_end(); + free(devs); + return 0; + } + + ipcarg_t retval; + async_wait_for(req, &retval); + async_serialize_end(); + + if (retval != EOK) + return 0; + + *data = devs; + return count; + } +} + +size_t devmap_get_devices(dev_handle_t ns_handle, dev_desc_t **data) +{ + int phone = devmap_get_phone(DEVMAP_CLIENT, IPC_FLAG_BLOCKING); + + if (phone < 0) + return 0; + + /* Loop until namespaces read succesful */ + while (true) { + size_t count = devmap_count_devices_internal(phone, ns_handle); + if (count == 0) + return 0; + + dev_desc_t *devs = (dev_desc_t *) calloc(count, sizeof(dev_desc_t)); + if (devs == NULL) + return 0; + + async_serialize_start(); + + ipc_call_t answer; + aid_t req = async_send_1(phone, DEVMAP_GET_DEVICES, ns_handle, &answer); + + int rc = async_data_read_start(phone, devs, count * sizeof(dev_desc_t)); + if (rc == EOVERFLOW) { + /* + * Number of devices has changed since + * the last call of DEVMAP_DEVICE_GET_DEVICE_COUNT + */ + async_serialize_end(); + free(devs); + continue; + } + + if (rc != EOK) { + async_wait_for(req, NULL); + async_serialize_end(); + free(devs); + return 0; + } + + ipcarg_t retval; + async_wait_for(req, &retval); + async_serialize_end(); + + if (retval != EOK) + return 0; + + *data = devs; + return count; + } +} Index: uspace/lib/libc/generic/vfs/vfs.c =================================================================== --- uspace/lib/libc/generic/vfs/vfs.c (revision fc6dd18feebbc66893aec4d86827b7c815dbbfe7) +++ uspace/lib/libc/generic/vfs/vfs.c (revision 1313ee92979dd133fd0dd0717213410aada3df10) @@ -117,5 +117,5 @@ } -int mount(const char *fs_name, const char *mp, const char *dev, +int mount(const char *fs_name, const char *mp, const char *fqdn, const char *opts, unsigned int flags) { @@ -126,5 +126,5 @@ dev_handle_t dev_handle; - res = devmap_device_get_handle(dev, &dev_handle, flags); + res = devmap_device_get_handle(fqdn, &dev_handle, flags); if (res != EOK) return res; @@ -703,8 +703,8 @@ rc = fstat(fildes, &stat); - if (!stat.devfs_stat.device) + if (!stat.device) return -1; - return devmap_device_connect(stat.devfs_stat.device, 0); + return devmap_device_connect(stat.device, 0); } Index: uspace/lib/libc/include/devmap.h =================================================================== --- uspace/lib/libc/include/devmap.h (revision fc6dd18feebbc66893aec4d86827b7c815dbbfe7) +++ uspace/lib/libc/include/devmap.h (revision 1313ee92979dd133fd0dd0717213410aada3df10) @@ -38,4 +38,5 @@ #include #include +#include extern int devmap_get_phone(devmap_interface_t, unsigned int); @@ -46,4 +47,7 @@ extern int devmap_device_get_handle(const char *, dev_handle_t *, unsigned int); +extern int devmap_namespace_get_handle(const char *, dev_handle_t *, unsigned int); +extern devmap_handle_type_t devmap_handle_probe(dev_handle_t); + extern int devmap_device_connect(dev_handle_t, unsigned int); @@ -51,6 +55,9 @@ extern void devmap_null_destroy(int); -extern ipcarg_t devmap_device_get_count(void); -extern ipcarg_t devmap_device_get_devices(ipcarg_t, dev_desc_t *); +extern size_t devmap_count_namespaces(void); +extern size_t devmap_count_devices(dev_handle_t); + +extern size_t devmap_get_namespaces(dev_desc_t **); +extern size_t devmap_get_devices(dev_handle_t, dev_desc_t **); #endif Index: uspace/lib/libc/include/ipc/devmap.h =================================================================== --- uspace/lib/libc/include/ipc/devmap.h (revision fc6dd18feebbc66893aec4d86827b7c815dbbfe7) +++ uspace/lib/libc/include/ipc/devmap.h (revision 1313ee92979dd133fd0dd0717213410aada3df10) @@ -43,14 +43,23 @@ typedef enum { + DEV_HANDLE_NONE, + DEV_HANDLE_NAMESPACE, + DEV_HANDLE_DEVICE +} devmap_handle_type_t; + +typedef enum { DEVMAP_DRIVER_REGISTER = IPC_FIRST_USER_METHOD, DEVMAP_DRIVER_UNREGISTER, DEVMAP_DEVICE_REGISTER, DEVMAP_DEVICE_UNREGISTER, - DEVMAP_DEVICE_GET_NAME, DEVMAP_DEVICE_GET_HANDLE, - DEVMAP_DEVICE_NULL_CREATE, - DEVMAP_DEVICE_NULL_DESTROY, - DEVMAP_DEVICE_GET_COUNT, - DEVMAP_DEVICE_GET_DEVICES + DEVMAP_NAMESPACE_GET_HANDLE, + DEVMAP_HANDLE_PROBE, + DEVMAP_NULL_CREATE, + DEVMAP_NULL_DESTROY, + DEVMAP_GET_NAMESPACE_COUNT, + DEVMAP_GET_DEVICE_COUNT, + DEVMAP_GET_NAMESPACES, + DEVMAP_GET_DEVICES } devmap_request_t; Index: uspace/lib/libc/include/sys/stat.h =================================================================== --- uspace/lib/libc/include/sys/stat.h (revision fc6dd18feebbc66893aec4d86827b7c815dbbfe7) +++ uspace/lib/libc/include/sys/stat.h (revision 1313ee92979dd133fd0dd0717213410aada3df10) @@ -42,15 +42,12 @@ struct stat { - fs_handle_t fs_handle; - dev_handle_t dev_handle; - fs_index_t index; - unsigned lnkcnt; - bool is_file; - off_t size; - union { - struct { - dev_handle_t device; - } devfs_stat; - }; + fs_handle_t fs_handle; + dev_handle_t dev_handle; + fs_index_t index; + unsigned int lnkcnt; + bool is_file; + bool is_directory; + off_t size; + dev_handle_t device; }; Index: uspace/lib/libfs/libfs.c =================================================================== --- uspace/lib/libfs/libfs.c (revision fc6dd18feebbc66893aec4d86827b7c815dbbfe7) +++ uspace/lib/libfs/libfs.c (revision 1313ee92979dd133fd0dd0717213410aada3df10) @@ -1,4 +1,4 @@ /* - * Copyright (c) 2009 Jakub Jermar + * Copyright (c) 2009 Jakub Jermar * All rights reserved. * @@ -27,13 +27,13 @@ */ -/** @addtogroup libfs +/** @addtogroup libfs * @{ - */ + */ /** * @file - * Glue code which is commonod to all FS implementations. - */ - -#include "libfs.h" + * Glue code which is common to all FS implementations. + */ + +#include "libfs.h" #include "../../srv/vfs/vfs.h" #include @@ -67,13 +67,14 @@ * code. * - * @param vfs_phone Open phone for communication with VFS. - * @param reg File system registration structure. It will be - * initialized by this function. - * @param info VFS info structure supplied by the file system - * implementation. - * @param conn Connection fibril for handling all calls originating in - * VFS. - * - * @return EOK on success or a non-zero error code on errror. + * @param vfs_phone Open phone for communication with VFS. + * @param reg File system registration structure. It will be + * initialized by this function. + * @param info VFS info structure supplied by the file system + * implementation. + * @param conn Connection fibril for handling all calls originating in + * VFS. + * + * @return EOK on success or a non-zero error code on errror. + * */ int fs_register(int vfs_phone, fs_reg_t *reg, vfs_info_t *info, @@ -87,5 +88,5 @@ ipc_call_t answer; aid_t req = async_send_0(vfs_phone, VFS_IN_REGISTER, &answer); - + /* * Send our VFS info structure to VFS. @@ -96,10 +97,10 @@ return rc; } - + /* * Ask VFS for callback connection. */ ipc_connect_to_me(vfs_phone, 0, 0, 0, ®->vfs_phonehash); - + /* * Allocate piece of address space for PLB. @@ -110,5 +111,5 @@ return ENOMEM; } - + /* * Request sharing the Path Lookup Buffer with VFS. @@ -136,5 +137,5 @@ */ async_set_client_connection(conn); - + return IPC_GET_RETVAL(answer); } @@ -154,18 +155,20 @@ int res; ipcarg_t rc; - + ipc_call_t call; ipc_callid_t callid; - - /* accept the phone */ + + /* Accept the phone */ callid = async_get_call(&call); int mountee_phone = (int)IPC_GET_ARG1(call); if ((IPC_GET_METHOD(call) != IPC_M_CONNECTION_CLONE) || - mountee_phone < 0) { + (mountee_phone < 0)) { ipc_answer_0(callid, EINVAL); ipc_answer_0(rid, EINVAL); return; } - ipc_answer_0(callid, EOK); /* acknowledge the mountee_phone */ + + /* Acknowledge the mountee_phone */ + ipc_answer_0(callid, EOK); res = async_data_write_receive(&callid, NULL); @@ -176,8 +179,8 @@ return; } - + fs_node_t *fn; res = ops->node_get(&fn, mp_dev_handle, mp_fs_index); - if (res != EOK || !fn) { + if ((res != EOK) || (!fn)) { ipc_hangup(mountee_phone); ipc_answer_0(callid, combine_rc(res, ENOENT)); @@ -185,5 +188,5 @@ return; } - + if (fn->mp_data.mp_active) { ipc_hangup(mountee_phone); @@ -193,5 +196,5 @@ return; } - + rc = async_req_0_0(mountee_phone, IPC_M_CONNECT_ME); if (rc != EOK) { @@ -215,4 +218,5 @@ fn->mp_data.phone = mountee_phone; } + /* * Do not release the FS node so that it stays in memory. @@ -238,24 +242,24 @@ ipc_call_t *request) { - unsigned first = IPC_GET_ARG1(*request); - unsigned last = IPC_GET_ARG2(*request); - unsigned next = first; + unsigned int first = IPC_GET_ARG1(*request); + unsigned int last = IPC_GET_ARG2(*request); + unsigned int next = first; dev_handle_t dev_handle = IPC_GET_ARG3(*request); int lflag = IPC_GET_ARG4(*request); - fs_index_t index = IPC_GET_ARG5(*request); /* when L_LINK specified */ + fs_index_t index = IPC_GET_ARG5(*request); char component[NAME_MAX + 1]; int len; int rc; - + if (last < next) last += PLB_SIZE; - + fs_node_t *par = NULL; fs_node_t *cur = NULL; fs_node_t *tmp = NULL; - + rc = ops->root_get(&cur, dev_handle); on_error(rc, goto out_with_answer); - + if (cur->mp_data.mp_active) { ipc_forward_slow(rid, cur->mp_data.phone, VFS_OUT_LOOKUP, @@ -265,42 +269,45 @@ return; } - + + /* Eat slash */ if (ops->plb_get_char(next) == '/') - next++; /* eat slash */ + next++; while (next <= last) { bool has_children; - + rc = ops->has_children(&has_children, cur); on_error(rc, goto out_with_answer); if (!has_children) break; - - /* collect the component */ + + /* Collect the component */ len = 0; - while ((next <= last) && (ops->plb_get_char(next) != '/')) { + while ((next <= last) && (ops->plb_get_char(next) != '/')) { if (len + 1 == NAME_MAX) { - /* component length overflow */ + /* Component length overflow */ ipc_answer_0(rid, ENAMETOOLONG); goto out; } component[len++] = ops->plb_get_char(next); - next++; /* process next character */ + /* Process next character */ + next++; } - + assert(len); component[len] = '\0'; - next++; /* eat slash */ - - /* match the component */ + /* Eat slash */ + next++; + + /* Match the component */ rc = ops->match(&tmp, cur, component); on_error(rc, goto out_with_answer); - - if (tmp && tmp->mp_data.mp_active) { + + if ((tmp) && (tmp->mp_data.mp_active)) { if (next > last) next = last = first; else next--; - + ipc_forward_slow(rid, tmp->mp_data.phone, VFS_OUT_LOOKUP, next, last, tmp->mp_data.dev_handle, @@ -312,19 +319,21 @@ return; } - - /* handle miss: match amongst siblings */ + + /* Handle miss: match amongst siblings */ if (!tmp) { if (next <= last) { - /* there are unprocessed components */ + /* There are unprocessed components */ ipc_answer_0(rid, ENOENT); goto out; } - /* miss in the last component */ - if (lflag & (L_CREATE | L_LINK)) { - /* request to create a new link */ + + /* Miss in the last component */ + if (lflag & (L_CREATE | L_LINK)) { + /* Request to create a new link */ if (!ops->is_directory(cur)) { ipc_answer_0(rid, ENOTDIR); goto out; } + fs_node_t *fn; if (lflag & L_CREATE) @@ -335,4 +344,5 @@ index); on_error(rc, goto out_with_answer); + if (fn) { rc = ops->link(cur, fn, component); @@ -349,33 +359,34 @@ (void) ops->node_put(fn); } - } else { + } else ipc_answer_0(rid, ENOSPC); - } + goto out; - } + } + ipc_answer_0(rid, ENOENT); goto out; } - + if (par) { rc = ops->node_put(par); on_error(rc, goto out_with_answer); } - - /* descend one level */ + + /* Descend one level */ par = cur; cur = tmp; tmp = NULL; } - - /* handle miss: excessive components */ + + /* Handle miss: excessive components */ if (next <= last) { bool has_children; - rc = ops->has_children(&has_children, cur); on_error(rc, goto out_with_answer); + if (has_children) goto skip_miss; - + if (lflag & (L_CREATE | L_LINK)) { if (!ops->is_directory(cur)) { @@ -383,24 +394,28 @@ goto out; } - - /* collect next component */ + + /* Collect next component */ len = 0; while (next <= last) { if (ops->plb_get_char(next) == '/') { - /* more than one component */ + /* More than one component */ ipc_answer_0(rid, ENOENT); goto out; } + if (len + 1 == NAME_MAX) { - /* component length overflow */ + /* Component length overflow */ ipc_answer_0(rid, ENAMETOOLONG); goto out; } + component[len++] = ops->plb_get_char(next); - next++; /* process next character */ + /* Process next character */ + next++; } + assert(len); component[len] = '\0'; - + fs_node_t *fn; if (lflag & L_CREATE) @@ -409,4 +424,5 @@ rc = ops->node_get(&fn, dev_handle, index); on_error(rc, goto out_with_answer); + if (fn) { rc = ops->link(cur, fn, component); @@ -423,22 +439,25 @@ (void) ops->node_put(fn); } - } else { + } else ipc_answer_0(rid, ENOSPC); - } + goto out; } + ipc_answer_0(rid, ENOENT); goto out; } + skip_miss: - - /* handle hit */ + + /* Handle hit */ if (lflag & L_UNLINK) { - unsigned old_lnkcnt = ops->lnkcnt_get(cur); + unsigned int old_lnkcnt = ops->lnkcnt_get(cur); rc = ops->unlink(par, cur, component); - ipc_answer_5(rid, (ipcarg_t)rc, fs_handle, dev_handle, + ipc_answer_5(rid, (ipcarg_t) rc, fs_handle, dev_handle, ops->index_get(cur), ops->size_get(cur), old_lnkcnt); goto out; } + if (((lflag & (L_CREATE | L_EXCLUSIVE)) == (L_CREATE | L_EXCLUSIVE)) || (lflag & L_LINK)) { @@ -446,27 +465,35 @@ goto out; } + if ((lflag & L_FILE) && (ops->is_directory(cur))) { ipc_answer_0(rid, EISDIR); goto out; } + if ((lflag & L_DIRECTORY) && (ops->is_file(cur))) { ipc_answer_0(rid, ENOTDIR); goto out; } - + out_with_answer: + if (rc == EOK) { - ipc_answer_5(rid, EOK, fs_handle, dev_handle, + if (lflag & L_OPEN) + rc = ops->node_open(cur); + + ipc_answer_5(rid, rc, fs_handle, dev_handle, ops->index_get(cur), ops->size_get(cur), ops->lnkcnt_get(cur)); - } else { + } else ipc_answer_0(rid, rc); - } - + out: + if (par) (void) ops->node_put(par); + if (cur) (void) ops->node_put(cur); + if (tmp) (void) ops->node_put(tmp); @@ -478,19 +505,19 @@ dev_handle_t dev_handle = (dev_handle_t) IPC_GET_ARG1(*request); fs_index_t index = (fs_index_t) IPC_GET_ARG2(*request); + fs_node_t *fn; - int rc; - - rc = ops->node_get(&fn, dev_handle, index); + int rc = ops->node_get(&fn, dev_handle, index); on_error(rc, answer_and_return(rid, rc)); - + ipc_callid_t callid; size_t size; - if (!async_data_read_receive(&callid, &size) || - size != sizeof(struct stat)) { + if ((!async_data_read_receive(&callid, &size)) || + (size != sizeof(struct stat))) { + ops->node_put(fn); ipc_answer_0(callid, EINVAL); ipc_answer_0(rid, EINVAL); return; } - + struct stat stat; memset(&stat, 0, sizeof(struct stat)); @@ -499,8 +526,12 @@ stat.dev_handle = dev_handle; stat.index = index; - stat.lnkcnt = ops->lnkcnt_get(fn); + stat.lnkcnt = ops->lnkcnt_get(fn); stat.is_file = ops->is_file(fn); + stat.is_directory = ops->is_directory(fn); stat.size = ops->size_get(fn); - + stat.device = ops->device_get(fn); + + ops->node_put(fn); + async_data_read_finalize(callid, &stat, sizeof(struct stat)); ipc_answer_0(rid, EOK); @@ -509,8 +540,8 @@ /** Open VFS triplet. * - * @param ops libfs operations structure with function pointers to - * file system implementation - * @param rid Request ID of the VFS_OUT_OPEN_NODE request. - * @param request VFS_OUT_OPEN_NODE request data itself. + * @param ops libfs operations structure with function pointers to + * file system implementation + * @param rid Request ID of the VFS_OUT_OPEN_NODE request. + * @param request VFS_OUT_OPEN_NODE request data itself. * */ @@ -531,5 +562,6 @@ } - ipc_answer_3(rid, EOK, ops->size_get(fn), ops->lnkcnt_get(fn), + rc = ops->node_open(fn); + ipc_answer_3(rid, rc, ops->size_get(fn), ops->lnkcnt_get(fn), (ops->is_file(fn) ? L_FILE : 0) | (ops->is_directory(fn) ? L_DIRECTORY : 0)); Index: uspace/lib/libfs/libfs.h =================================================================== --- uspace/lib/libfs/libfs.h (revision fc6dd18feebbc66893aec4d86827b7c815dbbfe7) +++ uspace/lib/libfs/libfs.h (revision 1313ee92979dd133fd0dd0717213410aada3df10) @@ -64,4 +64,5 @@ int (* match)(fs_node_t **, fs_node_t *, const char *); int (* node_get)(fs_node_t **, dev_handle_t, fs_index_t); + int (* node_open)(fs_node_t *); int (* node_put)(fs_node_t *); int (* create)(fs_node_t **, dev_handle_t, int); @@ -76,8 +77,9 @@ fs_index_t (* index_get)(fs_node_t *); size_t (* size_get)(fs_node_t *); - unsigned (* lnkcnt_get)(fs_node_t *); + unsigned int (* lnkcnt_get)(fs_node_t *); char (* plb_get_char)(unsigned pos); bool (* is_directory)(fs_node_t *); bool (* is_file)(fs_node_t *); + dev_handle_t (* device_get)(fs_node_t *); } libfs_ops_t;