| 1 | /*
 | 
|---|
| 2 |  * Copyright (c) 2008 Jakub 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 vfs
 | 
|---|
| 30 |  * @{
 | 
|---|
| 31 |  */
 | 
|---|
| 32 | 
 | 
|---|
| 33 | #ifndef VFS_VFS_H_
 | 
|---|
| 34 | #define VFS_VFS_H_
 | 
|---|
| 35 | 
 | 
|---|
| 36 | #include <async.h>
 | 
|---|
| 37 | #include <adt/list.h>
 | 
|---|
| 38 | #include <adt/hash_table.h>
 | 
|---|
| 39 | #include <fibril_synch.h>
 | 
|---|
| 40 | #include <stddef.h>
 | 
|---|
| 41 | #include <stdint.h>
 | 
|---|
| 42 | #include <loc.h>
 | 
|---|
| 43 | #include <stdbool.h>
 | 
|---|
| 44 | #include <ipc/vfs.h>
 | 
|---|
| 45 | #include <task.h>
 | 
|---|
| 46 | #include <vfs/vfs.h>
 | 
|---|
| 47 | 
 | 
|---|
| 48 | #ifndef dprintf
 | 
|---|
| 49 | #define dprintf(...)
 | 
|---|
| 50 | #endif
 | 
|---|
| 51 | 
 | 
|---|
| 52 | /**
 | 
|---|
| 53 |  * A structure like this will be allocated for each registered file system.
 | 
|---|
| 54 |  */
 | 
|---|
| 55 | typedef struct {
 | 
|---|
| 56 |         link_t fs_link;
 | 
|---|
| 57 |         vfs_info_t vfs_info;
 | 
|---|
| 58 |         fs_handle_t fs_handle;
 | 
|---|
| 59 |         async_sess_t *sess;
 | 
|---|
| 60 | } fs_info_t;
 | 
|---|
| 61 | 
 | 
|---|
| 62 | /** Uniquely represents a file system instance. */
 | 
|---|
| 63 | typedef struct {
 | 
|---|
| 64 |         fs_handle_t fs_handle;
 | 
|---|
| 65 |         service_id_t service_id;
 | 
|---|
| 66 | } vfs_pair_t;
 | 
|---|
| 67 | 
 | 
|---|
| 68 | /** Uniquely identifies a file system node (e.g. directory, file)
 | 
|---|
| 69 |  * but doesn't contain any state. For a stateful structure, see vfs_node_t.
 | 
|---|
| 70 |  *
 | 
|---|
| 71 |  * @note        fs_handle, service_id and index are meant to be returned in one
 | 
|---|
| 72 |  *              IPC reply.
 | 
|---|
| 73 |  */
 | 
|---|
| 74 | typedef struct {
 | 
|---|
| 75 |         fs_handle_t fs_handle;
 | 
|---|
| 76 |         service_id_t service_id;
 | 
|---|
| 77 |         fs_index_t index;
 | 
|---|
| 78 | } vfs_triplet_t;
 | 
|---|
| 79 | 
 | 
|---|
| 80 | typedef enum vfs_node_type {
 | 
|---|
| 81 |         VFS_NODE_UNKNOWN,
 | 
|---|
| 82 |         VFS_NODE_FILE,
 | 
|---|
| 83 |         VFS_NODE_DIRECTORY,
 | 
|---|
| 84 | } vfs_node_type_t;
 | 
|---|
| 85 | 
 | 
|---|
| 86 | typedef struct {
 | 
|---|
| 87 |         vfs_triplet_t triplet;
 | 
|---|
| 88 |         vfs_node_type_t type;
 | 
|---|
| 89 |         aoff64_t size;
 | 
|---|
| 90 | } vfs_lookup_res_t;
 | 
|---|
| 91 | 
 | 
|---|
| 92 | /**
 | 
|---|
| 93 |  * Instances of this type represent an active, in-memory VFS node and any state
 | 
|---|
| 94 |  * which may be associated with it.
 | 
|---|
| 95 |  */
 | 
|---|
| 96 | typedef struct _vfs_node {
 | 
|---|
| 97 |         /*
 | 
|---|
| 98 |          * Identity of the node
 | 
|---|
| 99 |          */
 | 
|---|
| 100 | 
 | 
|---|
| 101 |         fs_handle_t fs_handle;
 | 
|---|
| 102 |         service_id_t service_id;
 | 
|---|
| 103 |         fs_index_t index;
 | 
|---|
| 104 | 
 | 
|---|
| 105 |         /**
 | 
|---|
| 106 |          * Usage counter.  This includes, but is not limited to, all vfs_file_t
 | 
|---|
| 107 |          * structures that reference this node.
 | 
|---|
| 108 |          */
 | 
|---|
| 109 |         unsigned refcnt;
 | 
|---|
| 110 | 
 | 
|---|
| 111 |         ht_link_t nh_link;              /**< Node hash-table link. */
 | 
|---|
| 112 | 
 | 
|---|
| 113 |         vfs_node_type_t type;   /**< Partial info about the node type. */
 | 
|---|
| 114 | 
 | 
|---|
| 115 |         aoff64_t size;          /**< Cached size if the node is a file. */
 | 
|---|
| 116 | 
 | 
|---|
| 117 |         /**
 | 
|---|
| 118 |          * Holding this rwlock prevents modifications of the node's contents.
 | 
|---|
| 119 |          */
 | 
|---|
| 120 |         fibril_rwlock_t contents_rwlock;
 | 
|---|
| 121 | 
 | 
|---|
| 122 |         struct _vfs_node *mount;
 | 
|---|
| 123 | } vfs_node_t;
 | 
