BSD 4_4 development

Work on file usr/src/sys/tests/benchmarks/udgback.c

Synthesized-from: CSRG/cd3/4.4

diff --git a/usr/src/sys/tests/benchmarks/udgback.c b/usr/src/sys/tests/benchmarks/udgback.c
new file mode 100644 (file)
index 0000000..5454edb
--- /dev/null
+++ b/usr/src/sys/tests/benchmarks/udgback.c
@@ -0,0 +1,90 @@
+/*
+ * IPC benchmark,
+ * read and reply using UNIX domain datagram sockets.
+ *
+ * Process forks and exchanges messages using a
+ * UNIX domain datagram socket in a request-response fashion.
+ */
+
+#include <stdio.h>
+#include <signal.h>
+
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <sys/time.h>
+#include <sys/un.h>
+#include <sys/resource.h>
+
+struct sockaddr_un sun;
+struct sockaddr_un myname;
+
+void   catchsig();
+char   *malloc();
+
+main(argc, argv)
+       char *argv[];
+{
+       register char *buf;
+       register int i, msgs = 0;
+       int msglen = 0, ms;
+       int pid, s, sunlen;
+
+       if (argc < 3) {
+               printf("usage: %s #msgs msglen\n", argv[0]);
+               exit(1);
+       }
+       msgs = atoi(argv[1]);
+       msglen = atoi(argv[2]);
+       buf = malloc(msglen);
+       if (buf == 0) {
+               printf("Couldn't allocate data buffer\n");
+               exit(1);
+       }
+       myname.sun_family = AF_UNIX;
+       signal(SIGINT, catchsig);
+       s = socket(AF_UNIX, SOCK_DGRAM, 0);
+       if (s < 0) {
+               perror("socket");
+               exit(1);
+       }
+       sprintf(myname.sun_path, "unixdg%d", getpid());
+       sunlen = strlen(myname.sun_path) + 2;
+       if (bind(s, (const struct sockaddr *)&myname, sunlen) < 0) {
+               perror("bind");
+               exit(1);
+       }
+       pid = fork();
+       if (pid == 0)
+               for (i = 0; i < msgs; i++) {
+                       sunlen = sizeof (sun);
+                       if (recvfrom(s, buf, msglen, 0,
+                           (struct sockaddr *)&sun, &sunlen) < 0)
+                               perror("recvfrom (child)");
+                       sunlen = strlen(myname.sun_path) + 2;
+                       if (sendto(s, buf, msglen, 0,
+                           (const struct sockaddr *)&myname, sunlen) < 0)
+                               perror("sendto (child)");
+               }
+       else
+               for (i = 0; i < msgs; i++) {
+                       sunlen = strlen(myname.sun_path) + 2;
+                       if (sendto(s, buf, msglen, 0,
+                           (const struct sockaddr *)&myname, sunlen) < 0)
+                               perror("sendto (parent)");
+                       sunlen = sizeof (sun);
+                       if (recvfrom(s, buf, msglen, 0,
+                           (struct sockaddr *)&sun, &sunlen) < 0)
+                               perror("recvfrom (parent)");
+               }
+       close(s);
+       unlink(myname.sun_path);
+}
+
+void
+catchsig(s)
+       int s;
+{
+
+       unlink(myname.sun_path);
+       exit(1);
+}