Blame view
net/tipc/bcast.h
5.46 KB
b97bf3fd8 [TIPC] Initial merge |
1 2 |
/* * net/tipc/bcast.h: Include file for TIPC broadcast code |
c43072852 [NET] TIPC: Fix w... |
3 |
* |
9da1c8b69 [TIPC] Update of ... |
4 |
* Copyright (c) 2003-2006, Ericsson AB |
b97bf3fd8 [TIPC] Initial merge |
5 |
* Copyright (c) 2005, 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 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 tipc: Don't use s... |
44 |
* struct tipc_node_map - set of node identifiers |
b97bf3fd8 [TIPC] Initial merge |
45 46 47 |
* @count: # of nodes in set * @map: bitmap of node identifiers that are in the set */ |
6c00055a8 tipc: Don't use s... |
48 |
struct tipc_node_map { |
b97bf3fd8 [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 tipc: Don't use s... |
68 |
struct tipc_node; |
b97bf3fd8 [TIPC] Initial merge |
69 |
|
4b704d59d tipc: fix non-con... |
70 |
extern const char tipc_bclink_name[]; |
b97bf3fd8 [TIPC] Initial merge |
71 72 73 |
/** |
b97bf3fd8 [TIPC] Initial merge |
74 75 |
* nmap_add - add a node to a node map */ |
6c00055a8 tipc: Don't use s... |
76 |
static inline void tipc_nmap_add(struct tipc_node_map *nm_ptr, u32 node) |
b97bf3fd8 [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 [NET] TIPC: Fix w... |
87 |
/** |
b97bf3fd8 [TIPC] Initial merge |
88 89 |
* nmap_remove - remove a node from a node map */ |
6c00055a8 tipc: Don't use s... |
90 |
static inline void tipc_nmap_remove(struct tipc_node_map *nm_ptr, u32 node) |
b97bf3fd8 [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 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 [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 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 [TIPC] Initial merge |
118 |
{ |
6c614a502 net/tipc/bcast.h:... |
119 |
int stop = ARRAY_SIZE(nm_a->map); |
b97bf3fd8 [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 [TIPC] Avoid poll... |
140 |
static inline void tipc_port_list_add(struct port_list *pl_ptr, u32 port) |
b97bf3fd8 [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 [TIPC]: Enhanced ... |
161 162 |
warn("Incomplete multicast delivery, no memory "); |
b97bf3fd8 [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 [NET] TIPC: Fix w... |
172 |
* |
b97bf3fd8 [TIPC] Initial merge |
173 174 |
* Note: First item is on stack, so it doesn't need to be released */ |
4323add67 [TIPC] Avoid poll... |
175 |
static inline void tipc_port_list_free(struct port_list *pl_ptr) |
b97bf3fd8 [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 [TIPC] Avoid poll... |
185 186 |
int tipc_bclink_init(void); void tipc_bclink_stop(void); |
6c00055a8 tipc: Don't use s... |
187 |
void tipc_bclink_acknowledge(struct tipc_node *n_ptr, u32 acked); |
4323add67 [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 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 [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 [TIPC] Initial merge |
198 199 |
#endif |