blob: e9ef6df26562c224256006f4a71733347ca354f7 [file] [log] [blame]
Per Lidenb97bf3f2006-01-02 19:04:38 +01001/*
2 * net/tipc/msg.h: Include file for TIPC message header routines
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +09003 *
Allan Stephens1f9eda72007-04-24 14:51:55 -07004 * Copyright (c) 2000-2007, Ericsson AB
5 * Copyright (c) 2005-2007, Wind River Systems
Per Lidenb97bf3f2006-01-02 19:04:38 +01006 * All rights reserved.
7 *
Per Liden9ea1fd32006-01-11 13:30:43 +01008 * Redistribution and use in source and binary forms, with or without
Per Lidenb97bf3f2006-01-02 19:04:38 +01009 * modification, are permitted provided that the following conditions are met:
10 *
Per Liden9ea1fd32006-01-11 13:30:43 +010011 * 1. Redistributions of source code must retain the above copyright
12 * notice, this list of conditions and the following disclaimer.
13 * 2. Redistributions in binary form must reproduce the above copyright
14 * notice, this list of conditions and the following disclaimer in the
15 * documentation and/or other materials provided with the distribution.
16 * 3. Neither the names of the copyright holders nor the names of its
17 * contributors may be used to endorse or promote products derived from
18 * this software without specific prior written permission.
Per Lidenb97bf3f2006-01-02 19:04:38 +010019 *
Per Liden9ea1fd32006-01-11 13:30:43 +010020 * Alternatively, this software may be distributed under the terms of the
21 * GNU General Public License ("GPL") version 2 as published by the Free
22 * Software Foundation.
23 *
24 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
25 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
26 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
27 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
28 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
29 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
30 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
31 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
32 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
33 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
Per Lidenb97bf3f2006-01-02 19:04:38 +010034 * POSSIBILITY OF SUCH DAMAGE.
35 */
36
37#ifndef _TIPC_MSG_H
38#define _TIPC_MSG_H
39
Jon Maloy5f7c3ff2006-01-13 10:45:44 +000040#include "core.h"
Per Lidenb97bf3f2006-01-02 19:04:38 +010041
42#define TIPC_VERSION 2
43#define DATA_LOW TIPC_LOW_IMPORTANCE
44#define DATA_MEDIUM TIPC_MEDIUM_IMPORTANCE
45#define DATA_HIGH TIPC_HIGH_IMPORTANCE
46#define DATA_CRITICAL TIPC_CRITICAL_IMPORTANCE
47#define SHORT_H_SIZE 24 /* Connected,in cluster */
48#define DIR_MSG_H_SIZE 32 /* Directly addressed messages */
49#define CONN_MSG_H_SIZE 36 /* Routed connected msgs*/
50#define LONG_H_SIZE 40 /* Named Messages */
51#define MCAST_H_SIZE 44 /* Multicast messages */
52#define MAX_H_SIZE 60 /* Inclusive full options */
53#define MAX_MSG_SIZE (MAX_H_SIZE + TIPC_MAX_USER_MSG_SIZE)
54#define LINK_CONFIG 13
55
56
57/*
58 TIPC user data message header format, version 2
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +090059
Per Lidenb97bf3f2006-01-02 19:04:38 +010060 - Fundamental definitions available to privileged TIPC users
61 are located in tipc_msg.h.
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +090062 - Remaining definitions available to TIPC internal users appear below.
Per Lidenb97bf3f2006-01-02 19:04:38 +010063*/
64
65
66static inline void msg_set_word(struct tipc_msg *m, u32 w, u32 val)
67{
68 m->hdr[w] = htonl(val);
69}
70
71static inline void msg_set_bits(struct tipc_msg *m, u32 w,
72 u32 pos, u32 mask, u32 val)
73{
Allan Stephens1f9eda72007-04-24 14:51:55 -070074 val = (val & mask) << pos;
Al Viro582ee432007-07-26 17:33:39 +010075 m->hdr[w] &= ~htonl(mask << pos);
76 m->hdr[w] |= htonl(val);
Per Lidenb97bf3f2006-01-02 19:04:38 +010077}
78
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +090079/*
Per Lidenb97bf3f2006-01-02 19:04:38 +010080 * Word 0
81 */
82
83static inline u32 msg_version(struct tipc_msg *m)
84{
85 return msg_bits(m, 0, 29, 7);
86}
87
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +090088static inline void msg_set_version(struct tipc_msg *m)
Per Lidenb97bf3f2006-01-02 19:04:38 +010089{
90 msg_set_bits(m, 0, 29, 0xf, TIPC_VERSION);
91}
92
93static inline u32 msg_user(struct tipc_msg *m)
94{
95 return msg_bits(m, 0, 25, 0xf);
96}
97
98static inline u32 msg_isdata(struct tipc_msg *m)
99{
100 return (msg_user(m) <= DATA_CRITICAL);
101}
102
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900103static inline void msg_set_user(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100104{
105 msg_set_bits(m, 0, 25, 0xf, n);
106}
107
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900108static inline void msg_set_importance(struct tipc_msg *m, u32 i)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100109{
110 msg_set_user(m, i);
111}
112
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900113static inline void msg_set_hdr_sz(struct tipc_msg *m,u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100114{
115 msg_set_bits(m, 0, 21, 0xf, n>>2);
116}
117
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900118static inline int msg_non_seq(struct tipc_msg *m)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100119{
120 return msg_bits(m, 0, 20, 1);
121}
122
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900123static inline void msg_set_non_seq(struct tipc_msg *m)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100124{
125 msg_set_bits(m, 0, 20, 1, 1);
126}
127
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900128static inline int msg_dest_droppable(struct tipc_msg *m)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100129{
130 return msg_bits(m, 0, 19, 1);
131}
132
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900133static inline void msg_set_dest_droppable(struct tipc_msg *m, u32 d)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100134{
135 msg_set_bits(m, 0, 19, 1, d);
136}
137
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900138static inline int msg_src_droppable(struct tipc_msg *m)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100139{
140 return msg_bits(m, 0, 18, 1);
141}
142
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900143static inline void msg_set_src_droppable(struct tipc_msg *m, u32 d)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100144{
145 msg_set_bits(m, 0, 18, 1, d);
146}
147
148static inline void msg_set_size(struct tipc_msg *m, u32 sz)
149{
150 m->hdr[0] = htonl((msg_word(m, 0) & ~0x1ffff) | sz);
151}
152
153
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900154/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100155 * Word 1
156 */
157
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900158static inline void msg_set_type(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100159{
160 msg_set_bits(m, 1, 29, 0x7, n);
161}
162
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900163static inline void msg_set_errcode(struct tipc_msg *m, u32 err)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100164{
165 msg_set_bits(m, 1, 25, 0xf, err);
166}
167
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900168static inline u32 msg_reroute_cnt(struct tipc_msg *m)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100169{
170 return msg_bits(m, 1, 21, 0xf);
171}
172
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900173static inline void msg_incr_reroute_cnt(struct tipc_msg *m)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100174{
175 msg_set_bits(m, 1, 21, 0xf, msg_reroute_cnt(m) + 1);
176}
177
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900178static inline void msg_reset_reroute_cnt(struct tipc_msg *m)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100179{
180 msg_set_bits(m, 1, 21, 0xf, 0);
181}
182
183static inline u32 msg_lookup_scope(struct tipc_msg *m)
184{
185 return msg_bits(m, 1, 19, 0x3);
186}
187
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900188static inline void msg_set_lookup_scope(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100189{
190 msg_set_bits(m, 1, 19, 0x3, n);
191}
192
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900193static inline void msg_set_options(struct tipc_msg *m, const char *opt, u32 sz)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100194{
195 u32 hsz = msg_hdr_sz(m);
196 char *to = (char *)&m->hdr[hsz/4];
197
198 if ((hsz < DIR_MSG_H_SIZE) || ((hsz + sz) > MAX_H_SIZE))
199 return;
200 msg_set_bits(m, 1, 16, 0x7, (hsz - 28)/4);
201 msg_set_hdr_sz(m, hsz + sz);
202 memcpy(to, opt, sz);
203}
204
205static inline u32 msg_bcast_ack(struct tipc_msg *m)
206{
207 return msg_bits(m, 1, 0, 0xffff);
208}
209
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900210static inline void msg_set_bcast_ack(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100211{
212 msg_set_bits(m, 1, 0, 0xffff, n);
213}
214
215
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900216/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100217 * Word 2
218 */
219
220static inline u32 msg_ack(struct tipc_msg *m)
221{
222 return msg_bits(m, 2, 16, 0xffff);
223}
224
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900225static inline void msg_set_ack(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100226{
227 msg_set_bits(m, 2, 16, 0xffff, n);
228}
229
230static inline u32 msg_seqno(struct tipc_msg *m)
231{
232 return msg_bits(m, 2, 0, 0xffff);
233}
234
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900235static inline void msg_set_seqno(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100236{
237 msg_set_bits(m, 2, 0, 0xffff, n);
238}
239
240
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900241/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100242 * Words 3-10
243 */
244
245
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900246static inline void msg_set_prevnode(struct tipc_msg *m, u32 a)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100247{
248 msg_set_word(m, 3, a);
249}
250
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900251static inline void msg_set_origport(struct tipc_msg *m, u32 p)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100252{
253 msg_set_word(m, 4, p);
254}
255
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900256static inline void msg_set_destport(struct tipc_msg *m, u32 p)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100257{
258 msg_set_word(m, 5, p);
259}
260
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900261static inline void msg_set_mc_netid(struct tipc_msg *m, u32 p)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100262{
263 msg_set_word(m, 5, p);
264}
265
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900266static inline void msg_set_orignode(struct tipc_msg *m, u32 a)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100267{
268 msg_set_word(m, 6, a);
269}
270
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900271static inline void msg_set_destnode(struct tipc_msg *m, u32 a)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100272{
273 msg_set_word(m, 7, a);
274}
275
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900276static inline int msg_is_dest(struct tipc_msg *m, u32 d)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100277{
278 return(msg_short(m) || (msg_destnode(m) == d));
279}
280
281static inline u32 msg_routed(struct tipc_msg *m)
282{
283 if (likely(msg_short(m)))
284 return 0;
285 return(msg_destnode(m) ^ msg_orignode(m)) >> 11;
286}
287
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900288static inline void msg_set_nametype(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100289{
290 msg_set_word(m, 8, n);
291}
292
293static inline u32 msg_transp_seqno(struct tipc_msg *m)
294{
295 return msg_word(m, 8);
296}
297
298static inline void msg_set_timestamp(struct tipc_msg *m, u32 n)
299{
300 msg_set_word(m, 8, n);
301}
302
303static inline u32 msg_timestamp(struct tipc_msg *m)
304{
305 return msg_word(m, 8);
306}
307
308static inline void msg_set_transp_seqno(struct tipc_msg *m, u32 n)
309{
310 msg_set_word(m, 8, n);
311}
312
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900313static inline void msg_set_namelower(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100314{
315 msg_set_word(m, 9, n);
316}
317
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900318static inline void msg_set_nameinst(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100319{
320 msg_set_namelower(m, n);
321}
322
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900323static inline void msg_set_nameupper(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100324{
325 msg_set_word(m, 10, n);
326}
327
328static inline struct tipc_msg *msg_get_wrapped(struct tipc_msg *m)
329{
330 return (struct tipc_msg *)msg_data(m);
331}
332
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900333static inline void msg_expand(struct tipc_msg *m, u32 destnode)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100334{
335 if (!msg_short(m))
336 return;
337 msg_set_hdr_sz(m, LONG_H_SIZE);
338 msg_set_orignode(m, msg_prevnode(m));
339 msg_set_destnode(m, destnode);
340 memset(&m->hdr[8], 0, 12);
341}
342
343
344
345/*
346 TIPC internal message header format, version 2
347
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900348 1 0 9 8 7 6 5 4|3 2 1 0 9 8 7 6|5 4 3 2 1 0 9 8|7 6 5 4 3 2 1 0
Per Lidenb97bf3f2006-01-02 19:04:38 +0100349 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
350 w0:|vers |msg usr|hdr sz |n|resrv| packet size |
351 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
352 w1:|m typ|rsv=0| sequence gap | broadcast ack no |
353 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
354 w2:| link level ack no/bc_gap_from | seq no / bcast_gap_to |
355 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
356 w3:| previous node |
357 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
358 w4:| next sent broadcast/fragm no | next sent pkt/ fragm msg no |
359 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
360 w5:| session no |rsv=0|r|berid|link prio|netpl|p|
361 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
362 w6:| originating node |
363 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
364 w7:| destination node |
365 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
366 w8:| transport sequence number |
367 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
368 w9:| msg count / bcast tag | link tolerance |
369 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
370 \ \
371 / User Specific Data /
372 \ \
373 +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
374
375 NB: CONN_MANAGER use data message format. LINK_CONFIG has own format.
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900376*/
Per Lidenb97bf3f2006-01-02 19:04:38 +0100377
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900378/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100379 * Internal users
380 */
381
382#define BCAST_PROTOCOL 5
383#define MSG_BUNDLER 6
384#define LINK_PROTOCOL 7
385#define CONN_MANAGER 8
386#define ROUTE_DISTRIBUTOR 9
387#define CHANGEOVER_PROTOCOL 10
388#define NAME_DISTRIBUTOR 11
389#define MSG_FRAGMENTER 12
390#define LINK_CONFIG 13
391#define INT_H_SIZE 40
392#define DSC_H_SIZE 40
393
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900394/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100395 * Connection management protocol messages
396 */
397
398#define CONN_PROBE 0
399#define CONN_PROBE_REPLY 1
400#define CONN_ACK 2
401
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900402/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100403 * Name distributor messages
404 */
405
406#define PUBLICATION 0
407#define WITHDRAWAL 1
408
409
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900410/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100411 * Word 1
412 */
413
414static inline u32 msg_seq_gap(struct tipc_msg *m)
415{
416 return msg_bits(m, 1, 16, 0xff);
417}
418
419static inline void msg_set_seq_gap(struct tipc_msg *m, u32 n)
420{
421 msg_set_bits(m, 1, 16, 0xff, n);
422}
423
424static inline u32 msg_req_links(struct tipc_msg *m)
425{
426 return msg_bits(m, 1, 16, 0xfff);
427}
428
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900429static inline void msg_set_req_links(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100430{
431 msg_set_bits(m, 1, 16, 0xfff, n);
432}
433
434
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900435/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100436 * Word 2
437 */
438
439static inline u32 msg_dest_domain(struct tipc_msg *m)
440{
441 return msg_word(m, 2);
442}
443
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900444static inline void msg_set_dest_domain(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100445{
446 msg_set_word(m, 2, n);
447}
448
449static inline u32 msg_bcgap_after(struct tipc_msg *m)
450{
451 return msg_bits(m, 2, 16, 0xffff);
452}
453
454static inline void msg_set_bcgap_after(struct tipc_msg *m, u32 n)
455{
456 msg_set_bits(m, 2, 16, 0xffff, n);
457}
458
459static inline u32 msg_bcgap_to(struct tipc_msg *m)
460{
461 return msg_bits(m, 2, 0, 0xffff);
462}
463
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900464static inline void msg_set_bcgap_to(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100465{
466 msg_set_bits(m, 2, 0, 0xffff, n);
467}
468
469
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900470/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100471 * Word 4
472 */
473
474static inline u32 msg_last_bcast(struct tipc_msg *m)
475{
476 return msg_bits(m, 4, 16, 0xffff);
477}
478
479static inline void msg_set_last_bcast(struct tipc_msg *m, u32 n)
480{
481 msg_set_bits(m, 4, 16, 0xffff, n);
482}
483
484
485static inline u32 msg_fragm_no(struct tipc_msg *m)
486{
487 return msg_bits(m, 4, 16, 0xffff);
488}
489
490static inline void msg_set_fragm_no(struct tipc_msg *m, u32 n)
491{
492 msg_set_bits(m, 4, 16, 0xffff, n);
493}
494
495
496static inline u32 msg_next_sent(struct tipc_msg *m)
497{
498 return msg_bits(m, 4, 0, 0xffff);
499}
500
501static inline void msg_set_next_sent(struct tipc_msg *m, u32 n)
502{
503 msg_set_bits(m, 4, 0, 0xffff, n);
504}
505
506
507static inline u32 msg_long_msgno(struct tipc_msg *m)
508{
509 return msg_bits(m, 4, 0, 0xffff);
510}
511
512static inline void msg_set_long_msgno(struct tipc_msg *m, u32 n)
513{
514 msg_set_bits(m, 4, 0, 0xffff, n);
515}
516
517static inline u32 msg_bc_netid(struct tipc_msg *m)
518{
519 return msg_word(m, 4);
520}
521
522static inline void msg_set_bc_netid(struct tipc_msg *m, u32 id)
523{
524 msg_set_word(m, 4, id);
525}
526
527static inline u32 msg_link_selector(struct tipc_msg *m)
528{
529 return msg_bits(m, 4, 0, 1);
530}
531
532static inline void msg_set_link_selector(struct tipc_msg *m, u32 n)
533{
534 msg_set_bits(m, 4, 0, 1, (n & 1));
535}
536
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900537/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100538 * Word 5
539 */
540
541static inline u32 msg_session(struct tipc_msg *m)
542{
543 return msg_bits(m, 5, 16, 0xffff);
544}
545
546static inline void msg_set_session(struct tipc_msg *m, u32 n)
547{
548 msg_set_bits(m, 5, 16, 0xffff, n);
549}
550
551static inline u32 msg_probe(struct tipc_msg *m)
552{
553 return msg_bits(m, 5, 0, 1);
554}
555
556static inline void msg_set_probe(struct tipc_msg *m, u32 val)
557{
558 msg_set_bits(m, 5, 0, 1, (val & 1));
559}
560
561static inline char msg_net_plane(struct tipc_msg *m)
562{
563 return msg_bits(m, 5, 1, 7) + 'A';
564}
565
566static inline void msg_set_net_plane(struct tipc_msg *m, char n)
567{
568 msg_set_bits(m, 5, 1, 7, (n - 'A'));
569}
570
571static inline u32 msg_linkprio(struct tipc_msg *m)
572{
573 return msg_bits(m, 5, 4, 0x1f);
574}
575
576static inline void msg_set_linkprio(struct tipc_msg *m, u32 n)
577{
578 msg_set_bits(m, 5, 4, 0x1f, n);
579}
580
581static inline u32 msg_bearer_id(struct tipc_msg *m)
582{
583 return msg_bits(m, 5, 9, 0x7);
584}
585
586static inline void msg_set_bearer_id(struct tipc_msg *m, u32 n)
587{
588 msg_set_bits(m, 5, 9, 0x7, n);
589}
590
591static inline u32 msg_redundant_link(struct tipc_msg *m)
592{
593 return msg_bits(m, 5, 12, 0x1);
594}
595
596static inline void msg_set_redundant_link(struct tipc_msg *m)
597{
598 msg_set_bits(m, 5, 12, 0x1, 1);
599}
600
601static inline void msg_clear_redundant_link(struct tipc_msg *m)
602{
603 msg_set_bits(m, 5, 12, 0x1, 0);
604}
605
606
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900607/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100608 * Word 9
609 */
610
611static inline u32 msg_msgcnt(struct tipc_msg *m)
612{
613 return msg_bits(m, 9, 16, 0xffff);
614}
615
616static inline void msg_set_msgcnt(struct tipc_msg *m, u32 n)
617{
618 msg_set_bits(m, 9, 16, 0xffff, n);
619}
620
621static inline u32 msg_bcast_tag(struct tipc_msg *m)
622{
623 return msg_bits(m, 9, 16, 0xffff);
624}
625
626static inline void msg_set_bcast_tag(struct tipc_msg *m, u32 n)
627{
628 msg_set_bits(m, 9, 16, 0xffff, n);
629}
630
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900631static inline u32 msg_max_pkt(struct tipc_msg *m)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100632{
633 return (msg_bits(m, 9, 16, 0xffff) * 4);
634}
635
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900636static inline void msg_set_max_pkt(struct tipc_msg *m, u32 n)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100637{
638 msg_set_bits(m, 9, 16, 0xffff, (n / 4));
639}
640
641static inline u32 msg_link_tolerance(struct tipc_msg *m)
642{
643 return msg_bits(m, 9, 0, 0xffff);
644}
645
646static inline void msg_set_link_tolerance(struct tipc_msg *m, u32 n)
647{
648 msg_set_bits(m, 9, 0, 0xffff, n);
649}
650
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900651/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100652 * Routing table message data
653 */
654
655
656static inline u32 msg_remote_node(struct tipc_msg *m)
657{
658 return msg_word(m, msg_hdr_sz(m)/4);
659}
660
661static inline void msg_set_remote_node(struct tipc_msg *m, u32 a)
662{
663 msg_set_word(m, msg_hdr_sz(m)/4, a);
664}
665
Per Lidenb97bf3f2006-01-02 19:04:38 +0100666static inline void msg_set_dataoctet(struct tipc_msg *m, u32 pos)
667{
668 msg_data(m)[pos + 4] = 1;
669}
670
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900671/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100672 * Segmentation message types
673 */
674
675#define FIRST_FRAGMENT 0
676#define FRAGMENT 1
677#define LAST_FRAGMENT 2
678
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900679/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100680 * Link management protocol message types
681 */
682
683#define STATE_MSG 0
684#define RESET_MSG 1
685#define ACTIVATE_MSG 2
686
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900687/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100688 * Changeover tunnel message types
689 */
690#define DUPLICATE_MSG 0
691#define ORIGINAL_MSG 1
692
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900693/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100694 * Routing table message types
695 */
696#define EXT_ROUTING_TABLE 0
697#define LOCAL_ROUTING_TABLE 1
698#define SLAVE_ROUTING_TABLE 2
699#define ROUTE_ADDITION 3
700#define ROUTE_REMOVAL 4
701
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900702/*
Per Lidenb97bf3f2006-01-02 19:04:38 +0100703 * Config protocol message types
704 */
705
706#define DSC_REQ_MSG 0
707#define DSC_RESP_MSG 1
708
709static inline u32 msg_tot_importance(struct tipc_msg *m)
710{
711 if (likely(msg_isdata(m))) {
712 if (likely(msg_orignode(m) == tipc_own_addr))
713 return msg_importance(m);
714 return msg_importance(m) + 4;
715 }
716 if ((msg_user(m) == MSG_FRAGMENTER) &&
717 (msg_type(m) == FIRST_FRAGMENT))
718 return msg_importance(msg_get_wrapped(m));
719 return msg_importance(m);
720}
721
722
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900723static inline void msg_init(struct tipc_msg *m, u32 user, u32 type,
Per Lidenb97bf3f2006-01-02 19:04:38 +0100724 u32 err, u32 hsize, u32 destnode)
725{
726 memset(m, 0, hsize);
727 msg_set_version(m);
728 msg_set_user(m, user);
729 msg_set_hdr_sz(m, hsize);
730 msg_set_size(m, hsize);
731 msg_set_prevnode(m, tipc_own_addr);
732 msg_set_type(m, type);
733 msg_set_errcode(m, err);
734 if (!msg_short(m)) {
735 msg_set_orignode(m, tipc_own_addr);
736 msg_set_destnode(m, destnode);
737 }
738}
739
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900740/**
Per Lidenb97bf3f2006-01-02 19:04:38 +0100741 * msg_calc_data_size - determine total data size for message
742 */
743
744static inline int msg_calc_data_size(struct iovec const *msg_sect, u32 num_sect)
745{
746 int dsz = 0;
747 int i;
748
749 for (i = 0; i < num_sect; i++)
750 dsz += msg_sect[i].iov_len;
751 return dsz;
752}
753
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900754/**
Per Lidenb97bf3f2006-01-02 19:04:38 +0100755 * msg_build - create message using specified header and data
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900756 *
Per Lidenb97bf3f2006-01-02 19:04:38 +0100757 * Note: Caller must not hold any locks in case copy_from_user() is interrupted!
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900758 *
Per Lidenb97bf3f2006-01-02 19:04:38 +0100759 * Returns message data size or errno
760 */
761
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900762static inline int msg_build(struct tipc_msg *hdr,
Per Lidenb97bf3f2006-01-02 19:04:38 +0100763 struct iovec const *msg_sect, u32 num_sect,
764 int max_size, int usrmem, struct sk_buff** buf)
765{
766 int dsz, sz, hsz, pos, res, cnt;
767
768 dsz = msg_calc_data_size(msg_sect, num_sect);
769 if (unlikely(dsz > TIPC_MAX_USER_MSG_SIZE)) {
770 *buf = NULL;
771 return -EINVAL;
772 }
773
774 pos = hsz = msg_hdr_sz(hdr);
775 sz = hsz + dsz;
776 msg_set_size(hdr, sz);
777 if (unlikely(sz > max_size)) {
778 *buf = NULL;
779 return dsz;
780 }
781
782 *buf = buf_acquire(sz);
783 if (!(*buf))
784 return -ENOMEM;
Arnaldo Carvalho de Melo27d7ff42007-03-31 11:55:19 -0300785 skb_copy_to_linear_data(*buf, hdr, hsz);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100786 for (res = 1, cnt = 0; res && (cnt < num_sect); cnt++) {
787 if (likely(usrmem))
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900788 res = !copy_from_user((*buf)->data + pos,
789 msg_sect[cnt].iov_base,
Per Lidenb97bf3f2006-01-02 19:04:38 +0100790 msg_sect[cnt].iov_len);
791 else
Arnaldo Carvalho de Melo27d7ff42007-03-31 11:55:19 -0300792 skb_copy_to_linear_data_offset(*buf, pos,
793 msg_sect[cnt].iov_base,
794 msg_sect[cnt].iov_len);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100795 pos += msg_sect[cnt].iov_len;
796 }
797 if (likely(res))
798 return dsz;
799
800 buf_discard(*buf);
801 *buf = NULL;
802 return -EFAULT;
803}
804
Per Liden4323add2006-01-18 00:38:21 +0100805static inline void msg_set_media_addr(struct tipc_msg *m, struct tipc_media_addr *a)
806{
807 memcpy(&((int *)m)[5], a, sizeof(*a));
808}
Per Lidenb97bf3f2006-01-02 19:04:38 +0100809
Per Liden4323add2006-01-18 00:38:21 +0100810static inline void msg_get_media_addr(struct tipc_msg *m, struct tipc_media_addr *a)
811{
812 memcpy(a, &((int*)m)[5], sizeof(*a));
813}
Per Lidenb97bf3f2006-01-02 19:04:38 +0100814
815#endif