Subversion Repositories HelenOS

Rev

Rev 3536 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 3536 Rev 4377
Line 26... Line 26...
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 fs
 29 
/** @addtogroup fs
30 
 * @{
 30 
 * @{
31 
 */
 31 
 */
32 
 
 32 
 
33 
/**
 33 
/**
34 
 * @file    vfs.c
 34 
 * @file vfs.c
35 
 * @brief   VFS service for HelenOS.
 35 
 * @brief VFS service for HelenOS.
36 
 */
 36 
 */
37 
 
 37 
 
38 
#include <ipc/ipc.h>
 38 
#include <ipc/ipc.h>
39 
#include <ipc/services.h>
 39 
#include <ipc/services.h>
40 
#include <async.h>
 40 
#include <async.h>
Line 49... Line 49...
49 
 
 49 
 
50 
#define NAME "vfs"
 50 
#define NAME "vfs"
51 
 
 51 
 
52 
static void vfs_connection(ipc_callid_t iid, ipc_call_t *icall)
 52 
static void vfs_connection(ipc_callid_t iid, ipc_call_t *icall)
53 
{
 53 
{
54 
    bool keep_on_going = 1;
 54 
    bool keep_on_going = true;
55 
 
 55 
   
56 
    /*
 56 
    /*
57 
     * The connection was opened via the IPC_CONNECT_ME_TO call.
 57 
     * The connection was opened via the IPC_CONNECT_ME_TO call.
58 
     * This call needs to be answered.
 58 
     * This call needs to be answered.
59 
     */
 59 
     */
60 
    ipc_answer_0(iid, EOK);
 60 
    ipc_answer_0(iid, EOK);
61 
 
 61 
   
62 
    /*
 62 
    /*
63 
     * Here we enter the main connection fibril loop.
 63 
     * Here we enter the main connection fibril loop.
64 
     * The logic behind this loop and the protocol is that we'd like to keep
 64 
     * The logic behind this loop and the protocol is that we'd like to keep
65 
     * each connection open until the client hangs up. When the client hangs
 65 
     * each connection open until the client hangs up. When the client hangs
66 
     * up, we will free its VFS state. The act of hanging up the connection
 66 
     * up, we will free its VFS state. The act of hanging up the connection
Line 68... Line 68...
68 
     * distinguish one from the other. On the other hand, the client can
 68 
     * distinguish one from the other. On the other hand, the client can
69 
     * hang up arbitrarily if it has no open files and reestablish the
 69 
     * hang up arbitrarily if it has no open files and reestablish the
70 
     * connection later.
 70 
     * connection later.
71 
     */
 71 
     */
72 
    while (keep_on_going) {
 72 
    while (keep_on_going) {
73 
        ipc_callid_t callid;
 - 
 
74 
        ipc_call_t call;
 73 
        ipc_call_t call;
- 
 
 74 
        ipc_callid_t callid = async_get_call(&call);
75 
 
 75 
       
76 
        callid = async_get_call(&call);
 76 
        fs_handle_t fs_handle;
- 
 
 77 
        int phone;
77 
 
 78 
       
78 
        switch (IPC_GET_METHOD(call)) {
 79 
        switch (IPC_GET_METHOD(call)) {
79 
        case IPC_M_PHONE_HUNGUP:
 80 
        case IPC_M_PHONE_HUNGUP:
80 
            keep_on_going = false;
 81 
            keep_on_going = false;
81 
            break;
 82 
            break;
- 
 
 83 
        case IPC_M_CONNECT_ME_TO:
- 
 
 84 
            /*
- 
 
 85 
             * Connect the client file system to another one.
- 
 
 86 
             */
- 
 
 87 
            /* FIXME:
- 
 
 88 
             * Prevent ordinary clients from connecting to file
- 
 
 89 
             * system servers directly. This should be solved by
- 
 
 90 
             * applying some security mechanisms.
- 
 
 91 
             */
- 
 
 92 
            fs_handle = IPC_GET_ARG1(call);
- 
 
 93 
            phone = vfs_grab_phone(fs_handle);
- 
 
 94 
            (void) ipc_forward_fast(callid, phone, 0, 0, 0,
- 
 
 95 
                IPC_FF_NONE);
- 
 
 96 
            vfs_release_phone(phone);
- 
 
 97 
            break;
82 
        case VFS_REGISTER:
 98 
        case VFS_REGISTER:
83 
            vfs_register(callid, &call);
 99 
            vfs_register(callid, &call);
- 
 
 100 
            /*
84 
            keep_on_going = false;
 101 
             * Keep the connection open so that a file system can
- 
 
 102 
             * later ask us to connect it to another file system.
- 
 
 103 
             * This is necessary to support non-root mounts.
- 
 
 104 
             */
85 
            break;
 105 
            break;
86 
        case VFS_MOUNT:
 106 
        case VFS_MOUNT:
87 
            vfs_mount(callid, &call);
 107 
            vfs_mount(callid, &call);
88 
            break;
 108 
            break;
89 
        case VFS_OPEN:
 109 
        case VFS_OPEN:
Line 116... Line 136...
116 
        default:
 136 
        default:
117 
            ipc_answer_0(callid, ENOTSUP);
 137 
            ipc_answer_0(callid, ENOTSUP);
118 
            break;
 138 
            break;
119 
        }
 139 
        }
120 
    }
 140 
    }
121 
 
 - 
 
122 
    /* TODO: cleanup after the client */
 - 
 
123 
   
 141 
   
- 
 
 142 
    /* TODO: cleanup after the client */
124 
}
 143 
}
125 
 
 144 
 
