Blame view

net/tipc/bcast.h 5.46 KB
b97bf3fd8   Per Liden   [TIPC] Initial merge
1
2
  /*
   * net/tipc/bcast.h: Include file for TIPC broadcast code
c43072852   YOSHIFUJI Hideaki   [NET] TIPC: Fix w...
3
   *
9da1c8b69   Per Liden   [TIPC] Update of ...
4
   * Copyright (c) 2003-2006, Ericsson AB
b97bf3fd8   Per Liden   [TIPC] Initial merge
5
   * Copyright (c) 2005, Wind River Systems
b97bf3fd8   Per Liden   [TIPC] Initial merge
6
7
   * All rights reserved.
   *
9ea1fd3c1   Per Liden   [TIPC] License he...
8
   * Redistribution and use in source and binary forms, with or without
b97bf3fd8   Per Liden   [TIPC] Initial merge
9
10
   * modification, are permitted provided that the following conditions are met:
   *
9ea1fd3c1   Per Liden   [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   Per Liden   [TIPC] Initial merge
19
   *
9ea1fd3c1   Per Liden   [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   Per Liden   [TIPC] Initial merge
34
35
36
37
38
39
40
41
42
43
   * POSSIBILITY OF SUCH DAMAGE.
   */
  
  #ifndef _TIPC_BCAST_H
  #define _TIPC_BCAST_H
  
  #define MAX_NODES 4096
  #define WSIZE 32
  
  /**
6c00055a8   David S. Miller   tipc: Don't use s...
44
   * struct tipc_node_map - set of node identifiers
b97bf3fd8   Per Liden   [TIPC] Initial merge
45
46
47
   * @count: # of nodes in set
   * @map: bitmap of node identifiers that are in the set
   */
6c00055a8   David S. Miller   tipc: Don't use s...
48
  struct tipc_node_map {
b97bf3fd8   Per Liden   [TIPC] Initial merge
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
  	u32 count;
  	u32 map[MAX_NODES / WSIZE];
  };
  
  
  #define PLSIZE 32
  
  /**
   * struct port_list - set of node local destination ports
   * @count: # of ports in set (only valid for first entry in list)
   * @next: pointer to next entry in list
   * @ports: array of port references
   */
  
  struct port_list {
  	int count;
  	struct port_list *next;
  	u32 ports[PLSIZE];
  };
6c00055a8   David S. Miller   tipc: Don't use s...
68
  struct tipc_node;
b97bf3fd8   Per Liden   [TIPC] Initial merge
69

4b704d59d   Stephen Hemminger   tipc: fix non-con...
70
  extern const char tipc_bclink_name[];
b97bf3fd8   Per Liden   [TIPC] Initial merge
71
72
73
  
  
  /**
b97bf3fd8   Per Liden   [TIPC] Initial merge
74
75
   * nmap_add - add a node to a node map
   */
6c00055a8   David S. Miller   tipc: Don't use s...
76
  static inline void tipc_nmap_add(struct tipc_node_map *nm_ptr, u32 node)
b97bf3fd8   Per Liden   [TIPC] Initial merge
77
78
79
80
81
82
83
84
85
86
  {
  	int n = tipc_node(node);
  	int w = n / WSIZE;
  	u32 mask = (1 << (n % WSIZE));
  
  	if ((nm_ptr->map[w] & mask) == 0) {
  		nm_ptr->count++;
  		nm_ptr->map[w] |= mask;
  	}
  }
c43072852   YOSHIFUJI Hideaki   [NET] TIPC: Fix w...
87
  /**
b97bf3fd8   Per Liden   [TIPC] Initial merge
88
89
   * nmap_remove - remove a node from a node map
   */
6c00055a8   David S. Miller   tipc: Don't use s...
90
  static inline void tipc_nmap_remove(struct tipc_node_map *nm_ptr, u32 node)
b97bf3fd8   Per Liden   [TIPC] Initial merge
91
92
93
94
95
96
97
98
99
100
101
102
103
104
  {
  	int n = tipc_node(node);
  	int w = n / WSIZE;
  	u32 mask = (1 << (n % WSIZE));
  
  	if ((nm_ptr->map[w] & mask) != 0) {
  		nm_ptr->map[w] &= ~mask;
  		nm_ptr->count--;
  	}
  }
  
  /**
   * nmap_equal - test for equality of node maps
   */
6c00055a8   David S. Miller   tipc: Don't use s...
105
  static inline int tipc_nmap_equal(struct tipc_node_map *nm_a, struct tipc_node_map *nm_b)
