Blame view
net/tipc/msg.h
29.3 KB
b97bf3fd8 [TIPC] Initial merge |
1 2 |
/* * net/tipc/msg.h: Include file for TIPC message header routines |
c43072852 [NET] TIPC: Fix w... |
3 |
* |
75da2163d tipc: introduce c... |
4 |
* Copyright (c) 2000-2007, 2014-2017 Ericsson AB |
741de3e9f tipc: Remove supp... |
5 |
* Copyright (c) 2005-2008, 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 38 |
* POSSIBILITY OF SUCH DAMAGE. */ #ifndef _TIPC_MSG_H #define _TIPC_MSG_H |
1da465683 tipc: make tipc b... |
39 |
#include <linux/tipc.h> |
d999297c3 tipc: reduce lock... |
40 |
#include "core.h" |
b97bf3fd8 [TIPC] Initial merge |
41 |
|
cc4c4353f tipc: Update comm... |
42 43 44 45 46 |
/* * Constants and routines used to read and write TIPC payload message headers * * Note: Some items are also used with TIPC internal message headers */ |
b97bf3fd8 [TIPC] Initial merge |
47 |
#define TIPC_VERSION 2 |
c637c1035 tipc: resolve rac... |
48 |
struct plist; |
06d82c919 [TIPC]: Minor cle... |
49 |
|
d265fef6d tipc: Remove obso... |
50 |
/* |
cc4c4353f tipc: Update comm... |
51 52 53 54 55 56 |
* Payload message users are defined in TIPC's public API: * - TIPC_LOW_IMPORTANCE * - TIPC_MEDIUM_IMPORTANCE * - TIPC_HIGH_IMPORTANCE * - TIPC_CRITICAL_IMPORTANCE */ |
e3eea1eb4 tipc: clean up ha... |
57 |
#define TIPC_SYSTEM_IMPORTANCE 4 |
cc4c4353f tipc: Update comm... |
58 59 60 |
/* * Payload message types |
d265fef6d tipc: Remove obso... |
61 |
*/ |
75da2163d tipc: introduce c... |
62 63 64 65 |
#define TIPC_CONN_MSG 0 #define TIPC_MCAST_MSG 1 #define TIPC_NAMED_MSG 2 #define TIPC_DIRECT_MSG 3 |
ae236fb20 tipc: receive gro... |
66 67 |
#define TIPC_GRP_MEMBER_EVT 4 #define TIPC_GRP_BCAST_MSG 5 |
5b8dddb63 tipc: introduce g... |
68 69 |
#define TIPC_GRP_MCAST_MSG 6 #define TIPC_GRP_UCAST_MSG 7 |
d265fef6d tipc: Remove obso... |
70 |
|
cc4c4353f tipc: Update comm... |
71 |
/* |
e3eea1eb4 tipc: clean up ha... |
72 73 74 75 76 77 |
* Internal message users */ #define BCAST_PROTOCOL 5 #define MSG_BUNDLER 6 #define LINK_PROTOCOL 7 #define CONN_MANAGER 8 |
75da2163d tipc: introduce c... |
78 |
#define GROUP_PROTOCOL 9 |
dff29b1a8 tipc: eliminate d... |
79 |
#define TUNNEL_PROTOCOL 10 |
e3eea1eb4 tipc: clean up ha... |
80 81 82 |
#define NAME_DISTRIBUTOR 11 #define MSG_FRAGMENTER 12 #define LINK_CONFIG 13 |
1ef6f7c93 tipc: add automat... |
83 |
#define MSG_CRYPTO 14 |
e3eea1eb4 tipc: clean up ha... |
84 |
#define SOCK_WAKEUP 14 /* pseudo user */ |
14c04493c tipc: add ability... |
85 |
#define TOP_SRV 15 /* pseudo user */ |
e3eea1eb4 tipc: clean up ha... |
86 87 |
/* |
cc4c4353f tipc: Update comm... |
88 89 |
* Message header sizes */ |
741d9eb7b tipc: Cleanup of ... |
90 91 92 93 |
#define SHORT_H_SIZE 24 /* In-cluster basic payload message */ #define BASIC_H_SIZE 32 /* Basic payload message */ #define NAMED_H_SIZE 40 /* Named payload message */ #define MCAST_H_SIZE 44 /* Multicast payload message */ |
75da2163d tipc: introduce c... |
94 |
#define GROUP_H_SIZE 44 /* Group payload message */ |
06d82c919 [TIPC]: Minor cle... |
95 96 97 |
#define INT_H_SIZE 40 /* Internal messages */ #define MIN_H_SIZE 24 /* Smallest legal TIPC header size */ #define MAX_H_SIZE 60 /* Largest possible TIPC header size */ |
b97bf3fd8 [TIPC] Initial merge |
98 |
#define MAX_MSG_SIZE (MAX_H_SIZE + TIPC_MAX_USER_MSG_SIZE) |
4c94cc2d3 tipc: fall back t... |
99 |
#define FB_MTU 3744 |
91e2eb568 tipc: rename medi... |
100 |
#define TIPC_MEDIA_INFO_OFFSET 5 |
3d749a6a2 tipc: Hide media-... |
101 |
|
859fc7c0c tipc: cleanup cor... |
102 |
struct tipc_skb_cb { |
fc1b6d6de tipc: introduce T... |
103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 |
union { struct { struct sk_buff *tail; unsigned long nxt_retr; unsigned long retr_stamp; u32 bytes_read; u32 orig_member; u16 chain_imp; u16 ackers; u16 retr_cnt; } __packed; #ifdef CONFIG_TIPC_CRYPTO struct { struct tipc_crypto *rx; struct tipc_aead *last; u8 recurs; } tx_clone_ctx __packed; #endif } __packed; union { struct { u8 validated:1; #ifdef CONFIG_TIPC_CRYPTO u8 encrypted:1; u8 decrypted:1; |
daef1ee37 tipc: introduce e... |
128 129 130 |
#define SKB_PROBING 1 #define SKB_GRACING 2 u8 xmit_type:2; |
fc1b6d6de tipc: introduce T... |
131 132 133 134 135 136 137 138 139 140 |
u8 tx_clone_deferred:1; #endif }; u8 flags; }; u8 reserved; #ifdef CONFIG_TIPC_CRYPTO void *crypto_ctx; #endif } __packed; |
859fc7c0c tipc: cleanup cor... |
141 142 |
#define TIPC_SKB_CB(__skb) ((struct tipc_skb_cb *)&((__skb)->cb[0])) |
d265fef6d tipc: Remove obso... |
143 144 145 |
struct tipc_msg { __be32 hdr[15]; }; |
c43072852 [NET] TIPC: Fix w... |
146 |
|
9195948fb tipc: improve TIP... |
147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 |
/* struct tipc_gap_ack - TIPC Gap ACK block * @ack: seqno of the last consecutive packet in link deferdq * @gap: number of gap packets since the last ack * * E.g: * link deferdq: 1 2 3 4 10 11 13 14 15 20 * --> Gap ACK blocks: <4, 5>, <11, 1>, <15, 4>, <20, 0> */ struct tipc_gap_ack { __be16 ack; __be16 gap; }; /* struct tipc_gap_ack_blks * @len: actual length of the record |
d7626b5ac tipc: introduce G... |
162 163 164 165 |
* @ugack_cnt: number of Gap ACK blocks for unicast (following the broadcast * ones) * @start_index: starting index for "valid" broadcast Gap ACK blocks * @bgack_cnt: number of Gap ACK blocks for broadcast in the record |
9195948fb tipc: improve TIP... |
166 |
* @gacks: array of Gap ACK blocks |
d7626b5ac tipc: introduce G... |
167 168 169 170 171 172 173 174 175 176 177 178 179 |
* * 31 16 15 0 * +-------------+-------------+-------------+-------------+ * | bgack_cnt | ugack_cnt | len | * +-------------+-------------+-------------+-------------+ - * | gap | ack | | * +-------------+-------------+-------------+-------------+ > bc gacks * : : : | * +-------------+-------------+-------------+-------------+ - * | gap | ack | | * +-------------+-------------+-------------+-------------+ > uc gacks * : : : | * +-------------+-------------+-------------+-------------+ - |
9195948fb tipc: improve TIP... |
180 181 182 |
*/ struct tipc_gap_ack_blks { __be16 len; |
d7626b5ac tipc: introduce G... |
183 184 185 186 187 |
union { u8 ugack_cnt; u8 start_index; }; u8 bgack_cnt; |
9195948fb tipc: improve TIP... |
188 189 |
struct tipc_gap_ack gacks[]; }; |
d7626b5ac tipc: introduce G... |
190 |
#define MAX_GAP_ACK_BLKS 128 |
e034c6d23 tipc: Use struct_... |
191 192 |
#define MAX_GAP_ACK_BLKS_SZ (sizeof(struct tipc_gap_ack_blks) + \ sizeof(struct tipc_gap_ack) * MAX_GAP_ACK_BLKS) |
9195948fb tipc: improve TIP... |
193 |
|
859fc7c0c tipc: cleanup cor... |
194 195 196 197 |
static inline struct tipc_msg *buf_msg(struct sk_buff *skb) { return (struct tipc_msg *)skb->data; } |
d265fef6d tipc: Remove obso... |
198 199 200 201 |
static inline u32 msg_word(struct tipc_msg *m, u32 pos) { return ntohl(m->hdr[pos]); } |
b97bf3fd8 [TIPC] Initial merge |
202 203 204 205 206 |
static inline void msg_set_word(struct tipc_msg *m, u32 w, u32 val) { m->hdr[w] = htonl(val); } |
d265fef6d tipc: Remove obso... |
207 208 209 210 |
static inline u32 msg_bits(struct tipc_msg *m, u32 w, u32 pos, u32 mask) { return (msg_word(m, w) >> pos) & mask; } |
b97bf3fd8 [TIPC] Initial merge |
211 212 213 |
static inline void msg_set_bits(struct tipc_msg *m, u32 w, u32 pos, u32 mask, u32 val) { |
1f9eda7e2 [TIPC]: Enhanceme... |
214 |
val = (val & mask) << pos; |
becf3da20 tipc: endianness ... |
215 216 217 |
mask = mask << pos; m->hdr[w] &= ~htonl(mask); m->hdr[w] |= htonl(val); |
b97bf3fd8 [TIPC] Initial merge |
218 |
} |
40aecb1b1 tipc: Message rej... |
219 220 221 222 223 224 225 |
static inline void msg_swap_words(struct tipc_msg *msg, u32 a, u32 b) { u32 temp = msg->hdr[a]; msg->hdr[a] = msg->hdr[b]; msg->hdr[b] = temp; } |
c43072852 [NET] TIPC: Fix w... |
226 |
/* |
b97bf3fd8 [TIPC] Initial merge |
227 228 |
* Word 0 */ |
b97bf3fd8 [TIPC] Initial merge |
229 230 231 232 |
static inline u32 msg_version(struct tipc_msg *m) { return msg_bits(m, 0, 29, 7); } |
c43072852 [NET] TIPC: Fix w... |
233 |
static inline void msg_set_version(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
234 |
{ |
37695420a [TIPC]: Use corre... |
235 |
msg_set_bits(m, 0, 29, 7, TIPC_VERSION); |
b97bf3fd8 [TIPC] Initial merge |
236 237 238 239 240 241 242 243 244 |
} static inline u32 msg_user(struct tipc_msg *m) { return msg_bits(m, 0, 25, 0xf); } static inline u32 msg_isdata(struct tipc_msg *m) { |
a02cec215 net: return opera... |
245 |
return msg_user(m) <= TIPC_CRITICAL_IMPORTANCE; |
b97bf3fd8 [TIPC] Initial merge |
246 |
} |
c43072852 [NET] TIPC: Fix w... |
247 |
static inline void msg_set_user(struct tipc_msg *m, u32 n) |
b97bf3fd8 [TIPC] Initial merge |
248 249 250 |
{ msg_set_bits(m, 0, 25, 0xf, n); } |
d265fef6d tipc: Remove obso... |
251 252 253 254 |
static inline u32 msg_hdr_sz(struct tipc_msg *m) { return msg_bits(m, 0, 21, 0xf) << 2; } |
0e65967e3 tipc: cleanup var... |
255 |
static inline void msg_set_hdr_sz(struct tipc_msg *m, u32 n) |
b97bf3fd8 [TIPC] Initial merge |
256 257 258 |
{ msg_set_bits(m, 0, 21, 0xf, n>>2); } |
d265fef6d tipc: Remove obso... |
259 260 261 262 |
static inline u32 msg_size(struct tipc_msg *m) { return msg_bits(m, 0, 0, 0x1ffff); } |
5b8dddb63 tipc: introduce g... |
263 264 265 266 |
static inline u32 msg_blocks(struct tipc_msg *m) { return (msg_size(m) / 1024) + 1; } |
d265fef6d tipc: Remove obso... |
267 268 269 270 |
static inline u32 msg_data_sz(struct tipc_msg *m) { return msg_size(m) - msg_hdr_sz(m); } |
c43072852 [NET] TIPC: Fix w... |
271 |
static inline int msg_non_seq(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
272 273 274 |
{ return msg_bits(m, 0, 20, 1); } |
40aecb1b1 tipc: Message rej... |
275 |
static inline void msg_set_non_seq(struct tipc_msg *m, u32 n) |
b97bf3fd8 [TIPC] Initial merge |
276 |
{ |
40aecb1b1 tipc: Message rej... |
277 |
msg_set_bits(m, 0, 20, 1, n); |
b97bf3fd8 [TIPC] Initial merge |
278 |
} |
25b9221b9 tipc: add SYN bit... |
279 280 281 282 283 284 285 286 287 |
static inline int msg_is_syn(struct tipc_msg *m) { return msg_bits(m, 0, 17, 1); } static inline void msg_set_syn(struct tipc_msg *m, u32 d) { msg_set_bits(m, 0, 17, 1, d); } |
c43072852 [NET] TIPC: Fix w... |
288 |
static inline int msg_dest_droppable(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
289 290 291 |
{ return msg_bits(m, 0, 19, 1); } |
c43072852 [NET] TIPC: Fix w... |
292 |
static inline void msg_set_dest_droppable(struct tipc_msg *m, u32 d) |
b97bf3fd8 [TIPC] Initial merge |
293 294 295 |
{ msg_set_bits(m, 0, 19, 1, d); } |
8d6e79d3c tipc: improve lin... |
296 297 298 299 300 301 302 303 304 |
static inline int msg_is_keepalive(struct tipc_msg *m) { return msg_bits(m, 0, 19, 1); } static inline void msg_set_is_keepalive(struct tipc_msg *m, u32 d) { msg_set_bits(m, 0, 19, 1, d); } |
c43072852 [NET] TIPC: Fix w... |
305 |
static inline int msg_src_droppable(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
306 307 308 |
{ return msg_bits(m, 0, 18, 1); } |
c43072852 [NET] TIPC: Fix w... |
309 |
static inline void msg_set_src_droppable(struct tipc_msg *m, u32 d) |
b97bf3fd8 [TIPC] Initial merge |
310 311 312 |
{ msg_set_bits(m, 0, 18, 1, d); } |
c0bceb97d tipc: add smart n... |
313 314 315 316 |
static inline int msg_ack_required(struct tipc_msg *m) { return msg_bits(m, 0, 18, 1); } |
0a3e060f3 tipc: add test fo... |
317 |
static inline void msg_set_ack_required(struct tipc_msg *m) |
c0bceb97d tipc: add smart n... |
318 |
{ |
0a3e060f3 tipc: add test fo... |
319 320 321 322 323 324 325 326 327 328 329 |
msg_set_bits(m, 0, 18, 1, 1); } static inline int msg_nagle_ack(struct tipc_msg *m) { return msg_bits(m, 0, 18, 1); } static inline void msg_set_nagle_ack(struct tipc_msg *m) { msg_set_bits(m, 0, 18, 1, 1); |
c0bceb97d tipc: add smart n... |
330 |
} |
c55c8edaf tipc: smooth chan... |
331 332 333 334 335 336 337 338 339 |
static inline bool msg_is_rcast(struct tipc_msg *m) { return msg_bits(m, 0, 18, 0x1); } static inline void msg_set_is_rcast(struct tipc_msg *m, bool d) { msg_set_bits(m, 0, 18, 0x1, d); } |
b97bf3fd8 [TIPC] Initial merge |
340 341 342 343 |
static inline void msg_set_size(struct tipc_msg *m, u32 sz) { m->hdr[0] = htonl((msg_word(m, 0) & ~0x1ffff) | sz); } |
3127a0200 tipc: clean up ha... |
344 345 346 347 |
static inline unchar *msg_data(struct tipc_msg *m) { return ((unchar *)m) + msg_hdr_sz(m); } |
a7dc51adc tipc: rename func... |
348 |
static inline struct tipc_msg *msg_inner_hdr(struct tipc_msg *m) |
3127a0200 tipc: clean up ha... |
349 350 351 |
{ return (struct tipc_msg *)msg_data(m); } |
b97bf3fd8 [TIPC] Initial merge |
352 |
|
c43072852 [NET] TIPC: Fix w... |
353 |
/* |
b97bf3fd8 [TIPC] Initial merge |
354 355 |
* Word 1 */ |
d265fef6d tipc: Remove obso... |
356 357 358 359 |
static inline u32 msg_type(struct tipc_msg *m) { return msg_bits(m, 1, 29, 0x7); } |
c43072852 [NET] TIPC: Fix w... |
360 |
static inline void msg_set_type(struct tipc_msg *m, u32 n) |
b97bf3fd8 [TIPC] Initial merge |
361 362 363 |
{ msg_set_bits(m, 1, 29, 0x7, n); } |
75da2163d tipc: introduce c... |
364 365 |
static inline int msg_in_group(struct tipc_msg *m) { |
ae236fb20 tipc: receive gro... |
366 |
int mtyp = msg_type(m); |
27bd9ec02 tipc: introduce g... |
367 |
return mtyp >= TIPC_GRP_MEMBER_EVT && mtyp <= TIPC_GRP_UCAST_MSG; |
ae236fb20 tipc: receive gro... |
368 369 370 371 372 |
} static inline bool msg_is_grp_evt(struct tipc_msg *m) { return msg_type(m) == TIPC_GRP_MEMBER_EVT; |
75da2163d tipc: introduce c... |
373 |
} |
d265fef6d tipc: Remove obso... |
374 375 376 377 378 379 380 |
static inline u32 msg_named(struct tipc_msg *m) { return msg_type(m) == TIPC_NAMED_MSG; } static inline u32 msg_mcast(struct tipc_msg *m) { |
75da2163d tipc: introduce c... |
381 |
int mtyp = msg_type(m); |
5b8dddb63 tipc: introduce g... |
382 383 |
return ((mtyp == TIPC_MCAST_MSG) || (mtyp == TIPC_GRP_BCAST_MSG) || (mtyp == TIPC_GRP_MCAST_MSG)); |
d265fef6d tipc: Remove obso... |
384 385 386 387 388 389 |
} static inline u32 msg_connected(struct tipc_msg *m) { return msg_type(m) == TIPC_CONN_MSG; } |
8b1e5b0a9 tipc: Add a missi... |
390 391 392 393 |
static inline u32 msg_direct(struct tipc_msg *m) { return msg_type(m) == TIPC_DIRECT_MSG; } |
d265fef6d tipc: Remove obso... |
394 395 396 397 |
static inline u32 msg_errcode(struct tipc_msg *m) { return msg_bits(m, 1, 25, 0xf); } |
c43072852 [NET] TIPC: Fix w... |
398 |
static inline void msg_set_errcode(struct tipc_msg *m, u32 err) |
b97bf3fd8 [TIPC] Initial merge |
399 400 401 |
{ msg_set_bits(m, 1, 25, 0xf, err); } |
cad2929dc tipc: update a bi... |
402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 |
static inline void msg_set_bulk(struct tipc_msg *m) { msg_set_bits(m, 1, 28, 0x1, 1); } static inline u32 msg_is_bulk(struct tipc_msg *m) { return msg_bits(m, 1, 28, 0x1); } static inline void msg_set_last_bulk(struct tipc_msg *m) { msg_set_bits(m, 1, 27, 0x1, 1); } static inline u32 msg_is_last_bulk(struct tipc_msg *m) { return msg_bits(m, 1, 27, 0x1); } static inline void msg_set_non_legacy(struct tipc_msg *m) { msg_set_bits(m, 1, 26, 0x1, 1); } static inline u32 msg_is_legacy(struct tipc_msg *m) { return !msg_bits(m, 1, 26, 0x1); } |
c43072852 [NET] TIPC: Fix w... |
431 |
static inline u32 msg_reroute_cnt(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
432 433 434 |
{ return msg_bits(m, 1, 21, 0xf); } |
c43072852 [NET] TIPC: Fix w... |
435 |
static inline void msg_incr_reroute_cnt(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
436 437 438 |
{ msg_set_bits(m, 1, 21, 0xf, msg_reroute_cnt(m) + 1); } |
c43072852 [NET] TIPC: Fix w... |
439 |
static inline void msg_reset_reroute_cnt(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
440 441 442 443 444 445 446 447 |
{ msg_set_bits(m, 1, 21, 0xf, 0); } static inline u32 msg_lookup_scope(struct tipc_msg *m) { return msg_bits(m, 1, 19, 0x3); } |
c43072852 [NET] TIPC: Fix w... |
448 |
static inline void msg_set_lookup_scope(struct tipc_msg *m, u32 n) |
b97bf3fd8 [TIPC] Initial merge |
449 450 451 |
{ msg_set_bits(m, 1, 19, 0x3, n); } |
e4bf4f769 tipc: simplify pa... |
452 |
static inline u16 msg_bcast_ack(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
453 454 455 |
{ return msg_bits(m, 1, 0, 0xffff); } |
e4bf4f769 tipc: simplify pa... |
456 |
static inline void msg_set_bcast_ack(struct tipc_msg *m, u16 n) |
b97bf3fd8 [TIPC] Initial merge |
457 458 459 |
{ msg_set_bits(m, 1, 0, 0xffff, n); } |
91986ee16 tipc: fix link se... |
460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 |
/* Note: reusing bits in word 1 for ACTIVATE_MSG only, to re-synch * link peer session number */ static inline bool msg_dest_session_valid(struct tipc_msg *m) { return msg_bits(m, 1, 16, 0x1); } static inline void msg_set_dest_session_valid(struct tipc_msg *m, bool valid) { msg_set_bits(m, 1, 16, 0x1, valid); } static inline u16 msg_dest_session(struct tipc_msg *m) { return msg_bits(m, 1, 0, 0xffff); } static inline void msg_set_dest_session(struct tipc_msg *m, u16 n) { msg_set_bits(m, 1, 0, 0xffff, n); } |
b97bf3fd8 [TIPC] Initial merge |
482 |
|
c43072852 [NET] TIPC: Fix w... |
483 |
/* |
b97bf3fd8 [TIPC] Initial merge |
484 485 |
* Word 2 */ |
e4bf4f769 tipc: simplify pa... |
486 |
static inline u16 msg_ack(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
487 488 489 |
{ return msg_bits(m, 2, 16, 0xffff); } |
e4bf4f769 tipc: simplify pa... |
490 |
static inline void msg_set_ack(struct tipc_msg *m, u16 n) |
b97bf3fd8 [TIPC] Initial merge |
491 492 493 |
{ msg_set_bits(m, 2, 16, 0xffff, n); } |
e4bf4f769 tipc: simplify pa... |
494 |
static inline u16 msg_seqno(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
495 496 497 |
{ return msg_bits(m, 2, 0, 0xffff); } |
e4bf4f769 tipc: simplify pa... |
498 |
static inline void msg_set_seqno(struct tipc_msg *m, u16 n) |
b97bf3fd8 [TIPC] Initial merge |
499 500 501 |
{ msg_set_bits(m, 2, 0, 0xffff, n); } |
40aecb1b1 tipc: Message rej... |
502 |
/* |
b97bf3fd8 [TIPC] Initial merge |
503 504 |
* Words 3-10 */ |
e3eea1eb4 tipc: clean up ha... |
505 506 |
static inline u32 msg_importance(struct tipc_msg *m) { |
f21e897ec tipc: improve lin... |
507 508 509 510 511 |
int usr = msg_user(m); if (likely((usr <= TIPC_CRITICAL_IMPORTANCE) && !msg_errcode(m))) return usr; if ((usr == MSG_FRAGMENTER) || (usr == MSG_BUNDLER)) |
dde4b5ae6 tipc: move fragme... |
512 |
return msg_bits(m, 9, 0, 0x7); |
e3eea1eb4 tipc: clean up ha... |
513 514 515 516 517 |
return TIPC_SYSTEM_IMPORTANCE; } static inline void msg_set_importance(struct tipc_msg *m, u32 i) { |
f21e897ec tipc: improve lin... |
518 519 520 |
int usr = msg_user(m); if (likely((usr == MSG_FRAGMENTER) || (usr == MSG_BUNDLER))) |
dde4b5ae6 tipc: move fragme... |
521 |
msg_set_bits(m, 9, 0, 0x7, i); |
f21e897ec tipc: improve lin... |
522 |
else if (i < TIPC_SYSTEM_IMPORTANCE) |
e3eea1eb4 tipc: clean up ha... |
523 524 525 526 527 |
msg_set_user(m, i); else pr_warn("Trying to set illegal importance in message "); } |
d265fef6d tipc: Remove obso... |
528 529 530 531 |
static inline u32 msg_prevnode(struct tipc_msg *m) { return msg_word(m, 3); } |
c43072852 [NET] TIPC: Fix w... |
532 |
static inline void msg_set_prevnode(struct tipc_msg *m, u32 a) |
b97bf3fd8 [TIPC] Initial merge |
533 534 535 |
{ msg_set_word(m, 3, a); } |
d265fef6d tipc: Remove obso... |
536 537 |
static inline u32 msg_origport(struct tipc_msg *m) { |
3127a0200 tipc: clean up ha... |
538 |
if (msg_user(m) == MSG_FRAGMENTER) |
a7dc51adc tipc: rename func... |
539 |
m = msg_inner_hdr(m); |
d265fef6d tipc: Remove obso... |
540 541 |
return msg_word(m, 4); } |
c43072852 [NET] TIPC: Fix w... |
542 |
static inline void msg_set_origport(struct tipc_msg *m, u32 p) |
b97bf3fd8 [TIPC] Initial merge |
543 544 545 |
{ msg_set_word(m, 4, p); } |
cad2929dc tipc: update a bi... |
546 547 548 549 550 551 552 553 554 |
static inline u16 msg_named_seqno(struct tipc_msg *m) { return msg_bits(m, 4, 0, 0xffff); } static inline void msg_set_named_seqno(struct tipc_msg *m, u16 n) { msg_set_bits(m, 4, 0, 0xffff, n); } |
d265fef6d tipc: Remove obso... |
555 556 557 558 |
static inline u32 msg_destport(struct tipc_msg *m) { return msg_word(m, 5); } |
c43072852 [NET] TIPC: Fix w... |
559 |
static inline void msg_set_destport(struct tipc_msg *m, u32 p) |
b97bf3fd8 [TIPC] Initial merge |
560 561 562 |
{ msg_set_word(m, 5, p); } |
d265fef6d tipc: Remove obso... |
563 564 565 566 |
static inline u32 msg_mc_netid(struct tipc_msg *m) { return msg_word(m, 5); } |
c43072852 [NET] TIPC: Fix w... |
567 |
static inline void msg_set_mc_netid(struct tipc_msg *m, u32 p) |
b97bf3fd8 [TIPC] Initial merge |
568 569 570 |
{ msg_set_word(m, 5, p); } |
d265fef6d tipc: Remove obso... |
571 572 |
static inline int msg_short(struct tipc_msg *m) { |
741d9eb7b tipc: Cleanup of ... |
573 |
return msg_hdr_sz(m) == SHORT_H_SIZE; |
d265fef6d tipc: Remove obso... |
574 575 576 577 578 579 580 581 |
} static inline u32 msg_orignode(struct tipc_msg *m) { if (likely(msg_short(m))) return msg_prevnode(m); return msg_word(m, 6); } |
c43072852 [NET] TIPC: Fix w... |
582 |
static inline void msg_set_orignode(struct tipc_msg *m, u32 a) |
b97bf3fd8 [TIPC] Initial merge |
583 584 585 |
{ msg_set_word(m, 6, a); } |
d265fef6d tipc: Remove obso... |
586 587 588 589 |
static inline u32 msg_destnode(struct tipc_msg *m) { return msg_word(m, 7); } |
c43072852 [NET] TIPC: Fix w... |
590 |
static inline void msg_set_destnode(struct tipc_msg *m, u32 a) |
b97bf3fd8 [TIPC] Initial merge |
591 592 593 |
{ msg_set_word(m, 7, a); } |
d265fef6d tipc: Remove obso... |
594 595 596 597 |
static inline u32 msg_nametype(struct tipc_msg *m) { return msg_word(m, 8); } |
c43072852 [NET] TIPC: Fix w... |
598 |
static inline void msg_set_nametype(struct tipc_msg *m, u32 n) |
b97bf3fd8 [TIPC] Initial merge |
599 600 601 |
{ msg_set_word(m, 8, n); } |
d265fef6d tipc: Remove obso... |
602 603 604 605 606 607 608 609 610 |
static inline u32 msg_nameinst(struct tipc_msg *m) { return msg_word(m, 9); } static inline u32 msg_namelower(struct tipc_msg *m) { return msg_nameinst(m); } |
c43072852 [NET] TIPC: Fix w... |
611 |
static inline void msg_set_namelower(struct tipc_msg *m, u32 n) |
b97bf3fd8 [TIPC] Initial merge |
612 613 614 |
{ msg_set_word(m, 9, n); } |
c43072852 [NET] TIPC: Fix w... |
615 |
static inline void msg_set_nameinst(struct tipc_msg *m, u32 n) |
b97bf3fd8 [TIPC] Initial merge |
616 617 618 |
{ msg_set_namelower(m, n); } |
d265fef6d tipc: Remove obso... |
619 620 621 622 |
static inline u32 msg_nameupper(struct tipc_msg *m) { return msg_word(m, 10); } |
c43072852 [NET] TIPC: Fix w... |
623 |
static inline void msg_set_nameupper(struct tipc_msg *m, u32 n) |
b97bf3fd8 [TIPC] Initial merge |
624 625 626 |
{ msg_set_word(m, 10, n); } |
b97bf3fd8 [TIPC] Initial merge |
627 |
/* |
cc4c4353f tipc: Update comm... |
628 629 |
* Constants and routines used to read and write TIPC internal message headers */ |
b97bf3fd8 [TIPC] Initial merge |
630 |
|
c43072852 [NET] TIPC: Fix w... |
631 |
/* |
cc4c4353f tipc: Update comm... |
632 |
* Connection management protocol message types |
b97bf3fd8 [TIPC] Initial merge |
633 |
*/ |
b97bf3fd8 [TIPC] Initial merge |
634 635 636 |
#define CONN_PROBE 0 #define CONN_PROBE_REPLY 1 #define CONN_ACK 2 |
c43072852 [NET] TIPC: Fix w... |
637 |
/* |
cc4c4353f tipc: Update comm... |
638 |
* Name distributor message types |
b97bf3fd8 [TIPC] Initial merge |
639 |
*/ |
b97bf3fd8 [TIPC] Initial merge |
640 641 |
#define PUBLICATION 0 #define WITHDRAWAL 1 |
92138d1f2 tipc: Cosmetic co... |
642 643 644 |
/* * Segmentation message types */ |
92138d1f2 tipc: Cosmetic co... |
645 646 647 648 649 650 651 |
#define FIRST_FRAGMENT 0 #define FRAGMENT 1 #define LAST_FRAGMENT 2 /* * Link management protocol message types */ |
92138d1f2 tipc: Cosmetic co... |
652 653 654 655 656 657 658 |
#define STATE_MSG 0 #define RESET_MSG 1 #define ACTIVATE_MSG 2 /* * Changeover tunnel message types */ |
dff29b1a8 tipc: eliminate d... |
659 660 |
#define SYNCH_MSG 0 #define FAILOVER_MSG 1 |
92138d1f2 tipc: Cosmetic co... |
661 662 663 664 |
/* * Config protocol message types */ |
92138d1f2 tipc: Cosmetic co... |
665 666 |
#define DSC_REQ_MSG 0 #define DSC_RESP_MSG 1 |
25b0b9c4e tipc: handle coll... |
667 668 |
#define DSC_TRIAL_MSG 2 #define DSC_TRIAL_FAIL_MSG 3 |
92138d1f2 tipc: Cosmetic co... |
669 |
|
c43072852 [NET] TIPC: Fix w... |
670 |
/* |
75da2163d tipc: introduce c... |
671 672 673 674 |
* Group protocol message types */ #define GRP_JOIN_MSG 0 #define GRP_LEAVE_MSG 1 |
b7d426355 tipc: introduce f... |
675 |
#define GRP_ADV_MSG 2 |
2f487712b tipc: guarantee t... |
676 |
#define GRP_ACK_MSG 3 |
04d7b574b tipc: add multipo... |
677 678 |
#define GRP_RECLAIM_MSG 4 #define GRP_REMIT_MSG 5 |
75da2163d tipc: introduce c... |
679 |
|
1ef6f7c93 tipc: add automat... |
680 681 |
/* Crypto message types */ #define KEY_DISTR_MSG 0 |
75da2163d tipc: introduce c... |
682 |
/* |
b97bf3fd8 [TIPC] Initial merge |
683 684 |
* Word 1 */ |
b97bf3fd8 [TIPC] Initial merge |
685 686 |
static inline u32 msg_seq_gap(struct tipc_msg *m) { |
bd7845337 tipc: Expand link... |
687 |
return msg_bits(m, 1, 16, 0x1fff); |
b97bf3fd8 [TIPC] Initial merge |
688 689 690 691 |
} static inline void msg_set_seq_gap(struct tipc_msg *m, u32 n) { |
bd7845337 tipc: Expand link... |
692 |
msg_set_bits(m, 1, 16, 0x1fff, n); |
b97bf3fd8 [TIPC] Initial merge |
693 |
} |
fc0eea691 tipc: Introduce n... |
694 695 696 697 698 699 700 701 702 |
static inline u32 msg_node_sig(struct tipc_msg *m) { return msg_bits(m, 1, 0, 0xffff); } static inline void msg_set_node_sig(struct tipc_msg *m, u32 n) { msg_set_bits(m, 1, 0, 0xffff, n); } |
7764d6e83 tipc: add framewo... |
703 704 705 706 707 708 709 710 711 |
static inline u32 msg_node_capabilities(struct tipc_msg *m) { return msg_bits(m, 1, 15, 0x1fff); } static inline void msg_set_node_capabilities(struct tipc_msg *m, u32 n) { msg_set_bits(m, 1, 15, 0x1fff, n); } |
c43072852 [NET] TIPC: Fix w... |
712 |
/* |
b97bf3fd8 [TIPC] Initial merge |
713 714 |
* Word 2 */ |
b97bf3fd8 [TIPC] Initial merge |
715 716 717 718 |
static inline u32 msg_dest_domain(struct tipc_msg *m) { return msg_word(m, 2); } |
c43072852 [NET] TIPC: Fix w... |
719 |
static inline void msg_set_dest_domain(struct tipc_msg *m, u32 n) |
b97bf3fd8 [TIPC] Initial merge |
720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 |
{ msg_set_word(m, 2, n); } static inline u32 msg_bcgap_after(struct tipc_msg *m) { return msg_bits(m, 2, 16, 0xffff); } static inline void msg_set_bcgap_after(struct tipc_msg *m, u32 n) { msg_set_bits(m, 2, 16, 0xffff, n); } static inline u32 msg_bcgap_to(struct tipc_msg *m) { return msg_bits(m, 2, 0, 0xffff); } |
c43072852 [NET] TIPC: Fix w... |
738 |
static inline void msg_set_bcgap_to(struct tipc_msg *m, u32 n) |
b97bf3fd8 [TIPC] Initial merge |
739 740 741 |
{ msg_set_bits(m, 2, 0, 0xffff, n); } |
c43072852 [NET] TIPC: Fix w... |
742 |
/* |
b97bf3fd8 [TIPC] Initial merge |
743 744 |
* Word 4 */ |
b97bf3fd8 [TIPC] Initial merge |
745 746 747 748 |
static inline u32 msg_last_bcast(struct tipc_msg *m) { return msg_bits(m, 4, 16, 0xffff); } |
526669866 tipc: let broadca... |
749 750 751 752 |
static inline u32 msg_bc_snd_nxt(struct tipc_msg *m) { return msg_last_bcast(m) + 1; } |
b97bf3fd8 [TIPC] Initial merge |
753 754 755 756 |
static inline void msg_set_last_bcast(struct tipc_msg *m, u32 n) { msg_set_bits(m, 4, 16, 0xffff, n); } |
2320bcdae tipc: fix changeo... |
757 758 759 760 761 762 763 764 765 766 767 768 769 770 |
static inline u32 msg_nof_fragms(struct tipc_msg *m) { return msg_bits(m, 4, 0, 0xffff); } static inline void msg_set_nof_fragms(struct tipc_msg *m, u32 n) { msg_set_bits(m, 4, 0, 0xffff, n); } static inline u32 msg_fragm_no(struct tipc_msg *m) { return msg_bits(m, 4, 16, 0xffff); } |
b97bf3fd8 [TIPC] Initial merge |
771 772 773 774 |
static inline void msg_set_fragm_no(struct tipc_msg *m, u32 n) { msg_set_bits(m, 4, 16, 0xffff, n); } |
6e498158a tipc: move link s... |
775 |
static inline u16 msg_next_sent(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
776 777 778 |
{ return msg_bits(m, 4, 0, 0xffff); } |
6e498158a tipc: move link s... |
779 |
static inline void msg_set_next_sent(struct tipc_msg *m, u16 n) |
b97bf3fd8 [TIPC] Initial merge |
780 781 782 |
{ msg_set_bits(m, 4, 0, 0xffff, n); } |
b97bf3fd8 [TIPC] Initial merge |
783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 |
static inline void msg_set_long_msgno(struct tipc_msg *m, u32 n) { msg_set_bits(m, 4, 0, 0xffff, n); } static inline u32 msg_bc_netid(struct tipc_msg *m) { return msg_word(m, 4); } static inline void msg_set_bc_netid(struct tipc_msg *m, u32 id) { msg_set_word(m, 4, id); } static inline u32 msg_link_selector(struct tipc_msg *m) { |
a853e4c6d tipc: introduce r... |
800 801 |
if (msg_user(m) == MSG_FRAGMENTER) m = (void *)msg_data(m); |
b97bf3fd8 [TIPC] Initial merge |
802 803 |
return msg_bits(m, 4, 0, 1); } |
c43072852 [NET] TIPC: Fix w... |
804 |
/* |
b97bf3fd8 [TIPC] Initial merge |
805 806 |
* Word 5 */ |
d999297c3 tipc: reduce lock... |
807 |
static inline u16 msg_session(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
808 809 810 |
{ return msg_bits(m, 5, 16, 0xffff); } |
d999297c3 tipc: reduce lock... |
811 |
static inline void msg_set_session(struct tipc_msg *m, u16 n) |
b97bf3fd8 [TIPC] Initial merge |
812 813 814 815 816 817 818 819 820 821 822 |
{ msg_set_bits(m, 5, 16, 0xffff, n); } static inline u32 msg_probe(struct tipc_msg *m) { return msg_bits(m, 5, 0, 1); } static inline void msg_set_probe(struct tipc_msg *m, u32 val) { |
7eb878ed8 tipc: Eliminate r... |
823 |
msg_set_bits(m, 5, 0, 1, val); |
b97bf3fd8 [TIPC] Initial merge |
824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 |
} static inline char msg_net_plane(struct tipc_msg *m) { return msg_bits(m, 5, 1, 7) + 'A'; } static inline void msg_set_net_plane(struct tipc_msg *m, char n) { msg_set_bits(m, 5, 1, 7, (n - 'A')); } static inline u32 msg_linkprio(struct tipc_msg *m) { return msg_bits(m, 5, 4, 0x1f); } static inline void msg_set_linkprio(struct tipc_msg *m, u32 n) { msg_set_bits(m, 5, 4, 0x1f, n); } static inline u32 msg_bearer_id(struct tipc_msg *m) { return msg_bits(m, 5, 9, 0x7); } static inline void msg_set_bearer_id(struct tipc_msg *m, u32 n) { msg_set_bits(m, 5, 9, 0x7, n); } static inline u32 msg_redundant_link(struct tipc_msg *m) { return msg_bits(m, 5, 12, 0x1); } |
77f167fcc tipc: make msg_se... |
860 |
static inline void msg_set_redundant_link(struct tipc_msg *m, u32 r) |
b97bf3fd8 [TIPC] Initial merge |
861 |
{ |
77f167fcc tipc: make msg_se... |
862 |
msg_set_bits(m, 5, 12, 0x1, r); |
b97bf3fd8 [TIPC] Initial merge |
863 |
} |
634696b19 tipc: guarantee p... |
864 865 866 867 868 869 870 871 872 |
static inline u32 msg_peer_stopping(struct tipc_msg *m) { return msg_bits(m, 5, 13, 0x1); } static inline void msg_set_peer_stopping(struct tipc_msg *m, u32 s) { msg_set_bits(m, 5, 13, 0x1, s); } |
06bd2b1ed tipc: fix broadca... |
873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 |
static inline bool msg_bc_ack_invalid(struct tipc_msg *m) { switch (msg_user(m)) { case BCAST_PROTOCOL: case NAME_DISTRIBUTOR: case LINK_PROTOCOL: return msg_bits(m, 5, 14, 0x1); default: return false; } } static inline void msg_set_bc_ack_invalid(struct tipc_msg *m, bool invalid) { msg_set_bits(m, 5, 14, 0x1, invalid); } |
3d749a6a2 tipc: Hide media-... |
889 890 |
static inline char *msg_media_addr(struct tipc_msg *m) { |
91e2eb568 tipc: rename medi... |
891 |
return (char *)&m->hdr[TIPC_MEDIA_INFO_OFFSET]; |
3d749a6a2 tipc: Hide media-... |
892 |
} |
b97bf3fd8 [TIPC] Initial merge |
893 |
|
02d11ca20 tipc: transfer br... |
894 895 896 897 898 899 900 901 902 |
static inline u32 msg_bc_gap(struct tipc_msg *m) { return msg_bits(m, 8, 0, 0x3ff); } static inline void msg_set_bc_gap(struct tipc_msg *m, u32 n) { msg_set_bits(m, 8, 0, 0x3ff, n); } |
c43072852 [NET] TIPC: Fix w... |
903 |
/* |
b97bf3fd8 [TIPC] Initial merge |
904 905 |
* Word 9 */ |
6e498158a tipc: move link s... |
906 |
static inline u16 msg_msgcnt(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
907 908 909 |
{ return msg_bits(m, 9, 16, 0xffff); } |
6e498158a tipc: move link s... |
910 |
static inline void msg_set_msgcnt(struct tipc_msg *m, u16 n) |
b97bf3fd8 [TIPC] Initial merge |
911 912 913 |
{ msg_set_bits(m, 9, 16, 0xffff, n); } |
4929a932b tipc: optimize li... |
914 915 916 917 918 919 920 921 922 |
static inline u16 msg_syncpt(struct tipc_msg *m) { return msg_bits(m, 9, 16, 0xffff); } static inline void msg_set_syncpt(struct tipc_msg *m, u16 n) { msg_set_bits(m, 9, 16, 0xffff, n); } |
10724cc7b tipc: redesign co... |
923 |
static inline u32 msg_conn_ack(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
924 925 926 |
{ return msg_bits(m, 9, 16, 0xffff); } |
10724cc7b tipc: redesign co... |
927 |
static inline void msg_set_conn_ack(struct tipc_msg *m, u32 n) |
b97bf3fd8 [TIPC] Initial merge |
928 929 930 |
{ msg_set_bits(m, 9, 16, 0xffff, n); } |
b7d426355 tipc: introduce f... |
931 |
static inline u16 msg_adv_win(struct tipc_msg *m) |
10724cc7b tipc: redesign co... |
932 933 934 |
{ return msg_bits(m, 9, 0, 0xffff); } |
b7d426355 tipc: introduce f... |
935 |
static inline void msg_set_adv_win(struct tipc_msg *m, u16 n) |
10724cc7b tipc: redesign co... |
936 937 938 |
{ msg_set_bits(m, 9, 0, 0xffff, n); } |
c43072852 [NET] TIPC: Fix w... |
939 |
static inline u32 msg_max_pkt(struct tipc_msg *m) |
b97bf3fd8 [TIPC] Initial merge |
940 |
{ |
a02cec215 net: return opera... |
941 |
return msg_bits(m, 9, 16, 0xffff) * 4; |
b97bf3fd8 [TIPC] Initial merge |
942 |
} |
c43072852 [NET] TIPC: Fix w... |
943 |
static inline void msg_set_max_pkt(struct tipc_msg *m, u32 n) |
b97bf3fd8 [TIPC] Initial merge |
944 945 946 947 948 949 950 951 952 953 954 955 956 |
{ msg_set_bits(m, 9, 16, 0xffff, (n / 4)); } static inline u32 msg_link_tolerance(struct tipc_msg *m) { return msg_bits(m, 9, 0, 0xffff); } static inline void msg_set_link_tolerance(struct tipc_msg *m, u32 n) { msg_set_bits(m, 9, 0, 0xffff, n); } |
75da2163d tipc: introduce c... |
957 958 959 960 961 962 963 964 965 |
static inline u16 msg_grp_bc_syncpt(struct tipc_msg *m) { return msg_bits(m, 9, 16, 0xffff); } static inline void msg_set_grp_bc_syncpt(struct tipc_msg *m, u16 n) { msg_set_bits(m, 9, 16, 0xffff, n); } |
2f487712b tipc: guarantee t... |
966 967 968 969 970 971 972 973 974 |
static inline u16 msg_grp_bc_acked(struct tipc_msg *m) { return msg_bits(m, 9, 16, 0xffff); } static inline void msg_set_grp_bc_acked(struct tipc_msg *m, u16 n) { msg_set_bits(m, 9, 16, 0xffff, n); } |
04d7b574b tipc: add multipo... |
975 976 977 978 979 980 981 982 983 |
static inline u16 msg_grp_remitted(struct tipc_msg *m) { return msg_bits(m, 9, 16, 0xffff); } static inline void msg_set_grp_remitted(struct tipc_msg *m, u16 n) { msg_set_bits(m, 9, 16, 0xffff, n); } |
75da2163d tipc: introduce c... |
984 985 |
/* Word 10 */ |
ae236fb20 tipc: receive gro... |
986 987 988 989 990 991 992 993 994 |
static inline u16 msg_grp_evt(struct tipc_msg *m) { return msg_bits(m, 10, 0, 0x3); } static inline void msg_set_grp_evt(struct tipc_msg *m, int n) { msg_set_bits(m, 10, 0, 0x3, n); } |
2f487712b tipc: guarantee t... |
995 996 997 998 999 1000 1001 1002 1003 |
static inline u16 msg_grp_bc_ack_req(struct tipc_msg *m) { return msg_bits(m, 10, 0, 0x1); } static inline void msg_set_grp_bc_ack_req(struct tipc_msg *m, bool n) { msg_set_bits(m, 10, 0, 0x1, n); } |
75da2163d tipc: introduce c... |
1004 1005 1006 1007 1008 1009 1010 1011 1012 |
static inline u16 msg_grp_bc_seqno(struct tipc_msg *m) { return msg_bits(m, 10, 16, 0xffff); } static inline void msg_set_grp_bc_seqno(struct tipc_msg *m, u32 n) { msg_set_bits(m, 10, 16, 0xffff, n); } |
6e498158a tipc: move link s... |
1013 |
static inline bool msg_peer_link_is_up(struct tipc_msg *m) |
1a20cc254 tipc: introduce n... |
1014 |
{ |
d999297c3 tipc: reduce lock... |
1015 |
if (likely(msg_user(m) != LINK_PROTOCOL)) |
1a20cc254 tipc: introduce n... |
1016 |
return true; |
6e498158a tipc: move link s... |
1017 1018 1019 |
if (msg_type(m) == STATE_MSG) return true; return false; |
d999297c3 tipc: reduce lock... |
1020 |
} |
6e498158a tipc: move link s... |
1021 |
static inline bool msg_peer_node_is_up(struct tipc_msg *m) |
d999297c3 tipc: reduce lock... |
1022 |
{ |
6e498158a tipc: move link s... |
1023 1024 |
if (msg_peer_link_is_up(m)) return true; |
1a20cc254 tipc: introduce n... |
1025 1026 |
return msg_redundant_link(m); } |
5b7066c3d tipc: stricter fi... |
1027 1028 1029 1030 |
static inline bool msg_is_reset(struct tipc_msg *hdr) { return (msg_user(hdr) == LINK_PROTOCOL) && (msg_type(hdr) == RESET_MSG); } |
f73b12812 tipc: improve thr... |
1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 |
/* Word 13 */ static inline void msg_set_peer_net_hash(struct tipc_msg *m, u32 n) { msg_set_word(m, 13, n); } static inline u32 msg_peer_net_hash(struct tipc_msg *m) { return msg_word(m, 13); } /* Word 14 */ |
25b0b9c4e tipc: handle coll... |
1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 |
static inline u32 msg_sugg_node_addr(struct tipc_msg *m) { return msg_word(m, 14); } static inline void msg_set_sugg_node_addr(struct tipc_msg *m, u32 n) { msg_set_word(m, 14, n); } static inline void msg_set_node_id(struct tipc_msg *hdr, u8 *id) { memcpy(msg_data(hdr), id, 16); } static inline u8 *msg_node_id(struct tipc_msg *hdr) { return (u8 *)msg_data(hdr); } |
57d5f64d8 tipc: allocate us... |
1064 |
struct sk_buff *tipc_buf_acquire(u32 size, gfp_t gfp); |
d618d09a6 tipc: enforce val... |
1065 |
bool tipc_msg_validate(struct sk_buff **_skb); |
bcd3ffd4f tipc: introduce n... |
1066 |
bool tipc_msg_reverse(u32 own_addr, struct sk_buff **skb, int err); |
64ac5f597 tipc: refactor fu... |
1067 1068 |
void tipc_skb_reject(struct net *net, int err, struct sk_buff *skb, struct sk_buff_head *xmitq); |
c5898636c tipc: reduce usag... |
1069 |
void tipc_msg_init(u32 own_addr, struct tipc_msg *m, u32 user, u32 type, |
347475395 tipc: make tipc n... |
1070 |
u32 hsize, u32 destnode); |
e3a77561e tipc: split up fu... |
1071 1072 1073 |
struct sk_buff *tipc_msg_create(uint user, uint type, uint hdr_sz, uint data_sz, u32 dnode, u32 onode, u32 dport, u32 oport, int errcode); |
37e22164a tipc: rename and ... |
1074 |
int tipc_buf_append(struct sk_buff **headbuf, struct sk_buff **buf); |
06e7c70c6 tipc: improve mes... |
1075 1076 |
bool tipc_msg_try_bundle(struct sk_buff *tskb, struct sk_buff **skb, u32 mss, u32 dnode, bool *new_bundle); |
c637c1035 tipc: resolve rac... |
1077 |
bool tipc_msg_extract(struct sk_buff *skb, struct sk_buff **iskb, int *pos); |
2320bcdae tipc: fix changeo... |
1078 1079 |
int tipc_msg_fragment(struct sk_buff *skb, const struct tipc_msg *hdr, int pktmax, struct sk_buff_head *frags); |
c5898636c tipc: reduce usag... |
1080 |
int tipc_msg_build(struct tipc_msg *mhdr, struct msghdr *m, |
347475395 tipc: make tipc n... |
1081 |
int offset, int dsz, int mtu, struct sk_buff_head *list); |
c0bceb97d tipc: add smart n... |
1082 1083 |
int tipc_msg_append(struct tipc_msg *hdr, struct msghdr *m, int dlen, int mss, struct sk_buff_head *txq); |
cda3696d3 tipc: clean up so... |
1084 |
bool tipc_msg_lookup_dest(struct net *net, struct sk_buff *skb, int *err); |
4c94cc2d3 tipc: fall back t... |
1085 |
bool tipc_msg_assemble(struct sk_buff_head *list); |
2f5661245 tipc: let broadca... |
1086 |
bool tipc_msg_reassemble(struct sk_buff_head *list, struct sk_buff_head *rcvq); |
a853e4c6d tipc: introduce r... |
1087 1088 |
bool tipc_msg_pskb_copy(u32 dst, struct sk_buff_head *msg, struct sk_buff_head *cpy); |
03b6fefd9 tipc: add support... |
1089 |
bool __tipc_skb_queue_sorted(struct sk_buff_head *list, u16 seqno, |
8306f99a5 tipc: disallow pa... |
1090 |
struct sk_buff *skb); |
678792747 tipc: buffer over... |
1091 |
bool tipc_msg_skb_clone(struct sk_buff_head *msg, struct sk_buff_head *cpy); |
078bec826 tipc: add new fun... |
1092 |
|
e4bf4f769 tipc: simplify pa... |
1093 1094 1095 1096 |
static inline u16 buf_seqno(struct sk_buff *skb) { return msg_seqno(buf_msg(skb)); } |
d618d09a6 tipc: enforce val... |
1097 1098 1099 1100 |
static inline int buf_roundup_len(struct sk_buff *skb) { return (skb->len / 1024 + 1) * 1024; } |
cb1b72809 tipc: eliminate r... |
1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 |
/* tipc_skb_peek(): peek and reserve first buffer in list * @list: list to be peeked in * Returns pointer to first buffer in list, if any */ static inline struct sk_buff *tipc_skb_peek(struct sk_buff_head *list, spinlock_t *lock) { struct sk_buff *skb; spin_lock_bh(lock); skb = skb_peek(list); if (skb) skb_get(skb); spin_unlock_bh(lock); return skb; } |
c637c1035 tipc: resolve rac... |
1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 |
/* tipc_skb_peek_port(): find a destination port, ignoring all destinations * up to and including 'filter'. * Note: ignoring previously tried destinations minimizes the risk of * contention on the socket lock * @list: list to be peeked in * @filter: last destination to be ignored from search * Returns a destination port number, of applicable. */ static inline u32 tipc_skb_peek_port(struct sk_buff_head *list, u32 filter) { struct sk_buff *skb; u32 dport = 0; bool ignore = true; spin_lock_bh(&list->lock); skb_queue_walk(list, skb) { dport = msg_destport(buf_msg(skb)); if (!filter || skb_queue_is_last(list, skb)) break; if (dport == filter) ignore = false; else if (!ignore) break; } spin_unlock_bh(&list->lock); return dport; } /* tipc_skb_dequeue(): unlink first buffer with dest 'dport' from list * @list: list to be unlinked from * @dport: selection criteria for buffer to unlink */ static inline struct sk_buff *tipc_skb_dequeue(struct sk_buff_head *list, u32 dport) { struct sk_buff *_skb, *tmp, *skb = NULL; spin_lock_bh(&list->lock); skb_queue_walk_safe(list, _skb, tmp) { if (msg_destport(buf_msg(_skb)) == dport) { __skb_unlink(_skb, list); skb = _skb; break; } } spin_unlock_bh(&list->lock); return skb; } |
598411d70 tipc: make resett... |
1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 |
/* tipc_skb_queue_splice_tail - append an skb list to lock protected list * @list: the new list to append. Not lock protected * @head: target list. Lock protected. */ static inline void tipc_skb_queue_splice_tail(struct sk_buff_head *list, struct sk_buff_head *head) { spin_lock_bh(&head->lock); skb_queue_splice_tail(list, head); spin_unlock_bh(&head->lock); } /* tipc_skb_queue_splice_tail_init - merge two lock protected skb lists * @list: the new list to add. Lock protected. Will be reinitialized * @head: target list. Lock protected. */ static inline void tipc_skb_queue_splice_tail_init(struct sk_buff_head *list, struct sk_buff_head *head) { struct sk_buff_head tmp; __skb_queue_head_init(&tmp); spin_lock_bh(&list->lock); skb_queue_splice_tail_init(list, &tmp); spin_unlock_bh(&list->lock); tipc_skb_queue_splice_tail(&tmp, head); } |
382f598fb tipc: reduce dupl... |
1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 |
/* __tipc_skb_dequeue() - dequeue the head skb according to expected seqno * @list: list to be dequeued from * @seqno: seqno of the expected msg * * returns skb dequeued from the list if its seqno is less than or equal to * the expected one, otherwise the skb is still hold * * Note: must be used with appropriate locks held only */ static inline struct sk_buff *__tipc_skb_dequeue(struct sk_buff_head *list, u16 seqno) { struct sk_buff *skb = skb_peek(list); if (skb && less_eq(buf_seqno(skb), seqno)) { __skb_unlink(skb, list); return skb; } return NULL; } |
b97bf3fd8 [TIPC] Initial merge |
1213 |
#endif |