SAFE public projects git trees. - safe/jmp/linux-2.6/blob - net/tipc/msg.h

   1 /*
   2  * net/tipc/msg.h: Include file for TIPC message header routines
   3  *
   4  * Copyright (c) 2000-2007, Ericsson AB
   5  * Copyright (c) 2005-2007, Wind River Systems
   6  * All rights reserved.
   7  *
   8  * Redistribution and use in source and binary forms, with or without
   9  * modification, are permitted provided that the following conditions are met:
  10  *
  11  * 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.
  19  *
  20  * 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
  34  * POSSIBILITY OF SUCH DAMAGE.
  35  */
  36
  37 #ifndef _TIPC_MSG_H
  38 #define _TIPC_MSG_H
  39
  40 #include "core.h"
  41
  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
  59
  60         - Fundamental definitions available to privileged TIPC users
  61           are located in tipc_msg.h.
  62         - Remaining definitions available to TIPC internal users appear below.
  63 */
  64
  65
  66 static inline void msg_set_word(struct tipc_msg *m, u32 w, u32 val)
  67 {
  68         m->hdr[w] = htonl(val);
  69 }
  70
  71 static inline void msg_set_bits(struct tipc_msg *m, u32 w,
  72                                 u32 pos, u32 mask, u32 val)
  73 {
  74         val = (val & mask) << pos;
  75         m->hdr[w] &= ~htonl(mask << pos);
  76         m->hdr[w] |= htonl(val);
  77 }
  78
  79 /*
  80  * Word 0
  81  */
  82
  83 static inline u32 msg_version(struct tipc_msg *m)
  84 {
  85         return msg_bits(m, 0, 29, 7);
  86 }
  87
  88 static inline void msg_set_version(struct tipc_msg *m)
  89 {
  90         msg_set_bits(m, 0, 29, 0xf, TIPC_VERSION);
  91 }
  92
  93 static inline u32 msg_user(struct tipc_msg *m)
  94 {
  95         return msg_bits(m, 0, 25, 0xf);
  96 }
  97
  98 static inline u32 msg_isdata(struct tipc_msg *m)
  99 {
 100         return (msg_user(m) <= DATA_CRITICAL);
 101 }
 102
 103 static inline void msg_set_user(struct tipc_msg *m, u32 n)
 104 {
 105         msg_set_bits(m, 0, 25, 0xf, n);
 106 }
 107
 108 static inline void msg_set_importance(struct tipc_msg *m, u32 i)
 109 {
 110         msg_set_user(m, i);
 111 }
 112
 113 static inline void msg_set_hdr_sz(struct tipc_msg *m,u32 n)
 114 {
 115         msg_set_bits(m, 0, 21, 0xf, n>>2);
 116 }
 117
 118 static inline int msg_non_seq(struct tipc_msg *m)
 119 {
 120         return msg_bits(m, 0, 20, 1);
 121 }
 122
 123 static inline void msg_set_non_seq(struct tipc_msg *m)
 124 {
 125         msg_set_bits(m, 0, 20, 1, 1);
 126 }
 127
 128 static inline int msg_dest_droppable(struct tipc_msg *m)
 129 {
 130         return msg_bits(m, 0, 19, 1);
 131 }
 132
 133 static inline void msg_set_dest_droppable(struct tipc_msg *m, u32 d)
 134 {
 135         msg_set_bits(m, 0, 19, 1, d);
 136 }
 137
 138 static inline int msg_src_droppable(struct tipc_msg *m)
 139 {
 140         return msg_bits(m, 0, 18, 1);
 141 }
 142
 143 static inline void msg_set_src_droppable(struct tipc_msg *m, u32 d)
 144 {
 145         msg_set_bits(m, 0, 18, 1, d);
 146 }
 147
 148 static 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
 154 /*
 155  * Word 1
 156  */
 157
 158 static inline void msg_set_type(struct tipc_msg *m, u32 n)
 159 {
 160         msg_set_bits(m, 1, 29, 0x7, n);
 161 }
 162
 163 static inline void msg_set_errcode(struct tipc_msg *m, u32 err)
 164 {
 165         msg_set_bits(m, 1, 25, 0xf, err);
 166 }
 167
 168 static inline u32 msg_reroute_cnt(struct tipc_msg *m)
 169 {
 170         return msg_bits(m, 1, 21, 0xf);
 171 }
 172
 173 static inline void msg_incr_reroute_cnt(struct tipc_msg *m)
 174 {
 175         msg_set_bits(m, 1, 21, 0xf, msg_reroute_cnt(m) + 1);
 176 }
 177
 178 static inline void msg_reset_reroute_cnt(struct tipc_msg *m)
 179 {
 180         msg_set_bits(m, 1, 21, 0xf, 0);
 181 }
 182
 183 static inline u32 msg_lookup_scope(struct tipc_msg *m)
 184 {
 185         return msg_bits(m, 1, 19, 0x3);
 186 }
 187
 188 static inline void msg_set_lookup_scope(struct tipc_msg *m, u32 n)
 189 {
 190         msg_set_bits(m, 1, 19, 0x3, n);
 191 }
 192
 193 static inline u32 msg_bcast_ack(struct tipc_msg *m)
 194 {
 195         return msg_bits(m, 1, 0, 0xffff);
 196 }
 197
 198 static inline void msg_set_bcast_ack(struct tipc_msg *m, u32 n)
 199 {
 200         msg_set_bits(m, 1, 0, 0xffff, n);
 201 }
 202
 203
 204 /*
 205  * Word 2
 206  */
 207
 208 static inline u32 msg_ack(struct tipc_msg *m)
 209 {
 210         return msg_bits(m, 2, 16, 0xffff);
 211 }
 212
 213 static inline void msg_set_ack(struct tipc_msg *m, u32 n)
 214 {
 215         msg_set_bits(m, 2, 16, 0xffff, n);
 216 }
 217
 218 static inline u32 msg_seqno(struct tipc_msg *m)
 219 {
 220         return msg_bits(m, 2, 0, 0xffff);
 221 }
 222
 223 static inline void msg_set_seqno(struct tipc_msg *m, u32 n)
 224 {
 225         msg_set_bits(m, 2, 0, 0xffff, n);
 226 }
 227
 228
 229 /*
 230  * Words 3-10
 231  */
 232
 233
 234 static inline void msg_set_prevnode(struct tipc_msg *m, u32 a)
 235 {
 236         msg_set_word(m, 3, a);
 237 }
 238
 239 static inline void msg_set_origport(struct tipc_msg *m, u32 p)
 240 {
 241         msg_set_word(m, 4, p);
 242 }
 243
 244 static inline void msg_set_destport(struct tipc_msg *m, u32 p)
 245 {
 246         msg_set_word(m, 5, p);
 247 }
 248
 249 static inline void msg_set_mc_netid(struct tipc_msg *m, u32 p)
 250 {
 251         msg_set_word(m, 5, p);
 252 }
 253
 254 static inline void msg_set_orignode(struct tipc_msg *m, u32 a)
 255 {
 256         msg_set_word(m, 6, a);
 257 }
 258
 259 static inline void msg_set_destnode(struct tipc_msg *m, u32 a)
 260 {
 261         msg_set_word(m, 7, a);
 262 }
 263
 264 static inline int msg_is_dest(struct tipc_msg *m, u32 d)
 265 {
 266         return(msg_short(m) || (msg_destnode(m) == d));
 267 }
 268
 269 static inline u32 msg_routed(struct tipc_msg *m)
 270 {
 271         if (likely(msg_short(m)))
 272                 return 0;
 273         return(msg_destnode(m) ^ msg_orignode(m)) >> 11;
 274 }
 275
 276 static inline void msg_set_nametype(struct tipc_msg *m, u32 n)
 277 {
 278         msg_set_word(m, 8, n);
 279 }
 280
 281 static inline u32 msg_transp_seqno(struct tipc_msg *m)
 282 {
 283         return msg_word(m, 8);
 284 }
 285
 286 static inline void msg_set_timestamp(struct tipc_msg *m, u32 n)
 287 {
 288         msg_set_word(m, 8, n);
 289 }
 290
 291 static inline u32 msg_timestamp(struct tipc_msg *m)
 292 {
 293         return msg_word(m, 8);
 294 }
 295
 296 static inline void msg_set_transp_seqno(struct tipc_msg *m, u32 n)
 297 {
 298         msg_set_word(m, 8, n);
 299 }
 300
 301 static inline void msg_set_namelower(struct tipc_msg *m, u32 n)
 302 {
 303         msg_set_word(m, 9, n);
 304 }
 305
 306 static inline void msg_set_nameinst(struct tipc_msg *m, u32 n)
 307 {
 308         msg_set_namelower(m, n);
 309 }
 310
 311 static inline void msg_set_nameupper(struct tipc_msg *m, u32 n)
 312 {
 313         msg_set_word(m, 10, n);
 314 }
 315
 316 static inline struct tipc_msg *msg_get_wrapped(struct tipc_msg *m)
 317 {
 318         return (struct tipc_msg *)msg_data(m);
 319 }
 320
 321
 322 /*
 323                 TIPC internal message header format, version 2
 324
 325        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
 326       +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 327    w0:|vers |msg usr|hdr sz |n|resrv|            packet size          |
 328       +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 329    w1:|m typ|rsv=0|   sequence gap    |       broadcast ack no        |
 330       +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 331    w2:| link level ack no/bc_gap_from |     seq no / bcast_gap_to     |
 332       +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 333    w3:|                       previous node                           |
 334       +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 335    w4:|  next sent broadcast/fragm no | next sent pkt/ fragm msg no   |
 336       +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 337    w5:|          session no           |rsv=0|r|berid|link prio|netpl|p|
 338       +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 339    w6:|                      originating node                         |
 340       +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 341    w7:|                      destination node                         |
 342       +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 343    w8:|                   transport sequence number                   |
 344       +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 345    w9:|   msg count / bcast tag       |       link tolerance          |
 346       +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 347       \                                                               \
 348       /                     User Specific Data                        /
 349       \                                                               \
 350       +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 351
 352       NB: CONN_MANAGER use data message format. LINK_CONFIG has own format.
 353 */
 354
 355 /*
 356  * Internal users
 357  */
 358
 359 #define  BCAST_PROTOCOL       5
 360 #define  MSG_BUNDLER          6
 361 #define  LINK_PROTOCOL        7
 362 #define  CONN_MANAGER         8
 363 #define  ROUTE_DISTRIBUTOR    9
 364 #define  CHANGEOVER_PROTOCOL  10
 365 #define  NAME_DISTRIBUTOR     11
 366 #define  MSG_FRAGMENTER       12
 367 #define  LINK_CONFIG          13
 368 #define  INT_H_SIZE           40
 369 #define  DSC_H_SIZE           40
 370
 371 /*
 372  *  Connection management protocol messages
 373  */
 374
 375 #define CONN_PROBE        0
 376 #define CONN_PROBE_REPLY  1
 377 #define CONN_ACK          2
 378
 379 /*
 380  * Name distributor messages
 381  */
 382
 383 #define PUBLICATION       0
 384 #define WITHDRAWAL        1
 385
 386
 387 /*
 388  * Word 1
 389  */
 390
 391 static inline u32 msg_seq_gap(struct tipc_msg *m)
 392 {
 393         return msg_bits(m, 1, 16, 0xff);
 394 }
 395
 396 static inline void msg_set_seq_gap(struct tipc_msg *m, u32 n)
 397 {
 398         msg_set_bits(m, 1, 16, 0xff, n);
 399 }
 400
 401 static inline u32 msg_req_links(struct tipc_msg *m)
 402 {
 403         return msg_bits(m, 1, 16, 0xfff);
 404 }
 405
 406 static inline void msg_set_req_links(struct tipc_msg *m, u32 n)
 407 {
 408         msg_set_bits(m, 1, 16, 0xfff, n);
 409 }
 410
 411
 412 /*
 413  * Word 2
 414  */
 415
 416 static inline u32 msg_dest_domain(struct tipc_msg *m)
 417 {
 418         return msg_word(m, 2);
 419 }
 420
 421 static inline void msg_set_dest_domain(struct tipc_msg *m, u32 n)
 422 {
 423         msg_set_word(m, 2, n);
 424 }
 425
 426 static inline u32 msg_bcgap_after(struct tipc_msg *m)
 427 {
 428         return msg_bits(m, 2, 16, 0xffff);
 429 }
 430
 431 static inline void msg_set_bcgap_after(struct tipc_msg *m, u32 n)
 432 {
 433         msg_set_bits(m, 2, 16, 0xffff, n);
 434 }
 435
 436 static inline u32 msg_bcgap_to(struct tipc_msg *m)
 437 {
 438         return msg_bits(m, 2, 0, 0xffff);
 439 }
 440
 441 static inline void msg_set_bcgap_to(struct tipc_msg *m, u32 n)
 442 {
 443         msg_set_bits(m, 2, 0, 0xffff, n);
 444 }
 445
 446
 447 /*
 448  * Word 4
 449  */
 450
 451 static inline u32 msg_last_bcast(struct tipc_msg *m)
 452 {
 453         return msg_bits(m, 4, 16, 0xffff);
 454 }
 455
 456 static inline void msg_set_last_bcast(struct tipc_msg *m, u32 n)
 457 {
 458         msg_set_bits(m, 4, 16, 0xffff, n);
 459 }
 460
 461
 462 static inline u32 msg_fragm_no(struct tipc_msg *m)
 463 {
 464         return msg_bits(m, 4, 16, 0xffff);
 465 }
 466
 467 static inline void msg_set_fragm_no(struct tipc_msg *m, u32 n)
 468 {
 469         msg_set_bits(m, 4, 16, 0xffff, n);
 470 }
 471
 472
 473 static inline u32 msg_next_sent(struct tipc_msg *m)
 474 {
 475         return msg_bits(m, 4, 0, 0xffff);
 476 }
 477
 478 static inline void msg_set_next_sent(struct tipc_msg *m, u32 n)
 479 {
 480         msg_set_bits(m, 4, 0, 0xffff, n);
 481 }
 482
 483
 484 static inline u32 msg_long_msgno(struct tipc_msg *m)
 485 {
 486         return msg_bits(m, 4, 0, 0xffff);
 487 }
 488
 489 static inline void msg_set_long_msgno(struct tipc_msg *m, u32 n)
 490 {
 491         msg_set_bits(m, 4, 0, 0xffff, n);
 492 }
 493
 494 static inline u32 msg_bc_netid(struct tipc_msg *m)
 495 {
 496         return msg_word(m, 4);
 497 }
 498
 499 static inline void msg_set_bc_netid(struct tipc_msg *m, u32 id)
 500 {
 501         msg_set_word(m, 4, id);
 502 }
 503
 504 static inline u32 msg_link_selector(struct tipc_msg *m)
 505 {
 506         return msg_bits(m, 4, 0, 1);
 507 }
 508
 509 static inline void msg_set_link_selector(struct tipc_msg *m, u32 n)
 510 {
 511         msg_set_bits(m, 4, 0, 1, (n & 1));
 512 }
 513
 514 /*
 515  * Word 5
 516  */
 517
 518 static inline u32 msg_session(struct tipc_msg *m)
 519 {
 520         return msg_bits(m, 5, 16, 0xffff);
 521 }
 522
 523 static inline void msg_set_session(struct tipc_msg *m, u32 n)
 524 {
 525         msg_set_bits(m, 5, 16, 0xffff, n);
 526 }
 527
 528 static inline u32 msg_probe(struct tipc_msg *m)
 529 {
 530         return msg_bits(m, 5, 0, 1);
 531 }
 532
 533 static inline void msg_set_probe(struct tipc_msg *m, u32 val)
 534 {
 535         msg_set_bits(m, 5, 0, 1, (val & 1));
 536 }
 537
 538 static inline char msg_net_plane(struct tipc_msg *m)
 539 {
 540         return msg_bits(m, 5, 1, 7) + 'A';
 541 }
 542
 543 static inline void msg_set_net_plane(struct tipc_msg *m, char n)
 544 {
 545         msg_set_bits(m, 5, 1, 7, (n - 'A'));
 546 }
 547
 548 static inline u32 msg_linkprio(struct tipc_msg *m)
 549 {
 550         return msg_bits(m, 5, 4, 0x1f);
 551 }
 552
 553 static inline void msg_set_linkprio(struct tipc_msg *m, u32 n)
 554 {
 555         msg_set_bits(m, 5, 4, 0x1f, n);
 556 }
 557
 558 static inline u32 msg_bearer_id(struct tipc_msg *m)
 559 {
 560         return msg_bits(m, 5, 9, 0x7);
 561 }
 562
 563 static inline void msg_set_bearer_id(struct tipc_msg *m, u32 n)
 564 {
 565         msg_set_bits(m, 5, 9, 0x7, n);
 566 }
 567
 568 static inline u32 msg_redundant_link(struct tipc_msg *m)
 569 {
 570         return msg_bits(m, 5, 12, 0x1);
 571 }
 572
 573 static inline void msg_set_redundant_link(struct tipc_msg *m)
 574 {
 575         msg_set_bits(m, 5, 12, 0x1, 1);
 576 }
 577
 578 static inline void msg_clear_redundant_link(struct tipc_msg *m)
 579 {
 580         msg_set_bits(m, 5, 12, 0x1, 0);
 581 }
 582
 583
 584 /*
 585  * Word 9
 586  */
 587
 588 static inline u32 msg_msgcnt(struct tipc_msg *m)
 589 {
 590         return msg_bits(m, 9, 16, 0xffff);
 591 }
 592
 593 static inline void msg_set_msgcnt(struct tipc_msg *m, u32 n)
 594 {
 595         msg_set_bits(m, 9, 16, 0xffff, n);
 596 }
 597
 598 static inline u32 msg_bcast_tag(struct tipc_msg *m)
 599 {
 600         return msg_bits(m, 9, 16, 0xffff);
 601 }
 602
 603 static inline void msg_set_bcast_tag(struct tipc_msg *m, u32 n)
 604 {
 605         msg_set_bits(m, 9, 16, 0xffff, n);
 606 }
 607
 608 static inline u32 msg_max_pkt(struct tipc_msg *m)
 609 {
 610         return (msg_bits(m, 9, 16, 0xffff) * 4);
 611 }
 612
 613 static inline void msg_set_max_pkt(struct tipc_msg *m, u32 n)
 614 {
 615         msg_set_bits(m, 9, 16, 0xffff, (n / 4));
 616 }
 617
 618 static inline u32 msg_link_tolerance(struct tipc_msg *m)
 619 {
 620         return msg_bits(m, 9, 0, 0xffff);
 621 }
 622
 623 static inline void msg_set_link_tolerance(struct tipc_msg *m, u32 n)
 624 {
 625         msg_set_bits(m, 9, 0, 0xffff, n);
 626 }
 627
 628 /*
 629  * Routing table message data
 630  */
 631
 632
 633 static inline u32 msg_remote_node(struct tipc_msg *m)
 634 {
 635         return msg_word(m, msg_hdr_sz(m)/4);
 636 }
 637
 638 static inline void msg_set_remote_node(struct tipc_msg *m, u32 a)
 639 {
 640         msg_set_word(m, msg_hdr_sz(m)/4, a);
 641 }
 642
 643 static inline void msg_set_dataoctet(struct tipc_msg *m, u32 pos)
 644 {
 645         msg_data(m)[pos + 4] = 1;
 646 }
 647
 648 /*
 649  * Segmentation message types
 650  */
 651
 652 #define FIRST_FRAGMENT     0
 653 #define FRAGMENT           1
 654 #define LAST_FRAGMENT      2
 655
 656 /*
 657  * Link management protocol message types
 658  */
 659
 660 #define STATE_MSG       0
 661 #define RESET_MSG       1
 662 #define ACTIVATE_MSG    2
 663
 664 /*
 665  * Changeover tunnel message types
 666  */
 667 #define DUPLICATE_MSG    0
 668 #define ORIGINAL_MSG     1
 669
 670 /*
 671  * Routing table message types
 672  */
 673 #define EXT_ROUTING_TABLE    0
 674 #define LOCAL_ROUTING_TABLE  1
 675 #define SLAVE_ROUTING_TABLE  2
 676 #define ROUTE_ADDITION       3
 677 #define ROUTE_REMOVAL        4
 678
 679 /*
 680  * Config protocol message types
 681  */
 682
 683 #define DSC_REQ_MSG          0
 684 #define DSC_RESP_MSG         1
 685
 686 static inline u32 msg_tot_importance(struct tipc_msg *m)
 687 {
 688         if (likely(msg_isdata(m))) {
 689                 if (likely(msg_orignode(m) == tipc_own_addr))
 690                         return msg_importance(m);
 691                 return msg_importance(m) + 4;
 692         }
 693         if ((msg_user(m) == MSG_FRAGMENTER)  &&
 694             (msg_type(m) == FIRST_FRAGMENT))
 695                 return msg_importance(msg_get_wrapped(m));
 696         return msg_importance(m);
 697 }
 698
 699
 700 static inline void msg_init(struct tipc_msg *m, u32 user, u32 type,
 701                             u32 err, u32 hsize, u32 destnode)
 702 {
 703         memset(m, 0, hsize);
 704         msg_set_version(m);
 705         msg_set_user(m, user);
 706         msg_set_hdr_sz(m, hsize);
 707         msg_set_size(m, hsize);
 708         msg_set_prevnode(m, tipc_own_addr);
 709         msg_set_type(m, type);
 710         msg_set_errcode(m, err);
 711         if (!msg_short(m)) {
 712                 msg_set_orignode(m, tipc_own_addr);
 713                 msg_set_destnode(m, destnode);
 714         }
 715 }
 716
 717 /**
 718  * msg_calc_data_size - determine total data size for message
 719  */
 720
 721 static inline int msg_calc_data_size(struct iovec const *msg_sect, u32 num_sect)
 722 {
 723         int dsz = 0;
 724         int i;
 725
 726         for (i = 0; i < num_sect; i++)
 727                 dsz += msg_sect[i].iov_len;
 728         return dsz;
 729 }
 730
 731 /**
 732  * msg_build - create message using specified header and data
 733  *
 734  * Note: Caller must not hold any locks in case copy_from_user() is interrupted!
 735  *
 736  * Returns message data size or errno
 737  */
 738
 739 static inline int msg_build(struct tipc_msg *hdr,
 740                             struct iovec const *msg_sect, u32 num_sect,
 741                             int max_size, int usrmem, struct sk_buff** buf)
 742 {
 743         int dsz, sz, hsz, pos, res, cnt;
 744
 745         dsz = msg_calc_data_size(msg_sect, num_sect);
 746         if (unlikely(dsz > TIPC_MAX_USER_MSG_SIZE)) {
 747                 *buf = NULL;
 748                 return -EINVAL;
 749         }
 750
 751         pos = hsz = msg_hdr_sz(hdr);
 752         sz = hsz + dsz;
 753         msg_set_size(hdr, sz);
 754         if (unlikely(sz > max_size)) {
 755                 *buf = NULL;
 756                 return dsz;
 757         }
 758
 759         *buf = buf_acquire(sz);
 760         if (!(*buf))
 761                 return -ENOMEM;
 762         skb_copy_to_linear_data(*buf, hdr, hsz);
 763         for (res = 1, cnt = 0; res && (cnt < num_sect); cnt++) {
 764                 if (likely(usrmem))
 765                         res = !copy_from_user((*buf)->data + pos,
 766                                               msg_sect[cnt].iov_base,
 767                                               msg_sect[cnt].iov_len);
 768                 else
 769                         skb_copy_to_linear_data_offset(*buf, pos,
 770                                                        msg_sect[cnt].iov_base,
 771                                                        msg_sect[cnt].iov_len);
 772                 pos += msg_sect[cnt].iov_len;
 773         }
 774         if (likely(res))
 775                 return dsz;
 776
 777         buf_discard(*buf);
 778         *buf = NULL;
 779         return -EFAULT;
 780 }
 781
 782 static inline void msg_set_media_addr(struct tipc_msg *m, struct tipc_media_addr *a)
 783 {
 784         memcpy(&((int *)m)[5], a, sizeof(*a));
 785 }
 786
 787 static inline void msg_get_media_addr(struct tipc_msg *m, struct tipc_media_addr *a)
 788 {
 789         memcpy(a, &((int*)m)[5], sizeof(*a));
 790 }
 791
 792 #endif