ViewVC Help

View File | Revision Log | Show Annotations | Revision Graph | Root Listing

root/i-scream/projects/libstatgrab/src/libstatgrab/network_stats.c

Comparing projects/libstatgrab/src/libstatgrab/network_stats.c (file contents):
Revision 1.3 by pajs, Wed Feb 19 17:13:24 2003 UTC vs.
Revision 1.22 by tdb, Fri Jan 16 15:54:54 2004 UTC

#	Line 1 | Line 1
1	<	/*
1	>	/*
2		* i-scream central monitoring system
3	<	* http://www.i-scream.org.uk
4	<	* Copyright (C) 2000-2002 i-scream
3	>	* http://www.i-scream.org
4	>	* Copyright (C) 2000-2004 i-scream
5		*
6	<	* This program is free software; you can redistribute it and/or
7	<	* modify it under the terms of the GNU General Public License
8	<	* as published by the Free Software Foundation; either version 2
9	<	* of the License, or (at your option) any later version.
6	>	* This library is free software; you can redistribute it and/or
7	>	* modify it under the terms of the GNU Lesser General Public
8	>	* License as published by the Free Software Foundation; either
9	>	* version 2.1 of the License, or (at your option) any later version.
10		*
11	<	* This program is distributed in the hope that it will be useful,
11	>	* This library is distributed in the hope that it will be useful,
12		* but WITHOUT ANY WARRANTY; without even the implied warranty of
13	<	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14	<	* GNU General Public License for more details.
13	>	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
14	>	* Lesser General Public License for more details.
15		*
16	<	* You should have received a copy of the GNU General Public License
17	<	* along with this program; if not, write to the Free Software
18	<	* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
16	>	* You should have received a copy of the GNU Lesser General Public
17	>	* License along with this library; if not, write to the Free Software
18	>	* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
19	>	* 02111-1307 USA
20		*/
21
22		#ifdef HAVE_CONFIG_H
23		#include "config.h"
24		#endif
25
25	–	#include <stdio.h>
26	–	#include "statgrab.h"
26		#include <stdlib.h>
27	+	#include <string.h>
28	+	#include "statgrab.h"
29	+	#include <time.h>
30		#ifdef SOLARIS
31		#include <kstat.h>
32		#include <sys/sysinfo.h>
31	–	#include <string.h>
33		#endif
34	+	#ifdef LINUX
35	+	#include <stdio.h>
36	+	#include <sys/types.h>
37	+	#include <regex.h>
38	+	#include "tools.h"
39	+	#endif
40	+	#ifdef ALLBSD
41	+	#include <sys/types.h>
42	+	#include <sys/socket.h>
43	+	#include <ifaddrs.h>
44	+	#include <net/if.h>
45	+	#endif
46
47		static network_stat_t *network_stats=NULL;
48		static int interfaces=0;
#	Line 72 | Line 85 | network_stat_t *network_stat_malloc(int needed_entries
85
86
87		network_stat_t *get_network_stats(int *entries){
88	+
89	+	static int sizeof_network_stats=0;
90	+	network_stat_t *network_stat_ptr;
91	+
92	+	#ifdef SOLARIS
93		kstat_ctl_t *kc;
94		kstat_t *ksp;
95		kstat_named_t *knp;
96	+	#endif
97
98	<	static int sizeof_network_stats=0;
98	>	#ifdef LINUX
99	>	FILE *f;
100	>	/* Horrible big enough, but it should be easily big enough */
101	>	char line[8096];
102	>	regex_t regex;
103	>	regmatch_t line_match[4];
104	>	#endif
105	>	#ifdef ALLBSD
106	>	struct ifaddrs *net, *net_ptr;
107	>	struct if_data *net_data;
108	>	#endif
109	>
110	>	#ifdef ALLBSD
111	>	if(getifaddrs(&net) != 0){
112	>	return NULL;
113	>	}
114	>
115	>	interfaces=0;
116
117	<	network_stat_t *network_stat_ptr;
117	>	for(net_ptr=net;net_ptr!=NULL;net_ptr=net_ptr->ifa_next){
118	>	if(net_ptr->ifa_addr->sa_family != AF_LINK) continue;
119	>	network_stats=network_stat_malloc((interfaces+1), &sizeof_network_stats, network_stats);
120	>	if(network_stats==NULL){
121	>	return NULL;
122	>	}
123	>	network_stat_ptr=network_stats+interfaces;
124	>
125	>	if(network_stat_ptr->interface_name!=NULL) free(network_stat_ptr->interface_name);
126	>	network_stat_ptr->interface_name=strdup(net_ptr->ifa_name);
127	>	if(network_stat_ptr->interface_name==NULL) return NULL;
128	>	net_data=(struct if_data *)net_ptr->ifa_data;
129	>	network_stat_ptr->rx=net_data->ifi_ibytes;
130	>	network_stat_ptr->tx=net_data->ifi_obytes;
131	>	network_stat_ptr->systime=time(NULL);
132	>	interfaces++;
133	>	}
134	>	freeifaddrs(net);
135	>	#endif
136
137	+	#ifdef SOLARIS
138		if ((kc = kstat_open()) == NULL) {
139		return NULL;
140		}
141
142	<	interfaces=0;
142	>	interfaces=0;
143
144		for (ksp = kc->kc_chain; ksp; ksp = ksp->ks_next) {
145		if (!strcmp(ksp->ks_class, "net")) {
146		kstat_read(kc, ksp, NULL);
147
148	<	if((knp=kstat_data_lookup(ksp, "rbytes64"))==NULL){
148	>	#ifdef SOL7
149	>	#define RLOOKUP "rbytes"
150	>	#define WLOOKUP "obytes"
151	>	#define VALTYPE value.ui32
152	>	#else
153	>	#define RLOOKUP "rbytes64"
154	>	#define WLOOKUP "obytes64"
155	>	#define VALTYPE value.ui64
156	>	#endif
157	>
158	>	if((knp=kstat_data_lookup(ksp, RLOOKUP))==NULL){
159		/* Not a network interface, so skip to the next entry */
160		continue;
161		}
#	Line 100 | Line 165 | network_stat_t *get_network_stats(int *entries){
165		return NULL;
166		}
167		network_stat_ptr=network_stats+interfaces;
168	<	network_stat_ptr->rx=knp->value.ui64;
168	>	network_stat_ptr->rx=knp->VALTYPE;
169
170	<	if((knp=kstat_data_lookup(ksp, "obytes64"))==NULL){
170	>	if((knp=kstat_data_lookup(ksp, WLOOKUP))==NULL){
171		/* Not a network interface, so skip to the next entry */
172		continue;
173		}
174	<	network_stat_ptr->tx=knp->value.ui64;
174	>	network_stat_ptr->tx=knp->VALTYPE;
175		if(network_stat_ptr->interface_name!=NULL){
176		free(network_stat_ptr->interface_name);
177		}
#	Line 118 | Line 183 | network_stat_t *get_network_stats(int *entries){
183		}
184
185		kstat_close(kc);
186	+	#endif
187	+	#ifdef LINUX
188	+	f=fopen("/proc/net/dev", "r");
189	+	if(f==NULL){
190	+	return NULL;
191	+	}
192	+	/* read the 2 lines.. Its the title, so we dont care :) */
193	+	fgets(line, sizeof(line), f);
194	+	fgets(line, sizeof(line), f);
195
196	+
197	+	if((regcomp(&regex, "^[[:space:]]*([^:]+):[[:space:]]*([[:digit:]]+)[[:space:]]+[[:digit:]]+[[:space:]]+[[:digit:]]+[[:space:]]+[[:digit:]]+[[:space:]]+[[:digit:]]+[[:space:]]+[[:digit:]]+[[:space:]]+[[:digit:]]+[[:space:]]+[[:digit:]]+[[:space:]]+([[:digit:]]+)", REG_EXTENDED))!=0){
198	+	return NULL;
199	+	}
200	+
201	+	interfaces=0;
202	+
203	+	while((fgets(line, sizeof(line), f)) != NULL){
204	+	if((regexec(&regex, line, 4, line_match, 0))!=0){
205	+	continue;
206	+	}
207	+	network_stats=network_stat_malloc((interfaces+1), &sizeof_network_stats, network_stats);
208	+	if(network_stats==NULL){
209	+	return NULL;
210	+	}
211	+	network_stat_ptr=network_stats+interfaces;
212	+
213	+	if(network_stat_ptr->interface_name!=NULL){
214	+	free(network_stat_ptr->interface_name);
215	+	}
216	+
217	+	network_stat_ptr->interface_name=get_string_match(line, &line_match[1]);
218	+	network_stat_ptr->rx=get_ll_match(line, &line_match[2]);
219	+	network_stat_ptr->tx=get_ll_match(line, &line_match[3]);
220	+	network_stat_ptr->systime=time(NULL);
221	+
222	+	interfaces++;
223	+	}
224	+	fclose(f);
225	+	regfree(&regex);
226	+
227	+	#endif
228	+
229	+	#ifdef CYGWIN
230	+	return NULL;
231	+	#endif
232	+
233		*entries=interfaces;
234
235		return network_stats;
236		}
237
238	+	long long transfer_diff(long long new, long long old){
239	+	#if defined(SOL7) || defined(LINUX) || defined(FREEBSD)
240	+	#define MAXVAL 4294967296LL
241	+	#else
242	+	#define MAXVAL 18446744073709551616LL
243	+	#endif
244	+	long long result;
245	+	if(new>=old){
246	+	result = (new-old);
247	+	}else{
248	+	result = (MAXVAL+(new-old));
249	+	}
250	+
251	+	return result;
252	+
253	+	}
254	+
255		network_stat_t *get_network_stats_diff(int *entries){
256		static network_stat_t *network_stats_diff=NULL;
257		static int sizeof_net_stats_diff=0;
#	Line 157 | Line 285 | network_stat_t *get_network_stats_diff(int *entries){
285		network_stats_diff_ptr++;
286		}
287		network_stats_ptr=get_network_stats(&ifaces);
288	+	if (network_stats_ptr == NULL) {
289	+	return NULL;
290	+	}
291		network_stats_diff_ptr=network_stats_diff;
292
293		for(x=0;x<sizeof_net_stats_diff;x++){
294
295		if((strcmp(network_stats_diff_ptr->interface_name, network_stats_ptr->interface_name))==0){
296	<	network_stats_diff_ptr->tx = network_stats_ptr->tx - network_stats_diff_ptr->tx;
297	<	network_stats_diff_ptr->rx = network_stats_ptr->rx - network_stats_diff_ptr->rx;
296	>	network_stats_diff_ptr->tx = transfer_diff(network_stats_ptr->tx, network_stats_diff_ptr->tx);
297	>	network_stats_diff_ptr->rx = transfer_diff(network_stats_ptr->rx, network_stats_diff_ptr->rx);
298		network_stats_diff_ptr->systime = network_stats_ptr->systime - network_stats_diff_ptr->systime;
299		}else{
300
301		network_stats_ptr=network_stats;
302		for(y=0;y<ifaces;y++){
303		if((strcmp(network_stats_diff_ptr->interface_name, network_stats_ptr->interface_name))==0){
304	<	network_stats_diff_ptr->tx = network_stats_ptr->tx - network_stats_diff_ptr->tx;
305	<	network_stats_diff_ptr->rx = network_stats_ptr->rx - network_stats_diff_ptr->rx;
304	>	network_stats_diff_ptr->tx = transfer_diff(network_stats_ptr->tx, network_stats_diff_ptr->tx);
305	>	network_stats_diff_ptr->rx = transfer_diff(network_stats_ptr->rx, network_stats_diff_ptr->rx);
306		network_stats_diff_ptr->systime = network_stats_ptr->systime - network_stats_diff_ptr->systime;
307		break;
308		}
#	Line 184 | Line 315 | network_stat_t *get_network_stats_diff(int *entries){
315		network_stats_diff_ptr++;
316		}
317
318	+	*entries=sizeof_net_stats_diff;
319		return network_stats_diff;
320		}
189	–
190	–
321

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines