rabbitmq: removed unreachable code
[sip-router] / src / modules / rabbitmq / utils.c
1 /*
2  * MIT License
3  *
4  * Portions created by ONEm Communications Ltd. are Copyright (c) 2016
5  * ONEm Communications Ltd. All Rights Reserved.
6  *
7  * Portions created by ng-voice are Copyright (c) 2016
8  * ng-voice. All Rights Reserved.
9  *
10  * Portions created by Alan Antonuk are Copyright (c) 2012-2013
11  * Alan Antonuk. All Rights Reserved.
12  *
13  * Portions created by VMware are Copyright (c) 2007-2012 VMware, Inc.
14  * All Rights Reserved.
15  *
16  * Portions created by Tony Garnock-Jones are Copyright (c) 2009-2010
17  * VMware, Inc. and Tony Garnock-Jones. All Rights Reserved.
18  *
19  * Permission is hereby granted, free of charge, to any person
20  * obtaining a copy of this software and associated documentation
21  * files (the "Software"), to deal in the Software without
22  * restriction, including without limitation the rights to use, copy,
23  * modify, merge, publish, distribute, sublicense, and/or sell copies
24  * of the Software, and to permit persons to whom the Software is
25  * furnished to do so, subject to the following conditions:
26  *
27  * The above copyright notice and this permission notice shall be
28  * included in all copies or substantial portions of the Software.
29  *
30  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
31  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
32  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
33  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
34  * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
35  * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
36  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
37  * SOFTWARE.
38  */
39
40 #include <stdarg.h>
41 #include <stdlib.h>
42 #include <stdio.h>
43 #include <string.h>
44 #include <ctype.h>
45
46 #include <stdint.h>
47 #include <amqp.h>
48 #include <amqp_framing.h>
49
50 #include "utils.h"
51
52 int log_on_error(int x, char const *context)
53 {
54         if (x < 0) {
55                 LM_ERR("%s: %s\n", context, amqp_error_string2(x));
56                 return x;
57         }
58
59         return AMQP_RESPONSE_NORMAL;
60 }
61
62 int log_on_amqp_error(amqp_rpc_reply_t x, char const *context)
63 {
64         switch (x.reply_type) {
65                 case AMQP_RESPONSE_NONE:
66                         LM_NOTICE("%s: AMQP_RESPONSE_NONE\n", context);
67                         return AMQP_RESPONSE_NONE;
68
69                 case AMQP_RESPONSE_NORMAL:
70                         LM_DBG("%s: AMQP_RESPONSE_NORMAL\n", context);
71                         return AMQP_RESPONSE_NORMAL;
72
73                 case AMQP_RESPONSE_LIBRARY_EXCEPTION:
74                         LM_ERR("%s: AMQP_RESPONSE_LIBRARY_EXCEPTION: %s\n", context, amqp_error_string2(x.library_error));
75                         return AMQP_RESPONSE_LIBRARY_EXCEPTION;
76
77                 case AMQP_RESPONSE_SERVER_EXCEPTION:
78                         switch (x.reply.id) {
79                                 case AMQP_CONNECTION_CLOSE_METHOD: {
80                                         amqp_connection_close_t *m = (amqp_connection_close_t *) x.reply.decoded;
81                                         LM_ERR("%s: AMQP_CONNECTION_CLOSE_METHOD: server connection error %uh, message: %.*s\n",
82                                                 context, m->reply_code, (int) m->reply_text.len, (char *) m->reply_text.bytes);
83                                         break;
84                                 }
85
86                                 case AMQP_CHANNEL_CLOSE_METHOD: {
87                                         amqp_channel_close_t *m = (amqp_channel_close_t *) x.reply.decoded;
88                                         LM_ERR("%s: AMQP_CHANNEL_CLOSE_METHOD: server channel error %uh, message: %.*s\n",
89                                                 context, m->reply_code, (int) m->reply_text.len, (char *) m->reply_text.bytes);
90                                         break;
91                                 }
92
93                                 default:
94                                         LM_ERR("%s: unknown server error, method id 0x%08X\n", context, x.reply.id);
95                                         break;
96                         }
97
98                         LM_ERR("%s: AMQP_RESPONSE_SERVER_EXCEPTION: %s\n", context, amqp_error_string2(x.library_error));
99                         return AMQP_RESPONSE_SERVER_EXCEPTION;
100
101                 default:
102                         LM_ERR("%s: unknown reply type 0x%08X\n", context, x.reply_type);
103                         return x.reply_type;
104         }
105 }
106
107 static void dump_row(long count, int numinrow, int *chs)
108 {
109         int i;
110
111         printf("%08lX:", count - numinrow);
112
113         if (numinrow > 0) {
114                 for (i = 0; i < numinrow; i++) {
115                         if (i == 8) {
116                                 printf(" :");
117                         }
118                         printf(" %02X", chs[i]);
119                 }
120                 for (i = numinrow; i < 16; i++) {
121                         if (i == 8) {
122                                 printf(" :");
123                         }
124                         printf("         ");
125                 }
126                 printf("        ");
127                 for (i = 0; i < numinrow; i++) {
128                         if (isprint(chs[i])) {
129                                 printf("%c", chs[i]);
130                         } else {
131                                 printf(".");
132                         }
133                 }
134         }
135         printf("\n");
136 }
137
138 static int rows_eq(int *a, int *b)
139 {
140         int i;
141
142         for (i=0; i<16; i++)
143                 if (a[i] != b[i]) {
144                         return 0;
145                 }
146
147         return 1;
148 }
149
150 void amqp_dump(void const *buffer, size_t len)
151 {
152         unsigned char *buf = (unsigned char *) buffer;
153         long count = 0;
154         int numinrow = 0;
155         int chs[16];
156         int oldchs[16] = {0};
157         int showed_dots = 0;
158         size_t i;
159
160         for (i = 0; i < len; i++) {
161                 int ch = buf[i];
162
163                 if (numinrow == 16) {
164                         int j;
165
166                         if (rows_eq(oldchs, chs)) {
167                                 if (!showed_dots) {
168                                         showed_dots = 1;
169                                         printf("                                        .. .. .. .. .. .. .. .. : .. .. .. .. .. .. .. ..\n");
170                                 }
171                         } else {
172                                 showed_dots = 0;
173                                 dump_row(count, numinrow, chs);
174                         }
175
176                         for (j=0; j<16; j++) {
177                                 oldchs[j] = chs[j];
178                         }
179
180                         numinrow = 0;
181                 }
182
183                 count++;
184                 chs[numinrow++] = ch;
185         }
186
187         dump_row(count, numinrow, chs);
188
189         if (numinrow != 0) {
190                 printf("%08lX:\n", count);
191         }
192 }