[linux-block.git] / net / tipc / discover.c

/*
 * net/tipc/discover.c
 * 
 * Copyright (c) 2003-2005, Ericsson Research Canada
 * Copyright (c) 2005, Wind River Systems
 * Copyright (c) 2005-2006, Ericsson AB
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without 
 * modification, are permitted provided that the following conditions are met:
 *
 * Redistributions of source code must retain the above copyright notice, this 
 * list of conditions and the following disclaimer.
 * 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.
 * 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.
 *
 * 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 
 * POSSIBILITY OF SUCH DAMAGE.
 */

#include "core.h"
#include "dbg.h"
#include "link.h"
#include "zone.h"
#include "discover.h"
#include "port.h"
#include "name_table.h"

#define TIPC_LINK_REQ_INIT	125	/* min delay during bearer start up */
#define TIPC_LINK_REQ_FAST	2000	/* normal delay if bearer has no links */
#define TIPC_LINK_REQ_SLOW	600000	/* normal delay if bearer has links */

#if 0
#define  GET_NODE_INFO         300
#define  GET_NODE_INFO_RESULT  301
#define  FORWARD_LINK_PROBE    302
#define  LINK_REQUEST_REJECTED 303
#define  LINK_REQUEST_ACCEPTED 304
#define  DROP_LINK_REQUEST     305
#define  CHECK_LINK_COUNT      306
#endif

/* 
 * TODO: Most of the inter-cluster setup stuff should be
 * rewritten, and be made conformant with specification.
 */ 


/**
 * struct link_req - information about an ongoing link setup request
 * @bearer: bearer issuing requests
 * @dest: destination address for request messages
 * @buf: request message to be (repeatedly) sent
 * @timer: timer governing period between requests
 * @timer_intv: current interval between requests (in ms)
 */
struct link_req {
	struct bearer *bearer;
	struct tipc_media_addr dest;
	struct sk_buff *buf;
	struct timer_list timer;
	unsigned int timer_intv;
};


#if 0
int disc_create_link(const struct tipc_link_create *argv) 
{
	/* 
	 * Code for inter cluster link setup here 
	 */
	return TIPC_OK;
}
#endif

/*
 * disc_lost_link(): A link has lost contact
 */

void disc_link_event(u32 addr, char *name, int up) 
{
	if (in_own_cluster(addr))
		return;
	/* 
	 * Code for inter cluster link setup here 
	 */
}

/** 
 * disc_init_msg - initialize a link setup message
 * @type: message type (request or response)
 * @req_links: number of links associated with message
 * @dest_domain: network domain of node(s) which should respond to message
 * @b_ptr: ptr to bearer issuing message
 */

struct sk_buff *disc_init_msg(u32 type,
			      u32 req_links,
			      u32 dest_domain,
			      struct bearer *b_ptr)
{
	struct sk_buff *buf = buf_acquire(DSC_H_SIZE);
	struct tipc_msg *msg;

	if (buf) {
		msg = buf_msg(buf);
		msg_init(msg, LINK_CONFIG, type, TIPC_OK, DSC_H_SIZE,
			 dest_domain);
		msg_set_non_seq(msg);
		msg_set_req_links(msg, req_links);
		msg_set_dest_domain(msg, dest_domain);
		msg_set_bc_netid(msg, tipc_net_id);
		msg_set_media_addr(msg, &b_ptr->publ.addr);
	}
	return buf;
}

/**
 * disc_recv_msg - handle incoming link setup message (request or response)
 * @buf: buffer containing message
 */

