msg.h 18 KB

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