source: mainline/uspace/srv/fs/minixfs/mfs.c@ 51db5aeb

lfn serial ticket/834-toolchain-update topic/msim-upgrade topic/simplify-dev-export
Last change on this file since 51db5aeb was 51db5aeb, checked in by Maurizio Lombardi <m.lombardi85@…>, 14 years ago

Add the unmount and sync functions, do not destroy a node if its number of hard links is > 0

  • Property mode set to 100644
File size: 4.8 KB
RevLine 
[c2eef61c]1/*
2 * Copyright (c) 2006 Martin Decky
3 * Copyright (c) 2008 Jakub Jermar
4 * Copyright (c) 2011 Maurizio Lombardi
5 * All rights reserved.
6 *
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
9 * are met:
10 *
11 * - Redistributions of source code must retain the above copyright
12 * notice, this list of conditions and the following disclaimer.
13 * - Redistributions in binary form must reproduce the above copyright
14 * notice, this list of conditions and the following disclaimer in the
15 * documentation and/or other materials provided with the distribution.
16 * - The name of the author may not be used to endorse or promote products
17 * derived from this software without specific prior written permission.
18 *
19 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
20 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
21 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
22 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
23 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
24 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
25 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
26 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
27 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
28 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
29 */
30
31/** @addtogroup fs
32 * @{
33 */
34
35/**
36 * @file mfs.c
37 * @brief Minix file system driver for HelenOS.
38 */
39
[3b08178]40#define _MAIN
41
[c2eef61c]42#include <ipc/services.h>
[1affcdf3]43#include <ns.h>
[c2eef61c]44#include <async.h>
45#include <errno.h>
46#include <unistd.h>
47#include <task.h>
48#include <stdio.h>
[1affcdf3]49#include <libfs.h>
[7413683]50#include "mfs.h"
[c2eef61c]51
52vfs_info_t mfs_vfs_info = {
53 .name = NAME,
54 .concurrent_read_write = false,
[44c6091f]55 .write_retains_size = false,
[c2eef61c]56};
57
[7de65cd]58
59/**
60 * This connection fibril processes VFS requests from VFS.
61 *
62 * In order to support simultaneous VFS requests, our design is as follows.
63 * The connection fibril accepts VFS requests from VFS. If there is only one
64 * instance of the fibril, VFS will need to serialize all VFS requests it sends
[fd7f329a]65 * to MinixFS. To overcome this bottleneck, VFS can send MinixFS the IPC_M_CONNECT_ME_TO
[7de65cd]66 * call. In that case, a new connection fibril will be created, which in turn
67 * will accept the call. Thus, a new phone will be opened for VFS.
68 *
69 * There are few issues with this arrangement. First, VFS can run out of
70 * available phones. In that case, VFS can close some other phones or use one
[fd7f329a]71 * phone for more serialized requests. Similarily, MinixFS can refuse to duplicate
[7de65cd]72 * the connection. VFS should then just make use of already existing phones and
[44c6091f]73 * route its requests through them. To avoid paying the fibril creation price
[fd7f329a]74 * upon each request, MinixFS might want to keep the connections open after the
[7de65cd]75 * request has been completed.
76 */
77
78static void mfs_connection(ipc_callid_t iid, ipc_call_t *icall)
79{
80 if (iid) {
81 /*
82 * This only happens for connections opened by
83 * IPC_M_CONNECT_ME_TO calls as opposed to callback connections
84 * created by IPC_M_CONNECT_TO_ME.
85 */
86 async_answer_0(iid, EOK);
87 }
[44c6091f]88
[7de65cd]89 printf(NAME ": connection opened\n");
90 while (1) {
91 ipc_callid_t callid;
92 ipc_call_t call;
[44c6091f]93
[7de65cd]94 callid = async_get_call(&call);
[41202a9]95 int method = IPC_GET_IMETHOD(call);
96
[ff2e72e]97 /*mfsdebug(NAME "method = %d\n", method);*/
[41202a9]98 switch (method) {
[8ceba1e]99 case VFS_OUT_MOUNTED:
100 mfs_mounted(callid, &call);
101 break;
[92dd5c8]102 case VFS_OUT_MOUNT:
[3b08178]103 mfs_mount(callid, &call);
[92dd5c8]104 break;
[0d6ab10]105 case VFS_OUT_STAT:
106 mfs_stat(callid, &call);
107 break;
[54caa41b]108 case VFS_OUT_LOOKUP:
109 mfs_lookup(callid, &call);
110 break;
[668f1949]111 case VFS_OUT_READ:
112 mfs_read(callid, &call);
113 break;
[e700970]114 case VFS_OUT_OPEN_NODE:
115 mfs_open_node(callid, &call);
116 break;
117 case VFS_OUT_CLOSE:
118 mfs_close(callid, &call);
119 break;
120 case VFS_OUT_WRITE:
[bb7e8382]121 mfs_write(callid, &call);
[e700970]122 break;
[8a49fed]123 case VFS_OUT_TRUNCATE:
124 mfs_truncate(callid, &call);
125 break;
[d8af1bd]126 case VFS_OUT_DESTROY:
127 mfs_destroy(callid, &call);
128 break;
[51db5aeb]129 case VFS_OUT_UNMOUNTED:
130 mfs_unmounted(callid, &call);
131 break;
132 case VFS_OUT_UNMOUNT:
133 mfs_unmount(callid, &call);
134 break;
135 case VFS_OUT_SYNC:
136 mfs_sync(callid, &call);
137 break;
[92dd5c8]138 default:
139 async_answer_0(callid, ENOTSUP);
140 break;
[7de65cd]141 }
142 }
143}
144
145
[c2eef61c]146int main(int argc, char **argv)
147{
[7de65cd]148 int rc;
149
[c2eef61c]150 printf(NAME ": HelenOS Minix file system server\n");
[7de65cd]151
[1affcdf3]152 async_sess_t *vfs_sess = service_connect_blocking(EXCHANGE_SERIALIZE,
153 SERVICE_VFS, 0, 0);
[7de65cd]154
[1affcdf3]155 if (!vfs_sess) {
[7de65cd]156 printf(NAME ": failed to connect to VFS\n");
157 return -1;
158 }
159
[1affcdf3]160 rc = fs_register(vfs_sess, &mfs_reg, &mfs_vfs_info, mfs_connection);
[7de65cd]161 if (rc != EOK)
162 goto err;
[44c6091f]163
[f6d4462]164 printf(NAME ": Accepting connections\n");
165 task_retval(0);
166 async_manager();
[fd7f329a]167 /* not reached */
[c2eef61c]168 return 0;
[7de65cd]169
170err:
171 printf(NAME ": Failed to register file system (%d)\n", rc);
172 return rc;
[c2eef61c]173}
174
175/**
176 * @}
[44c6091f]177 */
[c2eef61c]178
Note: See TracBrowser for help on using the repository browser.