CommPipe_Skel.h

Go to the documentation of this file.

/*****************************************************************************
 * Copyright (C) 2011 by Benjamin Hadorn (b_hadorn@bluewin.ch)
 *****************************************************************************
 * Project    : Zeus Base Library
 * Module     : CommPipe_Skel
 * Package    : Zeus.ZeusBase.Messaging
 * Author     : Benjamin Hadorn
 * Date       : 27.12.2011
 * System     : Zeus-Framework
 *****************************************************************************
 * Licence:                                                                  *
 *   This library is free software; you can redistribute it and/or modify    *
 *   it under the terms of the GNU Lesser General Public License as          *
 *   published by the Free Software Foundation; either version               *
 *   2.1 of the License, or (at your option) any later version.              *
 *                                                                           *
 *   This library is distributed in the hope that it will be useful,         *
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of          *
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the            *
 *   GNU Lesser General Public License for more details.                     *
 *                                                                           *
 *   You should have received a copy of the GNU Lesser General Public        *
 *   License along with this library; if not, write to the Free Software     *
 *   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110, USA    *
 *****************************************************************************/

/*****************************************************************************
 * Changes:
 *  27.12.2011 bha: created zeus 2.0
 *****************************************************************************/

#ifndef CommPipe_SkelH
#define CommPipe_SkelH

#include <zeusbase/Remote/AbstractSkel.h>


BEGIN_NAMESPACE_Zeus

class TCommPipe;
class TCCTPRequest;
class TCCTPResponse;

/***************************************************************************/
/***************************************************************************/
zeusbase_class TCommPipe_Skel : public TAbstractSkel
{
  public :
    TCommPipe_Skel(TCommPipe& rInstance);
    void dispatch2(const TCCTPRequest& rRequest, TCCTPResponse& rResponse);

  protected:
    virtual ~TCommPipe_Skel();

    virtual Retval dispatchCommand(const IRemoteMethodCall& rMethod, IRemoteMethodCall*& rpMethodreturn);
    virtual void startNewHandler(TSocket& rClient);

  private:
    TCommPipe& m_rInstance;

    /**********************************************************************/
    /* This inner class manages the incomming requests of clients and
       calls the parenr dispatching method
    */
    /**********************************************************************/
    class TPipeHandlerThread : public TAbstractSkel::TClientHandlerThread
    {
      public :
        TPipeHandlerThread(TCommPipe_Skel& rParent, TSocket& rSocket);

        virtual bool signalizeStop(Float64 dTimeOut=5.0);
        virtual void execute();

      protected:
        virtual ~TPipeHandlerThread();

      private:
        TCommPipe_Skel& m_rPipeParent;
    };
};

END_NAMESPACE_Zeus


#endif