00001 /*---------------------------------------------------------------------------*\ 00002 * OpenSG * 00003 * * 00004 * * 00005 * Copyright (C) 2000-2002 by the OpenSG Forum * 00006 * * 00007 * www.opensg.org * 00008 * * 00009 * contact: dirk@opensg.org, gerrit.voss@vossg.org, jbehr@zgdv.de * 00010 * * 00011 \*---------------------------------------------------------------------------*/ 00012 /*---------------------------------------------------------------------------*\ 00013 * License * 00014 * * 00015 * This library is free software; you can redistribute it and/or modify it * 00016 * under the terms of the GNU Library General Public License as published * 00017 * by the Free Software Foundation, version 2. * 00018 * * 00019 * This library is distributed in the hope that it will be useful, but * 00020 * WITHOUT ANY WARRANTY; without even the implied warranty of * 00021 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * 00022 * Library General Public License for more details. * 00023 * * 00024 * You should have received a copy of the GNU Library General Public * 00025 * License along with this library; if not, write to the Free Software * 00026 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. * 00027 * * 00028 \*---------------------------------------------------------------------------*/ 00029 /*---------------------------------------------------------------------------*\ 00030 * Changes * 00031 * * 00032 * * 00033 * * 00034 * * 00035 * * 00036 * * 00037 \*---------------------------------------------------------------------------*/ 00038 00039 #ifndef _DGRAMQUEUE_H_ 00040 #define _DGRAMQUEUE_H_ 00041 #ifdef __sgi 00042 #pragma once 00043 #endif 00044 00045 #include <list> 00046 00047 #include <OSGBaseTypes.h> 00048 #include <OSGTime.h> 00049 #include <OSGBase.h> 00050 #include <OSGConnection.h> 00051 #include <OSGDgramSocket.h> 00052 #include <OSGSocketAddress.h> 00053 #include <OSGConnectionType.h> 00054 #include <OSGDgram.h> 00055 00056 OSG_BEGIN_NAMESPACE 00057 00058 class BaseThread; 00059 00060 class OSG_BASE_DLLMAPPING DgramQueue 00061 { 00062 /*========================== PUBLIC =================================*/ 00063 public: 00064 00065 typedef std::list<Dgram*> QueueT; 00066 00067 /*---------------------------------------------------------------------*/ 00071 DgramQueue(); 00072 00074 /*---------------------------------------------------------------------*/ 00078 virtual ~DgramQueue(); 00079 00081 /*---------------------------------------------------------------------*/ 00085 void put ( Dgram *dgram ); 00086 Dgram *get ( Lock *lock ); 00087 bool empty ( void ); 00088 void wait ( Lock *lock ); 00089 bool waiting ( void ); 00090 00092 /*========================= PROTECTED ===============================*/ 00093 protected: 00094 00095 /*---------------------------------------------------------------------*/ 00099 Barrier *_barrier; 00100 QueueT _queue; 00101 bool _waiting; 00102 00104 /*========================== PRIVATE ================================*/ 00105 private: 00106 00108 DgramQueue(const DgramQueue &source); 00109 void operator =(const DgramQueue &source); 00110 }; 00111 00112 // class pointer 00113 typedef DgramQueue *DgramQueueP; 00114 00115 OSG_END_NAMESPACE 00116 00117 #define OSG_DGRAMQUEUEHEADER_CVSID "@(#)$Id:$" 00118 00119 #endif /* _DGRAMQUEUE_H_ */
1.4.3