msg.h 18 KB

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