msg.c 9.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323
  1. /*
  2. * net/tipc/msg.c: 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. #include "core.h"
  37. #include "addr.h"
  38. #include "dbg.h"
  39. #include "msg.h"
  40. #include "bearer.h"
  41. void tipc_msg_print(struct print_buf *buf, struct tipc_msg *msg, const char *str)
  42. {
  43. u32 usr = msg_user(msg);
  44. tipc_printf(buf, str);
  45. switch (usr) {
  46. case MSG_BUNDLER:
  47. tipc_printf(buf, "BNDL::");
  48. tipc_printf(buf, "MSGS(%u):", msg_msgcnt(msg));
  49. break;
  50. case BCAST_PROTOCOL:
  51. tipc_printf(buf, "BCASTP::");
  52. break;
  53. case MSG_FRAGMENTER:
  54. tipc_printf(buf, "FRAGM::");
  55. switch (msg_type(msg)) {
  56. case FIRST_FRAGMENT:
  57. tipc_printf(buf, "FIRST:");
  58. break;
  59. case FRAGMENT:
  60. tipc_printf(buf, "BODY:");
  61. break;
  62. case LAST_FRAGMENT:
  63. tipc_printf(buf, "LAST:");
  64. break;
  65. default:
  66. tipc_printf(buf, "UNKNOWN:%x",msg_type(msg));
  67. }
  68. tipc_printf(buf, "NO(%u/%u):",msg_long_msgno(msg),
  69. msg_fragm_no(msg));
  70. break;
  71. case DATA_LOW:
  72. case DATA_MEDIUM:
  73. case DATA_HIGH:
  74. case DATA_CRITICAL:
  75. tipc_printf(buf, "DAT%u:", msg_user(msg));
  76. if (msg_short(msg)) {
  77. tipc_printf(buf, "CON:");
  78. break;
  79. }
  80. switch (msg_type(msg)) {
  81. case TIPC_CONN_MSG:
  82. tipc_printf(buf, "CON:");
  83. break;
  84. case TIPC_MCAST_MSG:
  85. tipc_printf(buf, "MCST:");
  86. break;
  87. case TIPC_NAMED_MSG:
  88. tipc_printf(buf, "NAM:");
  89. break;
  90. case TIPC_DIRECT_MSG:
  91. tipc_printf(buf, "DIR:");
  92. break;
  93. default:
  94. tipc_printf(buf, "UNKNOWN TYPE %u",msg_type(msg));
  95. }
  96. if (msg_routed(msg) && !msg_non_seq(msg))
  97. tipc_printf(buf, "ROUT:");
  98. if (msg_reroute_cnt(msg))
  99. tipc_printf(buf, "REROUTED(%u):",
  100. msg_reroute_cnt(msg));
  101. break;
  102. case NAME_DISTRIBUTOR:
  103. tipc_printf(buf, "NMD::");
  104. switch (msg_type(msg)) {
  105. case PUBLICATION:
  106. tipc_printf(buf, "PUBL(%u):", (msg_size(msg) - msg_hdr_sz(msg)) / 20); /* Items */
  107. break;
  108. case WITHDRAWAL:
  109. tipc_printf(buf, "WDRW:");
  110. break;
  111. default:
  112. tipc_printf(buf, "UNKNOWN:%x",msg_type(msg));
  113. }
  114. if (msg_routed(msg))
  115. tipc_printf(buf, "ROUT:");
  116. if (msg_reroute_cnt(msg))
  117. tipc_printf(buf, "REROUTED(%u):",
  118. msg_reroute_cnt(msg));
  119. break;
  120. case CONN_MANAGER:
  121. tipc_printf(buf, "CONN_MNG:");
  122. switch (msg_type(msg)) {
  123. case CONN_PROBE:
  124. tipc_printf(buf, "PROBE:");
  125. break;
  126. case CONN_PROBE_REPLY:
  127. tipc_printf(buf, "PROBE_REPLY:");
  128. break;
  129. case CONN_ACK:
  130. tipc_printf(buf, "CONN_ACK:");
  131. tipc_printf(buf, "ACK(%u):",msg_msgcnt(msg));
  132. break;
  133. default:
  134. tipc_printf(buf, "UNKNOWN TYPE:%x",msg_type(msg));
  135. }
  136. if (msg_routed(msg))
  137. tipc_printf(buf, "ROUT:");
  138. if (msg_reroute_cnt(msg))
  139. tipc_printf(buf, "REROUTED(%u):",msg_reroute_cnt(msg));
  140. break;
  141. case LINK_PROTOCOL:
  142. tipc_printf(buf, "PROT:TIM(%u):",msg_timestamp(msg));
  143. switch (msg_type(msg)) {
  144. case STATE_MSG:
  145. tipc_printf(buf, "STATE:");
  146. tipc_printf(buf, "%s:",msg_probe(msg) ? "PRB" :"");
  147. tipc_printf(buf, "NXS(%u):",msg_next_sent(msg));
  148. tipc_printf(buf, "GAP(%u):",msg_seq_gap(msg));
  149. tipc_printf(buf, "LSTBC(%u):",msg_last_bcast(msg));
  150. break;
  151. case RESET_MSG:
  152. tipc_printf(buf, "RESET:");
  153. if (msg_size(msg) != msg_hdr_sz(msg))
  154. tipc_printf(buf, "BEAR:%s:",msg_data(msg));
  155. break;
  156. case ACTIVATE_MSG:
  157. tipc_printf(buf, "ACTIVATE:");
  158. break;
  159. default:
  160. tipc_printf(buf, "UNKNOWN TYPE:%x",msg_type(msg));
  161. }
  162. tipc_printf(buf, "PLANE(%c):",msg_net_plane(msg));
  163. tipc_printf(buf, "SESS(%u):",msg_session(msg));
  164. break;
  165. case CHANGEOVER_PROTOCOL:
  166. tipc_printf(buf, "TUNL:");
  167. switch (msg_type(msg)) {
  168. case DUPLICATE_MSG:
  169. tipc_printf(buf, "DUPL:");
  170. break;
  171. case ORIGINAL_MSG:
  172. tipc_printf(buf, "ORIG:");
  173. tipc_printf(buf, "EXP(%u)",msg_msgcnt(msg));
  174. break;
  175. default:
  176. tipc_printf(buf, "UNKNOWN TYPE:%x",msg_type(msg));
  177. }
  178. break;
  179. case ROUTE_DISTRIBUTOR:
  180. tipc_printf(buf, "ROUTING_MNG:");
  181. switch (msg_type(msg)) {
  182. case EXT_ROUTING_TABLE:
  183. tipc_printf(buf, "EXT_TBL:");
  184. tipc_printf(buf, "TO:%x:",msg_remote_node(msg));
  185. break;
  186. case LOCAL_ROUTING_TABLE:
  187. tipc_printf(buf, "LOCAL_TBL:");
  188. tipc_printf(buf, "TO:%x:",msg_remote_node(msg));
  189. break;
  190. case SLAVE_ROUTING_TABLE:
  191. tipc_printf(buf, "DP_TBL:");
  192. tipc_printf(buf, "TO:%x:",msg_remote_node(msg));
  193. break;
  194. case ROUTE_ADDITION:
  195. tipc_printf(buf, "ADD:");
  196. tipc_printf(buf, "TO:%x:",msg_remote_node(msg));
  197. break;
  198. case ROUTE_REMOVAL:
  199. tipc_printf(buf, "REMOVE:");
  200. tipc_printf(buf, "TO:%x:",msg_remote_node(msg));
  201. break;
  202. default:
  203. tipc_printf(buf, "UNKNOWN TYPE:%x",msg_type(msg));
  204. }
  205. break;
  206. case LINK_CONFIG:
  207. tipc_printf(buf, "CFG:");
  208. switch (msg_type(msg)) {
  209. case DSC_REQ_MSG:
  210. tipc_printf(buf, "DSC_REQ:");
  211. break;
  212. case DSC_RESP_MSG:
  213. tipc_printf(buf, "DSC_RESP:");
  214. break;
  215. default:
  216. tipc_printf(buf, "UNKNOWN TYPE:%x:",msg_type(msg));
  217. break;
  218. }
  219. break;
  220. default:
  221. tipc_printf(buf, "UNKNOWN USER:");
  222. }
  223. switch (usr) {
  224. case CONN_MANAGER:
  225. case NAME_DISTRIBUTOR:
  226. case DATA_LOW:
  227. case DATA_MEDIUM:
  228. case DATA_HIGH:
  229. case DATA_CRITICAL:
  230. if (msg_short(msg))
  231. break; /* No error */
  232. switch (msg_errcode(msg)) {
  233. case TIPC_OK:
  234. break;
  235. case TIPC_ERR_NO_NAME:
  236. tipc_printf(buf, "NO_NAME:");
  237. break;
  238. case TIPC_ERR_NO_PORT:
  239. tipc_printf(buf, "NO_PORT:");
  240. break;
  241. case TIPC_ERR_NO_NODE:
  242. tipc_printf(buf, "NO_PROC:");
  243. break;
  244. case TIPC_ERR_OVERLOAD:
  245. tipc_printf(buf, "OVERLOAD:");
  246. break;
  247. case TIPC_CONN_SHUTDOWN:
  248. tipc_printf(buf, "SHUTDOWN:");
  249. break;
  250. default:
  251. tipc_printf(buf, "UNKNOWN ERROR(%x):",
  252. msg_errcode(msg));
  253. }
  254. default:{}
  255. }
  256. tipc_printf(buf, "HZ(%u):", msg_hdr_sz(msg));
  257. tipc_printf(buf, "SZ(%u):", msg_size(msg));
  258. tipc_printf(buf, "SQNO(%u):", msg_seqno(msg));
  259. if (msg_non_seq(msg))
  260. tipc_printf(buf, "NOSEQ:");
  261. else {
  262. tipc_printf(buf, "ACK(%u):", msg_ack(msg));
  263. }
  264. tipc_printf(buf, "BACK(%u):", msg_bcast_ack(msg));
  265. tipc_printf(buf, "PRND(%x)", msg_prevnode(msg));
  266. if (msg_isdata(msg)) {
  267. if (msg_named(msg)) {
  268. tipc_printf(buf, "NTYP(%u):", msg_nametype(msg));
  269. tipc_printf(buf, "NINST(%u)", msg_nameinst(msg));
  270. }
  271. }
  272. if ((usr != LINK_PROTOCOL) && (usr != LINK_CONFIG) &&
  273. (usr != MSG_BUNDLER)) {
  274. if (!msg_short(msg)) {
  275. tipc_printf(buf, ":ORIG(%x:%u):",
  276. msg_orignode(msg), msg_origport(msg));
  277. tipc_printf(buf, ":DEST(%x:%u):",
  278. msg_destnode(msg), msg_destport(msg));
  279. } else {
  280. tipc_printf(buf, ":OPRT(%u):", msg_origport(msg));
  281. tipc_printf(buf, ":DPRT(%u):", msg_destport(msg));
  282. }
  283. if (msg_routed(msg) && !msg_non_seq(msg))
  284. tipc_printf(buf, ":TSEQN(%u)", msg_transp_seqno(msg));
  285. }
  286. if (msg_user(msg) == NAME_DISTRIBUTOR) {
  287. tipc_printf(buf, ":ONOD(%x):", msg_orignode(msg));
  288. tipc_printf(buf, ":DNOD(%x):", msg_destnode(msg));
  289. if (msg_routed(msg)) {
  290. tipc_printf(buf, ":CSEQN(%u)", msg_transp_seqno(msg));
  291. }
  292. }
  293. if (msg_user(msg) == LINK_CONFIG) {
  294. u32* raw = (u32*)msg;
  295. struct tipc_media_addr* orig = (struct tipc_media_addr*)&raw[5];
  296. tipc_printf(buf, ":REQL(%u):", msg_req_links(msg));
  297. tipc_printf(buf, ":DDOM(%x):", msg_dest_domain(msg));
  298. tipc_printf(buf, ":NETID(%u):", msg_bc_netid(msg));
  299. tipc_media_addr_printf(buf, orig);
  300. }
  301. if (msg_user(msg) == BCAST_PROTOCOL) {
  302. tipc_printf(buf, "BCNACK:AFTER(%u):", msg_bcgap_after(msg));
  303. tipc_printf(buf, "TO(%u):", msg_bcgap_to(msg));
  304. }
  305. tipc_printf(buf, "\n");
  306. if ((usr == CHANGEOVER_PROTOCOL) && (msg_msgcnt(msg))) {
  307. tipc_msg_print(buf,msg_get_wrapped(msg)," /");
  308. }
  309. if ((usr == MSG_FRAGMENTER) && (msg_type(msg) == FIRST_FRAGMENT)) {
  310. tipc_msg_print(buf,msg_get_wrapped(msg)," /");
  311. }
  312. }