Changeset 41811af in mainline for uspace/lib/c/generic/loader.c

Timestamp:

2011-06-10T10:14:26Z (14 years ago)

Author:

Jiří Zárevúcky <zarevucky.jiri@…>

Branches:

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

Children:

ab547063

Parents:

9536e6e (diff), 390d80d (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge mainline

File:

• uspace/lib/c/generic/loader.c (modified) (13 diffs)

uspace/lib/c/generic/loader.c

@@ -35 +35 @@
 #include <ipc/loader.h>
 #include <ipc/services.h>
-#include <ipc/ns.h>
+#include <ns.h>
 #include <libc.h>
 #include <task.h>
@@ -44 +44 @@
 #include <vfs/vfs.h>
 #include <loader/loader.h>
+#include "private/loader.h"
 
 /** Connect to a new program loader.
@@ -63 +64 @@
 loader_t *loader_connect(void)
 {
-        int phone_id = service_connect_blocking(SERVICE_LOAD, 0, 0);
-        if (phone_id < 0)
-                return NULL;
-        
         loader_t *ldr = malloc(sizeof(loader_t));
         if (ldr == NULL)
                 return NULL;
         
-        ldr->phone_id = phone_id;
+        async_sess_t *sess =
+            service_connect_blocking(EXCHANGE_SERIALIZE, SERVICE_LOAD, 0, 0);
+        if (sess == NULL) {
+                free(ldr);
+                return NULL;
+        }
+        
+        ldr->sess = sess;
         return ldr;
 }
@@ -88 +92 @@
 {
         /* Get task ID. */
-        ipc_call_t answer;
-        aid_t req = async_send_0(ldr->phone_id, LOADER_GET_TASKID, &answer);
-        int rc = async_data_read_start(ldr->phone_id, task_id, sizeof(task_id_t));
-        if (rc != EOK) {
-                async_wait_for(req, NULL);
-                return rc;
-        }
-        
-        sysarg_t retval;
-        async_wait_for(req, &retval);
-        return (int) retval;
+        async_exch_t *exch = async_exchange_begin(ldr->sess);
+        
+        ipc_call_t answer;
+        aid_t req = async_send_0(exch, LOADER_GET_TASKID, &answer);
+        sysarg_t rc = async_data_read_start(exch, task_id, sizeof(task_id_t));
+        
+        async_exchange_end(exch);
+        
+        if (rc != EOK) {
+                async_wait_for(req, NULL);
+                return (int) rc;
+        }
+        
+        async_wait_for(req, &rc);
+        return (int) rc;
 }
 
@@ -112 +120 @@
 int loader_set_cwd(loader_t *ldr)
 {
-        char *cwd;
-        size_t len;
-
-        cwd = (char *) malloc(MAX_PATH_LEN + 1);
+        char *cwd = (char *) malloc(MAX_PATH_LEN + 1);
         if (!cwd)
                 return ENOMEM;
+        
         if (!getcwd(cwd, MAX_PATH_LEN + 1))
-                str_cpy(cwd, MAX_PATH_LEN + 1, "/"); 
-        len = str_length(cwd);
-        
-        ipc_call_t answer;
-        aid_t req = async_send_0(ldr->phone_id, LOADER_SET_CWD, &answer);
-        int rc = async_data_write_start(ldr->phone_id, cwd, len);
+                str_cpy(cwd, MAX_PATH_LEN + 1, "/");
+        
+        size_t len = str_length(cwd);
+        
+        async_exch_t *exch = async_exchange_begin(ldr->sess);
+        
+        ipc_call_t answer;
+        aid_t req = async_send_0(exch, LOADER_SET_CWD, &answer);
+        sysarg_t rc = async_data_write_start(exch, cwd, len);
+        
+        async_exchange_end(exch);
         free(cwd);
-        if (rc != EOK) {
-                async_wait_for(req, NULL);
-                return rc;
-        }
-        
-        sysarg_t retval;
-        async_wait_for(req, &retval);
-        return (int) retval;
+        
+        if (rc != EOK) {
+                async_wait_for(req, NULL);
+                return (int) rc;
+        }
+        
+        async_wait_for(req, &rc);
+        return (int) rc;
 }
 
@@ -153 +164 @@
         char *pa = absolutize(path, &pa_len);
         if (!pa)
-                return 0;
+                return ENOMEM;
         
         /* Send program pathname */
-        ipc_call_t answer;
-        aid_t req = async_send_0(ldr->phone_id, LOADER_SET_PATHNAME, &answer);
-        int rc = async_data_write_start(ldr->phone_id, (void *) pa, pa_len);
-        if (rc != EOK) {
-                free(pa);
-                async_wait_for(req, NULL);
-                return rc;
-        }
-        
+        async_exch_t *exch = async_exchange_begin(ldr->sess);
+        
+        ipc_call_t answer;
+        aid_t req = async_send_0(exch, LOADER_SET_PATHNAME, &answer);
+        sysarg_t rc = async_data_write_start(exch, (void *) pa, pa_len);
+        
+        async_exchange_end(exch);
         free(pa);
         
