Subversion Repositories HelenOS

Rev

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

Rev 4341 Rev 4345
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 
        int phone;
 75 
       
76 
        fs_handle_t fs_handle;
 76 
        fs_handle_t fs_handle;
77 
 
 - 
 
78 
        callid = async_get_call(&call);
 77 
        int phone;
79 
 
 78 
       
80 
        switch (IPC_GET_METHOD(call)) {
 79 
        switch (IPC_GET_METHOD(call)) {
81 
        case IPC_M_PHONE_HUNGUP:
 80 
        case IPC_M_PHONE_HUNGUP:
82 
            keep_on_going = false;
 81 
            keep_on_going = false;
83 
            break;
 82 
            break;
84 
        case IPC_M_CONNECT_ME_TO:
 83 
        case IPC_M_CONNECT_ME_TO:
Line 137... Line 136...
137 
        default:
 136 
        default:
138 
            ipc_answer_0(callid, ENOTSUP);
 137 
            ipc_answer_0(callid, ENOTSUP);
139 
            break;
 138 
            break;
140 
        }
 139 
        }
141 
    }
 140 
    }
142 
 
 - 
 
143 
    /* TODO: cleanup after the client */
 - 
 
144 
   
 141 
   
- 
 
 142 
    /* TODO: cleanup after the client */
145 
}
 143 
}
146 
 
 144 
 
147 
int main(int argc, char **argv)
 145 
int main(int argc, char **argv)
148 
{
 146 
{
149 
    ipcarg_t phonead;
 - 
 
150 
 
 - 
 
151 
    printf(NAME ": HelenOS VFS server\n");
 147 
    printf(NAME ": HelenOS VFS server\n");
152 
 
 148 
   
153 
    /*
 149 
    /*
154 
     * Initialize the list of registered file systems.
 150 
     * Initialize the list of registered file systems.
155 
     */
 151 
     */
156 
    list_initialize(&fs_head);
 152 
    list_initialize(&fs_head);
157 
 
 153 
   
158 
    /*
 154 
    /*
159 
     * Initialize VFS node hash table.
 155 
     * Initialize VFS node hash table.
160 
     */
 156 
     */
161 
    if (!vfs_nodes_init()) {
 157 
    if (!vfs_nodes_init()) {
162 
        printf(NAME ": Failed to initialize VFS node hash table\n");
 158 
        printf(NAME ": Failed to initialize VFS node hash table\n");
163 
        return ENOMEM;
 159 
        return ENOMEM;
164 
    }
 160 
    }
165 
 
 161 
   
166 
    /*
 162 
    /*
167 
     * Allocate and initialize the Path Lookup Buffer.
 163 
     * Allocate and initialize the Path Lookup Buffer.
168 
     */
 164 
     */
169 
    list_initialize(&plb_head);
 165 
    list_initialize(&plb_head);
170 
    plb = as_get_mappable_page(PLB_SIZE);
 166 
    plb = as_get_mappable_page(PLB_SIZE);
171 
    if (!plb) {
 167 
    if (!plb) {
172 
        printf(NAME ": Cannot allocate a mappable piece of address space\n");
 168 
        printf(NAME ": Cannot allocate a mappable piece of address space\n");
173 
        return ENOMEM;
 169 
        return ENOMEM;
174 
    }
 170 
    }
- 
 
 171 
   
175 
    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 |
176 
        AS_AREA_CACHEABLE) != plb) {
 173 
        AS_AREA_CACHEABLE) != plb) {
177 
        printf(NAME ": Cannot create address space area\n");
 174 
        printf(NAME ": Cannot create address space area\n");
178 
        return ENOMEM;
 175 
        return ENOMEM;
179 
    }
 176 
    }
Line 181... Line 178...
181 
   
 178 
   
182 
    /*
 179 
    /*
183 
     * Set a connectio handling function/fibril.
 180 
     * Set a connectio handling function/fibril.
184 
     */
 181 
     */
185 
    async_set_client_connection(vfs_connection);
 182 
    async_set_client_connection(vfs_connection);
186 
 
 183 
   
187 
    /*
 184 
    /*
188 
     * Register at the naming service.
 185 
     * Register at the naming service.
189 
     */
 186 
     */
- 
 
 187 
    ipcarg_t phonead;
190 
    ipc_connect_to_me(PHONE_NS, SERVICE_VFS, 0, 0, &phonead);
 188 
    ipc_connect_to_me(PHONE_NS, SERVICE_VFS, 0, 0, &phonead);
191 
 
 189 
   
192 
    /*
 190 
    /*
193 
     * Start accepting connections.
 191 
     * Start accepting connections.
194 
     */
 192 
     */
195 
    printf(NAME ": Accepting connections\n");
 193 
    printf(NAME ": Accepting connections\n");
196 
    async_manager();
 194 
    async_manager();
197 
    return 0;
 195 
    return 0;
198 
}
 196 
}
199 
 
 197 
 
200 
/**
 198 
/**
201 
 * @}
 199 
 * @}
202 
 */
 200 
 */