b97bf3fd8   Per Liden   [TIPC] Initial merge
106
107
108
109
110
111
112
113
114
115
  {
  	return !memcmp(nm_a, nm_b, sizeof(*nm_a));
  }
  
  /**
   * nmap_diff - find differences between node maps
   * @nm_a: input node map A
   * @nm_b: input node map B
   * @nm_diff: output node map A-B (i.e. nodes of A that are not in B)
   */
6c00055a8   David S. Miller   tipc: Don't use s...
116
117
  static inline void tipc_nmap_diff(struct tipc_node_map *nm_a, struct tipc_node_map *nm_b,
  				  struct tipc_node_map *nm_diff)
b97bf3fd8   Per Liden   [TIPC] Initial merge
118
  {
6c614a502   Julia Lawall   net/tipc/bcast.h:...
119
  	int stop = ARRAY_SIZE(nm_a->map);
b97bf3fd8   Per Liden   [TIPC] Initial merge
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
  	int w;
  	int b;
  	u32 map;
  
  	memset(nm_diff, 0, sizeof(*nm_diff));
  	for (w = 0; w < stop; w++) {
  		map = nm_a->map[w] ^ (nm_a->map[w] & nm_b->map[w]);
  		nm_diff->map[w] = map;
  		if (map != 0) {
  			for (b = 0 ; b < WSIZE; b++) {
  				if (map & (1 << b))
  					nm_diff->count++;
  			}
  		}
  	}
  }
  
  /**
   * port_list_add - add a port to a port list, ensuring no duplicates
   */
4323add67   Per Liden   [TIPC] Avoid poll...
140
  static inline void tipc_port_list_add(struct port_list *pl_ptr, u32 port)
b97bf3fd8   Per Liden   [TIPC] Initial merge
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
  {
  	struct port_list *item = pl_ptr;
  	int i;
  	int item_sz = PLSIZE;
  	int cnt = pl_ptr->count;
  
  	for (; ; cnt -= item_sz, item = item->next) {
  		if (cnt < PLSIZE)
  			item_sz = cnt;
  		for (i = 0; i < item_sz; i++)
  			if (item->ports[i] == port)
  				return;
  		if (i < PLSIZE) {
  			item->ports[i] = port;
  			pl_ptr->count++;
  			return;
  		}
  		if (!item->next) {
  			item->next = kmalloc(sizeof(*item), GFP_ATOMIC);
  			if (!item->next) {
a10bd924a   Allan Stephens   [TIPC]: Enhanced ...
161
162
  				warn("Incomplete multicast delivery, no memory
  ");
b97bf3fd8   Per Liden   [TIPC] Initial merge
163
164
165
166
167
168
169
170
171
  				return;
  			}
  			item->next->next = NULL;
  		}
  	}
  }
  
  /**
   * port_list_free - free dynamically created entries in port_list chain
c43072852   YOSHIFUJI Hideaki   [NET] TIPC: Fix w...
172
   *
b97bf3fd8   Per Liden   [TIPC] Initial merge
173
174
   * Note: First item is on stack, so it doesn't need to be released
   */
4323add67   Per Liden   [TIPC] Avoid poll...
175
  static inline void tipc_port_list_free(struct port_list *pl_ptr)
b97bf3fd8   Per Liden   [TIPC] Initial merge
176
177
178
179
180
181
182
183
184
  {
  	struct port_list *item;
  	struct port_list *next;
  
  	for (item = pl_ptr->next; item; item = next) {
  		next = item->next;
  		kfree(item);
  	}
  }
4323add67   Per Liden   [TIPC] Avoid poll...
185
186
  int  tipc_bclink_init(void);
  void tipc_bclink_stop(void);
6c00055a8   David S. Miller   tipc: Don't use s...
187
  void tipc_bclink_acknowledge(struct tipc_node *n_ptr, u32 acked);
4323add67   Per Liden   [TIPC] Avoid poll...
188
189
190
  int  tipc_bclink_send_msg(struct sk_buff *buf);
  void tipc_bclink_recv_pkt(struct sk_buff *buf);
  u32  tipc_bclink_get_last_sent(void);
6c00055a8   David S. Miller   tipc: Don't use s...
191
192
  u32  tipc_bclink_acks_missing(struct tipc_node *n_ptr);
  void tipc_bclink_check_gap(struct tipc_node *n_ptr, u32 seqno);
4323add67   Per Liden   [TIPC] Avoid poll...
193
194
195
196
197
  int  tipc_bclink_stats(char *stats_buf, const u32 buf_size);
  int  tipc_bclink_reset_stats(void);
  int  tipc_bclink_set_queue_limits(u32 limit);
  void tipc_bcbearer_sort(void);
  void tipc_bcbearer_push(void);
b97bf3fd8   Per Liden   [TIPC] Initial merge
198
199
  
  #endif