summaryrefslogtreecommitdiff
path: root/user/pingpong.c
diff options
context:
space:
mode:
authorSanjit Bhat <[email protected]>2023-10-26 06:44:48 -0400
committerSanjit Bhat <[email protected]>2023-10-26 06:44:48 -0400
commitcfae93475dfb4cb5cfe264f4c029136e1447c262 (patch)
tree699903e093e3a23caf7ce3899e7c80e48511f900 /user/pingpong.c
parent1ed40716eb54e371df9d1814b9129666b3fe4f09 (diff)
downloadxv6-labs-cfae93475dfb4cb5cfe264f4c029136e1447c262.tar.gz
xv6-labs-cfae93475dfb4cb5cfe264f4c029136e1447c262.tar.bz2
xv6-labs-cfae93475dfb4cb5cfe264f4c029136e1447c262.zip
net add missing files
Diffstat (limited to 'user/pingpong.c')
-rw-r--r--user/pingpong.c52
1 files changed, 52 insertions, 0 deletions
diff --git a/user/pingpong.c b/user/pingpong.c
new file mode 100644
index 0000000..6ed12e7
--- /dev/null
+++ b/user/pingpong.c
@@ -0,0 +1,52 @@
+#include "kernel/types.h"
+#include "kernel/stat.h"
+#include "user/user.h"
+
+#define N 5
+char buf[N];
+
+void
+pong(int *parent_to_child, int *child_to_parent) {
+ if (read(parent_to_child[0], buf, N) < 0) {
+ printf("read failed\n");
+ }
+ printf("%d: received %s\n", getpid(), buf);
+ if (write(child_to_parent[1], "pong", 4) != 4) {
+ printf("write failed\n");
+ }
+}
+
+void
+ping(int *parent_to_child, int *child_to_parent) {
+
+ if (write(parent_to_child[1], "ping", 4) != 4) {
+ printf("write failed\n");
+ }
+ if (read(child_to_parent[0], buf, N) < 0) {
+ printf("read failed\n");
+ }
+ printf("%d: received %s\n", getpid(), buf);
+}
+
+int
+main(int argc, char *argv[])
+{
+ int parent_to_child[2];
+ int child_to_parent[2];
+
+ int pid;
+
+ if (pipe(parent_to_child) < 0 || pipe(child_to_parent) < 0) {
+ printf("pipe failed\n");
+ }
+ if ((pid = fork()) < 0) {
+ printf("fork failed\n");
+ }
+ if (pid == 0) {
+ pong(parent_to_child, child_to_parent);
+ } else {
+ ping(parent_to_child, child_to_parent);
+ }
+
+ exit(0);
+}