compiler/posixc/pipe.c

   1 /*
   2     Copyright © 1995-2013, The AROS Development Team. All rights reserved.
   3     $Id$
   4 */
   5
   6 #include <proto/dos.h>
   7 #include <proto/exec.h>
   8 #include <exec/exec.h>
   9
  10 #include <stdio.h>
  11 #include <fcntl.h>
  12 #include <errno.h>
  13
  14 #include "__fdesc.h"
  15
  16 /*****************************************************************************
  17
  18     NAME */
  19 #include <unistd.h>
  20
  21         int pipe(
  22
  23 /*  SYNOPSIS */
  24         int *pipedes)
  25
  26 /*  FUNCTION
  27
  28     INPUTS
  29
  30     RESULT
  31
  32     NOTES
  33
  34     EXAMPLE
  35
  36     BUGS
  37
  38     SEE ALSO
  39
  40     INTERNALS
  41
  42 ******************************************************************************/
  43 {
  44     BPTR reader, writer;
  45     fcb *rfcb = NULL, *wfcb = NULL;
  46     fdesc *rdesc = NULL, *wdesc = NULL;
  47     /* PIPE:cpipe-%08x-%d, where %x is the getpid(), %d is the nth pipe */
  48     char pipe_name[5 + 6 + 8 + 1 + 16 + 1];
  49     static int pipeno = 0;
  50
  51     if (!pipedes)
  52     {
  53         errno = EFAULT;
  54
  55         return -1;
  56     }
  57
  58     if (
  59         (rfcb = AllocVec(sizeof(fcb), MEMF_ANY | MEMF_CLEAR)) == NULL ||
  60         (rdesc = __alloc_fdesc()) == NULL ||
  61         (wfcb = AllocVec(sizeof(fcb), MEMF_ANY | MEMF_CLEAR)) == NULL ||
  62         (wdesc = __alloc_fdesc()) == NULL
  63     )
  64     {
  65     FreeVec(rfcb);
  66         if(rdesc)
  67             __free_fdesc(rdesc);
  68     FreeVec(wfcb);
  69         if(wdesc)
  70             __free_fdesc(wdesc);
  71         errno = ENOMEM;
  72         return -1;
  73     }
  74
  75     /* Get the next pipe number */
  76     Forbid();
  77     pipeno++;
  78     Permit();
  79
  80     snprintf(pipe_name, sizeof(pipe_name), "PIPE:cpipe-%08lx-%d",
  81                (unsigned long)getpid(), pipeno);
  82     pipe_name[sizeof(pipe_name)-1] = 0;
  83
  84     writer = Open(pipe_name, MODE_NEWFILE);
  85     if (writer)
  86     {
  87         reader = Open(pipe_name, MODE_OLDFILE);
  88         if (!reader)
  89         {
  90             DeleteFile(pipe_name);
  91             Close(writer);
  92             writer = BNULL;
  93         }
  94     }
  95
  96     if (!writer)
  97     {
  98         errno = __stdc_ioerr2errno(IoErr());
  99         __free_fdesc(rdesc);
 100         __free_fdesc(wdesc);
 101         return -1;
 102     }
 103
 104     pipedes[0] = __getfdslot(__getfirstfd(0));
 105     rdesc->fdflags = 0;
 106     rdesc->fcb = rfcb;
 107     rdesc->fcb->handle    = reader;
 108     rdesc->fcb->flags     = O_RDONLY;
 109     rdesc->fcb->opencount = 1;
 110     __setfdesc(pipedes[0], rdesc);
 111
 112     pipedes[1] = __getfdslot(__getfirstfd(pipedes[0]));
 113     wdesc->fdflags = 0;
 114     wdesc->fcb = wfcb;
 115     wdesc->fcb->handle    = writer;
 116     wdesc->fcb->flags     = O_WRONLY;
 117     wdesc->fcb->opencount = 1;
 118     __setfdesc(pipedes[1], wdesc);
 119
 120     return 0;
 121 }
 122