Source/Base/Network/Socket/OSGPointSockPipeline.h

   1 /*---------------------------------------------------------------------------*\
   2  *                                OpenSG                                     *
   3  *                                                                           *
   4  *                                                                           *
   5  *             Copyright (C) 2000-2002 by the OpenSG Forum                   *
   6  *                                                                           *
   7  *                            www.opensg.org                                 *
   8  *                                                                           *
   9  *   contact: dirk@opensg.org, gerrit.voss@vossg.org, jbehr@zgdv.de          *
  10  *                                                                           *
  11 \*---------------------------------------------------------------------------*/
  12 /*---------------------------------------------------------------------------*\
  13  *                                License                                    *
  14  *                                                                           *
  15  * This library is free software; you can redistribute it and/or modify it   *
  16  * under the terms of the GNU Library General Public License as published    *
  17  * by the Free Software Foundation, version 2.                               *
  18  *                                                                           *
  19  * This library is distributed in the hope that it will be useful, but       *
  20  * WITHOUT ANY WARRANTY; without even the implied warranty of                *
  21  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU         *
  22  * Library General Public License for more details.                          *
  23  *                                                                           *
  24  * You should have received a copy of the GNU Library General Public         *
  25  * License along with this library; if not, write to the Free Software       *
  26  * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.                 *
  27  *                                                                           *
  28 \*---------------------------------------------------------------------------*/
  29 /*---------------------------------------------------------------------------*\
  30  *                                Changes                                    *
  31  *                                                                           *
  32  *                                                                           *
  33  *                                                                           *
  34  *                                                                           *
  35  *                                                                           *
  36  *                                                                           *
  37 \*---------------------------------------------------------------------------*/
  38
  39
  40 #ifndef _POINTSOCKPIPELINE_H_
  41 #define _POINTSOCKPIPELINE_H_
  42 #ifdef __sgi
  43 #pragma once
  44 #endif
  45
  46 //---------------------------------------------------------------------------
  47 //  Includes
  48 //---------------------------------------------------------------------------
  49
  50 #include <string>
  51 #include <map>
  52
  53 #include "OSGBaseDef.h"
  54 #include "OSGBaseTypes.h"
  55 #include "OSGPointSockConnection.h"
  56 #include "OSGTime.h"
  57 #include "OSGDgramSocket.h"
  58 #include "OSGDgram.h"
  59 #include "OSGDgramQueue.h"
  60
  61 OSG_BEGIN_NAMESPACE
  62
  63 /*! \ingroup GrpBaseNetwork
  64     \ingroup GrpBaseNetworkSockets
  65     \ingroup GrpLibOSGBase
  66 */
  67
  68 class OSG_BASE_DLLMAPPING PointSockPipeline : public PointSockConnection
  69 {
  70     /*==========================  PUBLIC  =================================*/
  71   public:
  72
  73     /*---------------------------------------------------------------------*/
  74     /*! \name                   Constructors                               */
  75     /*! \{                                                                 */
  76
  77              PointSockPipeline ( void );
  78     virtual ~PointSockPipeline ( void );
  79
  80     /*! \}                                                                 */
  81     /*---------------------------------------------------------------------*/
  82     /*! \name                   type info                                  */
  83     /*! \{                                                                 */
  84
  85     virtual const ConnectionType *getType (void);
  86
  87     /*! \}                                                                 */
  88     /*---------------------------------------------------------------------*/
  89     /*! \name                   connection                                 */
  90     /*! \{                                                                 */
  91
  92     virtual Channel     connectGroup(const std::string &address,
  93                                            Time        timeout=-1 );
  94     virtual void        disconnect  (      void                   );
  95     virtual Channel     acceptGroup (      Time        timeout=-1 );
  96
  97     /*! \}                                                                 */
  98     /*---------------------------------------------------------------------*/
  99     /*! \name                   channel handling                           */
 100     /*! \{                                                                 */
 101
 102     virtual Channel selectChannel (Time timeout=-1) OSG_THROW (ReadError);
 103
 104     /*! \}                                                                 */
 105     /*---------------------------------------------------------------------*/
 106     /*! \name                   create                                     */
 107     /*! \{                                                                 */
 108
 109     static PointConnection *create(void);
 110
 111     /*! \}                                                                 */
 112
 113     /*=========================  PROTECTED  ===============================*/
 114   protected:
 115
 116     /*---------------------------------------------------------------------*/
 117     /*! \name                   IO Implementation                          */
 118     /*! \{                                                                 */
 119
 120     virtual void read             (MemoryHandle mem, UInt32 size);
 121     virtual void readBuffer       (void) OSG_THROW (ReadError);
 122
 123     /*! \}                                                                 */
 124     /*---------------------------------------------------------------------*/
 125     /*! \name                   members                                    */
 126     /*! \{                                                                 */
 127
 128     StreamSocket                   _next;
 129     StreamSocket                   _prev;
 130     bool                           _last;
 131     bool                           _initialized;
 132
 133     /*! \}                                                                 */
 134
 135     /*==========================  PRIVATE  ================================*/
 136   private:
 137
 138     /*---------------------------------------------------------------------*/
 139     /*! \name               private helpers                                */
 140     /*! \{                                                                 */
 141
 142     void initialize(void);
 143
 144     /*! \}                                                                 */
 145     /*---------------------------------------------------------------------*/
 146     /*! \name                   static type                                */
 147     /*! \{                                                                 */
 148
 149     static ConnectionType _type;
 150
 151     /*! \}                                                                 */
 152
 153     typedef PointSockConnection Inherited;
 154
 155         // prohibit default functions (move to 'public' if you need one)
 156     PointSockPipeline(const PointSockPipeline &source);
 157     PointSockPipeline& operator =(const PointSockPipeline &source);
 158 };
 159
 160 //---------------------------------------------------------------------------
 161 //   Exported Types
 162 //---------------------------------------------------------------------------
 163
 164 // class pointer
 165
 166 typedef PointSockPipeline *PointSockPipelineP;
 167
 168 OSG_END_NAMESPACE
 169
 170 #endif /* _GROUPSOCKPIPELINE_H_ */