Subversion Repositories HelenOS

Rev

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

Rev 4345 Rev 4691
Line 41... Line 41...
41
#include <errno.h>
41
#include <errno.h>
42
#include <stdio.h>
42
#include <stdio.h>
43
#include <bool.h>
43
#include <bool.h>
44
#include <string.h>
44
#include <string.h>
45
#include <as.h>
45
#include <as.h>
46
#include <libadt/list.h>
-
 
47
#include <atomic.h>
46
#include <atomic.h>
48
#include "vfs.h"
47
#include "vfs.h"
49
 
48
 
50
#define NAME "vfs"
49
#define NAME "vfs"
51
 
50
 
52
static void vfs_connection(ipc_callid_t iid, ipc_call_t *icall)
51
static void vfs_connection(ipc_callid_t iid, ipc_call_t *icall)
53
{
52
{
54
    bool keep_on_going = true;
53
    bool keep_on_going = true;
55
   
54
 
56
    /*
55
    /*
57
     * The connection was opened via the IPC_CONNECT_ME_TO call.
56
     * The connection was opened via the IPC_CONNECT_ME_TO call.
58
     * This call needs to be answered.
57
     * This call needs to be answered.
59
     */
58
     */
60
    ipc_answer_0(iid, EOK);
59
    ipc_answer_0(iid, EOK);
Line 78... Line 77...
78
       
77
       
79
        switch (IPC_GET_METHOD(call)) {
78
        switch (IPC_GET_METHOD(call)) {
80
        case IPC_M_PHONE_HUNGUP:
79
        case IPC_M_PHONE_HUNGUP:
81
            keep_on_going = false;
80
            keep_on_going = false;
82
            break;
81
            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;
-
 
98
        case VFS_REGISTER:
82
        case VFS_IN_REGISTER:
99
            vfs_register(callid, &call);
83
            vfs_register(callid, &call);
100
            /*
-
 
101
             * Keep the connection open so that a file system can
84
            keep_on_going = false;
102
             * later ask us to connect it to another file system.
-
 
103
             * This is necessary to support non-root mounts.
-
 
104
             */
-
 
105
            break;
85
            break;
106
        case VFS_MOUNT:
86
        case VFS_IN_MOUNT:
107
            vfs_mount(callid, &call);
87
            vfs_mount(callid, &call);
108
            break;
88
            break;
109
        case VFS_OPEN:
89
        case VFS_IN_OPEN:
110
            vfs_open(callid, &call);
90
            vfs_open(callid, &call);
111
            break;
91
            break;
-
 
92
        case VFS_IN_OPEN_NODE:
-
 
93
            vfs_open_node(callid, &call);
-
 
94
            break;
112
        case VFS_CLOSE:
95
        case VFS_IN_CLOSE:
113
            vfs_close(callid, &call);
96
            vfs_close(callid, &call);
114
            break;
97
            break;
115
        case VFS_READ:
98
        case VFS_IN_READ:
116
            vfs_read(callid, &call);
99
            vfs_read(callid, &call);
117
            break;
100
            break;
118
        case VFS_WRITE:
101
        case VFS_IN_WRITE:
119
            vfs_write(callid, &call);
102
            vfs_write(callid, &call);
120
            break;
103
            break;
121
        case VFS_SEEK:
104
        case VFS_IN_SEEK:
122
            vfs_seek(callid, &call);
105
            vfs_seek(callid, &call);
123
            break;
106
            break;
124
        case VFS_TRUNCATE:
107
        case VFS_IN_TRUNCATE:
125
            vfs_truncate(callid, &call);
108
            vfs_truncate(callid, &call);
126
            break;
109
            break;
-
 
110
        case VFS_IN_FSTAT:
-
 
111
            vfs_fstat(callid, &call);
-
 
112
            break;
-
 
113
        case VFS_IN_STAT:
-
 
114
            vfs_stat(callid, &call);
-
 
115
            break;
127
        case VFS_MKDIR:
116
        case VFS_IN_MKDIR:
128
            vfs_mkdir(callid, &call);
117
            vfs_mkdir(callid, &call);
129
            break;
118
            break;
130
        case VFS_UNLINK:
119
        case VFS_IN_UNLINK:
131
            vfs_unlink(callid, &call);
120
            vfs_unlink(callid, &call);
132
            break;
121
            break;
133
        case VFS_RENAME:
122
        case VFS_IN_RENAME:
134
            vfs_rename(callid, &call);
123
            vfs_rename(callid, &call);
135
            break;
124
            break;
-
 
125
        case VFS_IN_SYNC:
-
 
126
            vfs_sync(callid, &call);
-
 
127
            break;
136
        default:
128
        default:
137
            ipc_answer_0(callid, ENOTSUP);
129
            ipc_answer_0(callid, ENOTSUP);
138
            break;
130
            break;
139
        }
131
        }
140
    }
132
    }
Line 145... Line 137...
145
int main(int argc, char **argv)
137
int main(int argc, char **argv)
146
{
138
{
147
    printf(NAME ": HelenOS VFS server\n");
139
    printf(NAME ": HelenOS VFS server\n");
148
   
140
   
149
    /*
141
    /*
150
     * Initialize the list of registered file systems.
-
 
151
     */
-
 
152
    list_initialize(&fs_head);
-
 
153
   
-
 
154
    /*
-
 
155
     * Initialize VFS node hash table.
142
     * Initialize VFS node hash table.
156
     */
143
     */
157
    if (!vfs_nodes_init()) {
144
    if (!vfs_nodes_init()) {
158
        printf(NAME ": Failed to initialize VFS node hash table\n");
145
        printf(NAME ": Failed to initialize VFS node hash table\n");
159
        return ENOMEM;
146
        return ENOMEM;
160
    }
147
    }
161
   
148
   
162
    /*
149
    /*
163
     * Allocate and initialize the Path Lookup Buffer.
150
     * Allocate and initialize the Path Lookup Buffer.
164
     */
151
     */
165
    list_initialize(&plb_head);
-
 
166
    plb = as_get_mappable_page(PLB_SIZE);
152
    plb = as_get_mappable_page(PLB_SIZE);
167
    if (!plb) {
153
    if (!plb) {
168
        printf(NAME ": Cannot allocate a mappable piece of address space\n");
154
        printf(NAME ": Cannot allocate a mappable piece of address space\n");
169
        return ENOMEM;
155
        return ENOMEM;
170
    }
156
    }
Line 175... Line 161...
175
        return ENOMEM;
161
        return ENOMEM;
176
    }
162
    }
177
    memset(plb, 0, PLB_SIZE);
163
    memset(plb, 0, PLB_SIZE);
178
   
164
   
179
    /*
165
    /*
180
     * Set a connectio handling function/fibril.
166
     * Set a connection handling function/fibril.
181
     */
167
     */
182
    async_set_client_connection(vfs_connection);
168
    async_set_client_connection(vfs_connection);
183
   
169
 
184
    /*
170
    /*
185
     * Register at the naming service.
171
     * Register at the naming service.
186
     */
172
     */
187
    ipcarg_t phonead;
173
    ipcarg_t phonead;
188
    ipc_connect_to_me(PHONE_NS, SERVICE_VFS, 0, 0, &phonead);
174
    ipc_connect_to_me(PHONE_NS, SERVICE_VFS, 0, 0, &phonead);