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