126 
int main(int argc, char **argv)
 145 
int main(int argc, char **argv)
127 
{
 146 
{
128 
    ipcarg_t phonead;
 - 
 
129 
 
 - 
 
130 
    printf(NAME ": HelenOS VFS server\n");
 147 
    printf(NAME ": HelenOS VFS server\n");
131 
 
 148 
   
132 
    /*
 149 
    /*
133 
     * Initialize the list of registered file systems.
 150 
     * Initialize the list of registered file systems.
134 
     */
 151 
     */
135 
    list_initialize(&fs_head);
 152 
    list_initialize(&fs_head);
136 
 
 153 
   
137 
    /*
 154 
    /*
138 
     * Initialize VFS node hash table.
 155 
     * Initialize VFS node hash table.
139 
     */
 156 
     */
140 
    if (!vfs_nodes_init()) {
 157 
    if (!vfs_nodes_init()) {
141 
        printf(NAME ": Failed to initialize VFS node hash table\n");
 158 
        printf(NAME ": Failed to initialize VFS node hash table\n");
142 
        return ENOMEM;
 159 
        return ENOMEM;
143 
    }
 160 
    }
144 
 
 161 
   
145 
    /*
 162 
    /*
146 
     * Allocate and initialize the Path Lookup Buffer.
 163 
     * Allocate and initialize the Path Lookup Buffer.
147 
     */
 164 
     */
148 
    list_initialize(&plb_head);
 165 
    list_initialize(&plb_head);
149 
    plb = as_get_mappable_page(PLB_SIZE);
 166 
    plb = as_get_mappable_page(PLB_SIZE);
150 
    if (!plb) {
 167 
    if (!plb) {
151 
        printf(NAME ": Cannot allocate a mappable piece of address space\n");
 168 
        printf(NAME ": Cannot allocate a mappable piece of address space\n");
152 
        return ENOMEM;
 169 
        return ENOMEM;
153 
    }
 170 
    }
- 
 
 171 
   
154 
    if (as_area_create(plb, PLB_SIZE, AS_AREA_READ | AS_AREA_WRITE |
 172 
    if (as_area_create(plb, PLB_SIZE, AS_AREA_READ | AS_AREA_WRITE |
155 
        AS_AREA_CACHEABLE) != plb) {
 173 
        AS_AREA_CACHEABLE) != plb) {
156 
        printf(NAME ": Cannot create address space area\n");
 174 
        printf(NAME ": Cannot create address space area\n");
157 
        return ENOMEM;
 175 
        return ENOMEM;
158 
    }
 176 
    }
Line 160... Line 178...
160 
   
 178 
   
161 
    /*
 179 
    /*
162 
     * Set a connectio handling function/fibril.
 180 
     * Set a connectio handling function/fibril.
163 
     */
 181 
     */
164 
    async_set_client_connection(vfs_connection);
 182 
    async_set_client_connection(vfs_connection);
165 
 
 183 
   
166 
    /*
 184 
    /*
167 
     * Register at the naming service.
 185 
     * Register at the naming service.
168 
     */
 186 
     */
- 
 
 187 
    ipcarg_t phonead;
169 
    ipc_connect_to_me(PHONE_NS, SERVICE_VFS, 0, 0, &phonead);
 188 
    ipc_connect_to_me(PHONE_NS, SERVICE_VFS, 0, 0, &phonead);
170 
 
 189 
   
171 
    /*
 190 
    /*
172 
     * Start accepting connections.
 191 
     * Start accepting connections.
173 
     */
 192 
     */
174 
    printf(NAME ": Accepting connections\n");
 193 
    printf(NAME ": Accepting connections\n");
175 
    async_manager();
 194 
    async_manager();
176 
    return 0;
 195 
    return 0;
177 
}
 196 
}
178 
 
 197 
 
179 
/**
 198 
/**
180 
 * @}
 199 
 * @}
181 
 */
 200 
 */