windows/JackWinNamedPipeServerChannel.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 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 #ifndef __JackWinNamedPipeServerChannel__
  21 #define __JackWinNamedPipeServerChannel__
  22
  23 #include "JackChannel.h"
  24 #include "JackWinNamedPipe.h"
  25 #include "JackThread.h"
  26 #include <map>
  27 #include <list>
  28
  29 namespace Jack
  30 {
  31
  32 class JackClientPipeThread : public JackRunnableInterface
  33 {
  34
  35     private:
  36
  37         JackWinNamedPipeClient* fPipe;
  38         JackServer*     fServer;
  39         JackThread*     fThread;
  40         int fRefNum;
  41
  42         void AddClient(JackWinNamedPipeClient* pipe, char* name, int* shared_engine, int* shared_client, int* shared_ports, int* result);
  43         void RemoveClient(JackWinNamedPipeClient* pipe, int refnum);
  44         void KillClient(JackWinNamedPipeClient* pipe);
  45
  46         static HANDLE fMutex;
  47
  48     public:
  49
  50         JackClientPipeThread(JackWinNamedPipeClient* pipe);
  51         virtual ~JackClientPipeThread();
  52
  53         int Open(JackServer* server);   // Open the Server/Client connection
  54         void Close();                                   // Close the Server/Client connection
  55
  56         int HandleRequest(JackWinNamedPipeClient* pipe);
  57
  58         // JackRunnableInterface interface
  59         bool Execute();
  60
  61         bool IsRunning()
  62         {
  63             return (fRefNum >= 0);
  64         }
  65 };
  66
  67 /*!
  68 \brief JackServerChannel using pipe.
  69 */
  70
  71 class JackWinNamedPipeServerChannel : public JackServerChannelInterface, public JackRunnableInterface
  72 {
  73
  74     private:
  75
  76         JackWinNamedPipeServer fRequestListenPipe;      // Pipe to create request socket for the client
  77         JackServer*     fServer;
  78         JackThread*     fThread;                                                // Thread to execute the event loop
  79
  80         std::list<JackClientPipeThread*> fClientList;
  81
  82         void AddClient(JackWinNamedPipeClient* pipe);
  83
  84     public:
  85
  86         JackWinNamedPipeServerChannel();
  87         virtual ~JackWinNamedPipeServerChannel();
  88
  89         int Open(JackServer* server);   // Open the Server/Client connection
  90         void Close();                                   // Close the Server/Client connection
  91
  92         // JackRunnableInterface interface
  93         bool Init();
  94         bool Execute();
  95 };
  96
  97
  98 } // end of namespace
  99
 100 #endif
 101