Rev 4668 | Details | Compare with Previous | Last modification | View Log | RSS feed
Rev | Author | Line No. | Line |
---|---|---|---|
2671 | jermar | 1 | /* |
2684 | jermar | 2 | * Copyright (c) 2008 Jakub Jermar |
2671 | jermar | 3 | * All rights reserved. |
4 | * |
||
5 | * Redistribution and use in source and binary forms, with or without |
||
6 | * modification, are permitted provided that the following conditions |
||
7 | * are met: |
||
8 | * |
||
9 | * - Redistributions of source code must retain the above copyright |
||
10 | * notice, this list of conditions and the following disclaimer. |
||
11 | * - Redistributions in binary form must reproduce the above copyright |
||
12 | * notice, this list of conditions and the following disclaimer in the |
||
13 | * documentation and/or other materials provided with the distribution. |
||
14 | * - The name of the author may not be used to endorse or promote products |
||
15 | * derived from this software without specific prior written permission. |
||
16 | * |
||
17 | * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR |
||
18 | * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |
||
19 | * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
||
20 | * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, |
||
21 | * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT |
||
22 | * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||
23 | * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||
24 | * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||
25 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF |
||
26 | * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||
27 | */ |
||
28 | |||
29 | /** @addtogroup libc |
||
30 | * @{ |
||
31 | */ |
||
32 | /** @file |
||
33 | */ |
||
4055 | trochtova | 34 | |
2755 | jermar | 35 | #include <vfs/vfs.h> |
36 | #include <vfs/canonify.h> |
||
2694 | jermar | 37 | #include <stdlib.h> |
2674 | jermar | 38 | #include <unistd.h> |
2694 | jermar | 39 | #include <dirent.h> |
2674 | jermar | 40 | #include <fcntl.h> |
4668 | trochtova | 41 | #include <stdio.h> |
2707 | jermar | 42 | #include <sys/stat.h> |
43 | #include <sys/types.h> |
||
2671 | jermar | 44 | #include <ipc/ipc.h> |
45 | #include <ipc/services.h> |
||
46 | #include <async.h> |
||
47 | #include <atomic.h> |
||
48 | #include <futex.h> |
||
49 | #include <errno.h> |
||
50 | #include <string.h> |
||
4420 | trochtova | 51 | #include <devmap.h> |
4537 | trochtova | 52 | #include <ipc/vfs.h> |
53 | #include <ipc/devmap.h> |
||
2671 | jermar | 54 | |
4537 | trochtova | 55 | static int vfs_phone = -1; |
56 | static futex_t vfs_phone_futex = FUTEX_INITIALIZER; |
||
57 | static futex_t cwd_futex = FUTEX_INITIALIZER; |
||
2671 | jermar | 58 | |
2755 | jermar | 59 | DIR *cwd_dir = NULL; |
60 | char *cwd_path = NULL; |
||
4296 | trochtova | 61 | size_t cwd_size = 0; |
2755 | jermar | 62 | |
4055 | trochtova | 63 | char *absolutize(const char *path, size_t *retlen) |
2755 | jermar | 64 | { |
65 | char *ncwd_path; |
||
4055 | trochtova | 66 | char *ncwd_path_nc; |
2755 | jermar | 67 | |
68 | futex_down(&cwd_futex); |
||
4296 | trochtova | 69 | size_t size = str_size(path); |
2755 | jermar | 70 | if (*path != '/') { |
71 | if (!cwd_path) { |
||
72 | futex_up(&cwd_futex); |
||
73 | return NULL; |
||
74 | } |
||
4296 | trochtova | 75 | ncwd_path_nc = malloc(cwd_size + 1 + size + 1); |
4055 | trochtova | 76 | if (!ncwd_path_nc) { |
2755 | jermar | 77 | futex_up(&cwd_futex); |
78 | return NULL; |
||
79 | } |
||
4296 | trochtova | 80 | str_cpy(ncwd_path_nc, cwd_size + 1 + size + 1, cwd_path); |
81 | ncwd_path_nc[cwd_size] = '/'; |
||
82 | ncwd_path_nc[cwd_size + 1] = '\0'; |
||
2755 | jermar | 83 | } else { |
4296 | trochtova | 84 | ncwd_path_nc = malloc(size + 1); |
4055 | trochtova | 85 | if (!ncwd_path_nc) { |
2755 | jermar | 86 | futex_up(&cwd_futex); |
87 | return NULL; |
||
88 | } |
||
4055 | trochtova | 89 | ncwd_path_nc[0] = '\0'; |
2755 | jermar | 90 | } |
4296 | trochtova | 91 | str_append(ncwd_path_nc, cwd_size + 1 + size + 1, path); |
4055 | trochtova | 92 | ncwd_path = canonify(ncwd_path_nc, retlen); |
93 | if (!ncwd_path) { |
||
2771 | jermar | 94 | futex_up(&cwd_futex); |
4055 | trochtova | 95 | free(ncwd_path_nc); |
2771 | jermar | 96 | return NULL; |
97 | } |
||
4055 | trochtova | 98 | /* |
99 | * We need to clone ncwd_path because canonify() works in-place and thus |
||
100 | * the address in ncwd_path need not be the same as ncwd_path_nc, even |
||
101 | * though they both point into the same dynamically allocated buffer. |
||
102 | */ |
||
4296 | trochtova | 103 | ncwd_path = str_dup(ncwd_path); |
4055 | trochtova | 104 | free(ncwd_path_nc); |
105 | if (!ncwd_path) { |
||
106 | futex_up(&cwd_futex); |
||
107 | return NULL; |
||
108 | } |
||
2755 | jermar | 109 | futex_up(&cwd_futex); |
110 | return ncwd_path; |
||
111 | } |
||
112 | |||
4055 | trochtova | 113 | static void vfs_connect(void) |
2671 | jermar | 114 | { |
4055 | trochtova | 115 | while (vfs_phone < 0) |
116 | vfs_phone = ipc_connect_me_to_blocking(PHONE_NS, SERVICE_VFS, 0, 0); |
||
2671 | jermar | 117 | } |
118 | |||
4055 | trochtova | 119 | int mount(const char *fs_name, const char *mp, const char *dev, |
4420 | trochtova | 120 | const char *opts, unsigned int flags) |
4055 | trochtova | 121 | { |
2671 | jermar | 122 | int res; |
123 | ipcarg_t rc; |
||
124 | aid_t req; |
||
4055 | trochtova | 125 | dev_handle_t dev_handle; |
126 | |||
4420 | trochtova | 127 | res = devmap_device_get_handle(dev, &dev_handle, flags); |
4055 | trochtova | 128 | if (res != EOK) |
129 | return res; |
||
130 | |||
4296 | trochtova | 131 | size_t mpa_size; |
132 | char *mpa = absolutize(mp, &mpa_size); |
||
2755 | jermar | 133 | if (!mpa) |
134 | return ENOMEM; |
||
4055 | trochtova | 135 | |
2671 | jermar | 136 | futex_down(&vfs_phone_futex); |
137 | async_serialize_start(); |
||
4055 | trochtova | 138 | vfs_connect(); |
139 | |||
4668 | trochtova | 140 | req = async_send_2(vfs_phone, VFS_IN_MOUNT, dev_handle, flags, NULL); |
4296 | trochtova | 141 | rc = ipc_data_write_start(vfs_phone, (void *) mpa, mpa_size); |
2671 | jermar | 142 | if (rc != EOK) { |
143 | async_wait_for(req, NULL); |
||
144 | async_serialize_end(); |
||
145 | futex_up(&vfs_phone_futex); |
||
2755 | jermar | 146 | free(mpa); |
2671 | jermar | 147 | return (int) rc; |
148 | } |
||
4055 | trochtova | 149 | |
4420 | trochtova | 150 | rc = ipc_data_write_start(vfs_phone, (void *) opts, str_size(opts)); |
151 | if (rc != EOK) { |
||
152 | async_wait_for(req, NULL); |
||
153 | async_serialize_end(); |
||
154 | futex_up(&vfs_phone_futex); |
||
155 | free(mpa); |
||
156 | return (int) rc; |
||
157 | } |
||
158 | |||
4296 | trochtova | 159 | rc = ipc_data_write_start(vfs_phone, (void *) fs_name, str_size(fs_name)); |
2671 | jermar | 160 | if (rc != EOK) { |
161 | async_wait_for(req, NULL); |
||
162 | async_serialize_end(); |
||
163 | futex_up(&vfs_phone_futex); |
||
2755 | jermar | 164 | free(mpa); |
2671 | jermar | 165 | return (int) rc; |
166 | } |
||
4420 | trochtova | 167 | |
168 | /* Ask VFS whether it likes fs_name. */ |
||
169 | rc = async_req_0_0(vfs_phone, IPC_M_PING); |
||
170 | if (rc != EOK) { |
||
171 | async_wait_for(req, NULL); |
||
172 | async_serialize_end(); |
||
173 | futex_up(&vfs_phone_futex); |
||
174 | free(mpa); |
||
175 | return (int) rc; |
||
176 | } |
||
4055 | trochtova | 177 | |
2671 | jermar | 178 | async_wait_for(req, &rc); |
179 | async_serialize_end(); |
||
180 | futex_up(&vfs_phone_futex); |
||
2755 | jermar | 181 | free(mpa); |
4055 | trochtova | 182 | |
2671 | jermar | 183 | return (int) rc; |
184 | } |
||
185 | |||
2700 | jermar | 186 | static int _open(const char *path, int lflag, int oflag, ...) |
2671 | jermar | 187 | { |
188 | ipcarg_t rc; |
||
189 | ipc_call_t answer; |
||
190 | aid_t req; |
||
191 | |||
4296 | trochtova | 192 | size_t pa_size; |
193 | char *pa = absolutize(path, &pa_size); |
||
2755 | jermar | 194 | if (!pa) |
195 | return ENOMEM; |
||
196 | |||
2671 | jermar | 197 | futex_down(&vfs_phone_futex); |
198 | async_serialize_start(); |
||
4055 | trochtova | 199 | vfs_connect(); |
200 | |||
4668 | trochtova | 201 | req = async_send_3(vfs_phone, VFS_IN_OPEN, lflag, oflag, 0, &answer); |
4296 | trochtova | 202 | rc = ipc_data_write_start(vfs_phone, pa, pa_size); |
2671 | jermar | 203 | if (rc != EOK) { |
204 | async_wait_for(req, NULL); |
||
205 | async_serialize_end(); |
||
206 | futex_up(&vfs_phone_futex); |
||
2755 | jermar | 207 | free(pa); |
2671 | jermar | 208 | return (int) rc; |
209 | } |
||
210 | async_wait_for(req, &rc); |
||
211 | async_serialize_end(); |
||
212 | futex_up(&vfs_phone_futex); |
||
2755 | jermar | 213 | free(pa); |
4537 | trochtova | 214 | |
4055 | trochtova | 215 | if (rc != EOK) |
216 | return (int) rc; |
||
4537 | trochtova | 217 | |
2671 | jermar | 218 | return (int) IPC_GET_ARG1(answer); |
219 | } |
||
220 | |||
2700 | jermar | 221 | int open(const char *path, int oflag, ...) |
222 | { |
||
223 | return _open(path, L_FILE, oflag); |
||
224 | } |
||
225 | |||
4537 | trochtova | 226 | int open_node(fdi_node_t *node, int oflag) |
227 | { |
||
228 | futex_down(&vfs_phone_futex); |
||
229 | async_serialize_start(); |
||
230 | vfs_connect(); |
||
231 | |||
232 | ipc_call_t answer; |
||
4668 | trochtova | 233 | aid_t req = async_send_4(vfs_phone, VFS_IN_OPEN_NODE, node->fs_handle, |
4537 | trochtova | 234 | node->dev_handle, node->index, oflag, &answer); |
235 | |||
236 | ipcarg_t rc; |
||
237 | async_wait_for(req, &rc); |
||
238 | async_serialize_end(); |
||
239 | futex_up(&vfs_phone_futex); |
||
240 | |||
241 | if (rc != EOK) |
||
242 | return (int) rc; |
||
243 | |||
244 | return (int) IPC_GET_ARG1(answer); |
||
245 | } |
||
246 | |||
2707 | jermar | 247 | int close(int fildes) |
248 | { |
||
2734 | jermar | 249 | ipcarg_t rc; |
4055 | trochtova | 250 | |
2734 | jermar | 251 | futex_down(&vfs_phone_futex); |
252 | async_serialize_start(); |
||
4055 | trochtova | 253 | vfs_connect(); |
254 | |||
4668 | trochtova | 255 | rc = async_req_1_0(vfs_phone, VFS_IN_CLOSE, fildes); |
4055 | trochtova | 256 | |
2734 | jermar | 257 | async_serialize_end(); |
258 | futex_up(&vfs_phone_futex); |
||
259 | |||
260 | return (int)rc; |
||
2707 | jermar | 261 | } |
262 | |||
2671 | jermar | 263 | ssize_t read(int fildes, void *buf, size_t nbyte) |
264 | { |
||
265 | ipcarg_t rc; |
||
266 | ipc_call_t answer; |
||
267 | aid_t req; |
||
268 | |||
269 | futex_down(&vfs_phone_futex); |
||
270 | async_serialize_start(); |
||
4055 | trochtova | 271 | vfs_connect(); |
272 | |||
4668 | trochtova | 273 | req = async_send_1(vfs_phone, VFS_IN_READ, fildes, &answer); |
2741 | jermar | 274 | rc = ipc_data_read_start(vfs_phone, (void *)buf, nbyte); |
275 | if (rc != EOK) { |
||
2671 | jermar | 276 | async_wait_for(req, NULL); |
277 | async_serialize_end(); |
||
278 | futex_up(&vfs_phone_futex); |
||
279 | return (ssize_t) rc; |
||
280 | } |
||
281 | async_wait_for(req, &rc); |
||
282 | async_serialize_end(); |
||
283 | futex_up(&vfs_phone_futex); |
||
2710 | jermar | 284 | if (rc == EOK) |
285 | return (ssize_t) IPC_GET_ARG1(answer); |
||
286 | else |
||
4055 | trochtova | 287 | return rc; |
2671 | jermar | 288 | } |
289 | |||
2674 | jermar | 290 | ssize_t write(int fildes, const void *buf, size_t nbyte) |
291 | { |
||
292 | ipcarg_t rc; |
||
293 | ipc_call_t answer; |
||
294 | aid_t req; |
||
295 | |||
296 | futex_down(&vfs_phone_futex); |
||
297 | async_serialize_start(); |
||
4055 | trochtova | 298 | vfs_connect(); |
299 | |||
4668 | trochtova | 300 | req = async_send_1(vfs_phone, VFS_IN_WRITE, fildes, &answer); |
2741 | jermar | 301 | rc = ipc_data_write_start(vfs_phone, (void *)buf, nbyte); |
302 | if (rc != EOK) { |
||
2674 | jermar | 303 | async_wait_for(req, NULL); |
304 | async_serialize_end(); |
||
305 | futex_up(&vfs_phone_futex); |
||
306 | return (ssize_t) rc; |
||
307 | } |
||
308 | async_wait_for(req, &rc); |
||
309 | async_serialize_end(); |
||
310 | futex_up(&vfs_phone_futex); |
||
2710 | jermar | 311 | if (rc == EOK) |
312 | return (ssize_t) IPC_GET_ARG1(answer); |
||
313 | else |
||
314 | return -1; |
||
2674 | jermar | 315 | } |
2684 | jermar | 316 | |
4668 | trochtova | 317 | int fsync(int fildes) |
4537 | trochtova | 318 | { |
319 | futex_down(&vfs_phone_futex); |
||
320 | async_serialize_start(); |
||
321 | vfs_connect(); |
||
322 | |||
4668 | trochtova | 323 | ipcarg_t rc = async_req_1_0(vfs_phone, VFS_IN_SYNC, fildes); |
4537 | trochtova | 324 | |
325 | async_serialize_end(); |
||
326 | futex_up(&vfs_phone_futex); |
||
327 | |||
4668 | trochtova | 328 | return (int) rc; |
4537 | trochtova | 329 | } |
330 | |||
4668 | trochtova | 331 | off_t lseek(int fildes, off_t offset, int whence) |
4537 | trochtova | 332 | { |
4668 | trochtova | 333 | ipcarg_t rc; |
334 | |||
4537 | trochtova | 335 | futex_down(&vfs_phone_futex); |
336 | async_serialize_start(); |
||
337 | vfs_connect(); |
||
338 | |||
4668 | trochtova | 339 | ipcarg_t newoffs; |
340 | rc = async_req_3_1(vfs_phone, VFS_IN_SEEK, fildes, offset, whence, |
||
341 | &newoffs); |
||
342 | |||
4537 | trochtova | 343 | async_serialize_end(); |
344 | futex_up(&vfs_phone_futex); |
||
4668 | trochtova | 345 | |
346 | if (rc != EOK) |
||
347 | return (off_t) -1; |
||
4537 | trochtova | 348 | |
4668 | trochtova | 349 | return (off_t) newoffs; |
4537 | trochtova | 350 | } |
351 | |||
4668 | trochtova | 352 | int ftruncate(int fildes, off_t length) |
4537 | trochtova | 353 | { |
4668 | trochtova | 354 | ipcarg_t rc; |
355 | |||
4537 | trochtova | 356 | futex_down(&vfs_phone_futex); |
357 | async_serialize_start(); |
||
358 | vfs_connect(); |
||
359 | |||
4668 | trochtova | 360 | rc = async_req_2_0(vfs_phone, VFS_IN_TRUNCATE, fildes, length); |
4537 | trochtova | 361 | async_serialize_end(); |
362 | futex_up(&vfs_phone_futex); |
||
363 | return (int) rc; |
||
364 | } |
||
365 | |||
4668 | trochtova | 366 | int fstat(int fildes, struct stat *stat) |
2684 | jermar | 367 | { |
368 | ipcarg_t rc; |
||
4668 | trochtova | 369 | aid_t req; |
2684 | jermar | 370 | |
371 | futex_down(&vfs_phone_futex); |
||
372 | async_serialize_start(); |
||
4055 | trochtova | 373 | vfs_connect(); |
374 | |||
4668 | trochtova | 375 | req = async_send_1(vfs_phone, VFS_IN_FSTAT, fildes, NULL); |
376 | rc = ipc_data_read_start(vfs_phone, (void *)stat, sizeof(struct stat)); |
||
377 | if (rc != EOK) { |
||
378 | async_wait_for(req, NULL); |
||
379 | async_serialize_end(); |
||
380 | futex_up(&vfs_phone_futex); |
||
381 | return (ssize_t) rc; |
||
382 | } |
||
383 | async_wait_for(req, &rc); |
||
2684 | jermar | 384 | async_serialize_end(); |
385 | futex_up(&vfs_phone_futex); |
||
386 | |||
4668 | trochtova | 387 | return rc; |
2684 | jermar | 388 | } |
389 | |||
4668 | trochtova | 390 | int stat(const char *path, struct stat *stat) |
2693 | jermar | 391 | { |
392 | ipcarg_t rc; |
||
4668 | trochtova | 393 | aid_t req; |
2693 | jermar | 394 | |
4668 | trochtova | 395 | size_t pa_size; |
396 | char *pa = absolutize(path, &pa_size); |
||
397 | if (!pa) |
||
398 | return ENOMEM; |
||
399 | |||
2693 | jermar | 400 | futex_down(&vfs_phone_futex); |
401 | async_serialize_start(); |
||
4055 | trochtova | 402 | vfs_connect(); |
403 | |||
4668 | trochtova | 404 | req = async_send_0(vfs_phone, VFS_IN_STAT, NULL); |
405 | rc = ipc_data_write_start(vfs_phone, pa, pa_size); |
||
406 | if (rc != EOK) { |
||
407 | async_wait_for(req, NULL); |
||
408 | async_serialize_end(); |
||
409 | futex_up(&vfs_phone_futex); |
||
410 | free(pa); |
||
411 | return (int) rc; |
||
412 | } |
||
413 | rc = ipc_data_read_start(vfs_phone, stat, sizeof(struct stat)); |
||
414 | if (rc != EOK) { |
||
415 | async_wait_for(req, NULL); |
||
416 | async_serialize_end(); |
||
417 | futex_up(&vfs_phone_futex); |
||
418 | free(pa); |
||
419 | return (int) rc; |
||
420 | } |
||
421 | async_wait_for(req, &rc); |
||
2693 | jermar | 422 | async_serialize_end(); |
423 | futex_up(&vfs_phone_futex); |
||
4668 | trochtova | 424 | free(pa); |
425 | return rc; |
||
2693 | jermar | 426 | } |
427 | |||
2694 | jermar | 428 | DIR *opendir(const char *dirname) |
429 | { |
||
430 | DIR *dirp = malloc(sizeof(DIR)); |
||
431 | if (!dirp) |
||
432 | return NULL; |
||
2700 | jermar | 433 | dirp->fd = _open(dirname, L_DIRECTORY, 0); |
2699 | jermar | 434 | if (dirp->fd < 0) { |
2694 | jermar | 435 | free(dirp); |
436 | return NULL; |
||
437 | } |
||
438 | return dirp; |
||
439 | } |
||
440 | |||
441 | struct dirent *readdir(DIR *dirp) |
||
442 | { |
||
2699 | jermar | 443 | ssize_t len = read(dirp->fd, &dirp->res.d_name[0], NAME_MAX + 1); |
444 | if (len <= 0) |
||
445 | return NULL; |
||
446 | return &dirp->res; |
||
2694 | jermar | 447 | } |
448 | |||
449 | void rewinddir(DIR *dirp) |
||
450 | { |
||
2699 | jermar | 451 | (void) lseek(dirp->fd, 0, SEEK_SET); |
2694 | jermar | 452 | } |
453 | |||
454 | int closedir(DIR *dirp) |
||
455 | { |
||
456 | (void) close(dirp->fd); |
||
457 | free(dirp); |
||
458 | return 0; |
||
459 | } |
||
460 | |||
2707 | jermar | 461 | int mkdir(const char *path, mode_t mode) |
2694 | jermar | 462 | { |
2707 | jermar | 463 | ipcarg_t rc; |
464 | aid_t req; |
||
465 | |||
4296 | trochtova | 466 | size_t pa_size; |
467 | char *pa = absolutize(path, &pa_size); |
||
2755 | jermar | 468 | if (!pa) |
469 | return ENOMEM; |
||
4055 | trochtova | 470 | |
2707 | jermar | 471 | futex_down(&vfs_phone_futex); |
472 | async_serialize_start(); |
||
4055 | trochtova | 473 | vfs_connect(); |
474 | |||
4668 | trochtova | 475 | req = async_send_1(vfs_phone, VFS_IN_MKDIR, mode, NULL); |
4296 | trochtova | 476 | rc = ipc_data_write_start(vfs_phone, pa, pa_size); |
2707 | jermar | 477 | if (rc != EOK) { |
478 | async_wait_for(req, NULL); |
||
479 | async_serialize_end(); |
||
480 | futex_up(&vfs_phone_futex); |
||
2755 | jermar | 481 | free(pa); |
2707 | jermar | 482 | return (int) rc; |
483 | } |
||
484 | async_wait_for(req, &rc); |
||
485 | async_serialize_end(); |
||
486 | futex_up(&vfs_phone_futex); |
||
2755 | jermar | 487 | free(pa); |
4537 | trochtova | 488 | return rc; |
2694 | jermar | 489 | } |
490 | |||
2735 | jermar | 491 | static int _unlink(const char *path, int lflag) |
492 | { |
||
493 | ipcarg_t rc; |
||
494 | aid_t req; |
||
495 | |||
4296 | trochtova | 496 | size_t pa_size; |
497 | char *pa = absolutize(path, &pa_size); |
||
2755 | jermar | 498 | if (!pa) |
499 | return ENOMEM; |
||
2771 | jermar | 500 | |
2735 | jermar | 501 | futex_down(&vfs_phone_futex); |
502 | async_serialize_start(); |
||
4055 | trochtova | 503 | vfs_connect(); |
504 | |||
4668 | trochtova | 505 | req = async_send_0(vfs_phone, VFS_IN_UNLINK, NULL); |
4296 | trochtova | 506 | rc = ipc_data_write_start(vfs_phone, pa, pa_size); |
2735 | jermar | 507 | if (rc != EOK) { |
508 | async_wait_for(req, NULL); |
||
509 | async_serialize_end(); |
||
510 | futex_up(&vfs_phone_futex); |
||
2755 | jermar | 511 | free(pa); |
2735 | jermar | 512 | return (int) rc; |
513 | } |
||
514 | async_wait_for(req, &rc); |
||
515 | async_serialize_end(); |
||
516 | futex_up(&vfs_phone_futex); |
||
2755 | jermar | 517 | free(pa); |
4537 | trochtova | 518 | return rc; |
2735 | jermar | 519 | } |
520 | |||
521 | int unlink(const char *path) |
||
522 | { |
||
523 | return _unlink(path, L_NONE); |
||
524 | } |
||
525 | |||
526 | int rmdir(const char *path) |
||
527 | { |
||
528 | return _unlink(path, L_DIRECTORY); |
||
529 | } |
||
530 | |||
2763 | jermar | 531 | int rename(const char *old, const char *new) |
532 | { |
||
533 | ipcarg_t rc; |
||
534 | aid_t req; |
||
535 | |||
4296 | trochtova | 536 | size_t olda_size; |
537 | char *olda = absolutize(old, &olda_size); |
||
2763 | jermar | 538 | if (!olda) |
539 | return ENOMEM; |
||
2771 | jermar | 540 | |
4296 | trochtova | 541 | size_t newa_size; |
542 | char *newa = absolutize(new, &newa_size); |
||
2763 | jermar | 543 | if (!newa) { |
544 | free(olda); |
||
545 | return ENOMEM; |
||
546 | } |
||
547 | |||
548 | futex_down(&vfs_phone_futex); |
||
549 | async_serialize_start(); |
||
4055 | trochtova | 550 | vfs_connect(); |
551 | |||
4668 | trochtova | 552 | req = async_send_0(vfs_phone, VFS_IN_RENAME, NULL); |
4296 | trochtova | 553 | rc = ipc_data_write_start(vfs_phone, olda, olda_size); |
2763 | jermar | 554 | if (rc != EOK) { |
555 | async_wait_for(req, NULL); |
||
556 | async_serialize_end(); |
||
557 | futex_up(&vfs_phone_futex); |
||
558 | free(olda); |
||
559 | free(newa); |
||
560 | return (int) rc; |
||
561 | } |
||
4296 | trochtova | 562 | rc = ipc_data_write_start(vfs_phone, newa, newa_size); |
2763 | jermar | 563 | if (rc != EOK) { |
564 | async_wait_for(req, NULL); |
||
565 | async_serialize_end(); |
||
566 | futex_up(&vfs_phone_futex); |
||
567 | free(olda); |
||
568 | free(newa); |
||
569 | return (int) rc; |
||
570 | } |
||
571 | async_wait_for(req, &rc); |
||
572 | async_serialize_end(); |
||
573 | futex_up(&vfs_phone_futex); |
||
574 | free(olda); |
||
575 | free(newa); |
||
576 | return rc; |
||
577 | } |
||
578 | |||
2755 | jermar | 579 | int chdir(const char *path) |
580 | { |
||
4296 | trochtova | 581 | size_t pa_size; |
582 | char *pa = absolutize(path, &pa_size); |
||
2755 | jermar | 583 | if (!pa) |
584 | return ENOMEM; |
||
585 | |||
2771 | jermar | 586 | DIR *d = opendir(pa); |
2755 | jermar | 587 | if (!d) { |
588 | free(pa); |
||
589 | return ENOENT; |
||
590 | } |
||
591 | |||
592 | futex_down(&cwd_futex); |
||
593 | if (cwd_dir) { |
||
594 | closedir(cwd_dir); |
||
595 | cwd_dir = NULL; |
||
596 | free(cwd_path); |
||
597 | cwd_path = NULL; |
||
4296 | trochtova | 598 | cwd_size = 0; |
2755 | jermar | 599 | } |
600 | cwd_dir = d; |
||
2771 | jermar | 601 | cwd_path = pa; |
4296 | trochtova | 602 | cwd_size = pa_size; |
2755 | jermar | 603 | futex_up(&cwd_futex); |
4055 | trochtova | 604 | return EOK; |
2755 | jermar | 605 | } |
606 | |||
607 | char *getcwd(char *buf, size_t size) |
||
608 | { |
||
609 | if (!size) |
||
610 | return NULL; |
||
611 | futex_down(&cwd_futex); |
||
4296 | trochtova | 612 | if (size < cwd_size + 1) { |
2755 | jermar | 613 | futex_up(&cwd_futex); |
614 | return NULL; |
||
615 | } |
||
4296 | trochtova | 616 | str_cpy(buf, size, cwd_path); |
2755 | jermar | 617 | futex_up(&cwd_futex); |
618 | return buf; |
||
619 | } |
||
620 | |||
4668 | trochtova | 621 | int fd_phone(int fildes) |
622 | { |
||
623 | struct stat stat; |
||
624 | int rc; |
||
625 | |||
626 | rc = fstat(fildes, &stat); |
||
627 | |||
628 | if (!stat.devfs_stat.device) |
||
629 | return -1; |
||
630 | |||
631 | return devmap_device_connect(stat.devfs_stat.device, 0); |
||
632 | } |
||
633 | |||
634 | int fd_node(int fildes, fdi_node_t *node) |
||
635 | { |
||
636 | struct stat stat; |
||
637 | int rc; |
||
638 | |||
639 | rc = fstat(fildes, &stat); |
||
640 | |||
641 | if (rc == EOK) { |
||
642 | node->fs_handle = stat.fs_handle; |
||
643 | node->dev_handle = stat.dev_handle; |
||
644 | node->index = stat.index; |
||
645 | } |
||
646 | |||
647 | return rc; |
||
648 | } |
||
649 | |||
2671 | jermar | 650 | /** @} |
651 | */ |