|---|
| 124 | 
 | 
|---|
| 125 | /**
 | 
|---|
| 126 |  * Instances of this type represent an open file. If the file is opened by more
 | 
|---|
| 127 |  * than one task, there will be a separate structure allocated for each task.
 | 
|---|
| 128 |  */
 | 
|---|
| 129 | typedef struct {
 | 
|---|
| 130 |         /** Serializes access to this open file. */
 | 
|---|
| 131 |         fibril_mutex_t _lock;
 | 
|---|
| 132 | 
 | 
|---|
| 133 |         vfs_node_t *node;
 | 
|---|
| 134 | 
 | 
|---|
| 135 |         /** Number of file handles referencing this file. */
 | 
|---|
| 136 |         unsigned refcnt;
 | 
|---|
| 137 | 
 | 
|---|
| 138 |         int permissions;
 | 
|---|
| 139 |         bool open_read;
 | 
|---|
| 140 |         bool open_write;
 | 
|---|
| 141 | 
 | 
|---|
| 142 |         /** Append on write. */
 | 
|---|
| 143 |         bool append;
 | 
|---|
| 144 | } vfs_file_t;
 | 
|---|
| 145 | 
 | 
|---|
| 146 | extern fibril_mutex_t nodes_mutex;
 | 
|---|
| 147 | 
 | 
|---|
| 148 | extern fibril_condvar_t fs_list_cv;
 | 
|---|
| 149 | extern fibril_mutex_t fs_list_lock;
 | 
|---|
| 150 | extern list_t fs_list;          /**< List of registered file systems. */
 | 
|---|
| 151 | 
 | 
|---|
| 152 | extern fibril_mutex_t fs_mntlist_lock;
 | 
|---|
| 153 | extern list_t fs_mntlist;       /**< List of mounted file systems. */
 | 
|---|
| 154 | 
 | 
|---|
| 155 | extern vfs_pair_t rootfs;       /**< Root file system. */
 | 
|---|
| 156 | 
 | 
|---|
| 157 | /** Each instance of this type describes one path lookup in progress. */
 | 
|---|
| 158 | typedef struct {
 | 
|---|
| 159 |         link_t  plb_link;       /**< Active PLB entries list link. */
 | 
|---|
| 160 |         unsigned index;         /**< Index of the first character in PLB. */
 | 
|---|
| 161 |         size_t len;             /**< Number of characters in this PLB entry. */
 | 
|---|
| 162 | } plb_entry_t;
 | 
|---|
| 163 | 
 | 
|---|
| 164 | extern fibril_mutex_t plb_mutex;/**< Mutex protecting plb and plb_entries. */
 | 
|---|
| 165 | extern uint8_t *plb;            /**< Path Lookup Buffer */
 | 
|---|
| 166 | extern list_t plb_entries;      /**< List of active PLB entries. */
 | 
|---|
| 167 | 
 | 
|---|
| 168 | /** Holding this rwlock prevents changes in file system namespace. */
 | 
|---|
| 169 | extern fibril_rwlock_t namespace_rwlock;
 | 
|---|
| 170 | 
 | 
|---|
| 171 | extern async_exch_t *vfs_exchange_grab(fs_handle_t);
 | 
|---|
| 172 | extern void vfs_exchange_release(async_exch_t *);
 | 
|---|
| 173 | 
 | 
|---|
| 174 | extern fs_handle_t fs_name_to_handle(unsigned int instance, const char *, bool);
 | 
|---|
| 175 | extern vfs_info_t *fs_handle_to_info(fs_handle_t);
 | 
|---|
| 176 | extern errno_t vfs_get_fstypes(vfs_fstypes_t *);
 | 
|---|
| 177 | 
 | 
|---|
| 178 | extern errno_t vfs_lookup_internal(vfs_node_t *, char *, int, vfs_lookup_res_t *);
 | 
|---|
| 179 | extern errno_t vfs_link_internal(vfs_node_t *, char *, vfs_triplet_t *);
 | 
|---|
| 180 | 
 | 
|---|
| 181 | extern bool vfs_nodes_init(void);
 | 
