Lines Matching defs:nmh
626 static int o2net_handler_cmp(struct o2net_msg_handler *nmh, u32 msg_type,
629 int ret = memcmp(&nmh->nh_key, &key, sizeof(key));
632 ret = memcmp(&nmh->nh_msg_type, &msg_type, sizeof(msg_type));
643 struct o2net_msg_handler *nmh, *ret = NULL;
648 nmh = rb_entry(parent, struct o2net_msg_handler, nh_node);
649 cmp = o2net_handler_cmp(nmh, msg_type, key);
656 ret = nmh;
671 struct o2net_msg_handler *nmh;
672 nmh = container_of(kref, struct o2net_msg_handler, nh_kref);
674 kfree(nmh);
677 static void o2net_handler_put(struct o2net_msg_handler *nmh)
679 kref_put(&nmh->nh_kref, o2net_handler_kref_release);
689 struct o2net_msg_handler *nmh = NULL;
713 nmh = kzalloc(sizeof(struct o2net_msg_handler), GFP_NOFS);
714 if (nmh == NULL) {
719 nmh->nh_func = func;
720 nmh->nh_func_data = data;
721 nmh->nh_post_func = post_func;
722 nmh->nh_msg_type = msg_type;
723 nmh->nh_max_len = max_len;
724 nmh->nh_key = key;
727 kref_init(&nmh->nh_kref);
728 INIT_LIST_HEAD(&nmh->nh_unregister_item);
734 rb_link_node(&nmh->nh_node, parent, p);
735 rb_insert_color(&nmh->nh_node, &o2net_handler_tree);
736 list_add_tail(&nmh->nh_unregister_item, unreg_list);
752 kfree(nmh);
761 struct o2net_msg_handler *nmh;
765 nmh = list_entry(pos, struct o2net_msg_handler,
768 nmh->nh_func, nmh->nh_msg_type, nmh->nh_key);
769 rb_erase(&nmh->nh_node, &o2net_handler_tree);
770 list_del_init(&nmh->nh_unregister_item);
771 kref_put(&nmh->nh_kref, o2net_handler_kref_release);
779 struct o2net_msg_handler *nmh;
782 nmh = o2net_handler_tree_lookup(msg_type, key, NULL, NULL);
783 if (nmh)
784 kref_get(&nmh->nh_kref);
787 return nmh;
1052 struct o2net_msg_handler *nmh = NULL;
1084 nmh = o2net_handler_get(be16_to_cpu(hdr->msg_type),
1086 if (!nmh) {
1095 if (be16_to_cpu(hdr->data_len) > nmh->nh_max_len)
1104 handler_status = (nmh->nh_func)(hdr, sizeof(struct o2net_msg) +
1106 nmh->nh_func_data, &ret_data);
1119 if (nmh) {
1120 BUG_ON(ret_data != NULL && nmh->nh_post_func == NULL);
1121 if (nmh->nh_post_func)
1122 (nmh->nh_post_func)(handler_status, nmh->nh_func_data,
1127 if (nmh)
1128 o2net_handler_put(nmh);