Source/Base/FieldContainer/Threading/OSGHardwareContextTask.cpp

   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 #include <cstdlib>
  40 #include <cstdio>
  41
  42 #include "OSGConfig.h"
  43
  44 #include "OSGHardwareContextTask.h"
  45 #include "OSGFieldContainer.h"
  46
  47 #include "OSGMField.ins"
  48
  49 OSG_BEGIN_NAMESPACE
  50
  51 /*! \class OSG::HardwareContextTask
  52     \ingroup GrpSystemRenderingBackend
  53  */
  54
  55 /*-------------------------------------------------------------------------*/
  56 /*                            Constructors                                 */
  57
  58 HardwareContextTask::HardwareContextTask(UInt32 uiTaskType) :
  59      Inherited (          ),
  60     _uiTypeTask(uiTaskType)
  61 {
  62 }
  63
  64 /*-------------------------------------------------------------------------*/
  65 /*                             Destructor                                  */
  66
  67 HardwareContextTask::~HardwareContextTask(void)
  68 {
  69 }
  70
  71
  72 //virtual void execute(DrawEnv *pEnv);
  73
  74 /*! \class OSG::BlockingTask
  75     \ingroup GrpSystemRenderingBackend
  76  */
  77
  78 /*-------------------------------------------------------------------------*/
  79 /*                            Constructors                                 */
  80
  81 BlockingTask::BlockingTask(UInt32 uiTaskType) :
  82      Inherited     (uiTaskType),
  83     _bBarrierActive(false     ),
  84     _pBarrier      (NULL      )
  85 {
  86 }
  87
  88 /*-------------------------------------------------------------------------*/
  89 /*                             Destructor                                  */
  90
  91 BlockingTask::~BlockingTask(void)
  92 {
  93     _pBarrier = NULL;
  94 }
  95
  96 void BlockingTask::activateBarrier(bool bVal)
  97 {
  98     _bBarrierActive = bVal;
  99
 100     if(_bBarrierActive == true && _pBarrier == NULL)
 101     {
 102         _pBarrier = Barrier::get(NULL, false);
 103         _pBarrier->setNumWaitFor(2);
 104     }
 105 }
 106
 107 void BlockingTask::setNumWaitFor(UInt32 uiWaitees)
 108 {
 109     if(_pBarrier != NULL && uiWaitees != 0)
 110     {
 111         _pBarrier->setNumWaitFor(uiWaitees);
 112     }
 113 }
 114
 115 void BlockingTask::waitForBarrier(void)
 116 {
 117     if(_bBarrierActive == false)
 118     {
 119         return;
 120     }
 121
 122     OSG_ASSERT(_pBarrier != NULL);
 123
 124     _pBarrier->enter();
 125 }
 126
 127
 128 /*! \class OSG::CallbackTask
 129     \ingroup GrpSystemRenderingBackend
 130  */
 131
 132 CallbackTask::CallbackTask(UInt32 uiType) :
 133      Inherited(uiType),
 134     _fCallback(      )
 135 {
 136 }
 137
 138 CallbackTask::CallbackTask(const CallbackFunctor &fCallback,
 139                                  UInt32            uiType  ) :
 140      Inherited (uiType   ),
 141     _fCallback (fCallback)
 142 {
 143 }
 144
 145 CallbackTask::~CallbackTask(void)
 146 {
 147 }
 148
 149 void CallbackTask::execute(HardwareContext *pContext, DrawEnv *pEnv)
 150 {
 151     OSG_ASSERT(_fCallback      );
 152
 153     switch(_uiTypeTask)
 154     {
 155         case Callback:
 156         {
 157             _fCallback(pContext, pEnv);
 158
 159             if(_bBarrierActive == true)
 160                 _pBarrier->enter();
 161         }
 162         break;
 163
 164         default:
 165             break;
 166     }
 167 }
 168
 169 void CallbackTask::setCallback(const CallbackFunctor &fCallback)
 170 {
 171     _fCallback = fCallback;
 172 }
 173
 174
 175 void CallbackTask::dump(UInt32 uiIndent)
 176 {
 177     for(UInt32 i = 0; i < uiIndent; ++i) { fprintf(stderr, " "); }
 178     fprintf(stderr, "CallbackTask : ");
 179
 180     switch(_uiTypeTask)
 181     {
 182         case Callback:
 183         {
 184             fprintf(stderr, "Callback, barrier active : %d\n",
 185                     UInt32(_bBarrierActive));
 186         }
 187         break;
 188
 189         default:
 190         {
 191             fprintf(stderr, "Unknown\n");
 192         }
 193         break;
 194     }
 195
 196 }
 197
 198
 199
 200 /*! \class OSG::HardwareContextTask
 201     \ingroup GrpSystemRenderingBackend
 202  */
 203
 204 /*-------------------------------------------------------------------------*/
 205 /*                            Constructors                                 */
 206
 207 HardwareContextTaskQueue::HardwareContextTaskQueue(void) :
 208     _qTaskStore(    ),
 209     _pStoreLock(NULL),
 210     _pStoreSema(NULL)
 211 {
 212     _pStoreLock = Lock     ::get(NULL, false);
 213     _pStoreSema = Semaphore::get(NULL, false);
 214 }
 215
 216 /*-------------------------------------------------------------------------*/
 217 /*                             Destructor                                  */
 218
 219 HardwareContextTaskQueue::~HardwareContextTaskQueue(void)
 220 {
 221     _qTaskStore.clear();
 222
 223     _pStoreLock = NULL;
 224     _pStoreSema = NULL;
 225 }
 226
 227 void HardwareContextTaskQueue::queueTask(HardwareContextTask *pTask)
 228 {
 229     if(pTask != NULL)
 230     {
 231         _pStoreLock->acquire();
 232
 233         _qTaskStore.push_back(pTask);
 234
 235         _pStoreLock->release();
 236
 237         _pStoreSema->post();
 238     }
 239
 240
 241 }
 242
 243 void HardwareContextTaskQueue::queueTaskFront(HardwareContextTask *pTask)
 244 {
 245     if(pTask != NULL)
 246     {
 247         _pStoreLock->acquire();
 248
 249         _qTaskStore.push_front(pTask);
 250
 251         _pStoreLock->release();
 252
 253         _pStoreSema->post();
 254     }
 255
 256
 257 }
 258
 259 HardwareContextTaskTransitPtr HardwareContextTaskQueue::popTask(void)
 260 {
 261     _pStoreSema->wait();
 262
 263     _pStoreLock->acquire();
 264
 265     OSG_ASSERT(_qTaskStore.size() != 0);
 266
 267     HardwareContextTaskTransitPtr returnValue(_qTaskStore.front());
 268
 269     _qTaskStore.pop_front();
 270
 271     _pStoreLock->release();
 272
 273     return returnValue;
 274 }
 275
 276 void HardwareContextTaskQueue::dumpQueue(void)
 277 {
 278     TaskStore::const_iterator qIt  = _qTaskStore.begin();
 279     TaskStore::const_iterator qEnd = _qTaskStore.end  ();
 280
 281     fprintf(stderr, "Dumping task queue\n");
 282     fprintf(stderr, "------------------\n");
 283
 284     for(; qIt != qEnd; ++qIt)
 285     {
 286         (*qIt)->dump(4);
 287     }
 288 }
 289
 290 void HardwareContextTaskQueue::runAndClearQueue(HardwareContext *pContext,
 291                                                 DrawEnv         *pEnv    )
 292 {
 293     TaskStore::const_iterator qIt  = _qTaskStore.begin();
 294     TaskStore::const_iterator qEnd = _qTaskStore.end  ();
 295
 296     for(; qIt != qEnd; ++qIt)
 297     {
 298         (*qIt)->execute(pContext, pEnv);
 299     }
 300
 301     _qTaskStore.clear();
 302 }
 303
 304 DataType FieldTraits<
 305              HardwareContextTaskRefPtr>::_type("HardwareContextTaskRefPtr",
 306                                                NULL);
 307
 308 OSG_FIELDTRAITS_GETTYPE(HardwareContextTaskRefPtr)
 309
 310 OSG_FIELD_DLLEXPORT_DEF1(MField, HardwareContextTaskRefPtr)
 311
 312
 313 OSG_END_NAMESPACE
 314
 315