-        sysarg_t retval;
-        async_wait_for(req, &retval);
-        return (int) retval;
+        if (rc != EOK) {
+                async_wait_for(req, NULL);
+                return (int) rc;
+        }
+        
+        async_wait_for(req, &rc);
+        return (int) rc;
 }
 
@@ -212 +225 @@
         
         /* Send serialized arguments to the loader */
-        ipc_call_t answer;
-        aid_t req = async_send_0(ldr->phone_id, LOADER_SET_ARGS, &answer);
-        sysarg_t rc = async_data_write_start(ldr->phone_id, (void *) arg_buf, buffer_size);
-        if (rc != EOK) {
-                async_wait_for(req, NULL);
-                return rc;
-        }
-        
-        async_wait_for(req, &rc);
-        if (rc != EOK)
-                return rc;
-        
-        /* Free temporary buffer */
+        async_exch_t *exch = async_exchange_begin(ldr->sess);
+        
+        ipc_call_t answer;
+        aid_t req = async_send_0(exch, LOADER_SET_ARGS, &answer);
+        sysarg_t rc = async_data_write_start(exch, (void *) arg_buf,
+            buffer_size);
+        
+        async_exchange_end(exch);
         free(arg_buf);
         
-        return EOK;
+        if (rc != EOK) {
+                async_wait_for(req, NULL);
+                return (int) rc;
+        }
+        
+        async_wait_for(req, &rc);
+        return (int) rc;
 }
 
@@ -266 +280 @@
         
         /* Send serialized files to the loader */
-        ipc_call_t answer;
-        aid_t req = async_send_0(ldr->phone_id, LOADER_SET_FILES, &answer);
-        sysarg_t rc = async_data_write_start(ldr->phone_id, (void *) files_buf,
+        async_exch_t *exch = async_exchange_begin(ldr->sess);
+        
+        ipc_call_t answer;
+        aid_t req = async_send_0(exch, LOADER_SET_FILES, &answer);
+        sysarg_t rc = async_data_write_start(exch, (void *) files_buf,
             count * sizeof(fdi_node_t));
-        if (rc != EOK) {
-                async_wait_for(req, NULL);
-                return rc;
-        }
-        
-        async_wait_for(req, &rc);
-        if (rc != EOK)
-                return rc;
-        
-        /* Free temporary buffer */
+        
+        async_exchange_end(exch);
         free(files_buf);
         
-        return EOK;
+        if (rc != EOK) {
+                async_wait_for(req, NULL);
+                return (int) rc;
+        }
+        
+        async_wait_for(req, &rc);
+        return (int) rc;
 }
 
@@ -297 +311 @@
 int loader_load_program(loader_t *ldr)
 {
-        return (int) async_req_0_0(ldr->phone_id, LOADER_LOAD);
+        async_exch_t *exch = async_exchange_begin(ldr->sess);
+        int rc = async_req_0_0(exch, LOADER_LOAD);
+        async_exchange_end(exch);
+        
+        return rc;
 }
 
@@ -306 +324 @@
  * the task and its thread is stopped.
  *
- * After using this function, no further operations must be performed
- * on the loader structure. It should be de-allocated using free().
+ * After using this function, no further operations can be performed
+ * on the loader structure and it is deallocated.
  *
  * @param ldr Loader connection structure.
@@ -316 +334 @@
 int loader_run(loader_t *ldr)
 {
-        int rc = async_req_0_0(ldr->phone_id, LOADER_RUN);
+        async_exch_t *exch = async_exchange_begin(ldr->sess);
+        int rc = async_req_0_0(exch, LOADER_RUN);
+        async_exchange_end(exch);
+        
         if (rc != EOK)
                 return rc;
         
-        async_hangup(ldr->phone_id);
-        ldr->phone_id = 0;
+        async_hangup(ldr->sess);
+        free(ldr);
+        
         return EOK;
 }
@@ -327 +349 @@
 /** Cancel the loader session.
  *
- * Tells the loader not to load any program and terminate.
- * After using this function, no further operations must be performed
- * on the loader structure. It should be de-allocated using free().
+ * Tell the loader not to load any program and terminate.
+ * After using this function, no further operations can be performed
+ * on the loader structure and it is deallocated.
  *
  * @param ldr Loader connection structure.
@@ -338 +360 @@
 void loader_abort(loader_t *ldr)
 {
-        async_hangup(ldr->phone_id);
-        ldr->phone_id = 0;
+        async_hangup(ldr->sess);
+        free(ldr);
 }