Subversion Repositories HelenOS

Rev

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

Rev 3424 Rev 3425
Line 69... Line 69...
69
 
69
 
70
void vfs_mount(ipc_callid_t rid, ipc_call_t *request)
70
void vfs_mount(ipc_callid_t rid, ipc_call_t *request)
71
{
71
{
72
    dev_handle_t dev_handle;
72
    dev_handle_t dev_handle;
73
    vfs_node_t *mp_node = NULL;
73
    vfs_node_t *mp_node = NULL;
-
 
74
    ipc_callid_t callid;
-
 
75
    ipc_call_t data;
74
    int rc;
76
    int rc;
75
    int phone;
77
    int phone;
-
 
78
    size_t size;
76
 
79
 
77
    /*
80
    /*
78
     * We expect the library to do the device-name to device-handle
81
     * We expect the library to do the device-name to device-handle
79
     * translation for us, thus the device handle will arrive as ARG1
82
     * translation for us, thus the device handle will arrive as ARG1
80
     * in the request.
83
     * in the request.
Line 84... Line 87...
84
    /*
87
    /*
85
     * For now, don't make use of ARG2 and ARG3, but they can be used to
88
     * For now, don't make use of ARG2 and ARG3, but they can be used to
86
     * carry mount options in the future.
89
     * carry mount options in the future.
87
     */
90
     */
88
 
91
 
89
    ipc_callid_t callid;
-
 
90
    size_t size;
-
 
91
 
-
 
92
    /*
92
    /*
93
     * Now, we expect the client to send us data with the name of the file
93
     * Now, we expect the client to send us data with the name of the file
94
     * system.
94
     * system.
95
     */
95
     */
96
    if (!ipc_data_write_receive(&callid, &size)) {
96
    if (!ipc_data_write_receive(&callid, &size)) {
Line 113... Line 113...
113
    char fs_name[FS_NAME_MAXLEN + 1];
113
    char fs_name[FS_NAME_MAXLEN + 1];
114
    (void) ipc_data_write_finalize(callid, fs_name, size);
114
    (void) ipc_data_write_finalize(callid, fs_name, size);
115
    fs_name[size] = '\0';
115
    fs_name[size] = '\0';
116
   
116
   
117
    /*
117
    /*
-
 
118
     * Wait for IPC_M_PING so that we can return an error if we don't know
-
 
119
     * fs_name.
-
 
120
     */
-
 
121
    callid = async_get_call(&data);
-
 
122
    if (IPC_GET_METHOD(data) != IPC_M_PING) {
-
 
123
        ipc_answer_0(callid, ENOTSUP);
-
 
124
        ipc_answer_0(rid, ENOTSUP);
-
 
125
        return;
-
 
126
    }
-
 
127
 
-
 
128
    /*
118
     * Check if we know a file system with the same name as is in fs_name.
129
     * Check if we know a file system with the same name as is in fs_name.
119
     * This will also give us its file system handle.
130
     * This will also give us its file system handle.
120
     */
131
     */
121
    fs_handle_t fs_handle = fs_name_to_handle(fs_name, true);
132
    fs_handle_t fs_handle = fs_name_to_handle(fs_name, true);
122
    if (!fs_handle) {
133
    if (!fs_handle) {
-
 
134
        ipc_answer_0(callid, ENOENT);
123
        ipc_answer_0(rid, ENOENT);
135
        ipc_answer_0(rid, ENOENT);
124
        return;
136
        return;
125
    }
137
    }
126
 
138
 
-
 
139
    /* Acknowledge that we know fs_name. */
-
 
140
    ipc_answer_0(callid, EOK);
-
 
141
 
127
    /* Now, we want the client to send us the mount point. */
142
    /* Now, we want the client to send us the mount point. */
128
    if (!ipc_data_write_receive(&callid, &size)) {
143
    if (!ipc_data_write_receive(&callid, &size)) {
129
        ipc_answer_0(callid, EINVAL);
144
        ipc_answer_0(callid, EINVAL);
130
        ipc_answer_0(rid, EINVAL);
145
        ipc_answer_0(rid, EINVAL);
131
        return;
146
        return;
Line 188... Line 203...
188
         */
203
         */
189
        rwlock_write_unlock(&namespace_rwlock);
204
        rwlock_write_unlock(&namespace_rwlock);
190
    } else {
205
    } else {
191
        /* We still don't have the root file system mounted. */
206
        /* We still don't have the root file system mounted. */
192
        if ((size == 1) && (buf[0] == '/')) {
207
        if ((size == 1) && (buf[0] == '/')) {
-
 
208
            vfs_lookup_res_t mr_res;
-
 
209
            vfs_node_t *mr_node;
-
 
210
            ipcarg_t rindex;
-
 
211
            ipcarg_t rsize;
-
 
212
            ipcarg_t rlnkcnt;
-
 
213
       
193
            /*
214
            /*
194
             * For this simple, but important case,
215
             * For this simple, but important case,
195
             * we are almost done.
216
             * we are almost done.
196
             */
217
             */
197
            free(buf);
218
            free(buf);
198
           
219
           
199
            /* Tell the mountee that it is being mounted. */
220
            /* Tell the mountee that it is being mounted. */
200
            phone = vfs_grab_phone(fs_handle);
221
            phone = vfs_grab_phone(fs_handle);
201
            rc = async_req_1_0(phone, VFS_MOUNTED,
222
            rc = async_req_1_3(phone, VFS_MOUNTED,
202
                (ipcarg_t) dev_handle);
223
                (ipcarg_t) dev_handle, &rindex, &rsize, &rlnkcnt);
203
            vfs_release_phone(phone);
224
            vfs_release_phone(phone);
204
 
225
           
205
            if (rc == EOK) {
226
            if (rc != EOK) {
206
                rootfs.fs_handle = fs_handle;
227
                futex_up(&rootfs_futex);
207
                rootfs.dev_handle = dev_handle;
228
                ipc_answer_0(rid, rc);
-
 
229
                return;
208
            }
230
            }
209
 
231
 
-
 
232
            mr_res.triplet.fs_handle = fs_handle;
-
 
233
            mr_res.triplet.dev_handle = dev_handle;
-
 
234
            mr_res.triplet.index = (fs_index_t) rindex;
-
 
235
            mr_res.size = (size_t) rsize;
-
 
236
            mr_res.lnkcnt = (unsigned) rlnkcnt;
-
 
237
 
-
 
238
            rootfs.fs_handle = fs_handle;
-
 
239
            rootfs.dev_handle = dev_handle;
210
            futex_up(&rootfs_futex);
240
            futex_up(&rootfs_futex);
-
 
241
 
-
 
242
            /* Add reference to the mounted root. */
-
 
243
            mr_node = vfs_node_get(&mr_res);
-
 
244
            assert(mr_node);
-
 
245
 
211
            ipc_answer_0(rid, rc);
246
            ipc_answer_0(rid, rc);
212
            return;
247
            return;
213
        } else {
248
        } else {
214
            /*
249
            /*
215
             * We can't resolve this without the root filesystem
250
             * We can't resolve this without the root filesystem
Line 372... Line 407...
372
}
407
}
373
 
408
 
374
void vfs_close(ipc_callid_t rid, ipc_call_t *request)
409
void vfs_close(ipc_callid_t rid, ipc_call_t *request)
375
{
410
{
376
    int fd = IPC_GET_ARG1(*request);
411
    int fd = IPC_GET_ARG1(*request);
377
    if (fd >= MAX_OPEN_FILES) {
-
 
378
        ipc_answer_0(rid, EBADF);
-
 
379
        return;
-
 
380
    }
-
 
381
    vfs_fd_free(fd);
412
    int rc = vfs_fd_free(fd);
382
    ipc_answer_0(rid, EOK);
413
    ipc_answer_0(rid, rc);
383
}
414
}
384
 
415
 
385
static void vfs_rdwr(ipc_callid_t rid, ipc_call_t *request, bool read)
416
static void vfs_rdwr(ipc_callid_t rid, ipc_call_t *request, bool read)
386
{
417
{
387
 
418