msg.h 18 KB

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