Subversion Repositories HelenOS

Rev

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

Rev 3386 Rev 4153
Line 34... Line 34...
34
 * Glue code which is commonod to all FS implementations.
34
 * Glue code which is commonod to all FS implementations.
35
 */
35
 */
36
 
36
 
37
#include "libfs.h" 
37
#include "libfs.h" 
38
#include "../../srv/vfs/vfs.h"
38
#include "../../srv/vfs/vfs.h"
39
#include "../../srv/rd/rd.h"
-
 
40
#include <errno.h>
39
#include <errno.h>
41
#include <async.h>
40
#include <async.h>
42
#include <ipc/ipc.h>
41
#include <ipc/ipc.h>
43
#include <as.h>
42
#include <as.h>
44
#include <assert.h>
43
#include <assert.h>
Line 190... Line 189...
190
                    ipc_answer_0(rid, ENOTDIR);
189
                    ipc_answer_0(rid, ENOTDIR);
191
                    goto out;
190
                    goto out;
192
                }
191
                }
193
                void *nodep;
192
                void *nodep;
194
                if (lflag & L_CREATE)
193
                if (lflag & L_CREATE)
195
                    nodep = ops->create(lflag);
194
                    nodep = ops->create(dev_handle, lflag);
196
                else
195
                else
197
                    nodep = ops->node_get(dev_handle,
196
                    nodep = ops->node_get(dev_handle,
198
                        index);
197
                        index);
199
                if (nodep) {
198
                if (nodep) {
-
 
199
                    int rc;
-
 
200
 
200
                    if (!ops->link(cur, nodep, component)) {
201
                    rc = ops->link(cur, nodep, component);
-
 
202
                    if (rc != EOK) {
201
                        if (lflag & L_CREATE) {
203
                        if (lflag & L_CREATE) {
202
                            (void)ops->destroy(
204
                            (void)ops->destroy(
203
                                nodep);
205
                                nodep);
204
                        }
206
                        }
205
                        ipc_answer_0(rid, ENOSPC);
207
                        ipc_answer_0(rid, rc);
206
                    } else {
208
                    } else {
207
                        ipc_answer_5(rid, EOK,
209
                        ipc_answer_5(rid, EOK,
208
                            fs_handle, dev_handle,
210
                            fs_handle, dev_handle,
209
                            ops->index_get(nodep),
211
                            ops->index_get(nodep),
210
                            ops->size_get(nodep),
212
                            ops->size_get(nodep),
Line 261... Line 263...
261
            assert(len);
263
            assert(len);
262
            component[len] = '\0';
264
            component[len] = '\0';
263
               
265
               
264
            void *nodep;
266
            void *nodep;
265
            if (lflag & L_CREATE)
267
            if (lflag & L_CREATE)
266
                nodep = ops->create(lflag);
268
                nodep = ops->create(dev_handle, lflag);
267
            else
269
            else
268
                nodep = ops->node_get(dev_handle, index);
270
                nodep = ops->node_get(dev_handle, index);
269
            if (nodep) {
271
            if (nodep) {
-
 
272
                int rc;
-
 
273
 
270
                if (!ops->link(cur, nodep, component)) {
274
                rc = ops->link(cur, nodep, component);
-
 
275
                if (rc != EOK) {
271
                    if (lflag & L_CREATE)
276
                    if (lflag & L_CREATE)
272
                        (void)ops->destroy(nodep);
277
                        (void)ops->destroy(nodep);
273
                    ipc_answer_0(rid, ENOSPC);
278
                    ipc_answer_0(rid, rc);
274
                } else {
279
                } else {
275
                    ipc_answer_5(rid, EOK,
280
                    ipc_answer_5(rid, EOK,
276
                        fs_handle, dev_handle,
281
                        fs_handle, dev_handle,
277
                        ops->index_get(nodep),
282
                        ops->index_get(nodep),
278
                        ops->size_get(nodep),
283
                        ops->size_get(nodep),
Line 329... Line 334...
329
        ops->node_put(cur);
334
        ops->node_put(cur);
330
    if (tmp)
335
    if (tmp)
331
        ops->node_put(tmp);
336
        ops->node_put(tmp);
332
}
337
}
333
 
338
 
334
/** Read data from a block device.
-
 
335
 *
-
 
336
 * @param phone     Phone to be used to communicate with the device.
-
 
337
 * @param buffer    Communication buffer shared with the device.
-
 
338
 * @param bufpos    Pointer to the first unread valid offset within the
-
 
339
 *          communication buffer.
-
 
340
 * @param buflen    Pointer to the number of unread bytes that are ready in
-
 
341
 *          the communication buffer.
-
 
342
 * @param pos       Device position to be read.
-
 
343
 * @param dst       Destination buffer.
-
 
344
 * @param size      Size of the destination buffer.
-
 
345
 * @param block_size    Block size to be used for the transfer.
-
 
346
 *
-
 
347
 * @return      True on success, false on failure.
-
 
348
 */
-
 
349
bool libfs_blockread(int phone, void *buffer, off_t *bufpos, size_t *buflen,
-
 
350
    off_t *pos, void *dst, size_t size, size_t block_size)
-
 
351
{
-
 
352
    off_t offset = 0;
-
 
353
    size_t left = size;
-
 
354
   
-
 
355
    while (left > 0) {
-
 
356
        size_t rd;
-
 
357
       
-
 
358
        if (*bufpos + left < *buflen)
-
 
359
            rd = left;
-
 
360
        else
-
 
361
            rd = *buflen - *bufpos;
-
 
362
       
-
 
363
        if (rd > 0) {
-
 
364
            /*
-
 
365
             * Copy the contents of the communication buffer to the
-
 
366
             * destination buffer.
-
 
367
             */
-
 
368
            memcpy(dst + offset, buffer + *bufpos, rd);
-
 
369
            offset += rd;
-
 
370
            *bufpos += rd;
-
 
371
            *pos += rd;
-
 
372
            left -= rd;
-
 
373
        }
-
 
374
       
-
 
375
        if (*bufpos == *buflen) {
-
 
376
            /* Refill the communication buffer with a new block. */
-
 
377
            ipcarg_t retval;
-
 
378
            int rc = async_req_2_1(phone, RD_READ_BLOCK,
-
 
379
                *pos / block_size, block_size, &retval);
-
 
380
            if ((rc != EOK) || (retval != EOK))
-
 
381
                return false;
-
 
382
           
-
 
383
            *bufpos = 0;
-
 
384
            *buflen = block_size;
-
 
385
        }
-
 
386
    }
-
 
387
   
-
 
388
    return true;
-
 
389
}
-
 
390
 
-
 
391
/** @}
339
/** @}
392
 */
340
 */