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