Changes in uspace/srv/volsrv/volsrv.c [1433ecda:1a9174e] in mainline

File:

• uspace/srv/volsrv/volsrv.c (modified) (11 diffs)

uspace/srv/volsrv/volsrv.c

@@ -144 +144 @@
         log_msg(LOG_DEFAULT, LVL_DEBUG, "vol_part_info_srv(%zu)",
             sid);
-        rc = vol_part_find_by_id(sid, &part);
+        rc = vol_part_find_by_id_ref(sid, &part);
         if (rc != EOK) {
                 async_answer_0(icall_handle, ENOENT);
@@ -153 +153 @@
         if (rc != EOK) {
                 async_answer_0(icall_handle, EIO);
-                return;
+                goto error;
         }
 
@@ -161 +161 @@
                 async_answer_0(chandle, EREFUSED);
                 async_answer_0(icall_handle, EREFUSED);
-                return;
+                goto error;
         }
 
@@ -167 +167 @@
                 async_answer_0(chandle, EINVAL);
                 async_answer_0(icall_handle, EINVAL);
-                return;
+                goto error;
         }
 
@@ -175 +175 @@
                 async_answer_0(chandle, rc);
                 async_answer_0(icall_handle, rc);
-                return;
-        }
-
-        async_answer_0(icall_handle, EOK);
+                goto error;
+        }
+
+        async_answer_0(icall_handle, EOK);
+error:
+        vol_part_del_ref(part);
+}
+
+static void vol_part_eject_srv(cap_call_handle_t icall_handle, ipc_call_t *icall)
+{
+        service_id_t sid;
+        vol_part_t *part;
+        errno_t rc;
+
+        sid = IPC_GET_ARG1(*icall);
+        log_msg(LOG_DEFAULT, LVL_DEBUG, "vol_part_eject_srv(%zu)", sid);
+
+        rc = vol_part_find_by_id_ref(sid, &part);
+        if (rc != EOK) {
+                async_answer_0(icall_handle, ENOENT);
+                goto error;
+        }
+
+        rc = vol_part_eject_part(part);
+        if (rc != EOK) {
+                async_answer_0(icall_handle, EIO);
+                goto error;
+        }
+
+        async_answer_0(icall_handle, EOK);
+error:
+        vol_part_del_ref(part);
 }
 
@@ -190 +218 @@
         log_msg(LOG_DEFAULT, LVL_DEBUG, "vol_part_empty_srv(%zu)", sid);
 
-        rc = vol_part_find_by_id(sid, &part);
+        rc = vol_part_find_by_id_ref(sid, &part);
         if (rc != EOK) {
                 async_answer_0(icall_handle, ENOENT);
@@ -199 +227 @@
         if (rc != EOK) {
                 async_answer_0(icall_handle, EIO);
-                return;
-        }
-
-        async_answer_0(icall_handle, EOK);
+                goto error;
+        }
+
+        async_answer_0(icall_handle, EOK);
+error:
+        vol_part_del_ref(part);
 }
 
@@ -251 +281 @@
         errno_t rc;
 
+        log_msg(LOG_DEFAULT, LVL_NOTE, "vol_part_mkfs_srv()");
+
         sid = IPC_GET_ARG1(*icall);
         fstype = IPC_GET_ARG2(*icall);
@@ -261 +293 @@
         }
 
-        printf("vol_part_mkfs_srv: label=%p\n", label);
-        if (label != NULL)
-                printf("vol_part_mkfs_srv: label='%s'\n", label);
-
-        rc = vol_part_find_by_id(sid, &part);
+        if (label != NULL) {
+                log_msg(LOG_DEFAULT, LVL_NOTE, "vol_part_mkfs_srv: label='%s'",
+                    label);
+        }
+
+        rc = vol_part_find_by_id_ref(sid, &part);
         if (rc != EOK) {
                 free(label);
@@ -276 +309 @@
                 free(label);
                 async_answer_0(icall_handle, rc);
+                vol_part_del_ref(part);
                 return;
         }
@@ -311 +345 @@
                         vol_part_info_srv(chandle, &call);
                         break;
+                case VOL_PART_EJECT:
+                        vol_part_eject_srv(chandle, &call);
+                        break;
                 case VOL_PART_EMPTY:
                         vol_part_empty_srv(chandle, &call);