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
|
/*
* tcpblast - test and estimate TCP thruput
*
* Daniel Karrenberg <dfk@nic.eu.net>
*/
#include <sys/types.h>
#include <machine/endian.h>
#include <sys/socket.h>
#include <sys/file.h>
#include <sys/time.h>
#include <netinet/in.h>
#include <netdb.h>
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <err.h>
#include <errno.h>
#define BLKSIZE 1024
struct sockaddr_in sock_in;
struct servent *sp;
struct hostent *host;
long starts, startms, stops, stopms, expms;
struct timeval ti;
struct timezone tiz;
char greet[BLKSIZE] = "Hi!";
int nblocks;
int f;
int main(argc, argv)
int argc; char **argv;
{
struct addrinfo hints, *res, *res0;
char *cause = NULL;
int ch, proto, error;
register int i;
memset(&hints, 0, sizeof(hints));
hints.ai_family = PF_UNSPEC;
hints.ai_socktype = SOCK_STREAM;
while ((ch = getopt(argc, argv, "46")) != -1) {
switch (ch) {
case '4':
hints.ai_family = PF_INET;
break;
case '6':
hints.ai_family = PF_INET6;
break;
}
}
argc -= optind;
argv += optind;
if (argc != 2) {
fprintf(stderr,
"usage: tcpblast [-4] [-6] destination nblkocks\n"
"blocksize: %d bytes %d\n", BLKSIZE, argc);
exit(1);
}
nblocks = atoi(argv[1]);
if (nblocks<=1 || nblocks>10000) {
fprintf(stderr, "tcpblast: 1 < nblocks <= 10000 \n");
exit(1);
}
error = getaddrinfo(argv[0], "discard", &hints, &res0);
if (error)
errx(1, "%s", gai_strerror(error));
f = -1;
cause = "no addresses";
errno = EADDRNOTAVAIL;
for (res = res0; res; res = res->ai_next) {
f = socket(res->ai_family, res->ai_socktype, res->ai_protocol);
if (f < 0) {
cause = "socket";
continue;
}
if (connect(f, res->ai_addr, res->ai_addrlen) < 0) {
cause = "connect";
close(f);
f = -1;
continue;
}
break;
}
if (f < 0)
err(1, cause);
freeaddrinfo(res);
if (gettimeofday(&ti, &tiz) < 0)
{
perror("tcpblast time:");
exit(1);
}
starts = ti.tv_sec;
startms = ti.tv_usec / 1000L;
for (i=0; i<nblocks; i++)
{
if (write(f, greet, BLKSIZE) != BLKSIZE)
perror("tcpblast send:");
write(1, ".", 1);
}
if (gettimeofday(&ti, &tiz) < 0)
{
perror("tcpblast time:");
exit(1);
}
stops = ti.tv_sec;
stopms = ti.tv_usec / 1000L;
expms = (stops-starts)*1000 + (stopms-startms);
printf("\n%d %d-byte blocks in %ld msec.\n", nblocks, BLKSIZE, expms);
printf("Throughput = %.1f kbit/s", (double) (nblocks*BLKSIZE) / expms * 8.0);
printf(" = %.1f kByte/s", (double) (nblocks*BLKSIZE) / expms);
printf(" = %.1f MByte/s\n", (double) (nblocks*BLKSIZE) / (double)(expms*1024.0));
return(0);
}
|
