windows/JackWinNamedPipeServerChannel.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 __JackWinNamedPipeServerChannel__
  22 #define __JackWinNamedPipeServerChannel__
  23
  24 #include "JackWinNamedPipe.h"
  25 #include "JackPlatformPlug.h"
  26 #include "JackConstants.h"
  27
  28 #include "JackRequestDecoder.h"
  29
  30 #include <list>
  31
  32 namespace Jack
  33 {
  34
  35 class JackServer;
  36
  37 class JackClientPipeThread : public JackRunnableInterface, public JackClientHandlerInterface
  38 {
  39
  40     private:
  41
  42         JackWinNamedPipeClient* fPipe;
  43         JackRequestDecoder* fDecoder;
  44         JackServer*     fServer;
  45         JackThread fThread;
  46         int fRefNum;
  47
  48         void ClientAdd(detail::JackChannelTransactionInterface* socket, JackClientOpenRequest* req, JackClientOpenResult *res);
  49         void ClientRemove(detail::JackChannelTransactionInterface* socket, int refnum);
  50
  51         void ClientKill();
  52
  53         static HANDLE fMutex;
  54
  55     public:
  56
  57         JackClientPipeThread(JackWinNamedPipeClient* pipe);
  58         virtual ~JackClientPipeThread();
  59
  60         int Open(JackServer* server);   // Open the Server/Client connection
  61         void Close();                   // Close the Server/Client connection
  62
  63         // JackRunnableInterface interface
  64         bool Execute();
  65
  66         // To be used for find out if the object can be deleted
  67         bool IsRunning()
  68         {
  69             return (fRefNum >= 0);
  70         }
  71
  72 };
  73
  74 /*!
  75 \brief JackServerChannel using pipe.
  76 */
  77
  78 class JackWinNamedPipeServerChannel : public JackRunnableInterface
  79 {
  80
  81     private:
  82
  83         JackWinNamedPipeServer fRequestListenPipe;      // Pipe to create request socket for the client
  84         JackServer*     fServer;
  85         JackThread fThread;                         // Thread to execute the event loop
  86         char fServerName[JACK_SERVER_CONTROL_NAME_SIZE];
  87
  88         std::list<JackClientPipeThread*> fClientList;
  89
  90         void ClientAdd(JackWinNamedPipeClient* pipe);
  91
  92         bool ClientListen();
  93         bool ClientAccept();
  94
  95     public:
  96
  97         JackWinNamedPipeServerChannel();
  98         ~JackWinNamedPipeServerChannel();
  99
 100         int Open(const char* server_name, JackServer* server);  // Open the Server/Client connection
 101         void Close();                                           // Close the Server/Client connection
 102
 103         int Start();
 104         void Stop();
 105
 106         // JackRunnableInterface interface
 107         bool Init();
 108         bool Execute();
 109 };
 110
 111
 112 } // end of namespace
 113
 114 #endif
 115