Subversion Repositories HelenOS

Rev

Rev 4419 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
4419 trochtova 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 fs
30
 * @{
31
 */
32
 
33
/**
34
 * @file vfs.c
35
 * @brief VFS service for HelenOS.
36
 */
37
 
38
#include <ipc/ipc.h>
39
#include <ipc/services.h>
40
#include <async.h>
41
#include <errno.h>
42
#include <stdio.h>
43
#include <bool.h>
44
#include <string.h>
45
#include <as.h>
46
#include <libadt/list.h>
47
#include <atomic.h>
48
#include "vfs.h"
49
 
50
#define NAME "vfs"
51
 
52
static void vfs_connection(ipc_callid_t iid, ipc_call_t *icall)
53
{
54
    bool keep_on_going = true;
4420 trochtova 55
 
4419 trochtova 56
    /*
57
     * The connection was opened via the IPC_CONNECT_ME_TO call.
58
     * This call needs to be answered.
59
     */
60
    ipc_answer_0(iid, EOK);
61
 
62
    /*
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
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
67
     * by the client is equivalent to client termination because we cannot
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
70
     * connection later.
71
     */
72
    while (keep_on_going) {
73
        ipc_call_t call;
74
        ipc_callid_t callid = async_get_call(&call);
75
 
76
        fs_handle_t fs_handle;
77
        int phone;
78
 
79
        switch (IPC_GET_METHOD(call)) {
80
        case IPC_M_PHONE_HUNGUP:
81
            keep_on_going = false;
82
            break;
83
        case VFS_REGISTER:
84
            vfs_register(callid, &call);
85
            /*
86
             * Keep the connection open so that a file system can
87
             * later ask us to connect it to another file system.
88
             * This is necessary to support non-root mounts.
89
             */
90
            break;
91
        case VFS_MOUNT:
92
            vfs_mount(callid, &call);
93
            break;
94
        case VFS_OPEN:
95
            vfs_open(callid, &call);
96
            break;
97
        case VFS_CLOSE:
98
            vfs_close(callid, &call);
99
            break;
100
        case VFS_READ:
101
            vfs_read(callid, &call);
102
            break;
103
        case VFS_WRITE:
104
            vfs_write(callid, &call);
105
            break;
106
        case VFS_SEEK:
107
            vfs_seek(callid, &call);
108
            break;
109
        case VFS_TRUNCATE:
110
            vfs_truncate(callid, &call);
111
            break;
112
        case VFS_MKDIR:
113
            vfs_mkdir(callid, &call);
114
            break;
115
        case VFS_UNLINK:
116
            vfs_unlink(callid, &call);
117
            break;
118
        case VFS_RENAME:
119
            vfs_rename(callid, &call);
120
            break;
121
        default:
122
            ipc_answer_0(callid, ENOTSUP);
123
            break;
124
        }
125
    }
126
 
127
    /* TODO: cleanup after the client */
128
}
129
 
130
int main(int argc, char **argv)
131
{
132
    printf(NAME ": HelenOS VFS server\n");
133
 
134
    /*
135
     * Initialize the list of registered file systems.
136
     */
137
    list_initialize(&fs_head);
138
 
139
    /*
140
     * Initialize VFS node hash table.
141
     */
142
    if (!vfs_nodes_init()) {
143
        printf(NAME ": Failed to initialize VFS node hash table\n");
144
        return ENOMEM;
145
    }
146
 
147
    /*
148
     * Allocate and initialize the Path Lookup Buffer.
149
     */
150
    list_initialize(&plb_head);
151
    plb = as_get_mappable_page(PLB_SIZE);
152
    if (!plb) {
153
        printf(NAME ": Cannot allocate a mappable piece of address space\n");
154
        return ENOMEM;
155
    }
156
 
157
    if (as_area_create(plb, PLB_SIZE, AS_AREA_READ | AS_AREA_WRITE |
158
        AS_AREA_CACHEABLE) != plb) {
159
        printf(NAME ": Cannot create address space area\n");
160
        return ENOMEM;
161
    }
162
    memset(plb, 0, PLB_SIZE);
163
 
164
    /*
165
     * Set a connectio handling function/fibril.
166
     */
167
    async_set_client_connection(vfs_connection);
168
 
169
    /*
170
     * Register at the naming service.
171
     */
172
    ipcarg_t phonead;
173
    ipc_connect_to_me(PHONE_NS, SERVICE_VFS, 0, 0, &phonead);
174
 
175
    /*
176
     * Start accepting connections.
177
     */
178
    printf(NAME ": Accepting connections\n");
179
    async_manager();
180
    return 0;
181
}
182
 
183
/**
184
 * @}
185
 */