void disc_recv_msg(struct sk_buff *buf)
{
	struct bearer *b_ptr = (struct bearer *)TIPC_SKB_CB(buf)->handle;
	struct link *link;
	struct tipc_media_addr media_addr;
	struct tipc_msg *msg = buf_msg(buf);
	u32 dest = msg_dest_domain(msg);
	u32 orig = msg_prevnode(msg);
	u32 net_id = msg_bc_netid(msg);
	u32 type = msg_type(msg);

	msg_get_media_addr(msg,&media_addr);
	msg_dbg(msg, "RECV:");
	buf_discard(buf);

	if (net_id != tipc_net_id)
		return;
	if (!addr_domain_valid(dest))
		return;
	if (!addr_node_valid(orig))
		return;
	if (orig == tipc_own_addr)
		return;
	if (!in_scope(dest, tipc_own_addr))
		return;
	if (is_slave(tipc_own_addr) && is_slave(orig))
		return;
	if (is_slave(orig) && !in_own_cluster(orig))
		return;
	if (in_own_cluster(orig)) {
		/* Always accept link here */
		struct sk_buff *rbuf;
		struct tipc_media_addr *addr;
		struct node *n_ptr = node_find(orig);
		int link_up;
		dbg(" in own cluster\n");
		if (n_ptr == NULL) {
			n_ptr = node_create(orig);
		}
		if (n_ptr == NULL) {
			warn("Memory squeeze; Failed to create node\n");
			return;
		}
		spin_lock_bh(&n_ptr->lock);
		link = n_ptr->links[b_ptr->identity];
		if (!link) {
			dbg("creating link\n");
			link = link_create(b_ptr, orig, &media_addr);
			if (!link) {
				spin_unlock_bh(&n_ptr->lock);                
				return;
			}
		}
		addr = &link->media_addr;
		if (memcmp(addr, &media_addr, sizeof(*addr))) {
			char addr_string[16];

			warn("New bearer address for %s\n", 
			     addr_string_fill(addr_string, orig));
			memcpy(addr, &media_addr, sizeof(*addr));
			link_reset(link);     
		}
		link_up = link_is_up(link);
		spin_unlock_bh(&n_ptr->lock);                
		if ((type == DSC_RESP_MSG) || link_up)
			return;
		rbuf = disc_init_msg(DSC_RESP_MSG, 1, orig, b_ptr);
		if (rbuf != NULL) {
			msg_dbg(buf_msg(rbuf),"SEND:");
			b_ptr->media->send_msg(rbuf, &b_ptr->publ, &media_addr);
			buf_discard(rbuf);
		}
	}
}

/**
 * disc_stop_link_req - stop sending periodic link setup requests
 * @req: ptr to link request structure
 */

void disc_stop_link_req(struct link_req *req) 
{
	if (!req)
		return;
		
	k_cancel_timer(&req->timer);
	k_term_timer(&req->timer);
	buf_discard(req->buf);
	kfree(req);
} 

/**
 * disc_update_link_req - update frequency of periodic link setup requests
 * @req: ptr to link request structure
 */

void disc_update_link_req(struct link_req *req) 
{
	if (!req)
		return;

	if (req->timer_intv == TIPC_LINK_REQ_SLOW) {
		if (!req->bearer->nodes.count) {
			req->timer_intv = TIPC_LINK_REQ_FAST;
			k_start_timer(&req->timer, req->timer_intv);
		}
	} else if (req->timer_intv == TIPC_LINK_REQ_FAST) {
		if (req->bearer->nodes.count) {
			req->timer_intv = TIPC_LINK_REQ_SLOW;
			k_start_timer(&req->timer, req->timer_intv);
		}
	} else {
		/* leave timer "as is" if haven't yet reached a "normal" rate */
	}
} 

/**
 * disc_timeout - send a periodic link setup request
 * @req: ptr to link request structure
 * 
 * Called whenever a link setup request timer associated with a bearer expires.
 */

static void disc_timeout(struct link_req *req) 
{
	struct tipc_msg *msg = buf_msg(req->buf);

	spin_lock_bh(&req->bearer->publ.lock);

#if 0
	/* CURRENTLY DON'T SUPPORT INTER-ZONE LINKS */
	u32 dest_domain = msg_dest_domain(msg);
	int stop = 0;
	if (!in_scope(dest_domain, tipc_own_addr)) {
		struct _zone *z_ptr = zone_find(dest_domain);

		if (z_ptr && (z_ptr->links >= msg_req_links(msg)))
			stop = 1;
		if (req->timer_intv >= 32000)
			stop = 1;
	}
	if (stop) {
		k_cancel_timer(&req->timer);
		buf_discard(req->buf);
		kfree(req);
		spin_unlock_bh(&req->bearer->publ.lock);
		return;
	}
#endif

	msg_dbg(msg,"SEND:");
	req->bearer->media->send_msg(req->buf, &req->bearer->publ, &req->dest);

	if ((req->timer_intv == TIPC_LINK_REQ_SLOW) ||
	    (req->timer_intv == TIPC_LINK_REQ_FAST)) {
		/* leave timer interval "as is" if already at a "normal" rate */
	} else {
		req->timer_intv *= 2;
		if (req->timer_intv > TIPC_LINK_REQ_FAST)
			req->timer_intv = TIPC_LINK_REQ_FAST;
		if ((req->timer_intv == TIPC_LINK_REQ_FAST) && 
		    (req->bearer->nodes.count))
			req->timer_intv = TIPC_LINK_REQ_SLOW;
	}
	k_start_timer(&req->timer, req->timer_intv);

	spin_unlock_bh(&req->bearer->publ.lock);
}

