msg.h 18 KB

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