change all file offsets from long to gint64 so we can - theoretically - handle files...
[obnox/wireshark/wip.git] / tap-mgcpstat.c
1 /* tap-mgcpstat.c
2  * mgcpstat   2003 Lars Roland
3  *
4  * $Id$
5  *
6  * Wireshark - Network traffic analyzer
7  * By Gerald Combs <gerald@wireshark.org>
8  * Copyright 1998 Gerald Combs
9  *
10  * This program is free software; you can redistribute it and/or
11  * modify it under the terms of the GNU General Public License
12  * as published by the Free Software Foundation; either version 2
13  * of the License, or (at your option) any later version.
14  *
15  * This program is distributed in the hope that it will be useful,
16  * but WITHOUT ANY WARRANTY; without even the implied warranty of
17  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
18  * GNU General Public License for more details.
19  *
20  * You should have received a copy of the GNU General Public License
21  * along with this program; if not, write to the Free Software
22  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
23  */
24
25 #ifdef HAVE_CONFIG_H
26 # include "config.h"
27 #endif
28
29 #include <stdio.h>
30
31 #ifdef HAVE_SYS_TYPES_H
32 # include <sys/types.h>
33 #endif
34
35 #include <string.h>
36 #include "epan/packet_info.h"
37 #include <epan/tap.h>
38 #include <epan/stat_cmd_args.h>
39 #include "epan/value_string.h"
40 #include "register.h"
41 #include "plugins/mgcp/packet-mgcp.h"
42 #include "timestats.h"
43
44 #define NUM_TIMESTATS 11
45
46 /* used to keep track of the statistics for an entire program interface */
47 typedef struct _mgcpstat_t {
48         char *filter;
49         timestat_t rtd[NUM_TIMESTATS];
50         guint32 open_req_num;
51         guint32 disc_rsp_num;
52         guint32 req_dup_num;
53         guint32 rsp_dup_num;
54 } mgcpstat_t;
55
56 static const value_string mgcp_mesage_type[] = {
57   {  0, "Overall"},
58   {  1, "EPCF   "},
59   {  2, "CRCX   "},
60   {  3, "MDCX   "},
61   {  4, "DLCX   "},
62   {  5, "RQNT   "},
63   {  6, "NTFY   "},
64   {  7, "AUEP   "},
65   {  8, "AUCX   "},
66   {  9, "RSIP   "},
67 };
68
69 static int
70 mgcpstat_packet(void *pms, packet_info *pinfo, epan_dissect_t *edt _U_, const void *pmi)
71 {
72         mgcpstat_t *ms=(mgcpstat_t *)pms;
73         const mgcp_info_t *mi=pmi;
74         nstime_t delta;
75
76         switch (mi->mgcp_type) {
77
78         case MGCP_REQUEST:
79                 if(mi->is_duplicate){
80                         /* Duplicate is ignored */
81                         ms->req_dup_num++;
82                         return 0;
83                 }
84                 else {
85                         ms->open_req_num++;
86                         return 0;
87                 }
88         break;
89
90         case MGCP_RESPONSE:
91                 if(mi->is_duplicate){
92                         /* Duplicate is ignored */
93                         ms->rsp_dup_num++;
94                         return 0;
95                 }
96                 else if (!mi->request_available) {
97                         /* no request was seen */
98                         ms->disc_rsp_num++;
99                         return 0;
100                 }
101                 else {
102                         ms->open_req_num--;
103                         /* calculate time delta between request and response */
104                         nstime_delta(&delta, &pinfo->fd->abs_ts, &mi->req_time);
105
106                         time_stat_update(&(ms->rtd[0]),&delta, pinfo);
107
108                         if (strncasecmp(mi->code, "EPCF", 4) == 0 ) {
109                                 time_stat_update(&(ms->rtd[1]),&delta, pinfo);
110                         }
111                         else if (strncasecmp(mi->code, "CRCX", 4) == 0 ) {
112                                 time_stat_update(&(ms->rtd[2]),&delta, pinfo);
113                         }
114                         else if (strncasecmp(mi->code, "MDCX", 4) == 0 ) {
115                                 time_stat_update(&(ms->rtd[3]),&delta, pinfo);
116                         }
117                         else if (strncasecmp(mi->code, "DLCX", 4) == 0 ) {
118                                 time_stat_update(&(ms->rtd[4]),&delta, pinfo);
119                         }
120                         else if (strncasecmp(mi->code, "RQNT", 4) == 0 ) {
121                                 time_stat_update(&(ms->rtd[5]),&delta, pinfo);
122                         }
123                         else if (strncasecmp(mi->code, "NTFY", 4) == 0 ) {
124                                 time_stat_update(&(ms->rtd[6]),&delta, pinfo);
125                         }
126                         else if (strncasecmp(mi->code, "AUEP", 4) == 0 ) {
127                                 time_stat_update(&(ms->rtd[7]),&delta, pinfo);
128                         }
129                         else if (strncasecmp(mi->code, "AUCX", 4) == 0 ) {
130                                 time_stat_update(&(ms->rtd[8]),&delta, pinfo);
131                         }
132                         else if (strncasecmp(mi->code, "RSIP", 4) == 0 ) {
133                                 time_stat_update(&(ms->rtd[9]),&delta, pinfo);
134                         }
135                         else {
136                                 time_stat_update(&(ms->rtd[10]),&delta, pinfo);
137                         }
138
139                         return 1;
140                 }
141         break;
142
143         default:
144                 return 0;
145         break;
146         }
147 }
148
149 static void
150 mgcpstat_draw(void *pms)
151 {
152         mgcpstat_t *ms=(mgcpstat_t *)pms;
153         int i;
154
155         /* printing results */
156         printf("\n");
157         printf("=====================================================================================================\n");
158         printf("MGCP Response Time Delay (RTD) Statistics:\n");
159         printf("Filter for statistics: %s\n",ms->filter?ms->filter:"");
160         printf("Duplicate requests: %u\n",ms->req_dup_num);
161         printf("Duplicate responses: %u\n",ms->rsp_dup_num);
162         printf("Open requests: %u\n",ms->open_req_num);
163         printf("Discarded responses: %u\n",ms->disc_rsp_num);
164         printf("Type    | Messages   |    Min RTD    |    Max RTD    |    Avg RTD    | Min in Frame | Max in Frame |\n");
165         for(i=0;i<NUM_TIMESTATS;i++) {
166                 if(ms->rtd[i].num) {
167                         printf("%s | %7u    | %8.2f msec | %8.2f msec | %8.2f msec |  %10u  |  %10u  |\n",
168                                 val_to_str(i,mgcp_mesage_type,"Other  "),ms->rtd[i].num,
169                                 nstime_to_msec(&(ms->rtd[i].min)), nstime_to_msec(&(ms->rtd[i].max)),
170                                 get_average(&(ms->rtd[i].tot), ms->rtd[i].num),
171                                 ms->rtd[i].min_num, ms->rtd[i].max_num
172                         );
173                 }
174         }
175         printf("=====================================================================================================\n");
176 }
177
178
179 static void
180 mgcpstat_init(const char *optarg, void* userdata _U_)
181 {
182         mgcpstat_t *ms;
183         int i;
184         const char *filter=NULL;
185         GString *error_string;
186
187         if(!strncmp(optarg,"mgcp,rtd,",9)){
188                 filter=optarg+9;
189         } else {
190                 filter="";
191         }
192
193         ms=g_malloc(sizeof(mgcpstat_t));
194         ms->filter=g_malloc(strlen(filter)+1);
195         strcpy(ms->filter, filter);
196
197         for(i=0;i<NUM_TIMESTATS;i++) {
198                 ms->rtd[i].num=0;
199                 ms->rtd[i].min_num=0;
200                 ms->rtd[i].max_num=0;
201                 ms->rtd[i].min.secs=0;
202                 ms->rtd[i].min.nsecs=0;
203                 ms->rtd[i].max.secs=0;
204                 ms->rtd[i].max.nsecs=0;
205                 ms->rtd[i].tot.secs=0;
206                 ms->rtd[i].tot.nsecs=0;
207         }
208
209         ms->open_req_num=0;
210         ms->disc_rsp_num=0;
211         ms->req_dup_num=0;
212         ms->rsp_dup_num=0;
213
214         error_string=register_tap_listener("mgcp", ms, filter, NULL, mgcpstat_packet, mgcpstat_draw);
215         if(error_string){
216                 /* error, we failed to attach to the tap. clean up */
217                 g_free(ms->filter);
218                 g_free(ms);
219
220                 fprintf(stderr, "tshark: Couldn't register mgcp,rtd tap: %s\n",
221                     error_string->str);
222                 g_string_free(error_string, TRUE);
223                 exit(1);
224         }
225 }
226
227
228 void
229 register_tap_listener_mgcpstat(void)
230 {
231         /* We don't register this tap, if we don't have the mgcp plugin loaded.*/
232         if (find_tap_id("mgcp")) {
233                 register_stat_cmd_arg("mgcp,rtd", mgcpstat_init, NULL);
234         }
235 }
236