windows/JackWinNamedPipe.h

   1 /*
   2 Copyright (C) 2004-2006 Grame
   3
   4 This program is free software; you can redistribute it and/or modify
   5   it under the terms of the GNU General Public License as published by
   6   the Free Software Foundation; either version 2 of the License, or
   7   (at your option) any later version.
   8
   9   This program is distributed in the hope that it will be useful,
  10   but WITHOUT ANY WARRANTY; without even the implied warranty of
  11   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12   GNU General Public License for more details.
  13
  14   You should have received a copy of the GNU General Public License
  15   along with this program; if not, write to the Free Software
  16   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  17
  18 */
  19
  20 #ifndef __JackWinNamedPipe__
  21 #define __JackWinNamedPipe__
  22
  23 #include "JackChannelTransaction.h"
  24 #include <assert.h>
  25 #include <stdio.h>
  26 #include <windows.h>
  27
  28 namespace Jack
  29 {
  30
  31 class JackWinNamedPipe : public JackChannelTransaction
  32 {
  33
  34     protected:
  35
  36         HANDLE fNamedPipe;
  37         char fName[256];
  38
  39     public:
  40
  41         JackWinNamedPipe(): fNamedPipe(INVALID_HANDLE_VALUE)
  42         {}
  43         JackWinNamedPipe(HANDLE pipe): fNamedPipe(pipe)
  44         {}
  45         virtual ~JackWinNamedPipe()
  46         {}
  47
  48         virtual int Read(void* data, int len);
  49         virtual int Write(void* data, int len);
  50 };
  51
  52 /*!
  53 \brief Client named pipe.
  54 */
  55
  56 class JackWinNamedPipeClient : public JackWinNamedPipe
  57 {
  58
  59     public:
  60
  61         JackWinNamedPipeClient(): JackWinNamedPipe()
  62         {}
  63         JackWinNamedPipeClient(HANDLE pipe): JackWinNamedPipe(pipe)
  64         {}
  65
  66         virtual ~JackWinNamedPipeClient()
  67         {}
  68
  69         virtual int Connect(const char* dir, int which);
  70         virtual int Connect(const char* dir, const char* name, int which);
  71         virtual int Close();
  72         virtual void SetReadTimeOut(long sec);
  73         virtual void SetWriteTimeOut(long sec);
  74 };
  75
  76 class JackWinAsyncNamedPipeClient : public JackWinNamedPipeClient
  77 {
  78         enum kIOState {kIdle = 0, kConnecting, kReading, kWriting};
  79
  80     private:
  81
  82         bool fPendingIO;
  83         kIOState fIOState;
  84         OVERLAPPED fOverlap;
  85
  86     public:
  87
  88         JackWinAsyncNamedPipeClient();
  89         JackWinAsyncNamedPipeClient(HANDLE pipe, bool pending);
  90         virtual ~JackWinAsyncNamedPipeClient();
  91
  92         virtual int Read(void* data, int len);
  93         virtual int Write(void* data, int len);
  94
  95         HANDLE GetEvent()
  96         {
  97             return fOverlap.hEvent;
  98         }
  99
 100         kIOState GetIOState()
 101         {
 102             return fIOState;
 103         }
 104
 105         bool GetPending()
 106         {
 107             return fPendingIO;
 108         }
 109
 110         int FinishIO();
 111 };
 112
 113 /*!
 114 \brief Server named pipe.
 115 */
 116
 117 class JackWinNamedPipeServer : public JackWinNamedPipe
 118 {
 119
 120     public:
 121
 122         JackWinNamedPipeServer(): JackWinNamedPipe()
 123         {}
 124         virtual ~JackWinNamedPipeServer()
 125         {}
 126
 127         virtual int Bind(const char* dir, int which);
 128         virtual int Bind(const char* dir, const char* name, int which);
 129         virtual bool Accept();
 130         virtual JackWinNamedPipeClient* AcceptClient();
 131         int Close();
 132 };
 133
 134 /*!
 135 \brief Server async named pipe.
 136 */
 137
 138 class JackWinAsyncNamedPipeServer : public JackWinNamedPipeServer
 139 {
 140
 141     public:
 142
 143         JackWinAsyncNamedPipeServer(): JackWinNamedPipeServer()
 144         {}
 145         virtual ~JackWinAsyncNamedPipeServer()
 146         {}
 147
 148         int Bind(const char* dir, int which);
 149         int Bind(const char* dir, const char* name, int which);
 150         bool Accept();
 151         JackWinNamedPipeClient* AcceptClient();
 152         int Close();
 153 };
 154
 155 } // end of namespace
 156
 157
 158 #endif
 159