/**
 * disc_init_link_req - start sending periodic link setup requests
 * @b_ptr: ptr to bearer issuing requests
 * @dest: destination address for request messages
 * @dest_domain: network domain of node(s) which should respond to message
 * @req_links: max number of desired links
 * 
 * Returns pointer to link request structure, or NULL if unable to create.
 */

struct link_req *disc_init_link_req(struct bearer *b_ptr, 
				    const struct tipc_media_addr *dest,
				    u32 dest_domain,
				    u32 req_links) 
{
	struct link_req *req;

	req = (struct link_req *)kmalloc(sizeof(*req), GFP_ATOMIC);
	if (!req)
		return NULL;

	req->buf = disc_init_msg(DSC_REQ_MSG, req_links, dest_domain, b_ptr);
	if (!req->buf) {
		kfree(req);
		return NULL;
	}

	memcpy(&req->dest, dest, sizeof(*dest));
	req->bearer = b_ptr;
	req->timer_intv = TIPC_LINK_REQ_INIT;
	k_init_timer(&req->timer, (Handler)disc_timeout, (unsigned long)req);
	k_start_timer(&req->timer, req->timer_intv);
	return req;
}
Commit	Line	Data
b97bf3fd PL	1	/*
	2	* net/tipc/discover.c
	3	*
	4	* Copyright (c) 2003-2005, Ericsson Research Canada
	5	* Copyright (c) 2005, Wind River Systems
	6	* Copyright (c) 2005-2006, Ericsson AB
	7	* All rights reserved.
	8	*
	9	* Redistribution and use in source and binary forms, with or without
	10	* modification, are permitted provided that the following conditions are met:
	11	*
	12	* Redistributions of source code must retain the above copyright notice, this
	13	* list of conditions and the following disclaimer.
	14	* Redistributions in binary form must reproduce the above copyright notice,
	15	* this list of conditions and the following disclaimer in the documentation
	16	* and/or other materials provided with the distribution.
	17	* Neither the names of the copyright holders nor the names of its
	18	* contributors may be used to endorse or promote products derived from this
	19	* software without specific prior written permission.
	20	*
	21	* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
	22	* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
	23	* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
	24	* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
	25	* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
	26	* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
	27	* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
	28	* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
	29	* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
	30	* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
	31	* POSSIBILITY OF SUCH DAMAGE.
	32	*/
	33
	34	#include "core.h"
	35	#include "dbg.h"
	36	#include "link.h"
	37	#include "zone.h"
	38	#include "discover.h"
	39	#include "port.h"
	40	#include "name_table.h"
	41
	42	#define TIPC_LINK_REQ_INIT 125 /* min delay during bearer start up */
	43	#define TIPC_LINK_REQ_FAST 2000 /* normal delay if bearer has no links */
	44	#define TIPC_LINK_REQ_SLOW 600000 /* normal delay if bearer has links */
	45
	46	#if 0
	47	#define GET_NODE_INFO 300
	48	#define GET_NODE_INFO_RESULT 301
	49	#define FORWARD_LINK_PROBE 302
	50	#define LINK_REQUEST_REJECTED 303
	51	#define LINK_REQUEST_ACCEPTED 304
	52	#define DROP_LINK_REQUEST 305
	53	#define CHECK_LINK_COUNT 306
	54	#endif
	55
	56	/*
	57	* TODO: Most of the inter-cluster setup stuff should be
	58	* rewritten, and be made conformant with specification.
	59	*/
	60
	61
	62	/**
	63	* struct link_req - information about an ongoing link setup request
	64	* @bearer: bearer issuing requests
65	* @dest: destination address for request messages
66	* @buf: request message to be (repeatedly) sent
67	* @timer: timer governing period between requests
68	* @timer_intv: current interval between requests (in ms)
69	*/
70	struct link_req {
71	struct bearer *bearer;
72	struct tipc_media_addr dest;
73	struct sk_buff *buf;
74	struct timer_list timer;
75	unsigned int timer_intv;
76	};
77
78
79	#if 0
80	int disc_create_link(const struct tipc_link_create *argv)
81	{
82	/*
83	* Code for inter cluster link setup here
84	*/
85	return TIPC_OK;
86	}
87	#endif
88
89	/*
90	* disc_lost_link(): A link has lost contact
91	*/
92
93	void disc_link_event(u32 addr, char *name, int up)
94	{
95	if (in_own_cluster(addr))
96	return;
97	/*
98	* Code for inter cluster link setup here
99	*/
100	}
101
102	/**
103	* disc_init_msg - initialize a link setup message
104	* @type: message type (request or response)
105	* @req_links: number of links associated with message
106	* @dest_domain: network domain of node(s) which should respond to message
107	* @b_ptr: ptr to bearer issuing message
108	*/
109
110	struct sk_buff *disc_init_msg(u32 type,
111	u32 req_links,
112	u32 dest_domain,
113	struct bearer *b_ptr)
114	{
115	struct sk_buff *buf = buf_acquire(DSC_H_SIZE);
116	struct tipc_msg *msg;
117
118	if (buf) {
119	msg = buf_msg(buf);
120	msg_init(msg, LINK_CONFIG, type, TIPC_OK, DSC_H_SIZE,
121	dest_domain);
122	msg_set_non_seq(msg);
123	msg_set_req_links(msg, req_links);
124	msg_set_dest_domain(msg, dest_domain);
125	msg_set_bc_netid(msg, tipc_net_id);
126	msg_set_media_addr(msg, &b_ptr->publ.addr);
127	}
128	return buf;
129	}
130
131	/**
132	* disc_recv_msg - handle incoming link setup message (request or response)
133	* @buf: buffer containing message
134	*/
135
136	void disc_recv_msg(struct sk_buff *buf)
137	{
138	struct bearer b_ptr = (struct bearer )TIPC_SKB_CB(buf)->handle;
139	struct link *link;
140	struct tipc_media_addr media_addr;
141	struct tipc_msg *msg = buf_msg(buf);
142	u32 dest = msg_dest_domain(msg);
143	u32 orig = msg_prevnode(msg);
144	u32 net_id = msg_bc_netid(msg);
145	u32 type = msg_type(msg);
146
147	msg_get_media_addr(msg,&media_addr);
148	msg_dbg(msg, "RECV:");
149	buf_discard(buf);
150
151	if (net_id != tipc_net_id)
152	return;
153	if (!addr_domain_valid(dest))
154	return;
155	if (!addr_node_valid(orig))
156	return;
157	if (orig == tipc_own_addr)
158	return;
159	if (!in_scope(dest, tipc_own_addr))
160	return;
161	if (is_slave(tipc_own_addr) && is_slave(orig))
162	return;
163	if (is_slave(orig) && !in_own_cluster(orig))
164	return;
165	if (in_own_cluster(orig)) {
166	/* Always accept link here */
167	struct sk_buff *rbuf;
168	struct tipc_media_addr *addr;
169	struct node *n_ptr = node_find(orig);
170	int link_up;
171	dbg(" in own cluster\n");
172	if (n_ptr == NULL) {
173	n_ptr = node_create(orig);
174	}
175	if (n_ptr == NULL) {
176	warn("Memory squeeze; Failed to create node\n");
177	return;
178	}
179	spin_lock_bh(&n_ptr->lock);
180	link = n_ptr->links[b_ptr->identity];
181	if (!link) {
182	dbg("creating link\n");
183	link = link_create(b_ptr, orig, &media_addr);
184	if (!link) {
185	spin_unlock_bh(&n_ptr->lock);
186	return;
187	}
188	}
189	addr = &link->media_addr;
190	if (memcmp(addr, &media_addr, sizeof(*addr))) {
191	char addr_string[16];
192
193	warn("New bearer address for %s\n",
194	addr_string_fill(addr_string, orig));
195	memcpy(addr, &media_addr, sizeof(*addr));
196	link_reset(link);
197	}
198	link_up = link_is_up(link);
199	spin_unlock_bh(&n_ptr->lock);
200	if ((type == DSC_RESP_MSG) \|\| link_up)
201	return;
202	rbuf = disc_init_msg(DSC_RESP_MSG, 1, orig, b_ptr);
203	if (rbuf != NULL) {
204	msg_dbg(buf_msg(rbuf),"SEND:");
205	b_ptr->media->send_msg(rbuf, &b_ptr->publ, &media_addr);
206	buf_discard(rbuf);
207	}
208	}
209	}
210
211	/**
212	* disc_stop_link_req - stop sending periodic link setup requests
213	* @req: ptr to link request structure
214	*/
215
216	void disc_stop_link_req(struct link_req *req)
217	{
218	if (!req)
219	return;
220
221	k_cancel_timer(&req->timer);
222	k_term_timer(&req->timer);
223	buf_discard(req->buf);
224	kfree(req);
225	}
226
227	/**
228	* disc_update_link_req - update frequency of periodic link setup requests
229	* @req: ptr to link request structure
230	*/
231
232	void disc_update_link_req(struct link_req *req)
233	{
234	if (!req)
235	return;
236
237	if (req->timer_intv == TIPC_LINK_REQ_SLOW) {
238	if (!req->bearer->nodes.count) {
239	req->timer_intv = TIPC_LINK_REQ_FAST;
240	k_start_timer(&req->timer, req->timer_intv);
241	}
242	} else if (req->timer_intv == TIPC_LINK_REQ_FAST) {
243	if (req->bearer->nodes.count) {
244	req->timer_intv = TIPC_LINK_REQ_SLOW;
245	k_start_timer(&req->timer, req->timer_intv);
246	}
247	} else {
248	/* leave timer "as is" if haven't yet reached a "normal" rate */
249	}
250	}
251
252	/**
253	* disc_timeout - send a periodic link setup request
254	* @req: ptr to link request structure
255	*
256	* Called whenever a link setup request timer associated with a bearer expires.
257	*/
258
259	static void disc_timeout(struct link_req *req)
260	{
261	struct tipc_msg *msg = buf_msg(req->buf);
262
263	spin_lock_bh(&req->bearer->publ.lock);
264
265	#if 0
266	/* CURRENTLY DON'T SUPPORT INTER-ZONE LINKS */
267	u32 dest_domain = msg_dest_domain(msg);
268	int stop = 0;
269	if (!in_scope(dest_domain, tipc_own_addr)) {
270	struct _zone *z_ptr = zone_find(dest_domain);
271
272	if (z_ptr && (z_ptr->links >= msg_req_links(msg)))
273	stop = 1;
274	if (req->timer_intv >= 32000)
275	stop = 1;
276	}
277	if (stop) {
278	k_cancel_timer(&req->timer);
279	buf_discard(req->buf);
280	kfree(req);
281	spin_unlock_bh(&req->bearer->publ.lock);
282	return;
283	}
284	#endif
285
286	msg_dbg(msg,"SEND:");
287	req->bearer->media->send_msg(req->buf, &req->bearer->publ, &req->dest);
288
289	if ((req->timer_intv == TIPC_LINK_REQ_SLOW) \|\|
290	(req->timer_intv == TIPC_LINK_REQ_FAST)) {
291	/* leave timer interval "as is" if already at a "normal" rate */
292	} else {
293	req->timer_intv *= 2;
294	if (req->timer_intv > TIPC_LINK_REQ_FAST)
295	req->timer_intv = TIPC_LINK_REQ_FAST;
296	if ((req->timer_intv == TIPC_LINK_REQ_FAST) &&
297	(req->bearer->nodes.count))
298	req->timer_intv = TIPC_LINK_REQ_SLOW;
299	}
300	k_start_timer(&req->timer, req->timer_intv);
301
302	spin_unlock_bh(&req->bearer->publ.lock);
303	}
304
305	/**
306	* disc_init_link_req - start sending periodic link setup requests
307	* @b_ptr: ptr to bearer issuing requests
308	* @dest: destination address for request messages
309	* @dest_domain: network domain of node(s) which should respond to message
310	* @req_links: max number of desired links
311	*
312	* Returns pointer to link request structure, or NULL if unable to create.
313	*/
314
315	struct link_req disc_init_link_req(struct bearer b_ptr,
316	const struct tipc_media_addr *dest,
317	u32 dest_domain,
318	u32 req_links)
319	{
320	struct link_req *req;
321
322	req = (struct link_req )kmalloc(sizeof(req), GFP_ATOMIC);
323	if (!req)
324	return NULL;
325
326	req->buf = disc_init_msg(DSC_REQ_MSG, req_links, dest_domain, b_ptr);
327	if (!req->buf) {
328	kfree(req);
329	return NULL;
330	}
331
332	memcpy(&req->dest, dest, sizeof(*dest));
333	req->bearer = b_ptr;
334	req->timer_intv = TIPC_LINK_REQ_INIT;
335	k_init_timer(&req->timer, (Handler)disc_timeout, (unsigned long)req);
336	k_start_timer(&req->timer, req->timer_intv);
337	return req;
338	}
339