-
Notifications
You must be signed in to change notification settings - Fork 2
/
ofdump.c
138 lines (126 loc) · 4.25 KB
/
ofdump.c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
/***********************************************************
Copyright (c) 2008 The Board of Trustees of The Leland Stanford Junior
University
We are making the OpenFlow specification and associated documentation
(Software) available for public use and benefit with the expectation
that others will use, modify and enhance the Software and contribute
those enhancements back to the community. However, since we would
like to make the Software available for broadest use, with as few
restrictions as possible permission is hereby granted, free of charge,
to any person obtaining a copy of this Software to deal in the Software
under the copyrights without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom the
Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED “AS IS”, WITHOUT WARRANTY OF ANY KIND,
EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR
THE USE OR OTHER DEALINGS IN THE SOFTWARE.
The name and trademarks of copyright holder(s) may NOT be used in
advertising or publicity pertaining to the Software or any derivatives
without specific, written prior permission.
*****************************************************************/
#include <assert.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include "oftrace.h"
#ifndef MIN
#define MIN(x,y) ((x)<(y)?(x):(y))
#endif
/************************
* main()
*
*/
int do_analyze(oftrace * oft, uint32_t ip, int port);
int main(int argc, char * argv[])
{
char * filename = "openflow.trace";
char * controller = "0.0.0.0";
int port = OFP_TCP_PORT;
uint32_t controller_ip;
oftrace *oft;
// FIXME: parse options from cmdline
if(argc>1)
filename=argv[1];
if(argc>2)
controller=argv[2];
if(argc>3)
port=atoi(argv[3]);
if(!strcmp(controller,"0.0.0.0"))
fprintf(stderr,"Reading from pcap file %s for any controller ip on port %d\n",
filename,port);
else
fprintf(stderr,"Reading from pcap file %s for controller %s on port %d\n",
filename,controller,port);
inet_pton(AF_INET,controller,&controller_ip); // FIXME: use getaddrinfo
oft= oftrace_open(filename);
if(!oft)
{
fprintf(stderr,"Problem openning %s; aborting....\n",filename);
return 0;
}
return do_analyze(oft,controller_ip, port);
}
/************************************************************************
* do_analyze:
* analyze openflow msgs from the given file
*/
int do_analyze(oftrace * oft, uint32_t ip, int port)
{
int count = 0;
int tcp_list[BUFLEN];
int n_sessions,i;
const openflow_msg *m;
char dst_ip[BUFLEN];
char src_ip[BUFLEN];
struct timeval start,diff;
start.tv_sec = start.tv_usec= 0;
memset(&m, 0, sizeof(m)); // zero msg contents
// for each openflow msg
while( (m = oftrace_next_msg(oft, ip, port)) != NULL)
{
count ++;
if((count%10000)==0)
{
n_sessions =oftrace_tcp_stats(oft,BUFLEN,tcp_list);
fprintf(stderr," --- %d sessions: ",n_sessions);
for(i=0;i<MIN(n_sessions,BUFLEN);i++)
fprintf(stderr, " %d",tcp_list[i]);
fprintf(stderr,"\n");
}
if(start.tv_sec == 0)
{
start.tv_sec = m->phdr.ts_sec;
start.tv_usec = m->phdr.ts_usec;
}
diff.tv_sec = m->phdr.ts_sec - start.tv_sec;
if(m->phdr.ts_usec < start.tv_usec)
{
diff.tv_usec = m->phdr.ts_usec + 100000 + start.tv_usec;
diff.tv_sec--;
}
else
diff.tv_usec = m->phdr.ts_usec - start.tv_usec;
inet_ntop(AF_INET,&m->ip->saddr,src_ip,BUFLEN);
inet_ntop(AF_INET,&m->ip->daddr,dst_ip,BUFLEN);
printf("FROM %s:%u TO %s:%u OFP_TYPE %d LEN %d TIME %lu.%.6lu\n",
src_ip,
ntohs(m->tcp->source),
dst_ip,
ntohs(m->tcp->dest),
m->ofph->type,
ntohs(m->ofph->length),
diff.tv_sec,
diff.tv_usec
);
}
fprintf(stderr,"Total OpenFlow Messages: %d\n",count);
return count;
}