Subversion Repositories HelenOS

Rev

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

Rev 3425 Rev 3471
Line 32... Line 32...
32 
 */
 32 
 */
33 
/** @file
 33 
/** @file
34 
 */
 34 
 */
35 
 
 35 
 
36 
#include <task.h>
 36 
#include <task.h>
37 
#include <ipc/ipc.h>
 - 
 
38 
#include <ipc/loader.h>
 - 
 
39 
#include <libc.h>
 37 
#include <libc.h>
40 
#include <string.h>
 - 
 
41 
#include <stdlib.h>
 38 
#include <stdlib.h>
42 
#include <async.h>
 - 
 
43 
#include <errno.h>
 39 
#include <errno.h>
44 
#include <vfs/vfs.h>
 40 
#include <loader/loader.h>
45 
 
 41 
 
46 
task_id_t task_get_id(void)
 42 
task_id_t task_get_id(void)
47 
{
 43 
{
48 
    task_id_t task_id;
 44 
    task_id_t task_id;
49 
 
 45 
 
50 
    (void) __SYSCALL1(SYS_TASK_GET_ID, (sysarg_t) &task_id);
 46 
    (void) __SYSCALL1(SYS_TASK_GET_ID, (sysarg_t) &task_id);
51 
 
 47 
 
52 
    return task_id;
 48 
    return task_id;
53 
}
 49 
}
54 
 
 50 
 
55 
static int task_spawn_loader(void)
 - 
 
56 
{
 - 
 
57 
    int phone_id, rc;
 - 
 
58 
 
 - 
 
59 
    rc = __SYSCALL1(SYS_PROGRAM_SPAWN_LOADER, (sysarg_t) &phone_id);
 - 
 
60 
    if (rc != 0)
 - 
 
61 
        return rc;
 - 
 
62 
 
 - 
 
63 
    return phone_id;
 - 
 
64 
}
 - 
 
65 
 
 - 
 
66 
static int loader_set_args(int phone_id, const char *argv[])
 - 
 
67 
{
 - 
 
68 
    aid_t req;
 - 
 
69 
    ipc_call_t answer;
 - 
 
70 
    ipcarg_t rc;
 - 
 
71 
 
 - 
 
72 
    const char **ap;
 - 
 
73 
    char *dp;
 - 
 
74 
    char *arg_buf;
 - 
 
75 
    size_t buffer_size;
 - 
 
76 
    size_t len;
 - 
 
77 
 
 - 
 
78 
    /*
 - 
 
79 
     * Serialize the arguments into a single array. First
 51 
/** Create a new task by running an executable from the filesystem.
80 
     * compute size of the buffer needed.
 - 
 
81 
     */
 52 
 *
82 
    ap = argv;
 - 
 
83 
    buffer_size = 0;
 - 
 
84 
    while (*ap != NULL) {
 - 
 
85 
        buffer_size += strlen(*ap) + 1;
 - 
 
86 
        ++ap;
 - 
 
87 
    }
 - 
 
88 
 
 - 
 
89 
    arg_buf = malloc(buffer_size);
 - 
 
90 
    if (arg_buf == NULL) return ENOMEM;
 - 
 
91 
 
 - 
 
92 
    /* Now fill the buffer with null-terminated argument strings */
 53 
 * This is really just a convenience wrapper over the more complicated
93 
    ap = argv;
 - 
 
94 
    dp = arg_buf;
 54 
 * loader API.
95 
    while (*ap != NULL) {
 - 
 
96 
        strcpy(dp, *ap);
 - 
 
97 
        dp += strlen(*ap) + 1;
 - 
 
98 
 
 - 
 
99 
        ++ap;
 - 
 
100 
    }
 - 
 
101 
 
 - 
 
102 
    /* Send serialized arguments to the loader */
 - 
 
103 
 
 - 
 
104 
    req = async_send_0(phone_id, LOADER_SET_ARGS, &answer);
 - 
 
105 
    rc = ipc_data_write_start(phone_id, (void *)arg_buf, buffer_size);
 - 
 
106 
    if (rc != EOK) {
 - 
 
107 
        async_wait_for(req, NULL);
 - 
 
108 
        return rc;
 - 
 
109 
    }
 - 
 
110 
 
 - 
 
111 
    async_wait_for(req, &rc);
 - 
 
112 
    if (rc != EOK) return rc;
 - 
 
113 
 
 - 
 
114 
    /* Free temporary buffer */
 - 
 
115 
    free(arg_buf);
 - 
 
116 
 
 - 
 
117 
    return EOK;
 - 
 
118 
}
 - 
 
