test/pipe.c

   1 #include <proto/exec.h>
   2 #include <proto/alib.h>
   3 #include <proto/dos.h>
   4 #include <dos/filesystem.h>
   5 #include <dos/dos.h>
   6 #include <exec/memory.h>
   7
   8 #include <assert.h>
   9
  10 static struct IOFileSys *CreateIOFS(ULONG type, struct MsgPort *port, struct FileHandle *fh)
  11 {
  12     struct IOFileSys *iofs = (struct IOFileSys *)AllocMem(sizeof(struct IOFileSys), MEMF_PUBLIC|MEMF_CLEAR);
  13
  14     if (iofs == NULL)
  15         return NULL;
  16
  17     iofs->IOFS.io_Message.mn_Node.ln_Type = NT_REPLYMSG;
  18     iofs->IOFS.io_Message.mn_ReplyPort    = port;
  19     iofs->IOFS.io_Message.mn_Length       = sizeof(struct IOFileSys);
  20     iofs->IOFS.io_Command                 = type;
  21     iofs->IOFS.io_Flags                   = 0;
  22     iofs->IOFS.io_Device                  = fh->fh_Device;
  23     iofs->IOFS.io_Unit                    = fh->fh_Unit;
  24
  25     return iofs;
  26 }
  27
  28 static BPTR DupFH(BPTR fh, LONG mode)
  29 {
  30     BPTR ret = NULL;
  31
  32     if (fh)
  33     {
  34         BPTR olddir = CurrentDir(fh);
  35         ret    = Open("", mode);
  36
  37         CurrentDir(olddir);
  38     }
  39
  40     return ret;
  41 }
  42
  43 int main(void)
  44 {
  45     struct FileHandle *fhin, *fhout;
  46     struct MsgPort *port;
  47     struct IOFileSys *iofs;
  48
  49     fhin = Open("PIPEFS:__UNNAMED__", FMF_READ|FMF_NONBLOCK);
  50     fhout = DupFH(fhin, FMF_WRITE);
  51     assert(fhin!=NULL && fhout!=NULL);
  52     ChangeMode(CHANGE_FH, fhin, FMF_READ);
  53
  54     port = CreatePort(NULL, 0);
  55     assert(port!=NULL);
  56
  57     iofs = CreateIOFS(FSA_WRITE, port, fhout);
  58     iofs->io_Union.io_WRITE.io_Buffer = "Test\n";
  59     iofs->io_Union.io_WRITE.io_Length = 5;
  60
  61     SendIO(&iofs->IOFS);
  62
  63     Close(fhin);
  64
  65     iofs = CreateIOFS(FSA_WRITE, port, fhout);
  66     iofs->io_Union.io_WRITE.io_Buffer = "Test\n";
  67     iofs->io_Union.io_WRITE.io_Length = 5;
  68
  69     SendIO(&iofs->IOFS);
  70
  71     Close(fhout);
  72     DeletePort(port);
  73
  74     return 0;
  75 }