|---|
| 182 | extern vfs_node_t *vfs_node_get(vfs_lookup_res_t *);
 | 
|---|
| 183 | extern vfs_node_t *vfs_node_peek(vfs_lookup_res_t *result);
 | 
|---|
| 184 | extern void vfs_node_put(vfs_node_t *);
 | 
|---|
| 185 | extern void vfs_node_forget(vfs_node_t *);
 | 
|---|
| 186 | extern unsigned vfs_nodes_refcount_sum_get(fs_handle_t, service_id_t);
 | 
|---|
| 187 | 
 | 
|---|
| 188 | extern bool vfs_node_has_children(vfs_node_t *node);
 | 
|---|
| 189 | 
 | 
|---|
| 190 | extern void *vfs_client_data_create(void);
 | 
|---|
| 191 | extern void vfs_client_data_destroy(void *);
 | 
|---|
| 192 | 
 | 
|---|
| 193 | extern void vfs_op_pass_handle(task_id_t, task_id_t, int);
 | 
|---|
| 194 | extern errno_t vfs_wait_handle_internal(bool, int *);
 | 
|---|
| 195 | 
 | 
|---|
| 196 | extern vfs_file_t *vfs_file_get(int);
 | 
|---|
| 197 | extern void vfs_file_put(vfs_file_t *);
 | 
|---|
| 198 | extern errno_t vfs_fd_assign(vfs_file_t *, int);
 | 
|---|
| 199 | extern errno_t vfs_fd_alloc(vfs_file_t **file, bool desc, int *);
 | 
|---|
| 200 | extern errno_t vfs_fd_free(int);
 | 
|---|
| 201 | 
 | 
|---|
| 202 | extern void vfs_node_addref(vfs_node_t *);
 | 
|---|
| 203 | extern void vfs_node_delref(vfs_node_t *);
 | 
|---|
| 204 | extern errno_t vfs_open_node_remote(vfs_node_t *);
 | 
|---|
| 205 | 
 | 
|---|
| 206 | extern errno_t vfs_op_clone(int oldfd, int newfd, bool desc, int *);
 | 
|---|
| 207 | extern errno_t vfs_op_fsprobe(const char *, service_id_t, vfs_fs_probe_info_t *);
 | 
|---|
| 208 | extern errno_t vfs_op_mount(int mpfd, unsigned servid, unsigned flags, unsigned instance, const char *opts, const char *fsname, int *outfd);
 | 
|---|
| 209 | extern errno_t vfs_op_mtab_get(void);
 | 
|---|
| 210 | extern errno_t vfs_op_open(int fd, int flags);
 | 
|---|
| 211 | extern errno_t vfs_op_put(int fd);
 | 
|---|
| 212 | extern errno_t vfs_op_read(int fd, aoff64_t, size_t *out_bytes);
 | 
|---|
| 213 | extern errno_t vfs_op_rename(int basefd, char *old, char *new);
 | 
|---|
| 214 | extern errno_t vfs_op_resize(int fd, int64_t size);
 | 
|---|
| 215 | extern errno_t vfs_op_stat(int fd);
 | 
|---|
| 216 | extern errno_t vfs_op_statfs(int fd);
 | 
|---|
| 217 | extern errno_t vfs_op_sync(int fd);
 | 
|---|
| 218 | extern errno_t vfs_op_unlink(int parentfd, int expectfd, char *path);
 | 
|---|
| 219 | extern errno_t vfs_op_unmount(int mpfd);
 | 
|---|
| 220 | extern errno_t vfs_op_wait_handle(bool high_fd, int *out_fd);
 | 
|---|
| 221 | extern errno_t vfs_op_walk(int parentfd, int flags, char *path, int *out_fd);
 | 
|---|
| 222 | extern errno_t vfs_op_write(int fd, aoff64_t, size_t *out_bytes);
 | 
|---|
| 223 | 
 | 
|---|
| 224 | extern void vfs_register(ipc_call_t *);
 | 
|---|
| 225 | 
 | 
|---|
| 226 | extern void vfs_page_in(ipc_call_t *);
 | 
|---|
| 227 | 
 | 
|---|
| 228 | typedef struct {
 | 
|---|
| 229 |         void *buffer;
 | 
|---|
| 230 |         size_t size;
 | 
|---|
| 231 | } rdwr_io_chunk_t;
 | 
|---|
| 232 | 
 | 
|---|
| 233 | extern errno_t vfs_rdwr_internal(int, aoff64_t, bool, rdwr_io_chunk_t *);
 | 
|---|
| 234 | 
 | 
|---|
| 235 | extern void vfs_connection(ipc_call_t *, void *);
 | 
|---|
| 236 | 
 | 
|---|
| 237 | #endif
 | 
|---|
| 238 | 
 | 
|---|
| 239 | /**
 | 
|---|
| 240 |  * @}
 | 
|---|
| 241 |  */
 | 
|---|