119 
 
 - 
 
120 
/** Create a new task by running an executable from VFS.
 - 
 
121 
 *
 55 
 *
122 
 * @param path  pathname of the binary to execute
 56 
 * @param path  pathname of the binary to execute
123 
 * @param argv  command-line arguments
 57 
 * @param argv  command-line arguments
124 
 * @return  ID of the newly created task or zero on error.
 58 
 * @return  ID of the newly created task or zero on error.
125 
 */
 59 
 */
126 
task_id_t task_spawn(const char *path, const char *argv[])
 60 
task_id_t task_spawn(const char *path, char *const argv[])
127 
{
 61 
{
128 
    int phone_id;
 - 
 
129 
    ipc_call_t answer;
 62 
    loader_t *ldr;
130 
    aid_t req;
 63 
    task_id_t task_id;
131 
    int rc;
 64 
    int rc;
132 
    ipcarg_t retval;
 - 
 
133 
 
 - 
 
134 
    char *pa;
 - 
 
135 
    size_t pa_len;
 - 
 
136 
 
 - 
 
137 
    pa = absolutize(path, &pa_len);
 - 
 
138 
    if (!pa)
 - 
 
139 
        return 0;
 - 
 
140 
 
 65 
 
141 
    /* Spawn a program loader */   
 66 
    /* Spawn a program loader. */  
142 
    phone_id = task_spawn_loader();
 67 
    ldr = loader_spawn();
143 
    if (phone_id < 0)
 68 
    if (ldr == NULL)
144 
        return 0;
 69 
        return 0;
145 
 
 70 
 
146 
    /*
 - 
 
147 
     * Say hello so that the loader knows the incoming connection's
 - 
 
148 
     * phone hash.
 71 
    /* Get task ID. */
149 
     */
 - 
 
150 
    rc = async_req_0_0(phone_id, LOADER_HELLO);
 72 
    rc = loader_get_task_id(ldr, &task_id);
151 
    if (rc != EOK)
 73 
    if (rc != EOK)
152 
        return 0;
 74 
        goto error;
153 
 
 75 
 
154 
    /* Send program pathname */
 76 
    /* Send program pathname. */
155 
    req = async_send_0(phone_id, LOADER_SET_PATHNAME, &answer);
 - 
 
156 
    rc = ipc_data_write_start(phone_id, (void *)pa, pa_len);
 77 
    rc = loader_set_pathname(ldr, path);
157 
    if (rc != EOK) {
 78 
    if (rc != EOK)
158 
        async_wait_for(req, NULL);
 - 
 
159 
        return 1;
 79 
        goto error;
160 
    }
 - 
 
161 
 
 80 
 
- 
 
 81 
    /* Send arguments. */
162 
    async_wait_for(req, &retval);
 82 
    rc = loader_set_args(ldr, argv);
163 
    if (retval != EOK)
 83 
    if (rc != EOK)
164 
        goto error;
 84 
        goto error;
165 
 
 85 
 
166 
    /* Send arguments */
 86 
    /* Load the program. */
167 
    rc = loader_set_args(phone_id, argv);
 87 
    rc = loader_load_program(ldr);
168 
    if (rc != EOK)
 88 
    if (rc != EOK)
169 
        goto error;
 89 
        goto error;
170 
 
 90 
 
- 
 
 91 
    /* Run it. */
171 
    /* Request loader to start the program */  
 92 
    /* Load the program. */
172 
    rc = async_req_0_0(phone_id, LOADER_RUN);
 93 
    rc = loader_run(ldr);
173 
    if (rc != EOK)
 94 
    if (rc != EOK)
174 
        goto error;
 95 
        goto error;
175 
 
 96 
 
176 
    /* Success */
 97 
    /* Success */
- 
 
 98 
 
177 
    ipc_hangup(phone_id);
 99 
    free(ldr);
178 
    return 1;
 100 
    return task_id;
179 
 
 101 
 
180 
    /* Error exit */
 102 
    /* Error exit */
181 
error:
 103 
error:
182 
    ipc_hangup(phone_id);
 104 
    loader_abort(ldr);
- 
 
 105 
    free(ldr);
- 
 
 106 
 
183 
    return 0;
 107 
    return 0;
184 
}
 108 
}
185 
 
 109 
 
186 
/** @}
 110 
/** @}
187 
 */
 111 
 */