Changes between Initial Version and Version 1 of shunfa/2011/0811

Timestamp:

Aug 11, 2011, 3:51:34 PM (14 years ago)

Author:

shunfa

Comment:

--

shunfa/2011/0811

@@ +1 @@
+= 別人寫的pipe程式 =
+ 
+ * pipe函式用一個int[]作參數，int[] fd中fd[0]用於讀，fd[1]用於寫
+
+{{{
+#!c
+#include <stdio.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <string.h>
+#include <sys/types.h>
+
+int main()
+{
+  int pipe1_fd[2], pipe2_fd[2];
+
+      char * parent_talks[] = {"Hi, my baby","Can you tell daddy date and time?","Daddy have to leave here, bye!",NULL};
+      char * child_talks[] = {"Hi, daddy","Sure,","Bye!",NULL};
+
+      char parent_buf[256], child_buf[256];
+      char * parent_ptr, * child_ptr;
+
+      int i,j, len;
+      int child_status;
+      time_t curtime;
+
+  if(pipe(pipe1_fd) < 0)
+  {
+   printf("pipe1 create error\n");
+         return -1;
+         }
+
+  if(pipe(pipe2_fd) < 0)
+         {
+       printf("pipe2 create error\n");
+       return -1;
+         }
+
+      if(fork() == 0)   //child
+         {
+       //pipe1_fd[0] is used to read, pipe2_fd[1] is used to write
+         close(pipe1_fd[1]);
+         close(pipe2_fd[0]);
+
+         i = 0;
+         child_ptr = child_talks[i];
+         while(child_ptr != NULL)
+                 {
+          len = read(pipe1_fd[0],child_buf,255);
+            child_buf[len] = '\0';
+            printf("Parent: %s\n",child_buf);
+
+            if(i == 1) 
+    {
+             time(&curtime);
+               len = sprintf(child_buf, "%s %s", child_ptr, ctime(&curtime)); 
+               child_buf[len-1] = '\0';
+               write(pipe2_fd[1],child_buf,strlen(child_buf));
+                         }
+            else 
+    {
+             write(pipe2_fd[1],child_ptr,strlen(child_ptr));
+                         }
+           
+    child_ptr = child_talks[++i];
+                 }
+
+         close(pipe1_fd[0]);
+         close(pipe2_fd[1]);
+         exit(0);
+         }
+      else   //parent
+  {
+       //pipe1_fd[1] is used to write, pipe2_fd[0] is used to read
+         close(pipe1_fd[0]);
+         close(pipe2_fd[1]);
+
+         j = 0;
+         parent_ptr = parent_talks[j];
+         while(parent_ptr != NULL) 
+   {
+          write(pipe1_fd[1],parent_ptr,strlen(parent_ptr));
+            len = read(pipe2_fd[0],parent_buf,255);
+            parent_buf[len] = '\0';
+            printf("Child: %s\n", parent_buf);
+            parent_ptr = parent_talks[++j];
+                 }
+
+         close(pipe1_fd[1]);
+         close(pipe2_fd[0]);
+         wait(&child_status);
+         exit(0);
+         }
+}
+
+}}}
+