251ace13ed56b0e319a48d9b904523919c1ebb29
[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         LM_ERR("%s: unknown reply type, method id 0x%08X - should not reach here!\n", context, x.reply_type);
107         return x.reply_type;
108 }
109
110 static void dump_row(long count, int numinrow, int *chs)
111 {
112         int i;
113
114         printf("%08lX:", count - numinrow);
115
116         if (numinrow > 0) {
117                 for (i = 0; i < numinrow; i++) {
118                         if (i == 8) {
119                                 printf(" :");
120                         }
121                         printf(" %02X", chs[i]);
122                 }
123                 for (i = numinrow; i < 16; i++) {
124                         if (i == 8) {
125                                 printf(" :");
126                         }
127                         printf("         ");
128                 }
129                 printf("        ");
130                 for (i = 0; i < numinrow; i++) {
131                         if (isprint(chs[i])) {
132                                 printf("%c", chs[i]);
133                         } else {
134                                 printf(".");
135                         }
136                 }
137         }
138         printf("\n");
139 }
140
141 static int rows_eq(int *a, int *b)
142 {
143         int i;
144
145         for (i=0; i<16; i++)
146                 if (a[i] != b[i]) {
147                         return 0;
148                 }
149
150         return 1;
151 }
152
153 void amqp_dump(void const *buffer, size_t len)
154 {
155         unsigned char *buf = (unsigned char *) buffer;
156         long count = 0;
157         int numinrow = 0;
158         int chs[16];
159         int oldchs[16] = {0};
160         int showed_dots = 0;
161         size_t i;
162
163         for (i = 0; i < len; i++) {
164                 int ch = buf[i];
165
166                 if (numinrow == 16) {
167                         int j;
168
169                         if (rows_eq(oldchs, chs)) {
170                                 if (!showed_dots) {
171                                         showed_dots = 1;
172                                         printf("                                        .. .. .. .. .. .. .. .. : .. .. .. .. .. .. .. ..\n");
173                                 }
174                         } else {
175                                 showed_dots = 0;
176                                 dump_row(count, numinrow, chs);
177                         }
178
179                         for (j=0; j<16; j++) {
180                                 oldchs[j] = chs[j];
181                         }
182
183                         numinrow = 0;
184                 }
185
186                 count++;
187                 chs[numinrow++] = ch;
188         }
189
190         dump_row(count, numinrow, chs);
191
192         if (numinrow != 0) {
193                 printf("%08lX:\n", count);
194         }
195 }