source: mainline/uspace/lib/libc/generic/vfs.c@ 8ccd2ea

lfn serial ticket/834-toolchain-update topic/msim-upgrade topic/simplify-dev-export
Last change on this file since 8ccd2ea was f7017572, checked in by Jakub Jermar <jakub@…>, 17 years ago

VFS_WRITE and tmpfs_write fixes.
  • Property mode set to 100644
File size: 7.0 KB
Line 
1/*
2 * Copyright (c) 2008 Jakub 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 */
34
35#include <vfs.h>
36#include <stdlib.h>
37#include <unistd.h>
38#include <dirent.h>
39#include <fcntl.h>
40#include <sys/stat.h>
41#include <sys/types.h>
42#include <ipc/ipc.h>
43#include <ipc/services.h>
44#include <async.h>
45#include <atomic.h>
46#include <futex.h>
47#include <errno.h>
48#include <string.h>
49#include "../../srv/vfs/vfs.h"
50
51int vfs_phone = -1;
52atomic_t vfs_phone_futex = FUTEX_INITIALIZER;
53
54static int vfs_connect(void)
55{
56 if (vfs_phone < 0)
57 vfs_phone = ipc_connect_me_to(PHONE_NS, SERVICE_VFS, 0, 0);
58 return vfs_phone;
59}
60
61int mount(const char *fs_name, const char *mp, const char *dev)
62{
63 int res;
64 ipcarg_t rc;
65 aid_t req;
66
67 int dev_handle = 0; /* TODO */
68
69 futex_down(&vfs_phone_futex);
70 async_serialize_start();
71 if (vfs_phone < 0) {
72 res = vfs_connect();
73 if (res < 0) {
74 async_serialize_end();
75 futex_up(&vfs_phone_futex);
76 return res;
77 }
78 }
79 req = async_send_1(vfs_phone, VFS_MOUNT, dev_handle, NULL);
80 rc = ipc_data_write_start(vfs_phone, (void *)fs_name, strlen(fs_name));
81 if (rc != EOK) {
82 async_wait_for(req, NULL);
83 async_serialize_end();
84 futex_up(&vfs_phone_futex);
85 return (int) rc;
86 }
87 rc = ipc_data_write_start(vfs_phone, (void *)mp, strlen(mp));
88 if (rc != EOK) {
89 async_wait_for(req, NULL);
90 async_serialize_end();
91 futex_up(&vfs_phone_futex);
92 return (int) rc;
93 }
94 async_wait_for(req, &rc);
95 async_serialize_end();
96 futex_up(&vfs_phone_futex);
97 return (int) rc;
98}
99
100static int _open(const char *path, int lflag, int oflag, ...)
101{
102 int res;
103 ipcarg_t rc;
104 ipc_call_t answer;
105 aid_t req;
106
107 futex_down(&vfs_phone_futex);
108 async_serialize_start();
109 if (vfs_phone < 0) {
110 res = vfs_connect();
111 if (res < 0) {
112 async_serialize_end();
113 futex_up(&vfs_phone_futex);
114 return res;
115 }
116 }
117 req = async_send_3(vfs_phone, VFS_OPEN, lflag, oflag, 0, &answer);
118 rc = ipc_data_write_start(vfs_phone, path, strlen(path));
119 if (rc != EOK) {
120 async_wait_for(req, NULL);
121 async_serialize_end();
122 futex_up(&vfs_phone_futex);
123 return (int) rc;
124 }
125 async_wait_for(req, &rc);
126 async_serialize_end();
127 futex_up(&vfs_phone_futex);
128 return (int) IPC_GET_ARG1(answer);
129}
130
131int open(const char *path, int oflag, ...)
132{
133 return _open(path, L_FILE, oflag);
134}
135
136int close(int fildes)
137{
138 return 0; /* TODO */
139}
140
141ssize_t read(int fildes, void *buf, size_t nbyte)
142{
143 int res;
144 ipcarg_t rc;
145 ipc_call_t answer;
146 aid_t req;
147
148 futex_down(&vfs_phone_futex);
149 async_serialize_start();
150 if (vfs_phone < 0) {
151 res = vfs_connect();
152 if (res < 0) {
153 async_serialize_end();
154 futex_up(&vfs_phone_futex);
155 return res;
156 }
157 }
158 req = async_send_1(vfs_phone, VFS_READ, fildes, &answer);
159 if (ipc_data_read_start(vfs_phone, (void *)buf, nbyte) != EOK) {
160 async_wait_for(req, NULL);
161 async_serialize_end();
162 futex_up(&vfs_phone_futex);
163 return (ssize_t) rc;
164 }
165 async_wait_for(req, &rc);
166 async_serialize_end();
167 futex_up(&vfs_phone_futex);
168 if (rc == EOK)
169 return (ssize_t) IPC_GET_ARG1(answer);
170 else
171 return -1;
172}
173
174ssize_t write(int fildes, const void *buf, size_t nbyte)
175{
176 int res;
177 ipcarg_t rc;
178 ipc_call_t answer;
179 aid_t req;
180
181 futex_down(&vfs_phone_futex);
182 async_serialize_start();
183 if (vfs_phone < 0) {
184 res = vfs_connect();
185 if (res < 0) {
186 async_serialize_end();
187 futex_up(&vfs_phone_futex);
188 return res;
189 }
190 }
191 req = async_send_1(vfs_phone, VFS_WRITE, fildes, &answer);
192 if (ipc_data_write_start(vfs_phone, (void *)buf, nbyte) != EOK) {
193 async_wait_for(req, NULL);
194 async_serialize_end();
195 futex_up(&vfs_phone_futex);
196 return (ssize_t) rc;
197 }
198 async_wait_for(req, &rc);
199 async_serialize_end();
200 futex_up(&vfs_phone_futex);
201 if (rc == EOK)
202 return (ssize_t) IPC_GET_ARG1(answer);
203 else
204 return -1;
205}
206
207off_t lseek(int fildes, off_t offset, int whence)
208{
209 int res;
210 ipcarg_t rc;
211
212 futex_down(&vfs_phone_futex);
213 async_serialize_start();
214 if (vfs_phone < 0) {
215 res = vfs_connect();
216 if (res < 0) {
217 async_serialize_end();
218 futex_up(&vfs_phone_futex);
219 return res;
220 }
221 }
222
223 off_t newoffs;
224 rc = async_req_3_1(vfs_phone, VFS_SEEK, fildes, offset, whence,
225 (ipcarg_t)&newoffs);
226
227 async_serialize_end();
228 futex_up(&vfs_phone_futex);
229
230 if (rc != EOK)
231 return (off_t) -1;
232
233 return newoffs;
234}
235
236int ftruncate(int fildes, off_t length)
237{
238 int res;
239 ipcarg_t rc;
240
241 futex_down(&vfs_phone_futex);
242 async_serialize_start();
243 if (vfs_phone < 0) {
244 res = vfs_connect();
245 if (res < 0) {
246 async_serialize_end();
247 futex_up(&vfs_phone_futex);
248 return res;
249 }
250 }
251 rc = async_req_2_0(vfs_phone, VFS_TRUNCATE, fildes, length);
252 async_serialize_end();
253 futex_up(&vfs_phone_futex);
254 return (int) rc;
255}
256
257DIR *opendir(const char *dirname)
258{
259 DIR *dirp = malloc(sizeof(DIR));
260 if (!dirp)
261 return NULL;
262 dirp->fd = _open(dirname, L_DIRECTORY, 0);
263 if (dirp->fd < 0) {
264 free(dirp);
265 return NULL;
266 }
267 return dirp;
268}
269
270struct dirent *readdir(DIR *dirp)
271{
272 ssize_t len = read(dirp->fd, &dirp->res.d_name[0], NAME_MAX + 1);
273 if (len <= 0)
274 return NULL;
275 return &dirp->res;
276}
277
278void rewinddir(DIR *dirp)
279{
280 (void) lseek(dirp->fd, 0, SEEK_SET);
281}
282
283int closedir(DIR *dirp)
284{
285 (void) close(dirp->fd);
286 free(dirp);
287 return 0;
288}
289
290int mkdir(const char *path, mode_t mode)
291{
292 int res;
293 ipcarg_t rc;
294 ipc_call_t answer;
295 aid_t req;
296
297 futex_down(&vfs_phone_futex);
298 async_serialize_start();
299 if (vfs_phone < 0) {
300 res = vfs_connect();
301 if (res < 0) {
302 async_serialize_end();
303 futex_up(&vfs_phone_futex);
304 return res;
305 }
306 }
307 req = async_send_1(vfs_phone, VFS_MKDIR, mode, &answer);
308 rc = ipc_data_write_start(vfs_phone, path, strlen(path));
309 if (rc != EOK) {
310 async_wait_for(req, NULL);
311 async_serialize_end();
312 futex_up(&vfs_phone_futex);
313 return (int) rc;
314 }
315 async_wait_for(req, &rc);
316 async_serialize_end();
317 futex_up(&vfs_phone_futex);
318 return EOK;
319}
320
321/** @}
322 */
Note: See TracBrowser for help on using the repository browser.