Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed
  • uspace/srv/devman/devman.c

    r15f3c3f r4022513  
    3737#include <ipc/driver.h>
    3838#include <ipc/devman.h>
    39 #include <loc.h>
     39#include <devmap.h>
    4040#include <str_error.h>
    4141#include <stdio.h>
     
    6666}
    6767
    68 static int loc_functions_compare(unsigned long key[], hash_count_t keys,
     68static int devmap_functions_compare(unsigned long key[], hash_count_t keys,
    6969    link_t *item)
    7070{
    71         fun_node_t *fun = hash_table_get_instance(item, fun_node_t, loc_fun);
    72         return (fun->service_id == (service_id_t) key[0]);
    73 }
    74 
    75 static int loc_devices_class_compare(unsigned long key[], hash_count_t keys,
     71        fun_node_t *fun = hash_table_get_instance(item, fun_node_t, devmap_fun);
     72        return (fun->devmap_handle == (devmap_handle_t) key[0]);
     73}
     74
     75static int devmap_devices_class_compare(unsigned long key[], hash_count_t keys,
    7676    link_t *item)
    7777{
    7878        dev_class_info_t *class_info
    79             = hash_table_get_instance(item, dev_class_info_t, loc_link);
     79            = hash_table_get_instance(item, dev_class_info_t, devmap_link);
    8080        assert(class_info != NULL);
    8181
    82         return (class_info->service_id == (service_id_t) key[0]);
     82        return (class_info->devmap_handle == (devmap_handle_t) key[0]);
    8383}
    8484
     
    9999};
    100100
    101 static hash_table_operations_t loc_devices_ops = {
     101static hash_table_operations_t devmap_devices_ops = {
    102102        .hash = devices_hash,
    103         .compare = loc_functions_compare,
     103        .compare = devmap_functions_compare,
    104104        .remove_callback = devices_remove_callback
    105105};
    106106
    107 static hash_table_operations_t loc_devices_class_ops = {
     107static hash_table_operations_t devmap_devices_class_ops = {
    108108        .hash = devices_hash,
    109         .compare = loc_devices_class_compare,
     109        .compare = devmap_devices_class_compare,
    110110        .remove_callback = devices_remove_callback
    111111};
     
    270270        }
    271271       
    272         ssize_t read_bytes = safe_read(fd, buf, len);
     272        ssize_t read_bytes = read_all(fd, buf, len);
    273273        if (read_bytes <= 0) {
    274                 log_msg(LVL_ERROR, "Unable to read file '%s'.", conf_path);
     274                log_msg(LVL_ERROR, "Unable to read file '%s' (%zd).", conf_path,
     275                    read_bytes);
    275276                goto cleanup;
    276277        }
     
    421422        }
    422423       
    423         insert_fun_node(tree, fun, clone_string(""), NULL);
     424        insert_fun_node(tree, fun, str_dup(""), NULL);
    424425        match_id_t *id = create_match_id();
    425         id->id = clone_string("root");
     426        id->id = str_dup("root");
    426427        id->score = 100;
    427428        add_match_id(&fun->match_ids, id);
     
    700701}
    701702
    702 /** Create loc path and name for the function. */
    703 void loc_register_tree_function(fun_node_t *fun, dev_tree_t *tree)
    704 {
    705         char *loc_pathname = NULL;
    706         char *loc_name = NULL;
    707        
    708         asprintf(&loc_name, "%s", fun->pathname);
    709         if (loc_name == NULL)
     703/** Create devmap path and name for the function. */
     704void devmap_register_tree_function(fun_node_t *fun, dev_tree_t *tree)
     705{
     706        char *devmap_pathname = NULL;
     707        char *devmap_name = NULL;
     708       
     709        asprintf(&devmap_name, "%s", fun->pathname);
     710        if (devmap_name == NULL)
    710711                return;
    711712       
    712         replace_char(loc_name, '/', LOC_SEPARATOR);
    713        
    714         asprintf(&loc_pathname, "%s/%s", LOC_DEVICE_NAMESPACE,
    715             loc_name);
    716         if (loc_pathname == NULL) {
    717                 free(loc_name);
     713        replace_char(devmap_name, '/', DEVMAP_SEPARATOR);
     714       
     715        asprintf(&devmap_pathname, "%s/%s", DEVMAP_DEVICE_NAMESPACE,
     716            devmap_name);
     717        if (devmap_pathname == NULL) {
     718                free(devmap_name);
    718719                return;
    719720        }
    720721       
    721         loc_service_register_with_iface(loc_pathname,
    722             &fun->service_id, DEVMAN_CONNECT_FROM_LOC);
    723        
    724         tree_add_loc_function(tree, fun);
    725        
    726         free(loc_name);
    727         free(loc_pathname);
     722        devmap_device_register_with_iface(devmap_pathname,
     723            &fun->devmap_handle, DEVMAN_CONNECT_FROM_DEVMAP);
     724       
     725        tree_add_devmap_function(tree, fun);
     726       
     727        free(devmap_name);
     728        free(devmap_pathname);
    728729}
    729730
     
    855856        hash_table_create(&tree->devman_functions, DEVICE_BUCKETS, 1,
    856857            &devman_functions_ops);
    857         hash_table_create(&tree->loc_functions, DEVICE_BUCKETS, 1,
    858             &loc_devices_ops);
     858        hash_table_create(&tree->devmap_functions, DEVICE_BUCKETS, 1,
     859            &devmap_devices_ops);
    859860       
    860861        fibril_rwlock_initialize(&tree->rwlock);
     
    951952                list_initialize(&res->classes);
    952953                link_initialize(&res->devman_fun);
    953                 link_initialize(&res->loc_fun);
     954                link_initialize(&res->devmap_fun);
    954955        }
    955956       
     
    12671268                memset(info, 0, sizeof(dev_class_info_t));
    12681269                link_initialize(&info->dev_classes);
    1269                 link_initialize(&info->loc_link);
     1270                link_initialize(&info->devmap_link);
    12701271                link_initialize(&info->link);
    12711272        }
     
    14131414        list_initialize(&class_list->classes);
    14141415        fibril_rwlock_initialize(&class_list->rwlock);
    1415         hash_table_create(&class_list->loc_functions, DEVICE_BUCKETS, 1,
    1416             &loc_devices_class_ops);
    1417 }
    1418 
    1419 
    1420 /* loc devices */
    1421 
    1422 fun_node_t *find_loc_tree_function(dev_tree_t *tree, service_id_t service_id)
     1416        hash_table_create(&class_list->devmap_functions, DEVICE_BUCKETS, 1,
     1417            &devmap_devices_class_ops);
     1418}
     1419
     1420
     1421/* Devmap devices */
     1422
     1423fun_node_t *find_devmap_tree_function(dev_tree_t *tree, devmap_handle_t devmap_handle)
    14231424{
    14241425        fun_node_t *fun = NULL;
    14251426        link_t *link;
    1426         unsigned long key = (unsigned long) service_id;
     1427        unsigned long key = (unsigned long) devmap_handle;
    14271428       
    14281429        fibril_rwlock_read_lock(&tree->rwlock);
    1429         link = hash_table_find(&tree->loc_functions, &key);
     1430        link = hash_table_find(&tree->devmap_functions, &key);
    14301431        if (link != NULL)
    1431                 fun = hash_table_get_instance(link, fun_node_t, loc_fun);
     1432                fun = hash_table_get_instance(link, fun_node_t, devmap_fun);
    14321433        fibril_rwlock_read_unlock(&tree->rwlock);
    14331434       
     
    14351436}
    14361437
    1437 fun_node_t *find_loc_class_function(class_list_t *classes,
    1438     service_id_t service_id)
     1438fun_node_t *find_devmap_class_function(class_list_t *classes,
     1439    devmap_handle_t devmap_handle)
    14391440{
    14401441        fun_node_t *fun = NULL;
    14411442        dev_class_info_t *cli;
    14421443        link_t *link;
    1443         unsigned long key = (unsigned long)service_id;
     1444        unsigned long key = (unsigned long)devmap_handle;
    14441445       
    14451446        fibril_rwlock_read_lock(&classes->rwlock);
    1446         link = hash_table_find(&classes->loc_functions, &key);
     1447        link = hash_table_find(&classes->devmap_functions, &key);
    14471448        if (link != NULL) {
    14481449                cli = hash_table_get_instance(link, dev_class_info_t,
    1449                     loc_link);
     1450                    devmap_link);
    14501451                fun = cli->fun;
    14511452        }
     
    14551456}
    14561457
    1457 void class_add_loc_function(class_list_t *class_list, dev_class_info_t *cli)
    1458 {
    1459         unsigned long key = (unsigned long) cli->service_id;
     1458void class_add_devmap_function(class_list_t *class_list, dev_class_info_t *cli)
     1459{
     1460        unsigned long key = (unsigned long) cli->devmap_handle;
    14601461       
    14611462        fibril_rwlock_write_lock(&class_list->rwlock);
    1462         hash_table_insert(&class_list->loc_functions, &key, &cli->loc_link);
     1463        hash_table_insert(&class_list->devmap_functions, &key, &cli->devmap_link);
    14631464        fibril_rwlock_write_unlock(&class_list->rwlock);
    14641465
    1465         assert(find_loc_class_function(class_list, cli->service_id) != NULL);
    1466 }
    1467 
    1468 void tree_add_loc_function(dev_tree_t *tree, fun_node_t *fun)
    1469 {
    1470         unsigned long key = (unsigned long) fun->service_id;
     1466        assert(find_devmap_class_function(class_list, cli->devmap_handle) != NULL);
     1467}
     1468
     1469void tree_add_devmap_function(dev_tree_t *tree, fun_node_t *fun)
     1470{
     1471        unsigned long key = (unsigned long) fun->devmap_handle;
    14711472        fibril_rwlock_write_lock(&tree->rwlock);
    1472         hash_table_insert(&tree->loc_functions, &key, &fun->loc_fun);
     1473        hash_table_insert(&tree->devmap_functions, &key, &fun->devmap_fun);
    14731474        fibril_rwlock_write_unlock(&tree->rwlock);
    14741475}
Note: See TracChangeset for help on using the changeset viewer.