Changes in uspace/srv/fs/mfs/mfs_ops.c [4e00f87:9d58539] in mainline
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/fs/mfs/mfs_ops.c
r4e00f87 r9d58539 35 35 #include <align.h> 36 36 #include <adt/hash_table.h> 37 #include <adt/hash.h>38 37 #include "mfs.h" 39 38 39 #define OPEN_NODES_KEYS 2 40 #define OPEN_NODES_SERVICE_KEY 0 41 #define OPEN_NODES_INODE_KEY 1 42 #define OPEN_NODES_BUCKETS 256 40 43 41 44 static bool check_magic_number(uint16_t magic, bool *native, … … 58 61 static int mfs_unlink(fs_node_t *, fs_node_t *, const char *name); 59 62 static int mfs_destroy_node(fs_node_t *fn); 63 static hash_index_t open_nodes_hash(unsigned long key[]); 64 static int open_nodes_compare(unsigned long key[], hash_count_t keys, 65 link_t *item); 66 static void open_nodes_remove_cb(link_t *link); 60 67 static int mfs_node_get(fs_node_t **rfn, service_id_t service_id, 61 68 fs_index_t index); … … 88 95 89 96 /* Hash table interface for open nodes hash table */ 90 91 typedef struct { 92 service_id_t service_id; 93 fs_index_t index;94 } node_key_t;95 96 static size_t 97 open_nodes_key_hash(void *key) 98 { 99 node_key_t *node_key = (node_key_t*)key; 100 return hash_combine(node_key->service_id, node_key->index); 101 } 102 103 static size_t 104 open_nodes_hash(const ht_link_t *item) 105 { 106 struct mfs_node *m = hash_table_get_inst(item, struct mfs_node, link);107 return hash_combine(m->instance->service_id, m->ino_i->index);108 } 109 110 static bool 111 open_nodes_key_equal(void *key, const ht_link_t *item) 112 { 113 node_key_t *node_key = (node_key_t*)key; 114 struct mfs_node *mnode = hash_table_get_inst(item, struct mfs_node, link); 115 116 return node_key->service_id == mnode->instance->service_id 117 && node_key->index == mnode->ino_i->index;118 } 119 120 static hash_table_op s_t open_nodes_ops = {97 static hash_index_t 98 open_nodes_hash(unsigned long key[]) 99 { 100 /* TODO: This is very simple and probably can be improved */ 101 return key[OPEN_NODES_INODE_KEY] % OPEN_NODES_BUCKETS; 102 } 103 104 static int 105 open_nodes_compare(unsigned long key[], hash_count_t keys, 106 link_t *item) 107 { 108 struct mfs_node *mnode = hash_table_get_instance(item, struct mfs_node, link); 109 assert(keys > 0); 110 if (mnode->instance->service_id != 111 ((service_id_t) key[OPEN_NODES_SERVICE_KEY])) { 112 return false; 113 } 114 if (keys == 1) { 115 return true; 116 } 117 assert(keys == 2); 118 return (mnode->ino_i->index == key[OPEN_NODES_INODE_KEY]); 119 } 120 121 static void 122 open_nodes_remove_cb(link_t *link) 123 { 124 /* We don't use remove callback for this hash table */ 125 } 126 127 static hash_table_operations_t open_nodes_ops = { 121 128 .hash = open_nodes_hash, 122 .key_hash = open_nodes_key_hash, 123 .key_equal = open_nodes_key_equal, 124 .equal = NULL, 125 .remove_callback = NULL, 129 .compare = open_nodes_compare, 130 .remove_callback = open_nodes_remove_cb, 126 131 }; 127 132 … … 129 134 mfs_global_init(void) 130 135 { 131 if (!hash_table_create(&open_nodes, 0, 0, &open_nodes_ops)) { 136 if (!hash_table_create(&open_nodes, OPEN_NODES_BUCKETS, 137 OPEN_NODES_KEYS, &open_nodes_ops)) { 132 138 return ENOMEM; 133 139 } … … 400 406 mnode->refcnt = 1; 401 407 408 link_initialize(&mnode->link); 409 410 unsigned long key[] = { 411 [OPEN_NODES_SERVICE_KEY] = inst->service_id, 412 [OPEN_NODES_INODE_KEY] = inum, 413 }; 414 402 415 fibril_mutex_lock(&open_nodes_lock); 403 hash_table_insert(&open_nodes, &mnode->link);416 hash_table_insert(&open_nodes, key, &mnode->link); 404 417 fibril_mutex_unlock(&open_nodes_lock); 405 418 inst->open_nodes_cnt++; … … 500 513 mnode->refcnt--; 501 514 if (mnode->refcnt == 0) { 502 hash_table_remove_item(&open_nodes, &mnode->link); 515 unsigned long key[] = { 516 [OPEN_NODES_SERVICE_KEY] = mnode->instance->service_id, 517 [OPEN_NODES_INODE_KEY] = mnode->ino_i->index 518 }; 519 hash_table_remove(&open_nodes, key, OPEN_NODES_KEYS); 503 520 assert(mnode->instance->open_nodes_cnt > 0); 504 521 mnode->instance->open_nodes_cnt--; … … 559 576 560 577 /* Check if the node is not already open */ 561 node_key_t key= {562 .service_id= inst->service_id,563 .index = index578 unsigned long key[] = { 579 [OPEN_NODES_SERVICE_KEY] = inst->service_id, 580 [OPEN_NODES_INODE_KEY] = index, 564 581 }; 565 566 ht_link_t *already_open = hash_table_find(&open_nodes, &key); 582 link_t *already_open = hash_table_find(&open_nodes, key); 567 583 568 584 if (already_open) { 569 mnode = hash_table_get_inst (already_open, struct mfs_node, link);585 mnode = hash_table_get_instance(already_open, struct mfs_node, link); 570 586 *rfn = mnode->fsnode; 571 587 mnode->refcnt++; … … 598 614 mnode->ino_i = ino_i; 599 615 mnode->refcnt = 1; 616 link_initialize(&mnode->link); 600 617 601 618 mnode->instance = inst; … … 604 621 *rfn = node; 605 622 606 hash_table_insert(&open_nodes, &mnode->link);623 hash_table_insert(&open_nodes, key, &mnode->link); 607 624 inst->open_nodes_cnt++; 608 625
Note:
See TracChangeset
for help on using the changeset viewer.