nmh               740 fs/ocfs2/cluster/tcp.c static int o2net_handler_cmp(struct o2net_msg_handler *nmh, u32 msg_type,
nmh               743 fs/ocfs2/cluster/tcp.c 	int ret = memcmp(&nmh->nh_key, &key, sizeof(key));
nmh               746 fs/ocfs2/cluster/tcp.c 		ret = memcmp(&nmh->nh_msg_type, &msg_type, sizeof(msg_type));
nmh               757 fs/ocfs2/cluster/tcp.c 	struct o2net_msg_handler *nmh, *ret = NULL;
nmh               762 fs/ocfs2/cluster/tcp.c 		nmh = rb_entry(parent, struct o2net_msg_handler, nh_node);
nmh               763 fs/ocfs2/cluster/tcp.c 		cmp = o2net_handler_cmp(nmh, msg_type, key);
nmh               770 fs/ocfs2/cluster/tcp.c 			ret = nmh;
nmh               785 fs/ocfs2/cluster/tcp.c 	struct o2net_msg_handler *nmh;
nmh               786 fs/ocfs2/cluster/tcp.c 	nmh = container_of(kref, struct o2net_msg_handler, nh_kref);
nmh               788 fs/ocfs2/cluster/tcp.c 	kfree(nmh);
nmh               791 fs/ocfs2/cluster/tcp.c static void o2net_handler_put(struct o2net_msg_handler *nmh)
nmh               793 fs/ocfs2/cluster/tcp.c 	kref_put(&nmh->nh_kref, o2net_handler_kref_release);
nmh               803 fs/ocfs2/cluster/tcp.c 	struct o2net_msg_handler *nmh = NULL;
nmh               827 fs/ocfs2/cluster/tcp.c        	nmh = kzalloc(sizeof(struct o2net_msg_handler), GFP_NOFS);
nmh               828 fs/ocfs2/cluster/tcp.c 	if (nmh == NULL) {
nmh               833 fs/ocfs2/cluster/tcp.c 	nmh->nh_func = func;
nmh               834 fs/ocfs2/cluster/tcp.c 	nmh->nh_func_data = data;
nmh               835 fs/ocfs2/cluster/tcp.c 	nmh->nh_post_func = post_func;
nmh               836 fs/ocfs2/cluster/tcp.c 	nmh->nh_msg_type = msg_type;
nmh               837 fs/ocfs2/cluster/tcp.c 	nmh->nh_max_len = max_len;
nmh               838 fs/ocfs2/cluster/tcp.c 	nmh->nh_key = key;
nmh               841 fs/ocfs2/cluster/tcp.c 	kref_init(&nmh->nh_kref);
nmh               842 fs/ocfs2/cluster/tcp.c 	INIT_LIST_HEAD(&nmh->nh_unregister_item);
nmh               848 fs/ocfs2/cluster/tcp.c 	        rb_link_node(&nmh->nh_node, parent, p);
nmh               849 fs/ocfs2/cluster/tcp.c 		rb_insert_color(&nmh->nh_node, &o2net_handler_tree);
nmh               850 fs/ocfs2/cluster/tcp.c 		list_add_tail(&nmh->nh_unregister_item, unreg_list);
nmh               864 fs/ocfs2/cluster/tcp.c 		kfree(nmh);
nmh               872 fs/ocfs2/cluster/tcp.c 	struct o2net_msg_handler *nmh, *n;
nmh               875 fs/ocfs2/cluster/tcp.c 	list_for_each_entry_safe(nmh, n, list, nh_unregister_item) {
nmh               877 fs/ocfs2/cluster/tcp.c 		     nmh->nh_func, nmh->nh_msg_type, nmh->nh_key);
nmh               878 fs/ocfs2/cluster/tcp.c 		rb_erase(&nmh->nh_node, &o2net_handler_tree);
nmh               879 fs/ocfs2/cluster/tcp.c 		list_del_init(&nmh->nh_unregister_item);
nmh               880 fs/ocfs2/cluster/tcp.c 		kref_put(&nmh->nh_kref, o2net_handler_kref_release);
nmh               888 fs/ocfs2/cluster/tcp.c 	struct o2net_msg_handler *nmh;
nmh               891 fs/ocfs2/cluster/tcp.c 	nmh = o2net_handler_tree_lookup(msg_type, key, NULL, NULL);
nmh               892 fs/ocfs2/cluster/tcp.c 	if (nmh)
nmh               893 fs/ocfs2/cluster/tcp.c 		kref_get(&nmh->nh_kref);
nmh               896 fs/ocfs2/cluster/tcp.c 	return nmh;
nmh              1174 fs/ocfs2/cluster/tcp.c 	struct o2net_msg_handler *nmh = NULL;
nmh              1206 fs/ocfs2/cluster/tcp.c 	nmh = o2net_handler_get(be16_to_cpu(hdr->msg_type),
nmh              1208 fs/ocfs2/cluster/tcp.c 	if (!nmh) {
nmh              1217 fs/ocfs2/cluster/tcp.c 	if (be16_to_cpu(hdr->data_len) > nmh->nh_max_len)
nmh              1226 fs/ocfs2/cluster/tcp.c 	handler_status = (nmh->nh_func)(hdr, sizeof(struct o2net_msg) +
nmh              1228 fs/ocfs2/cluster/tcp.c 					nmh->nh_func_data, &ret_data);
nmh              1243 fs/ocfs2/cluster/tcp.c 	if (nmh) {
nmh              1244 fs/ocfs2/cluster/tcp.c 		BUG_ON(ret_data != NULL && nmh->nh_post_func == NULL);
nmh              1245 fs/ocfs2/cluster/tcp.c 		if (nmh->nh_post_func)
nmh              1246 fs/ocfs2/cluster/tcp.c 			(nmh->nh_post_func)(handler_status, nmh->nh_func_data,
nmh              1251 fs/ocfs2/cluster/tcp.c 	if (nmh)
nmh              1252 fs/ocfs2/cluster/tcp.c 		o2net_handler_put(nmh);