Lines Matching refs:nmh
694 static int o2net_handler_cmp(struct o2net_msg_handler *nmh, u32 msg_type,
697 int ret = memcmp(&nmh->nh_key, &key, sizeof(key));
700 ret = memcmp(&nmh->nh_msg_type, &msg_type, sizeof(msg_type));
711 struct o2net_msg_handler *nmh, *ret = NULL;
716 nmh = rb_entry(parent, struct o2net_msg_handler, nh_node);
717 cmp = o2net_handler_cmp(nmh, msg_type, key);
724 ret = nmh;
739 struct o2net_msg_handler *nmh;
740 nmh = container_of(kref, struct o2net_msg_handler, nh_kref);
742 kfree(nmh);
745 static void o2net_handler_put(struct o2net_msg_handler *nmh)
747 kref_put(&nmh->nh_kref, o2net_handler_kref_release);
757 struct o2net_msg_handler *nmh = NULL;
781 nmh = kzalloc(sizeof(struct o2net_msg_handler), GFP_NOFS);
782 if (nmh == NULL) {
787 nmh->nh_func = func;
788 nmh->nh_func_data = data;
789 nmh->nh_post_func = post_func;
790 nmh->nh_msg_type = msg_type;
791 nmh->nh_max_len = max_len;
792 nmh->nh_key = key;
795 kref_init(&nmh->nh_kref);
796 INIT_LIST_HEAD(&nmh->nh_unregister_item);
802 rb_link_node(&nmh->nh_node, parent, p);
803 rb_insert_color(&nmh->nh_node, &o2net_handler_tree);
804 list_add_tail(&nmh->nh_unregister_item, unreg_list);
820 kfree(nmh);
828 struct o2net_msg_handler *nmh, *n;
831 list_for_each_entry_safe(nmh, n, list, nh_unregister_item) {
833 nmh->nh_func, nmh->nh_msg_type, nmh->nh_key);
834 rb_erase(&nmh->nh_node, &o2net_handler_tree);
835 list_del_init(&nmh->nh_unregister_item);
836 kref_put(&nmh->nh_kref, o2net_handler_kref_release);
844 struct o2net_msg_handler *nmh;
847 nmh = o2net_handler_tree_lookup(msg_type, key, NULL, NULL);
848 if (nmh)
849 kref_get(&nmh->nh_kref);
852 return nmh;
1136 struct o2net_msg_handler *nmh = NULL;
1168 nmh = o2net_handler_get(be16_to_cpu(hdr->msg_type),
1170 if (!nmh) {
1179 if (be16_to_cpu(hdr->data_len) > nmh->nh_max_len)
1188 handler_status = (nmh->nh_func)(hdr, sizeof(struct o2net_msg) +
1190 nmh->nh_func_data, &ret_data);
1203 if (nmh) {
1204 BUG_ON(ret_data != NULL && nmh->nh_post_func == NULL);
1205 if (nmh->nh_post_func)
1206 (nmh->nh_post_func)(handler_status, nmh->nh_func_data,
1211 if (nmh)
1212 o2net_handler_put(nmh);