juce/source/src/events/juce_InterprocessConnectionServer.cpp

   1 /*
   2   ==============================================================================
   3
   4    This file is part of the JUCE library - "Jules' Utility Class Extensions"
   5    Copyright 2004-11 by Raw Material Software Ltd.
   6
   7   ------------------------------------------------------------------------------
   8
   9    JUCE can be redistributed and/or modified under the terms of the GNU General
  10    Public License (Version 2), as published by the Free Software Foundation.
  11    A copy of the license is included in the JUCE distribution, or can be found
  12    online at www.gnu.org/licenses.
  13
  14    JUCE is distributed in the hope that it will be useful, but WITHOUT ANY
  15    WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
  16    A PARTICULAR PURPOSE.  See the GNU General Public License for more details.
  17
  18   ------------------------------------------------------------------------------
  19
  20    To release a closed-source product which uses JUCE, commercial licenses are
  21    available: visit www.rawmaterialsoftware.com/juce for more information.
  22
  23   ==============================================================================
  24 */
  25
  26 #include "../core/juce_StandardHeader.h"
  27
  28 BEGIN_JUCE_NAMESPACE
  29
  30 #include "juce_InterprocessConnectionServer.h"
  31 #include "../memory/juce_ScopedPointer.h"
  32
  33
  34 //==============================================================================
  35 InterprocessConnectionServer::InterprocessConnectionServer()
  36     : Thread ("Juce IPC server")
  37 {
  38 }
  39
  40 InterprocessConnectionServer::~InterprocessConnectionServer()
  41 {
  42     stop();
  43 }
  44
  45 //==============================================================================
  46 bool InterprocessConnectionServer::beginWaitingForSocket (const int portNumber)
  47 {
  48     stop();
  49
  50     socket = new StreamingSocket();
  51
  52     if (socket->createListener (portNumber))
  53     {
  54         startThread();
  55         return true;
  56     }
  57
  58     socket = nullptr;
  59     return false;
  60 }
  61
  62 void InterprocessConnectionServer::stop()
  63 {
  64     signalThreadShouldExit();
  65
  66     if (socket != nullptr)
  67         socket->close();
  68
  69     stopThread (4000);
  70     socket = nullptr;
  71 }
  72
  73 void InterprocessConnectionServer::run()
  74 {
  75     while ((! threadShouldExit()) && socket != nullptr)
  76     {
  77         ScopedPointer <StreamingSocket> clientSocket (socket->waitForNextConnection());
  78
  79         if (clientSocket != nullptr)
  80         {
  81             InterprocessConnection* newConnection = createConnectionObject();
  82
  83             if (newConnection != nullptr)
  84                 newConnection->initialiseWithSocket (clientSocket.release());
  85         }
  86     }
  87 }
  88
  89
  90 END_JUCE_NAMESPACE