Changeset 16dc887 in mainline for uspace/lib


Ignore:
Timestamp:
2011-08-16T14:00:32Z (14 years ago)
Author:
Jiri Svoboda <jiri@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
278ac72, b112055
Parents:
3751a08 (diff), cc574511 (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 Location service.

Location:
uspace/lib
Files:
1 added
1 deleted
15 edited
2 moved

Legend:

Unmodified
Added
Removed
  • uspace/lib/block/libblock.c

    r3751a08 r16dc887  
    3939#include "libblock.h"
    4040#include "../../srv/vfs/vfs.h"
    41 #include <ipc/devmap.h>
     41#include <ipc/loc.h>
    4242#include <ipc/bd.h>
    4343#include <ipc/services.h>
     
    7878typedef struct {
    7979        link_t link;
    80         devmap_handle_t devmap_handle;
     80        service_id_t service_id;
    8181        async_sess_t *sess;
    8282        fibril_mutex_t comm_area_lock;
     
    9595static aoff64_t ba_ltop(devcon_t *, aoff64_t);
    9696
    97 static devcon_t *devcon_search(devmap_handle_t devmap_handle)
     97static devcon_t *devcon_search(service_id_t service_id)
    9898{
    9999        fibril_mutex_lock(&dcl_lock);
     
    101101        list_foreach(dcl, cur) {
    102102                devcon_t *devcon = list_get_instance(cur, devcon_t, link);
    103                 if (devcon->devmap_handle == devmap_handle) {
     103                if (devcon->service_id == service_id) {
    104104                        fibril_mutex_unlock(&dcl_lock);
    105105                        return devcon;
     
    111111}
    112112
    113 static int devcon_add(devmap_handle_t devmap_handle, async_sess_t *sess,
     113static int devcon_add(service_id_t service_id, async_sess_t *sess,
    114114    size_t bsize, void *comm_area, size_t comm_size)
    115115{
     
    124124       
    125125        link_initialize(&devcon->link);
    126         devcon->devmap_handle = devmap_handle;
     126        devcon->service_id = service_id;
    127127        devcon->sess = sess;
    128128        fibril_mutex_initialize(&devcon->comm_area_lock);
     
    137137        list_foreach(dcl, cur) {
    138138                devcon_t *d = list_get_instance(cur, devcon_t, link);
    139                 if (d->devmap_handle == devmap_handle) {
     139                if (d->service_id == service_id) {
    140140                        fibril_mutex_unlock(&dcl_lock);
    141141                        free(devcon);
     
    155155}
    156156
    157 int block_init(exch_mgmt_t mgmt, devmap_handle_t devmap_handle,
     157int block_init(exch_mgmt_t mgmt, service_id_t service_id,
    158158    size_t comm_size)
    159159{
     
    163163                return ENOMEM;
    164164       
    165         async_sess_t *sess = devmap_device_connect(mgmt, devmap_handle,
     165        async_sess_t *sess = loc_service_connect(mgmt, service_id,
    166166            IPC_FLAG_BLOCKING);
    167167        if (!sess) {
     
    190190        }
    191191       
    192         rc = devcon_add(devmap_handle, sess, bsize, comm_area, comm_size);
     192        rc = devcon_add(service_id, sess, bsize, comm_area, comm_size);
    193193        if (rc != EOK) {
    194194                munmap(comm_area, comm_size);
     
    200200}
    201201
    202 void block_fini(devmap_handle_t devmap_handle)
    203 {
    204         devcon_t *devcon = devcon_search(devmap_handle);
     202void block_fini(service_id_t service_id)
     203{
     204        devcon_t *devcon = devcon_search(service_id);
    205205        assert(devcon);
    206206       
    207207        if (devcon->cache)
    208                 (void) block_cache_fini(devmap_handle);
     208                (void) block_cache_fini(service_id);
    209209       
    210210        devcon_remove(devcon);
     
    219219}
    220220
    221 int block_bb_read(devmap_handle_t devmap_handle, aoff64_t ba)
     221int block_bb_read(service_id_t service_id, aoff64_t ba)
    222222{
    223223        void *bb_buf;
    224224        int rc;
    225225
    226         devcon_t *devcon = devcon_search(devmap_handle);
     226        devcon_t *devcon = devcon_search(service_id);
    227227        if (!devcon)
    228228                return ENOENT;
     
    249249}
    250250
    251 void *block_bb_get(devmap_handle_t devmap_handle)
    252 {
    253         devcon_t *devcon = devcon_search(devmap_handle);
     251void *block_bb_get(service_id_t service_id)
     252{
     253        devcon_t *devcon = devcon_search(service_id);
    254254        assert(devcon);
    255255        return devcon->bb_buf;
     
    277277};
    278278
    279 int block_cache_init(devmap_handle_t devmap_handle, size_t size, unsigned blocks,
     279int block_cache_init(service_id_t service_id, size_t size, unsigned blocks,
    280280    enum cache_mode mode)
    281281{
    282         devcon_t *devcon = devcon_search(devmap_handle);
     282        devcon_t *devcon = devcon_search(service_id);
    283283        cache_t *cache;
    284284        if (!devcon)
     
    315315}
    316316
    317 int block_cache_fini(devmap_handle_t devmap_handle)
    318 {
    319         devcon_t *devcon = devcon_search(devmap_handle);
     317int block_cache_fini(service_id_t service_id)
     318{
     319        devcon_t *devcon = devcon_search(service_id);
    320320        cache_t *cache;
    321321        int rc;
     
    387387 * @param block                 Pointer to where the function will store the
    388388 *                              block pointer on success.
    389  * @param devmap_handle         Device handle of the block device.
     389 * @param service_id            Service ID of the block device.
    390390 * @param ba                    Block address (logical).
    391391 * @param flags                 If BLOCK_FLAGS_NOREAD is specified, block_get()
     
    395395 * @return                      EOK on success or a negative error code.
    396396 */
    397 int block_get(block_t **block, devmap_handle_t devmap_handle, aoff64_t ba, int flags)
     397int block_get(block_t **block, service_id_t service_id, aoff64_t ba, int flags)
    398398{
    399399        devcon_t *devcon;
     
    408408        int rc;
    409409       
    410         devcon = devcon_search(devmap_handle);
     410        devcon = devcon_search(service_id);
    411411
    412412        assert(devcon);
     
    536536
    537537                block_initialize(b);
    538                 b->devmap_handle = devmap_handle;
     538                b->service_id = service_id;
    539539                b->size = cache->lblock_size;
    540540                b->lba = ba;
     
    586586int block_put(block_t *block)
    587587{
    588         devcon_t *devcon = devcon_search(block->devmap_handle);
     588        devcon_t *devcon = devcon_search(block->service_id);
    589589        cache_t *cache;
    590590        unsigned blocks_cached;
     
    687687/** Read sequential data from a block device.
    688688 *
    689  * @param devmap_handle Device handle of the block device.
     689 * @param service_id    Service ID of the block device.
    690690 * @param bufpos        Pointer to the first unread valid offset within the
    691691 *                      communication buffer.
     
    699699 * @return              EOK on success or a negative return code on failure.
    700700 */
    701 int block_seqread(devmap_handle_t devmap_handle, size_t *bufpos, size_t *buflen,
     701int block_seqread(service_id_t service_id, size_t *bufpos, size_t *buflen,
    702702    aoff64_t *pos, void *dst, size_t size)
    703703{
     
    707707        devcon_t *devcon;
    708708
    709         devcon = devcon_search(devmap_handle);
     709        devcon = devcon_search(service_id);
    710710        assert(devcon);
    711711        block_size = devcon->pblock_size;
     
    753753/** Read blocks directly from device (bypass cache).
    754754 *
    755  * @param devmap_handle Device handle of the block device.
     755 * @param service_id    Service ID of the block device.
    756756 * @param ba            Address of first block (physical).
    757757 * @param cnt           Number of blocks.
     
    760760 * @return              EOK on success or negative error code on failure.
    761761 */
    762 int block_read_direct(devmap_handle_t devmap_handle, aoff64_t ba, size_t cnt, void *buf)
     762int block_read_direct(service_id_t service_id, aoff64_t ba, size_t cnt, void *buf)
    763763{
    764764        devcon_t *devcon;
    765765        int rc;
    766766
    767         devcon = devcon_search(devmap_handle);
     767        devcon = devcon_search(service_id);
    768768        assert(devcon);
    769769       
     
    781781/** Write blocks directly to device (bypass cache).
    782782 *
    783  * @param devmap_handle Device handle of the block device.
     783 * @param service_id    Service ID of the block device.
    784784 * @param ba            Address of first block (physical).
    785785 * @param cnt           Number of blocks.
     
    788788 * @return              EOK on success or negative error code on failure.
    789789 */
    790 int block_write_direct(devmap_handle_t devmap_handle, aoff64_t ba, size_t cnt,
     790int block_write_direct(service_id_t service_id, aoff64_t ba, size_t cnt,
    791791    const void *data)
    792792{
     
    794794        int rc;
    795795
    796         devcon = devcon_search(devmap_handle);
     796        devcon = devcon_search(service_id);
    797797        assert(devcon);
    798798       
     
    809809/** Get device block size.
    810810 *
    811  * @param devmap_handle Device handle of the block device.
     811 * @param service_id    Service ID of the block device.
    812812 * @param bsize         Output block size.
    813813 *
    814814 * @return              EOK on success or negative error code on failure.
    815815 */
    816 int block_get_bsize(devmap_handle_t devmap_handle, size_t *bsize)
     816int block_get_bsize(service_id_t service_id, size_t *bsize)
    817817{
    818818        devcon_t *devcon;
    819819
    820         devcon = devcon_search(devmap_handle);
     820        devcon = devcon_search(service_id);
    821821        assert(devcon);
    822822       
     
    826826/** Get number of blocks on device.
    827827 *
    828  * @param devmap_handle Device handle of the block device.
     828 * @param service_id    Service ID of the block device.
    829829 * @param nblocks       Output number of blocks.
    830830 *
    831831 * @return              EOK on success or negative error code on failure.
    832832 */
    833 int block_get_nblocks(devmap_handle_t devmap_handle, aoff64_t *nblocks)
    834 {
    835         devcon_t *devcon = devcon_search(devmap_handle);
     833int block_get_nblocks(service_id_t service_id, aoff64_t *nblocks)
     834{
     835        devcon_t *devcon = devcon_search(service_id);
    836836        assert(devcon);
    837837       
     
    841841/** Read bytes directly from the device (bypass cache)
    842842 *
    843  * @param devmap_handle Device handle of the block device.
     843 * @param service_id    Service ID of the block device.
    844844 * @param abs_offset    Absolute offset in bytes where to start reading
    845845 * @param bytes                 Number of bytes to read
     
    848848 * @return              EOK on success or negative error code on failure.
    849849 */
    850 int block_read_bytes_direct(devmap_handle_t devmap_handle, aoff64_t abs_offset,
     850int block_read_bytes_direct(service_id_t service_id, aoff64_t abs_offset,
    851851    size_t bytes, void *data)
    852852{
     
    860860        size_t offset;
    861861       
    862         rc = block_get_bsize(devmap_handle, &phys_block_size);
     862        rc = block_get_bsize(service_id, &phys_block_size);
    863863        if (rc != EOK) {
    864864                return rc;
     
    878878        }
    879879       
    880         rc = block_read_direct(devmap_handle, first_block, blocks, buffer);
     880        rc = block_read_direct(service_id, first_block, blocks, buffer);
    881881        if (rc != EOK) {
    882882                free(buffer);
     
    912912                printf("Error %d reading %zu blocks starting at block %" PRIuOFF64
    913913                    " from device handle %" PRIun "\n", rc, cnt, ba,
    914                     devcon->devmap_handle);
     914                    devcon->service_id);
    915915#ifndef NDEBUG
    916916                stacktrace_print();
     
    941941        if (rc != EOK) {
    942942                printf("Error %d writing %zu blocks starting at block %" PRIuOFF64
    943                     " to device handle %" PRIun "\n", rc, cnt, ba, devcon->devmap_handle);
     943                    " to device handle %" PRIun "\n", rc, cnt, ba, devcon->service_id);
    944944#ifndef NDEBUG
    945945                stacktrace_print();
  • uspace/lib/block/libblock.h

    r3751a08 r16dc887  
    11/*
    22 * Copyright (c) 2008 Jakub Jermar
    3  * Copyright (c) 2008 Martin Decky 
    4  * Copyright (c) 2011 Martin Sucha 
     3 * Copyright (c) 2008 Martin Decky
     4 * Copyright (c) 2011 Martin Sucha
    55 * All rights reserved.
    66 *
     
    7373        /** Readers / Writer lock protecting the contents of the block. */
    7474        fibril_rwlock_t contents_lock;
    75         /** Handle of the device where the block resides. */
    76         devmap_handle_t devmap_handle;
     75        /** Service ID of service providing the block device. */
     76        service_id_t service_id;
    7777        /** Logical block address */
    7878        aoff64_t lba;
     
    9797};
    9898
    99 extern int block_init(exch_mgmt_t, devmap_handle_t, size_t);
    100 extern void block_fini(devmap_handle_t);
     99extern int block_init(exch_mgmt_t, service_id_t, size_t);
     100extern void block_fini(service_id_t);
    101101
    102 extern int block_bb_read(devmap_handle_t, aoff64_t);
    103 extern void *block_bb_get(devmap_handle_t);
     102extern int block_bb_read(service_id_t, aoff64_t);
     103extern void *block_bb_get(service_id_t);
    104104
    105 extern int block_cache_init(devmap_handle_t, size_t, unsigned, enum cache_mode);
    106 extern int block_cache_fini(devmap_handle_t);
     105extern int block_cache_init(service_id_t, size_t, unsigned, enum cache_mode);
     106extern int block_cache_fini(service_id_t);
    107107
    108 extern int block_get(block_t **, devmap_handle_t, aoff64_t, int);
     108extern int block_get(block_t **, service_id_t, aoff64_t, int);
    109109extern int block_put(block_t *);
    110110
    111 extern int block_seqread(devmap_handle_t, size_t *, size_t *, aoff64_t *, void *,
     111extern int block_seqread(service_id_t, size_t *, size_t *, aoff64_t *, void *,
    112112    size_t);
    113113
    114 extern int block_get_bsize(devmap_handle_t, size_t *);
    115 extern int block_get_nblocks(devmap_handle_t, aoff64_t *);
    116 extern int block_read_direct(devmap_handle_t, aoff64_t, size_t, void *);
    117 extern int block_read_bytes_direct(devmap_handle_t, aoff64_t, size_t, void *);
    118 extern int block_write_direct(devmap_handle_t, aoff64_t, size_t, const void *);
     114extern int block_get_bsize(service_id_t, size_t *);
     115extern int block_get_nblocks(service_id_t, aoff64_t *);
     116extern int block_read_direct(service_id_t, aoff64_t, size_t, void *);
     117extern int block_read_bytes_direct(service_id_t, aoff64_t, size_t, void *);
     118extern int block_write_direct(service_id_t, aoff64_t, size_t, const void *);
    119119
    120120#endif
  • uspace/lib/c/Makefile

    r3751a08 r16dc887  
    6464        generic/cap.c \
    6565        generic/clipboard.c \
    66         generic/devmap.c \
    6766        generic/devman.c \
    6867        generic/device/hw_res.c \
     
    7170        generic/event.c \
    7271        generic/errno.c \
     72        generic/loc.c \
    7373        generic/mem.c \
    7474        generic/str.c \
  • uspace/lib/c/generic/io/io.c

    r3751a08 r16dc887  
    4545#include <vfs/vfs.h>
    4646#include <vfs/vfs_sess.h>
    47 #include <ipc/devmap.h>
     47#include <ipc/loc.h>
    4848#include <adt/list.h>
    4949#include "../private/io.h"
  • uspace/lib/c/generic/vfs/vfs.c

    r3751a08 r16dc887  
    5151#include <assert.h>
    5252#include <str.h>
    53 #include <devmap.h>
     53#include <loc.h>
    5454#include <ipc/vfs.h>
    55 #include <ipc/devmap.h>
     55#include <ipc/loc.h>
    5656
    5757static FIBRIL_MUTEX_INITIALIZE(vfs_mutex);
     
    142142}
    143143
    144 int mount(const char *fs_name, const char *mp, const char *fqdn,
     144int mount(const char *fs_name, const char *mp, const char *fqsn,
    145145    const char *opts, unsigned int flags)
    146146{
    147147        int null_id = -1;
    148         char null[DEVMAP_NAME_MAXLEN];
    149        
    150         if (str_cmp(fqdn, "") == 0) {
     148        char null[LOC_NAME_MAXLEN];
     149       
     150        if (str_cmp(fqsn, "") == 0) {
    151151                /* No device specified, create a fresh
    152152                   null/%d device instead */
    153                 null_id = devmap_null_create();
     153                null_id = loc_null_create();
    154154               
    155155                if (null_id == -1)
    156156                        return ENOMEM;
    157157               
    158                 snprintf(null, DEVMAP_NAME_MAXLEN, "null/%d", null_id);
    159                 fqdn = null;
    160         }
    161        
    162         devmap_handle_t devmap_handle;
    163         int res = devmap_device_get_handle(fqdn, &devmap_handle, flags);
     158                snprintf(null, LOC_NAME_MAXLEN, "null/%d", null_id);
     159                fqsn = null;
     160        }
     161       
     162        service_id_t service_id;
     163        int res = loc_service_get_id(fqsn, &service_id, flags);
    164164        if (res != EOK) {
    165165                if (null_id != -1)
    166                         devmap_null_destroy(null_id);
     166                        loc_null_destroy(null_id);
    167167               
    168168                return res;
     
    173173        if (!mpa) {
    174174                if (null_id != -1)
    175                         devmap_null_destroy(null_id);
     175                        loc_null_destroy(null_id);
    176176               
    177177                return ENOMEM;
     
    181181
    182182        sysarg_t rc_orig;
    183         aid_t req = async_send_2(exch, VFS_IN_MOUNT, devmap_handle, flags, NULL);
     183        aid_t req = async_send_2(exch, VFS_IN_MOUNT, service_id, flags, NULL);
    184184        sysarg_t rc = async_data_write_start(exch, (void *) mpa, mpa_size);
    185185        if (rc != EOK) {
     
    189189               
    190190                if (null_id != -1)
    191                         devmap_null_destroy(null_id);
     191                        loc_null_destroy(null_id);
    192192               
    193193                if (rc_orig == EOK)
     
    204204               
    205205                if (null_id != -1)
    206                         devmap_null_destroy(null_id);
     206                        loc_null_destroy(null_id);
    207207               
    208208                if (rc_orig == EOK)
     
    219219               
    220220                if (null_id != -1)
    221                         devmap_null_destroy(null_id);
     221                        loc_null_destroy(null_id);
    222222               
    223223                if (rc_orig == EOK)
     
    235235               
    236236                if (null_id != -1)
    237                         devmap_null_destroy(null_id);
     237                        loc_null_destroy(null_id);
    238238               
    239239                if (rc_orig == EOK)
     
    248248       
    249249        if ((rc != EOK) && (null_id != -1))
    250                 devmap_null_destroy(null_id);
     250                loc_null_destroy(null_id);
    251251       
    252252        return (int) rc;
     
    335335        ipc_call_t answer;
    336336        aid_t req = async_send_4(exch, VFS_IN_OPEN_NODE, node->fs_handle,
    337             node->devmap_handle, node->index, oflag, &answer);
     337            node->service_id, node->index, oflag, &answer);
    338338       
    339339        vfs_exchange_end(exch);
     
    811811        }
    812812       
    813         if (!stat.device) {
     813        if (!stat.service) {
    814814                errno = ENOENT;
    815815                return NULL;
    816816        }
    817817       
    818         return devmap_device_connect(mgmt, stat.device, 0);
     818        return loc_service_connect(mgmt, stat.service, 0);
    819819}
    820820
     
    826826        if (rc == EOK) {
    827827                node->fs_handle = stat.fs_handle;
    828                 node->devmap_handle = stat.devmap_handle;
     828                node->service_id = stat.service_id;
    829829                node->index = stat.index;
    830830        }
  • uspace/lib/c/include/ipc/devman.h

    r3751a08 r16dc887  
    130130        DEVMAN_CLIENT,
    131131        DEVMAN_CONNECT_TO_DEVICE,
    132         DEVMAN_CONNECT_FROM_DEVMAP,
     132        DEVMAN_CONNECT_FROM_LOC,
    133133        DEVMAN_CONNECT_TO_PARENTS_DEVICE
    134134} devman_interface_t;
  • uspace/lib/c/include/ipc/loc.h

    r3751a08 r16dc887  
    11/*
    22 * Copyright (c) 2007 Josef Cejka
     3 * Copyright (c) 2011 Jiri Svoboda
    34 * All rights reserved.
    45 *
     
    2728 */
    2829
    29 /** @addtogroup devmap
     30/** @addtogroup loc
    3031 * @{
    3132 */
    3233
    33 #ifndef LIBC_IPC_DEVMAP_H_
    34 #define LIBC_IPC_DEVMAP_H_
     34#ifndef LIBC_IPC_LOC_H_
     35#define LIBC_IPC_LOC_H_
    3536
    3637#include <ipc/common.h>
    3738
    38 #define DEVMAP_NAME_MAXLEN  255
     39#define LOC_NAME_MAXLEN  255
    3940
    40 typedef sysarg_t devmap_handle_t;
     41typedef sysarg_t service_id_t;
     42typedef sysarg_t category_id_t;
    4143
    4244typedef enum {
    43         DEV_HANDLE_NONE,
    44         DEV_HANDLE_NAMESPACE,
    45         DEV_HANDLE_DEVICE
    46 } devmap_handle_type_t;
     45        LOC_OBJECT_NONE,
     46        LOC_OBJECT_NAMESPACE,
     47        LOC_OBJECT_SERVICE
     48} loc_object_type_t;
    4749
    4850typedef enum {
    49         DEVMAP_DRIVER_REGISTER = IPC_FIRST_USER_METHOD,
    50         DEVMAP_DRIVER_UNREGISTER,
    51         DEVMAP_DEVICE_REGISTER,
    52         DEVMAP_DEVICE_UNREGISTER,
    53         DEVMAP_DEVICE_GET_HANDLE,
    54         DEVMAP_NAMESPACE_GET_HANDLE,
    55         DEVMAP_HANDLE_PROBE,
    56         DEVMAP_NULL_CREATE,
    57         DEVMAP_NULL_DESTROY,
    58         DEVMAP_GET_NAMESPACE_COUNT,
    59         DEVMAP_GET_DEVICE_COUNT,
    60         DEVMAP_GET_NAMESPACES,
    61         DEVMAP_GET_DEVICES
    62 } devmap_request_t;
     51        LOC_SERVER_REGISTER = IPC_FIRST_USER_METHOD,
     52        LOC_SERVER_UNREGISTER,
     53        LOC_SERVICE_ADD_TO_CAT,
     54        LOC_SERVICE_REGISTER,
     55        LOC_SERVICE_UNREGISTER,
     56        LOC_SERVICE_GET_ID,
     57        LOC_NAMESPACE_GET_ID,
     58        LOC_CATEGORY_GET_ID,
     59        LOC_CATEGORY_GET_SVCS,
     60        LOC_ID_PROBE,
     61        LOC_NULL_CREATE,
     62        LOC_NULL_DESTROY,
     63        LOC_GET_NAMESPACE_COUNT,
     64        LOC_GET_SERVICE_COUNT,
     65        LOC_GET_NAMESPACES,
     66        LOC_GET_SERVICES
     67} loc_request_t;
    6368
    64 /** Interface provided by devmap.
     69/** Ports provided by location service.
    6570 *
    66  * Every process that connects to devmap must ask one of following
    67  * interfaces otherwise connection will be refused.
     71 * Every process that connects to loc must ask one of following
     72 * ports, otherwise connection will be refused.
    6873 *
    6974 */
    7075typedef enum {
    71         /** Connect as device driver */
    72         DEVMAP_DRIVER = 1,
    73         /** Connect as client */
    74         DEVMAP_CLIENT,
     76        /** Service supplier (server) port */
     77        LOC_PORT_SUPPLIER = 1,
     78        /** Service consumer (client) port */
     79        LOC_PORT_CONSUMER,
    7580        /** Create new connection to instance of device that
    7681            is specified by second argument of call. */
    77         DEVMAP_CONNECT_TO_DEVICE
    78 } devmap_interface_t;
     82        LOC_CONNECT_TO_SERVICE
     83} loc_interface_t;
    7984
    8085typedef struct {
    81         devmap_handle_t handle;
    82         char name[DEVMAP_NAME_MAXLEN + 1];
    83 } dev_desc_t;
     86        service_id_t id;
     87        char name[LOC_NAME_MAXLEN + 1];
     88} loc_sdesc_t;
    8489
    8590#endif
  • uspace/lib/c/include/ipc/services.h

    r3751a08 r16dc887  
    4545        SERVICE_VIDEO      = FOURCC('v', 'i', 'd', ' '),
    4646        SERVICE_VFS        = FOURCC('v', 'f', 's', ' '),
    47         SERVICE_DEVMAP     = FOURCC('d', 'e', 'v', 'p'),
     47        SERVICE_LOC        = FOURCC('l', 'o', 'c', ' '),
    4848        SERVICE_DEVMAN     = FOURCC('d', 'e', 'v', 'n'),
    4949        SERVICE_IRC        = FOURCC('i', 'r', 'c', ' '),
  • uspace/lib/c/include/loc.h

    r3751a08 r16dc887  
    3333 */
    3434
    35 #ifndef LIBC_DEVMAP_H_
    36 #define LIBC_DEVMAP_H_
     35#ifndef LIBC_LOC_H_
     36#define LIBC_LOC_H_
    3737
    38 #include <ipc/devmap.h>
     38#include <ipc/loc.h>
    3939#include <async.h>
    4040#include <bool.h>
    4141
    42 extern async_exch_t *devmap_exchange_begin_blocking(devmap_interface_t);
    43 extern async_exch_t *devmap_exchange_begin(devmap_interface_t);
    44 extern void devmap_exchange_end(async_exch_t *);
     42extern async_exch_t *loc_exchange_begin_blocking(loc_interface_t);
     43extern async_exch_t *loc_exchange_begin(loc_interface_t);
     44extern void loc_exchange_end(async_exch_t *);
    4545
    46 extern int devmap_driver_register(const char *, async_client_conn_t);
    47 extern int devmap_device_register(const char *, devmap_handle_t *);
    48 extern int devmap_device_register_with_iface(const char *, devmap_handle_t *,
     46extern int loc_server_register(const char *, async_client_conn_t);
     47extern int loc_service_register(const char *, service_id_t *);
     48extern int loc_service_register_with_iface(const char *, service_id_t *,
    4949    sysarg_t);
     50extern int loc_service_add_to_cat(service_id_t, category_id_t);
    5051
    51 extern int devmap_device_get_handle(const char *, devmap_handle_t *,
     52extern int loc_service_get_id(const char *, service_id_t *,
    5253    unsigned int);
    53 extern int devmap_namespace_get_handle(const char *, devmap_handle_t *,
     54extern int loc_namespace_get_id(const char *, service_id_t *,
    5455    unsigned int);
    55 extern devmap_handle_type_t devmap_handle_probe(devmap_handle_t);
     56extern int loc_category_get_id(const char *, category_id_t *,
     57    unsigned int);
     58extern int loc_category_get_svcs(category_id_t, category_id_t **, size_t *);
     59extern loc_object_type_t loc_id_probe(service_id_t);
    5660
    57 extern async_sess_t *devmap_device_connect(exch_mgmt_t, devmap_handle_t,
     61extern async_sess_t *loc_service_connect(exch_mgmt_t, service_id_t,
    5862    unsigned int);
    5963
    60 extern int devmap_null_create(void);
    61 extern void devmap_null_destroy(int);
     64extern int loc_null_create(void);
     65extern void loc_null_destroy(int);
    6266
    63 extern size_t devmap_count_namespaces(void);
    64 extern size_t devmap_count_devices(devmap_handle_t);
     67extern size_t loc_count_namespaces(void);
     68extern size_t loc_count_services(service_id_t);
    6569
    66 extern size_t devmap_get_namespaces(dev_desc_t **);
    67 extern size_t devmap_get_devices(devmap_handle_t, dev_desc_t **);
     70extern size_t loc_get_namespaces(loc_sdesc_t **);
     71extern size_t loc_get_services(service_id_t, loc_sdesc_t **);
    6872
    6973#endif
  • uspace/lib/c/include/sys/stat.h

    r3751a08 r16dc887  
    3939#include <bool.h>
    4040#include <ipc/vfs.h>
    41 #include <ipc/devmap.h>
     41#include <ipc/loc.h>
    4242
    4343struct stat {
    4444        fs_handle_t fs_handle;
    45         devmap_handle_t devmap_handle;
     45        service_id_t service_id;
    4646        fs_index_t index;
    4747        unsigned int lnkcnt;
     
    4949        bool is_directory;
    5050        aoff64_t size;
    51         devmap_handle_t device;
     51        service_id_t service;
    5252};
    5353
  • uspace/lib/c/include/vfs/vfs.h

    r3751a08 r16dc887  
    3838#include <sys/types.h>
    3939#include <ipc/vfs.h>
    40 #include <ipc/devmap.h>
     40#include <ipc/loc.h>
    4141#include <stdio.h>
    4242
     
    4949typedef struct {
    5050        fs_handle_t fs_handle;
    51         devmap_handle_t devmap_handle;
     51        service_id_t service_id;
    5252        fs_index_t index;
    5353} fdi_node_t;
  • uspace/lib/ext2/libext2_filesystem.c

    r3751a08 r16dc887  
    5050 *
    5151 * @param fs                    Pointer to ext2_filesystem_t to initialize
    52  * @param devmap_handle Device handle of the block device
    53  *
    54  * @return              EOK on success or negative error code on failure
    55  */
    56 int ext2_filesystem_init(ext2_filesystem_t *fs, devmap_handle_t devmap_handle)
     52 * @param service_id    Service ID of the block device
     53 *
     54 * @return              EOK on success or negative error code on failure
     55 */
     56int ext2_filesystem_init(ext2_filesystem_t *fs, service_id_t service_id)
    5757{
    5858        int rc;
     
    6060        size_t block_size;
    6161       
    62         fs->device = devmap_handle;
     62        fs->device = service_id;
    6363       
    6464        rc = block_init(EXCHANGE_SERIALIZE, fs->device, 2048);
     
    8080        }
    8181       
    82         rc = block_cache_init(devmap_handle, block_size, 0, CACHE_MODE_WT);
     82        rc = block_cache_init(service_id, block_size, 0, CACHE_MODE_WT);
    8383        if (rc != EOK) {
    8484                block_fini(fs->device);
  • uspace/lib/ext2/libext2_filesystem.h

    r3751a08 r16dc887  
    4343
    4444typedef struct ext2_filesystem {
    45         devmap_handle_t         device;
     45        service_id_t            device;
    4646        ext2_superblock_t *     superblock;
    4747} ext2_filesystem_t;
     
    5959#define EXT2_SUPPORTED_READ_ONLY_FEATURES 0
    6060
    61 extern int ext2_filesystem_init(ext2_filesystem_t *, devmap_handle_t);
     61extern int ext2_filesystem_init(ext2_filesystem_t *, service_id_t);
    6262extern int ext2_filesystem_check_sanity(ext2_filesystem_t *);
    6363extern int ext2_filesystem_check_flags(ext2_filesystem_t *, bool *);
  • uspace/lib/ext2/libext2_superblock.c

    r3751a08 r16dc887  
    321321/** Read a superblock directly from device (i.e. no libblock cache)
    322322 *
    323  * @param devmap_handle Device handle of the block device.
     323 * @param service_id    Service ID of the block device.
    324324 * @param superblock    Pointer where to store pointer to new superblock
    325325 *
    326326 * @return              EOK on success or negative error code on failure.
    327327 */
    328 int ext2_superblock_read_direct(devmap_handle_t devmap_handle,
     328int ext2_superblock_read_direct(service_id_t service_id,
    329329    ext2_superblock_t **superblock)
    330330{
     
    337337        }
    338338       
    339         rc = block_read_bytes_direct(devmap_handle, EXT2_SUPERBLOCK_OFFSET,
     339        rc = block_read_bytes_direct(service_id, EXT2_SUPERBLOCK_OFFSET,
    340340            EXT2_SUPERBLOCK_SIZE, data);
    341341        if (rc != EOK) {
  • uspace/lib/ext2/libext2_superblock.h

    r3751a08 r16dc887  
    110110extern uint32_t ext2_superblock_get_features_read_only(ext2_superblock_t *);
    111111
    112 extern int ext2_superblock_read_direct(devmap_handle_t, ext2_superblock_t **);
     112extern int ext2_superblock_read_direct(service_id_t, ext2_superblock_t **);
    113113extern int ext2_superblock_check_sanity(ext2_superblock_t *);
    114114
  • uspace/lib/fs/libfs.c

    r3751a08 r16dc887  
    7777static void vfs_out_mounted(ipc_callid_t rid, ipc_call_t *req)
    7878{
    79         devmap_handle_t devmap_handle = (devmap_handle_t) IPC_GET_ARG1(*req);
     79        service_id_t service_id = (service_id_t) IPC_GET_ARG1(*req);
    8080        char *opts;
    8181        int rc;
     
    9191        aoff64_t size;
    9292        unsigned lnkcnt;
    93         rc = vfs_out_ops->mounted(devmap_handle, opts, &index, &size, &lnkcnt);
     93        rc = vfs_out_ops->mounted(service_id, opts, &index, &size, &lnkcnt);
    9494
    9595        if (rc == EOK)
     
    109109static void vfs_out_unmounted(ipc_callid_t rid, ipc_call_t *req)
    110110{
    111         devmap_handle_t devmap_handle = (devmap_handle_t) IPC_GET_ARG1(*req);
     111        service_id_t service_id = (service_id_t) IPC_GET_ARG1(*req);
    112112        int rc;
    113113
    114         rc = vfs_out_ops->unmounted(devmap_handle);
     114        rc = vfs_out_ops->unmounted(service_id);
    115115
    116116        async_answer_0(rid, rc);
     
    130130static void vfs_out_read(ipc_callid_t rid, ipc_call_t *req)
    131131{
    132         devmap_handle_t devmap_handle = (devmap_handle_t) IPC_GET_ARG1(*req);
     132        service_id_t service_id = (service_id_t) IPC_GET_ARG1(*req);
    133133        fs_index_t index = (fs_index_t) IPC_GET_ARG2(*req);
    134134        aoff64_t pos = (aoff64_t) MERGE_LOUP32(IPC_GET_ARG3(*req),
     
    137137        int rc;
    138138
    139         rc = vfs_out_ops->read(devmap_handle, index, pos, &rbytes);
     139        rc = vfs_out_ops->read(service_id, index, pos, &rbytes);
    140140
    141141        if (rc == EOK)
     
    147147static void vfs_out_write(ipc_callid_t rid, ipc_call_t *req)
    148148{
    149         devmap_handle_t devmap_handle = (devmap_handle_t) IPC_GET_ARG1(*req);
     149        service_id_t service_id = (service_id_t) IPC_GET_ARG1(*req);
    150150        fs_index_t index = (fs_index_t) IPC_GET_ARG2(*req);
    151151        aoff64_t pos = (aoff64_t) MERGE_LOUP32(IPC_GET_ARG3(*req),
     
    155155        int rc;
    156156
    157         rc = vfs_out_ops->write(devmap_handle, index, pos, &wbytes, &nsize);
     157        rc = vfs_out_ops->write(service_id, index, pos, &wbytes, &nsize);
    158158
    159159        if (rc == EOK)
     
    165165static void vfs_out_truncate(ipc_callid_t rid, ipc_call_t *req)
    166166{
    167         devmap_handle_t devmap_handle = (devmap_handle_t) IPC_GET_ARG1(*req);
     167        service_id_t service_id = (service_id_t) IPC_GET_ARG1(*req);
    168168        fs_index_t index = (fs_index_t) IPC_GET_ARG2(*req);
    169169        aoff64_t size = (aoff64_t) MERGE_LOUP32(IPC_GET_ARG3(*req),
     
    171171        int rc;
    172172
    173         rc = vfs_out_ops->truncate(devmap_handle, index, size);
     173        rc = vfs_out_ops->truncate(service_id, index, size);
    174174
    175175        async_answer_0(rid, rc);
     
    178178static void vfs_out_close(ipc_callid_t rid, ipc_call_t *req)
    179179{
    180         devmap_handle_t devmap_handle = (devmap_handle_t) IPC_GET_ARG1(*req);
     180        service_id_t service_id = (service_id_t) IPC_GET_ARG1(*req);
    181181        fs_index_t index = (fs_index_t) IPC_GET_ARG2(*req);
    182182        int rc;
    183183
    184         rc = vfs_out_ops->close(devmap_handle, index);
     184        rc = vfs_out_ops->close(service_id, index);
    185185
    186186        async_answer_0(rid, rc);
     
    189189static void vfs_out_destroy(ipc_callid_t rid, ipc_call_t *req)
    190190{
    191         devmap_handle_t devmap_handle = (devmap_handle_t) IPC_GET_ARG1(*req);
     191        service_id_t service_id = (service_id_t) IPC_GET_ARG1(*req);
    192192        fs_index_t index = (fs_index_t) IPC_GET_ARG2(*req);
    193193        int rc;
    194194
    195         rc = vfs_out_ops->destroy(devmap_handle, index);
     195        rc = vfs_out_ops->destroy(service_id, index);
    196196
    197197        async_answer_0(rid, rc);
     
    210210static void vfs_out_sync(ipc_callid_t rid, ipc_call_t *req)
    211211{
    212         devmap_handle_t devmap_handle = (devmap_handle_t) IPC_GET_ARG1(*req);
     212        service_id_t service_id = (service_id_t) IPC_GET_ARG1(*req);
    213213        fs_index_t index = (fs_index_t) IPC_GET_ARG2(*req);
    214214        int rc;
    215215
    216         rc = vfs_out_ops->sync(devmap_handle, index);
     216        rc = vfs_out_ops->sync(service_id, index);
    217217
    218218        async_answer_0(rid, rc);
     
    380380    ipc_call_t *req)
    381381{
    382         devmap_handle_t mp_devmap_handle = (devmap_handle_t) IPC_GET_ARG1(*req);
     382        service_id_t mp_service_id = (service_id_t) IPC_GET_ARG1(*req);
    383383        fs_index_t mp_fs_index = (fs_index_t) IPC_GET_ARG2(*req);
    384384        fs_handle_t mr_fs_handle = (fs_handle_t) IPC_GET_ARG3(*req);
    385         devmap_handle_t mr_devmap_handle = (devmap_handle_t) IPC_GET_ARG4(*req);
     385        service_id_t mr_service_id = (service_id_t) IPC_GET_ARG4(*req);
    386386       
    387387        async_sess_t *mountee_sess = async_clone_receive(EXCHANGE_PARALLEL);
     
    392392       
    393393        fs_node_t *fn;
    394         int res = ops->node_get(&fn, mp_devmap_handle, mp_fs_index);
     394        int res = ops->node_get(&fn, mp_service_id, mp_fs_index);
    395395        if ((res != EOK) || (!fn)) {
    396396                async_hangup(mountee_sess);
     
    422422        ipc_call_t answer;
    423423        int rc = async_data_write_forward_1_1(exch, VFS_OUT_MOUNTED,
    424             mr_devmap_handle, &answer);
     424            mr_service_id, &answer);
    425425        async_exchange_end(exch);
    426426       
     
    428428                fn->mp_data.mp_active = true;
    429429                fn->mp_data.fs_handle = mr_fs_handle;
    430                 fn->mp_data.devmap_handle = mr_devmap_handle;
     430                fn->mp_data.service_id = mr_service_id;
    431431                fn->mp_data.sess = mountee_sess;
    432432        }
     
    441441void libfs_unmount(libfs_ops_t *ops, ipc_callid_t rid, ipc_call_t *req)
    442442{
    443         devmap_handle_t mp_devmap_handle = (devmap_handle_t) IPC_GET_ARG1(*req);
     443        service_id_t mp_service_id = (service_id_t) IPC_GET_ARG1(*req);
    444444        fs_index_t mp_fs_index = (fs_index_t) IPC_GET_ARG2(*req);
    445445        fs_node_t *fn;
    446446        int res;
    447447
    448         res = ops->node_get(&fn, mp_devmap_handle, mp_fs_index);
     448        res = ops->node_get(&fn, mp_service_id, mp_fs_index);
    449449        if ((res != EOK) || (!fn)) {
    450450                async_answer_0(rid, combine_rc(res, ENOENT));
     
    465465         */
    466466        async_exch_t *exch = async_exchange_begin(fn->mp_data.sess);
    467         res = async_req_1_0(exch, VFS_OUT_UNMOUNTED, fn->mp_data.devmap_handle);
     467        res = async_req_1_0(exch, VFS_OUT_UNMOUNTED, fn->mp_data.service_id);
    468468        async_exchange_end(exch);
    469469
     
    475475                fn->mp_data.mp_active = false;
    476476                fn->mp_data.fs_handle = 0;
    477                 fn->mp_data.devmap_handle = 0;
     477                fn->mp_data.service_id = 0;
    478478                fn->mp_data.sess = NULL;
    479479               
     
    510510        unsigned int last = IPC_GET_ARG2(*req);
    511511        unsigned int next = first;
    512         devmap_handle_t devmap_handle = IPC_GET_ARG3(*req);
     512        service_id_t service_id = IPC_GET_ARG3(*req);
    513513        int lflag = IPC_GET_ARG4(*req);
    514514        fs_index_t index = IPC_GET_ARG5(*req);
     
    524524        fs_node_t *tmp = NULL;
    525525       
    526         rc = ops->root_get(&cur, devmap_handle);
     526        rc = ops->root_get(&cur, service_id);
    527527        on_error(rc, goto out_with_answer);
    528528       
     
    530530                async_exch_t *exch = async_exchange_begin(cur->mp_data.sess);
    531531                async_forward_slow(rid, exch, VFS_OUT_LOOKUP, next, last,
    532                     cur->mp_data.devmap_handle, lflag, index,
     532                    cur->mp_data.service_id, lflag, index,
    533533                    IPC_FF_ROUTE_FROM_ME);
    534534                async_exchange_end(exch);
     
    591591                        async_exch_t *exch = async_exchange_begin(tmp->mp_data.sess);
    592592                        async_forward_slow(rid, exch, VFS_OUT_LOOKUP, next,
    593                             last, tmp->mp_data.devmap_handle, lflag, index,
     593                            last, tmp->mp_data.service_id, lflag, index,
    594594                            IPC_FF_ROUTE_FROM_ME);
    595595                        async_exchange_end(exch);
     
    620620                                fs_node_t *fn;
    621621                                if (lflag & L_CREATE)
    622                                         rc = ops->create(&fn, devmap_handle,
     622                                        rc = ops->create(&fn, service_id,
    623623                                            lflag);
    624624                                else
    625                                         rc = ops->node_get(&fn, devmap_handle,
     625                                        rc = ops->node_get(&fn, service_id,
    626626                                            index);
    627627                                on_error(rc, goto out_with_answer);
     
    638638                                                aoff64_t size = ops->size_get(fn);
    639639                                                async_answer_5(rid, fs_handle,
    640                                                     devmap_handle,
     640                                                    service_id,
    641641                                                    ops->index_get(fn),
    642642                                                    LOWER32(size),
     
    706706                        fs_node_t *fn;
    707707                        if (lflag & L_CREATE)
    708                                 rc = ops->create(&fn, devmap_handle, lflag);
     708                                rc = ops->create(&fn, service_id, lflag);
    709709                        else
    710                                 rc = ops->node_get(&fn, devmap_handle, index);
     710                                rc = ops->node_get(&fn, service_id, index);
    711711                        on_error(rc, goto out_with_answer);
    712712                       
     
    722722                                        aoff64_t size = ops->size_get(fn);
    723723                                        async_answer_5(rid, fs_handle,
    724                                             devmap_handle,
     724                                            service_id,
    725725                                            ops->index_get(fn),
    726726                                            LOWER32(size),
     
    748748                if (rc == EOK) {
    749749                        aoff64_t size = ops->size_get(cur);
    750                         async_answer_5(rid, fs_handle, devmap_handle,
     750                        async_answer_5(rid, fs_handle, service_id,
    751751                            ops->index_get(cur), LOWER32(size), UPPER32(size),
    752752                            old_lnkcnt);
     
    786786                if (rc == EOK) {
    787787                        aoff64_t size = ops->size_get(cur);
    788                         async_answer_5(rid, fs_handle, devmap_handle,
     788                        async_answer_5(rid, fs_handle, service_id,
    789789                            ops->index_get(cur), LOWER32(size), UPPER32(size),
    790790                            ops->lnkcnt_get(cur));
     
    810810    ipc_call_t *request)
    811811{
    812         devmap_handle_t devmap_handle = (devmap_handle_t) IPC_GET_ARG1(*request);
     812        service_id_t service_id = (service_id_t) IPC_GET_ARG1(*request);
    813813        fs_index_t index = (fs_index_t) IPC_GET_ARG2(*request);
    814814       
    815815        fs_node_t *fn;
    816         int rc = ops->node_get(&fn, devmap_handle, index);
     816        int rc = ops->node_get(&fn, service_id, index);
    817817        on_error(rc, answer_and_return(rid, rc));
    818818       
     
    831831       
    832832        stat.fs_handle = fs_handle;
    833         stat.devmap_handle = devmap_handle;
     833        stat.service_id = service_id;
    834834        stat.index = index;
    835835        stat.lnkcnt = ops->lnkcnt_get(fn);
     
    837837        stat.is_directory = ops->is_directory(fn);
    838838        stat.size = ops->size_get(fn);
    839         stat.device = ops->device_get(fn);
     839        stat.service = ops->device_get(fn);
    840840       
    841841        ops->node_put(fn);
     
    856856    ipc_call_t *request)
    857857{
    858         devmap_handle_t devmap_handle = IPC_GET_ARG1(*request);
     858        service_id_t service_id = IPC_GET_ARG1(*request);
    859859        fs_index_t index = IPC_GET_ARG2(*request);
    860860       
    861861        fs_node_t *fn;
    862         int rc = ops->node_get(&fn, devmap_handle, index);
     862        int rc = ops->node_get(&fn, service_id, index);
    863863        on_error(rc, answer_and_return(rid, rc));
    864864       
  • uspace/lib/fs/libfs.h

    r3751a08 r16dc887  
    4040#include <stdint.h>
    4141#include <async.h>
    42 #include <devmap.h>
     42#include <loc.h>
    4343
    4444typedef struct {
    45         int (* mounted)(devmap_handle_t, const char *, fs_index_t *, aoff64_t *,
     45        int (* mounted)(service_id_t, const char *, fs_index_t *, aoff64_t *,
    4646            unsigned *);
    47         int (* unmounted)(devmap_handle_t);
    48         int (* read)(devmap_handle_t, fs_index_t, aoff64_t, size_t *);
    49         int (* write)(devmap_handle_t, fs_index_t, aoff64_t, size_t *,
     47        int (* unmounted)(service_id_t);
     48        int (* read)(service_id_t, fs_index_t, aoff64_t, size_t *);
     49        int (* write)(service_id_t, fs_index_t, aoff64_t, size_t *,
    5050            aoff64_t *);
    51         int (* truncate)(devmap_handle_t, fs_index_t, aoff64_t);
    52         int (* close)(devmap_handle_t, fs_index_t);
    53         int (* destroy)(devmap_handle_t, fs_index_t);
    54         int (* sync)(devmap_handle_t, fs_index_t);
     51        int (* truncate)(service_id_t, fs_index_t, aoff64_t);
     52        int (* close)(service_id_t, fs_index_t);
     53        int (* destroy)(service_id_t, fs_index_t);
     54        int (* sync)(service_id_t, fs_index_t);
    5555} vfs_out_ops_t;
    5656
     
    5959        async_sess_t *sess;
    6060        fs_handle_t fs_handle;
    61         devmap_handle_t devmap_handle;
     61        service_id_t service_id;
    6262} mp_data_t;
    6363
     
    7373         * argument holds the output argument.
    7474         */
    75         int (* root_get)(fs_node_t **, devmap_handle_t);
     75        int (* root_get)(fs_node_t **, service_id_t);
    7676        int (* match)(fs_node_t **, fs_node_t *, const char *);
    77         int (* node_get)(fs_node_t **, devmap_handle_t, fs_index_t);
     77        int (* node_get)(fs_node_t **, service_id_t, fs_index_t);
    7878        int (* node_open)(fs_node_t *);
    7979        int (* node_put)(fs_node_t *);
    80         int (* create)(fs_node_t **, devmap_handle_t, int);
     80        int (* create)(fs_node_t **, service_id_t, int);
    8181        int (* destroy)(fs_node_t *);
    8282        int (* link)(fs_node_t *, fs_node_t *, const char *);
     
    9292        bool (* is_directory)(fs_node_t *);
    9393        bool (* is_file)(fs_node_t *);
    94         devmap_handle_t (* device_get)(fs_node_t *);
     94        service_id_t (* device_get)(fs_node_t *);
    9595} libfs_ops_t;
    9696
Note: See TracChangeset for help on using the changeset viewer.