Changeset 72bde81 in mainline for uspace/srv/vfs/vfs_ops.c

Timestamp:

2008-01-27T14:59:32Z (17 years ago)

Author:

Jakub Jermar <jakub@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

2db4ac8

Parents:

1fe186f

Message:

Support for mkdir().

File:

• uspace/srv/vfs/vfs_ops.c (modified) (17 diffs)

uspace/srv/vfs/vfs_ops.c

@@ -116 +116 @@
         }
 
-        /*
-         * Deliver the file system name.
-         */
+        /* Deliver the file system name. */
         char fs_name[FS_NAME_MAXLEN + 1];
         (void) ipc_data_write_finalize(callid, fs_name, size);
@@ -133 +131 @@
         }
 
-        /*
-         * Now, we want the client to send us the mount point.
-         */
+        /* Now, we want the client to send us the mount point. */
         if (!ipc_data_write_receive(&callid, &size)) {
                 ipc_answer_0(callid, EINVAL);
@@ -142 +138 @@
         }
 
-        /*
-         * Check whether size is reasonable wrt. the mount point.
-         */
+        /* Check whether size is reasonable wrt. the mount point. */
         if (size < 1 || size > MAX_PATH_LEN) {
                 ipc_answer_0(callid, EINVAL);
@@ -150 +144 @@
                 return;
         }
-        /*
-         * Allocate buffer for the mount point data being received.
-         */
+        /* Allocate buffer for the mount point data being received. */
         uint8_t *buf;
         buf = malloc(size);
@@ -161 +153 @@
         }
 
-        /*
-         * Deliver the mount point.
-         */
+        /* Deliver the mount point. */
         (void) ipc_data_write_finalize(callid, buf, size);
 
@@ -187 +177 @@
         }
 
-        /*
-         * Finally, we need to resolve the path to the mountpoint. 
-         */
+        /* Finally, we need to resolve the path to the mountpoint. */
         vfs_lookup_res_t mp_res;
         futex_down(&rootfs_futex);
         if (rootfs.fs_handle) {
-                /*
-                 * We already have the root FS.
-                 */
+                /* We already have the root FS. */
                 rwlock_write_lock(&namespace_rwlock);
                 rc = vfs_lookup_internal(buf, size, L_DIRECTORY, &mp_res,
                     NULL);
                 if (rc != EOK) {
-                        /*
-                         * The lookup failed for some reason.
-                         */
+                        /* The lookup failed for some reason. */
                         rwlock_write_unlock(&namespace_rwlock);
                         futex_up(&rootfs_futex);
@@ -226 +210 @@
                 rwlock_write_unlock(&namespace_rwlock);
         } else {
-                /*
-                 * We still don't have the root file system mounted.
-                 */
+                /* We still don't have the root file system mounted. */
                 if ((size == 1) && (buf[0] == '/')) {
-                        /*
-                         * For this simple, but important case, we are done.
-                         */
+                        /* For this simple, but important case, we are done. */
                         rootfs = mr_res.triplet;
                         futex_up(&rootfs_futex);
@@ -348 +328 @@
         rwlock_read_lock(&namespace_rwlock);
 
-        /*
-         * The path is now populated and we can call vfs_lookup_internal().
-         */
+        /* The path is now populated and we can call vfs_lookup_internal(). */
         vfs_lookup_res_t lr;
         rc = vfs_lookup_internal(path, len, lflag, &lr, NULL);
@@ -360 +338 @@
         }
 
-        /*
-         * Path is no longer needed.
-         */
+        /** Path is no longer needed. */
         free(path);
 
@@ -391 +367 @@
         vfs_node_put(node);
 
-        /*
-         * Success! Return the new file descriptor to the client.
-         */
+        /* Success! Return the new file descriptor to the client. */
         ipc_answer_1(rid, EOK, fd);
 }
@@ -412 +386 @@
         int fd = IPC_GET_ARG1(*request);
 
-        /*
-         * Lookup the file structure corresponding to the file descriptor.
-         */
+        /* Lookup the file structure corresponding to the file descriptor. */
         vfs_file_t *file = vfs_file_get(fd);
         if (!file) {
@@ -454 +426 @@
         int fs_phone = vfs_grab_phone(file->node->fs_handle);   
         
-        /*
-         * Make a VFS_READ/VFS_WRITE request at the destination FS server.
-         */
+        /* Make a VFS_READ/VFS_WRITE request at the destination FS server. */
         aid_t msg;
         ipc_call_t answer;
@@ -472 +442 @@
         vfs_release_phone(fs_phone);
 
-        /*
-         * Wait for reply from the FS server.
-         */
+        /* Wait for reply from the FS server. */
         ipcarg_t rc;
         async_wait_for(msg, &rc);
         size_t bytes = IPC_GET_ARG1(answer);
 
-        /*
-         * Unlock the VFS node.
-         */
+        /* Unlock the VFS node. */
         if (read)
                 rwlock_read_unlock(&file->node->contents_rwlock);
@@ -490 +456 @@
         }
 
-        /*
-         * Update the position pointer and unlock the open file.
-         */
+        /* Update the position pointer and unlock the open file. */
         file->pos += bytes;
         futex_up(&file->lock);
@@ -520 +484 @@
 
 
-        /*
-         * Lookup the file structure corresponding to the file descriptor.
-         */
+        /* Lookup the file structure corresponding to the file descriptor. */
         vfs_file_t *file = vfs_file_get(fd);
         if (!file) {
@@ -582 +544 @@
         rwlock_write_lock(&file->node->contents_rwlock);
         int fs_phone = vfs_grab_phone(file->node->fs_handle);
-        rc = async_req_3_0(fs_phone, VFS_TRUNCATE, (ipcarg_t)file->node->dev_handle,
-            (ipcarg_t)file->node->index, (ipcarg_t)size);
+        rc = async_req_3_0(fs_phone, VFS_TRUNCATE,
+            (ipcarg_t)file->node->dev_handle, (ipcarg_t)file->node->index,
+            (ipcarg_t)size);
         vfs_release_phone(fs_phone);
         if (rc == EOK)
@@ -593 +556 @@
 }
 
+void vfs_mkdir(ipc_callid_t rid, ipc_call_t *request)
+{
+        int mode = IPC_GET_ARG1(*request);
+        size_t len;
+
+        ipc_callid_t callid;
+
+        if (!ipc_data_write_receive(&callid, &len)) {
+                ipc_answer_0(callid, EINVAL);
+                ipc_answer_0(rid, EINVAL);
+                return;
+        }
+
+        /*
+         * Now we are on the verge of accepting the path.
+         *
+         * There is one optimization we could do in the future: copy the path
+         * directly into the PLB using some kind of a callback.
+         */
+        char *path = malloc(len);
+        
+        if (!path) {
+                ipc_answer_0(callid, ENOMEM);
+                ipc_answer_0(rid, ENOMEM);
+                return;
+        }
+
+        int rc;
+        if ((rc = ipc_data_write_finalize(callid, path, len))) {
+                ipc_answer_0(rid, rc);
+                free(path);
+                return;
+        }
+        
+        rwlock_write_lock(&namespace_rwlock);
+        int lflag = L_DIRECTORY | L_CREATE | L_EXCLUSIVE;
+        rc = vfs_lookup_internal(path, len, lflag, NULL, NULL);
+        rwlock_write_unlock(&namespace_rwlock);
+        free(path);
+        ipc_answer_0(rid, rc);
+}
+
 /**
  * @}