| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  | /*
 | 
					
						
							|  |  |  |  * net/tipc/node_subscr.c: TIPC "node down" subscription handling | 
					
						
							| 
									
										
										
										
											2007-02-09 23:25:21 +09:00
										 |  |  |  * | 
					
						
							| 
									
										
										
										
											2006-01-11 19:14:19 +01:00
										 |  |  |  * Copyright (c) 1995-2006, Ericsson AB | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  |  * Copyright (c) 2005, Wind River Systems | 
					
						
							|  |  |  |  * All rights reserved. | 
					
						
							|  |  |  |  * | 
					
						
							| 
									
										
										
										
											2006-01-11 13:30:43 +01:00
										 |  |  |  * Redistribution and use in source and binary forms, with or without | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  |  * modification, are permitted provided that the following conditions are met: | 
					
						
							|  |  |  |  * | 
					
						
							| 
									
										
										
										
											2006-01-11 13:30:43 +01:00
										 |  |  |  * 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. | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  |  * | 
					
						
							| 
									
										
										
										
											2006-01-11 13:30:43 +01:00
										 |  |  |  * 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 | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  |  * POSSIBILITY OF SUCH DAMAGE. | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | #include "core.h"
 | 
					
						
							|  |  |  | #include "dbg.h"
 | 
					
						
							|  |  |  | #include "node_subscr.h"
 | 
					
						
							|  |  |  | #include "node.h"
 | 
					
						
							|  |  |  | #include "addr.h"
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | /**
 | 
					
						
							| 
									
										
										
										
											2006-01-18 00:38:21 +01:00
										 |  |  |  * tipc_nodesub_subscribe - create "node down" subscription for specified node | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2008-09-02 23:38:32 -07:00
										 |  |  | void tipc_nodesub_subscribe(struct tipc_node_subscr *node_sub, u32 addr, | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  | 		       void *usr_handle, net_ev_handler handle_down) | 
					
						
							|  |  |  | { | 
					
						
							| 
									
										
										
										
											2006-06-25 23:51:37 -07:00
										 |  |  | 	if (addr == tipc_own_addr) { | 
					
						
							|  |  |  | 		node_sub->node = NULL; | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  | 		return; | 
					
						
							| 
									
										
										
										
											2006-06-25 23:51:37 -07:00
										 |  |  | 	} | 
					
						
							| 
									
										
										
										
											2007-02-09 23:25:21 +09:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2006-06-25 23:51:37 -07:00
										 |  |  | 	node_sub->node = tipc_node_find(addr); | 
					
						
							|  |  |  | 	if (!node_sub->node) { | 
					
						
							|  |  |  | 		warn("Node subscription rejected, unknown node 0x%x\n", addr); | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  | 		return; | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	node_sub->handle_node_down = handle_down; | 
					
						
							|  |  |  | 	node_sub->usr_handle = usr_handle; | 
					
						
							| 
									
										
										
										
											2006-06-25 23:51:37 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2006-01-18 00:38:21 +01:00
										 |  |  | 	tipc_node_lock(node_sub->node); | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  | 	list_add_tail(&node_sub->nodesub_list, &node_sub->node->nsub); | 
					
						
							| 
									
										
										
										
											2006-01-18 00:38:21 +01:00
										 |  |  | 	tipc_node_unlock(node_sub->node); | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | /**
 | 
					
						
							| 
									
										
										
										
											2006-01-18 00:38:21 +01:00
										 |  |  |  * tipc_nodesub_unsubscribe - cancel "node down" subscription (if any) | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2008-09-02 23:38:32 -07:00
										 |  |  | void tipc_nodesub_unsubscribe(struct tipc_node_subscr *node_sub) | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  | { | 
					
						
							|  |  |  | 	if (!node_sub->node) | 
					
						
							|  |  |  | 		return; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2006-01-18 00:38:21 +01:00
										 |  |  | 	tipc_node_lock(node_sub->node); | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  | 	list_del_init(&node_sub->nodesub_list); | 
					
						
							| 
									
										
										
										
											2006-01-18 00:38:21 +01:00
										 |  |  | 	tipc_node_unlock(node_sub->node); | 
					
						
							| 
									
										
										
										
											2006-01-02 19:04:38 +01:00
										 |  |  | } |