Blame view
net/tipc/node_subscr.c
3.21 KB
b97bf3fd8 [TIPC] Initial merge |
1 2 |
/* * net/tipc/node_subscr.c: TIPC "node down" subscription handling |
c43072852 [NET] TIPC: Fix w... |
3 |
* |
593a5f22d [TIPC] More updat... |
4 |
* Copyright (c) 1995-2006, Ericsson AB |
f13791733 tipc: Cosmetic ch... |
5 |
* Copyright (c) 2005, 2010-2011, Wind River Systems |
b97bf3fd8 [TIPC] Initial merge |
6 7 |
* All rights reserved. * |
9ea1fd3c1 [TIPC] License he... |
8 |
* Redistribution and use in source and binary forms, with or without |
b97bf3fd8 [TIPC] Initial merge |
9 10 |
* modification, are permitted provided that the following conditions are met: * |
9ea1fd3c1 [TIPC] License he... |
11 12 13 14 15 16 17 18 |
* 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * 3. Neither the names of the copyright holders nor the names of its * contributors may be used to endorse or promote products derived from * this software without specific prior written permission. |
b97bf3fd8 [TIPC] Initial merge |
19 |
* |
9ea1fd3c1 [TIPC] License he... |
20 21 22 23 24 25 26 27 28 29 30 31 32 33 |
* Alternatively, this software may be distributed under the terms of the * GNU General Public License ("GPL") version 2 as published by the Free * Software Foundation. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE |
b97bf3fd8 [TIPC] Initial merge |
34 35 36 37 |
* POSSIBILITY OF SUCH DAMAGE. */ #include "core.h" |
b97bf3fd8 [TIPC] Initial merge |
38 39 |
#include "node_subscr.h" #include "node.h" |
b97bf3fd8 [TIPC] Initial merge |
40 41 |
/** |
4323add67 [TIPC] Avoid poll... |
42 |
* tipc_nodesub_subscribe - create "node down" subscription for specified node |
b97bf3fd8 [TIPC] Initial merge |
43 |
*/ |
6c00055a8 tipc: Don't use s... |
44 |
void tipc_nodesub_subscribe(struct tipc_node_subscr *node_sub, u32 addr, |
b97bf3fd8 [TIPC] Initial merge |
45 46 |
void *usr_handle, net_ev_handler handle_down) { |
f131072c3 [TIPC]: First pha... |
47 48 |
if (addr == tipc_own_addr) { node_sub->node = NULL; |
b97bf3fd8 [TIPC] Initial merge |
49 |
return; |
f131072c3 [TIPC]: First pha... |
50 |
} |
c43072852 [NET] TIPC: Fix w... |
51 |
|
f131072c3 [TIPC]: First pha... |
52 53 54 55 |
node_sub->node = tipc_node_find(addr); if (!node_sub->node) { warn("Node subscription rejected, unknown node 0x%x ", addr); |
b97bf3fd8 [TIPC] Initial merge |
56 57 |
return; } |
b97bf3fd8 [TIPC] Initial merge |
58 59 |
node_sub->handle_node_down = handle_down; node_sub->usr_handle = usr_handle; |
f131072c3 [TIPC]: First pha... |
60 |
|
4323add67 [TIPC] Avoid poll... |
61 |
tipc_node_lock(node_sub->node); |
b97bf3fd8 [TIPC] Initial merge |
62 |
list_add_tail(&node_sub->nodesub_list, &node_sub->node->nsub); |
4323add67 [TIPC] Avoid poll... |
63 |
tipc_node_unlock(node_sub->node); |
b97bf3fd8 [TIPC] Initial merge |
64 65 66 |
} /** |
4323add67 [TIPC] Avoid poll... |
67 |
* tipc_nodesub_unsubscribe - cancel "node down" subscription (if any) |
b97bf3fd8 [TIPC] Initial merge |
68 |
*/ |
6c00055a8 tipc: Don't use s... |
69 |
void tipc_nodesub_unsubscribe(struct tipc_node_subscr *node_sub) |
b97bf3fd8 [TIPC] Initial merge |
70 71 72 |
{ if (!node_sub->node) return; |
4323add67 [TIPC] Avoid poll... |
73 |
tipc_node_lock(node_sub->node); |
b97bf3fd8 [TIPC] Initial merge |
74 |
list_del_init(&node_sub->nodesub_list); |
4323add67 [TIPC] Avoid poll... |
75 |
tipc_node_unlock(node_sub->node); |
b97bf3fd8 [TIPC] Initial merge |
76 |
} |
f13791733 tipc: Cosmetic ch... |
77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 |
/** * tipc_nodesub_notify - notify subscribers that a node is unreachable * * Note: node is locked by caller */ void tipc_nodesub_notify(struct tipc_node *node) { struct tipc_node_subscr *ns; list_for_each_entry(ns, &node->nsub, nodesub_list) { if (ns->handle_node_down) { tipc_k_signal((Handler)ns->handle_node_down, (unsigned long)ns->usr_handle); ns->handle_node_down = NULL; } } } |