windows/JackWinNamedPipe.h

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