![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to inetdg.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Net/2] / Net2 / tests / benchmarks / inet|
Return to inetdg.c CVS log | Up to [Net/2] / Net2 / tests / benchmarks / inet |
1.1 root 1: #include <stdio.h>
2: #include <strings.h>
3: #include <signal.h>
4: #include <netdb.h>
5:
6: #include <sys/types.h>
7: #include <sys/socket.h>
8: #include <sys/time.h>
9: #include <netinet/in.h>
10: #include <sys/resource.h>
11:
12: struct sockaddr_in sin;
13: char myname[256];
14:
15: #define MAXMSGS (5000 - 1)
16: #define MAXMSGLEN BUFSIZ
17:
18: char *malloc();
19:
20: main(argc, argv)
21: char *argv[];
22: {
23: int s, sinlen;
24: struct hostent *hp;
25: register char *buf;
26: register int i, kb, msgs = 0;
27: int msglen = 0, ms, lens[MAXMSGS];
28: struct timeval t1, t2;
29: struct rusage r1, r2;
30:
31: if (argc < 2) {
32: printf("usage: %s port [ #msgs ] [ max-msg-length ]\n",
33: argv[0]);
34: exit(1);
35: }
36: s = socket(AF_INET, SOCK_DGRAM, 0);
37: if (s < 0) {
38: perror("socket");
39: exit(1);
40: }
41: sinlen = sizeof (myname);
42: gethostname(myname, &sinlen);
43: hp = gethostbyname(myname);
44: if (hp == 0) {
45: printf("%s: host unknown\n", myname);
46: exit(1);
47: }
48: sin.sin_family = AF_INET;
49: bcopy(hp->h_addr, &sin.sin_addr, hp->h_length);
50: if (bind(s, &sin, sizeof (sin)) < 0) {
51: perror("inetdg: bind");
52: exit(1);
53: }
54: sin.sin_port = htons(atoi(argv[1]));
55: if (argc > 2)
56: msgs = atoi(argv[2]);
57: if (msgs <= 0 || msgs > MAXMSGS)
58: msgs = MAXMSGS;
59: if (argc > 3)
60: msglen = atoi(argv[3]);
61: if (msglen <= 0 || msglen >= MAXMSGLEN)
62: msglen = MAXMSGLEN;
63: buf = malloc(msglen);
64: if (buf == 0) {
65: printf("couldn't allocate data buffer\n");
66: exit(1);
67: }
68: for (i = 0; i < msgs; i++)
69: lens[i] = random() % msglen;
70: for (i = 0; i < msglen; i++)
71: buf[i] = random() & 0xff;
72: printf("%d messages, max message length %d bytes\n",
73: msgs + 1, msglen);
74: (void) sendto(s, "begin", 5, 0, &sin, sizeof (sin));
75: kb = 0;
76: getrusage(RUSAGE_SELF, &r1);
77: gettimeofday(&t1, (struct timezone *)0);
78: for (i = 0; i < msgs; i++) {
79: if (sendto(s, buf, lens[i], 0, &sin, sizeof (sin)) < 0)
80: perror("inetdg: sendto");
81: kb += lens[i];
82: }
83: (void) sendto(s, "end", 3, 0, &sin, sizeof (sin));
84: gettimeofday(&t2, (struct timezone *)0);
85: getrusage(RUSAGE_SELF, &r2);
86: msgs++, kb += 3;
87: timevalsub(&t2, &t1);
88: ms = t2.tv_usec / 1000;
89: printf("%d msgs (%d bytes) in %d.%d secs", msgs,
90: kb, t2.tv_sec, ms / 100);
91: printf(", %d bytes/msg, %6.2f kb/s, %4.1f ms/msg\n",
92: kb / msgs, (8. * kb) / (t2.tv_sec * 1024.),
93: (1000. * t2.tv_sec + ms) / msgs);
94: timevalsub(&r2.ru_stime, &r1.ru_stime);
95: timevalsub(&r2.ru_utime, &r1.ru_utime);
96: r2.ru_nvcsw -= r1.ru_nvcsw;
97: r2.ru_nivcsw -= r1.ru_nivcsw;
98: printf("System %d.%d, user %d.%d, %d vcsw, %d ivcsw\n",
99: r2.ru_stime.tv_sec, r2.ru_stime.tv_usec / 100000,
100: r2.ru_utime.tv_sec, r2.ru_utime.tv_usec / 100000,
101: r2.ru_nvcsw, r2.ru_nivcsw);
102: pause();
103: }
104:
105: /*
106: * Add and subtract routines for timevals.
107: * N.B.: subtract routine doesn't deal with
108: * results which are before the beginning,
109: * it just gets very confused in this case.
110: * Caveat emptor.
111: */
112: timevaladd(t1, t2)
113: struct timeval *t1, *t2;
114: {
115:
116: t1->tv_sec += t2->tv_sec;
117: t1->tv_usec += t2->tv_usec;
118: timevalfix(t1);
119: }
120:
121: timevalsub(t1, t2)
122: struct timeval *t1, *t2;
123: {
124:
125: t1->tv_sec -= t2->tv_sec;
126: t1->tv_usec -= t2->tv_usec;
127: timevalfix(t1);
128: }
129:
130: timevalfix(t1)
131: struct timeval *t1;
132: {
133:
134: if (t1->tv_usec < 0) {
135: t1->tv_sec--;
136: t1->tv_usec += 1000000;
137: }
138: if (t1->tv_usec >= 1000000) {
139: t1->tv_sec++;
140: t1->tv_usec -= 1000000;
141: }
142: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.