From: CSRG <csrg@ucbvax.Berkeley.EDU>
Date: Tue, 8 Jun 1993 05:26:35 +0000 (-0800)
Subject: BSD 4_4 development
X-Git-Tag: BSD-4_4~282
X-Git-Url: https://git.subgeniuskitty.com/unix-history/.git/commitdiff_plain/4a754c118facceb8533d465d6eae59ccea97c7a5

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
index 0000000000..5454edb0d8
--- /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);
+}