Source/Contrib/ComplexSceneManager/OSGCSMDrawManager.cpp

   1 /*---------------------------------------------------------------------------*\
   2  *                                OpenSG                                     *
   3  *                                                                           *
   4  *                                                                           *
   5  *               Copyright (C) 2000-2006 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 //  Includes
  41 //---------------------------------------------------------------------------
  42
  43 #include <cstdlib>
  44 #include <cstdio>
  45
  46 #include "OSGConfig.h"
  47
  48 #include "OSGCSMDrawManager.h"
  49 #include "OSGNameAttachment.h"
  50 #include "OSGCSMNativeWindow.h"
  51
  52 OSG_BEGIN_NAMESPACE
  53
  54 // Documentation for this class is emitted in the
  55 // OSGCSMDrawManagerBase.cpp file.
  56 // To modify it, please change the .fcd file (OSGCSMDrawManager.fcd) and
  57 // regenerate the base file.
  58
  59 /***************************************************************************\
  60  *                           Class variables                               *
  61 \***************************************************************************/
  62
  63 /***************************************************************************\
  64  *                           Class methods                                 *
  65 \***************************************************************************/
  66
  67 void CSMDrawManager::initMethod(InitPhase ePhase)
  68 {
  69     Inherited::initMethod(ePhase);
  70
  71     if(ePhase == TypeObject::SystemPost)
  72     {
  73     }
  74 }
  75
  76
  77 /***************************************************************************\
  78  *                           Instance methods                              *
  79 \***************************************************************************/
  80
  81 /*-------------------------------------------------------------------------*\
  82  -  private                                                                 -
  83 \*-------------------------------------------------------------------------*/
  84
  85 /*----------------------- constructors & destructors ----------------------*/
  86
  87 CSMDrawManager::CSMDrawManager(void) :
  88      Inherited   (    ),
  89
  90     _pThread     (NULL),
  91     _pSyncBarrier(NULL),
  92     _pSwapBarrier(NULL),
  93 #ifdef OSG_GLOBAL_SYNC_LOCK
  94     _pSyncLock   (NULL),
  95 #endif
  96     _uiSyncCount (0   )
  97 {
  98 }
  99
 100 CSMDrawManager::CSMDrawManager(const CSMDrawManager &source) :
 101     Inherited    (source),
 102
 103     _pThread     (NULL  ),
 104     _pSyncBarrier(NULL  ),
 105     _pSwapBarrier(NULL  ),
 106 #ifdef OSG_GLOBAL_SYNC_LOCK
 107     _pSyncLock   (NULL  ),
 108 #endif
 109     _uiSyncCount (0     )
 110 {
 111 }
 112
 113 CSMDrawManager::~CSMDrawManager(void)
 114 {
 115 }
 116
 117 /*----------------------------- class specific ----------------------------*/
 118
 119 void CSMDrawManager::changed(ConstFieldMaskArg whichField,
 120                              UInt32            origin,
 121                              BitVector         details)
 122 {
 123     Inherited::changed(whichField, origin, details);
 124 }
 125
 126 void CSMDrawManager::dump(      UInt32    ,
 127                           const BitVector ) const
 128 {
 129     SLOG << "Dump CSMDrawManager NI" << std::endl;
 130 }
 131
 132 bool CSMDrawManager::init(void)
 133 {
 134     bool returnValue = true;
 135
 136     if(_sfParallel.getValue() == true)
 137     {
 138         CSMNativeWindow::initWindowSystemThreading();
 139     }
 140
 141     if(_sfAppDrawer.getValue() != NULL)
 142     {
 143         returnValue = _sfAppDrawer.getValue()->init();
 144     }
 145
 146     MFUnrecCSMDrawerPtr::const_iterator dIt  = getMFDrawer()->begin();
 147     MFUnrecCSMDrawerPtr::const_iterator dEnd = getMFDrawer()->end  ();
 148
 149     if(_sfParallel.getValue() == true)
 150     {
 151         _pThread   = dynamic_cast<OSG::Thread *>(Thread::getCurrent());
 152
 153 #ifdef OSG_GLOBAL_SYNC_LOCK
 154         _pSyncLock = Lock::get("DM::synclock", false);
 155 #endif
 156
 157         _pSyncBarrier = Barrier::get(_sfSyncBarrierName.getValue().c_str(),
 158                                      false);
 159
 160         if(_sfSwapBarrierName.getValue().empty() == false)
 161         {
 162             _pSwapBarrier = Barrier::get(_sfSwapBarrierName.getValue().c_str(),
 163                                          false);
 164         }
 165
 166         OSG_ASSERT(_pSyncBarrier != NULL);
 167         OSG_ASSERT(_pThread      != NULL);
 168 #ifdef OSG_GLOBAL_SYNC_LOCK
 169         OSG_ASSERT(_pSyncLock    != NULL);
 170 #endif
 171
 172         _uiSyncCount = _mfDrawer.size32() + 1;
 173
 174         while(dIt != dEnd)
 175         {
 176             (*dIt)->setParallel      ( true             );
 177
 178             (*dIt)->setSyncBarrier   (_pSyncBarrier     );
 179             (*dIt)->setSwapBarrier   (_pSwapBarrier     );
 180 #ifdef OSG_GLOBAL_SYNC_LOCK
 181             (*dIt)->setSyncLock      (_pSyncLock        );
 182 #endif
 183
 184             (*dIt)->setSyncCount     (_uiSyncCount      );
 185             (*dIt)->setSyncFromThread(_pThread          );
 186
 187             (*dIt)->setSwapCount     (_mfDrawer.size32());
 188             (*dIt)->init();
 189
 190             ++dIt;
 191         }
 192     }
 193     else
 194     {
 195         while(dIt != dEnd)
 196         {
 197             returnValue = (*dIt)->init();
 198
 199             if(returnValue == false)
 200                 break;
 201
 202             ++dIt;
 203         }
 204     }
 205
 206     return returnValue;
 207 }
 208
 209 void CSMDrawManager::shutdown(void)
 210 {
 211     if(_sfAppDrawer.getValue() != NULL)
 212     {
 213         _sfAppDrawer.getValue()->shutdown();
 214     }
 215
 216     if(_sfParallel.getValue() == true)
 217     {
 218         MFUnrecCSMDrawerPtr::const_iterator dIt  = getMFDrawer()->begin();
 219         MFUnrecCSMDrawerPtr::const_iterator dEnd = getMFDrawer()->end  ();
 220
 221
 222         // Stop drawer
 223
 224         commitChanges();
 225
 226         _pSyncBarrier->enter(_uiSyncCount);
 227         _pSyncBarrier->enter(_uiSyncCount);
 228
 229         while(dIt != dEnd)
 230         {
 231             (*dIt)->endDrawThread();
 232
 233             ++dIt;
 234         }
 235
 236         _pSyncBarrier->enter(_uiSyncCount);
 237         _pSyncBarrier->enter(_uiSyncCount);
 238
 239         _pThread->getChangeList()->clear();
 240
 241
 242         // resolve structure
 243
 244         dIt  = getMFDrawer()->begin();
 245
 246         while(dIt != dEnd)
 247         {
 248             (*dIt)->shutdown();
 249
 250             ++dIt;
 251         }
 252
 253         AttachmentContainer::resolveLinks();
 254
 255         if(_sfAppDrawer.getValue() != NULL)
 256         {
 257             _sfAppDrawer.getValue()->terminateGLContexts();
 258         }
 259
 260         // sync structure takedown
 261
 262         commitChanges();
 263
 264         _pSyncBarrier->enter(_uiSyncCount);
 265         _pSyncBarrier->enter(_uiSyncCount);
 266
 267         _pThread->getChangeList()->clear();
 268
 269
 270         // release gl contexts
 271
 272         dIt  = getMFDrawer()->begin();
 273
 274         while(dIt != dEnd)
 275         {
 276             (*dIt)->terminateGLContexts();
 277
 278             ++dIt;
 279         }
 280
 281         // sync gl takedown
 282
 283         commitChanges();
 284
 285         _pSyncBarrier->enter(_uiSyncCount);
 286         _pSyncBarrier->enter(_uiSyncCount);
 287
 288         _pThread->getChangeList()->clear();
 289
 290
 291         // release windows
 292
 293         if(_sfAppDrawer.getValue() != NULL)
 294         {
 295             _sfAppDrawer.getValue()->resolveLinks();
 296         }
 297
 298         dIt  = getMFDrawer()->begin();
 299
 300         while(dIt != dEnd)
 301         {
 302             (*dIt)->resolveLinks();
 303
 304             ++dIt;
 305         }
 306
 307         commitChanges();
 308
 309         _pSyncBarrier->enter(_uiSyncCount);
 310         _pSyncBarrier->enter(_uiSyncCount);
 311
 312         _pThread->getChangeList()->clear();
 313
 314
 315         // wait for draw threads to finish
 316
 317         dIt  = getMFDrawer()->begin();
 318
 319         while(dIt != dEnd)
 320         {
 321             (*dIt)->joinDrawThread();
 322
 323             ++dIt;
 324         }
 325
 326         dIt  = getMFDrawer()->begin();
 327
 328         while(dIt != dEnd)
 329         {
 330             (*dIt)->setSyncBarrier   (NULL);
 331             (*dIt)->setSwapBarrier   (NULL);
 332
 333 #ifdef OSG_GLOBAL_SYNC_LOCK
 334             (*dIt)->setSyncLock      (NULL);
 335 #endif
 336
 337             (*dIt)->setSyncFromThread(NULL);
 338
 339             ++dIt;
 340         }
 341
 342         _pThread      = NULL;
 343         _pSyncBarrier = NULL;
 344         _pSwapBarrier = NULL;
 345
 346 #ifdef OSG_GLOBAL_SYNC_LOCK
 347         _pSyncLock    = NULL;
 348 #endif
 349     }
 350     else
 351     {
 352         MFUnrecCSMDrawerPtr::const_iterator dIt  = getMFDrawer()->begin();
 353         MFUnrecCSMDrawerPtr::const_iterator dEnd = getMFDrawer()->end  ();
 354
 355         for(; dIt != dEnd; ++dIt)
 356         {
 357             (*dIt)->shutdown();
 358         }
 359
 360         commitChanges();
 361
 362         AttachmentContainer::resolveLinks();
 363
 364         if(_sfAppDrawer.getValue() != NULL)
 365         {
 366             _sfAppDrawer.getValue()->terminateGLContexts();
 367         }
 368
 369         dIt  = getMFDrawer()->begin();
 370
 371         while(dIt != dEnd)
 372         {
 373             (*dIt)->terminateGLContexts();
 374
 375             ++dIt;
 376         }
 377
 378         commitChanges();
 379     }
 380 }
 381
 382 void CSMDrawManager::frame(Time oTime, UInt32 uiFrame)
 383 {
 384     commitChanges();
 385
 386     if(_sfParallel.getValue() == true)
 387     {
 388         _pSyncBarrier->enter(_uiSyncCount);
 389
 390          this->syncProducers(uiFrame);
 391
 392         _pSyncBarrier->enter(_uiSyncCount);
 393         _pSyncBarrier->enter(_uiSyncCount);
 394
 395         MFUnrecCSMDrawerPtr::const_iterator drawerIt  = getMFDrawer()->begin();
 396         MFUnrecCSMDrawerPtr::const_iterator drawerEnd = getMFDrawer()->end  ();
 397
 398         for(; drawerIt != drawerEnd; ++drawerIt)
 399         {
 400             (*drawerIt)->postSync();
 401         }
 402
 403         _pThread->getChangeList()->clear();
 404
 405         if(_sfAppDrawer.getValue() != NULL)
 406         {
 407             _sfAppDrawer.getValue()->frame(oTime, uiFrame);
 408         }
 409     }
 410     else
 411     {
 412         this->syncProducers(uiFrame);
 413
 414         if(_sfAppDrawer.getValue() != NULL)
 415         {
 416             _sfAppDrawer.getValue()->frame(oTime, uiFrame);
 417         }
 418
 419         MFUnrecCSMDrawerPtr::const_iterator drawerIt  = getMFDrawer()->begin();
 420         MFUnrecCSMDrawerPtr::const_iterator drawerEnd = getMFDrawer()->end  ();
 421
 422         for(; drawerIt != drawerEnd; ++drawerIt)
 423         {
 424             (*drawerIt)->frame(oTime, uiFrame);
 425         }
 426     }
 427 }
 428
 429 FieldContainer *CSMDrawManager::findNamedComponent(const Char8 *szName)
 430 {
 431     MFUnrecCSMDrawerPtr::const_iterator drawerIt  = _mfDrawer.begin();
 432     MFUnrecCSMDrawerPtr::const_iterator drawerEnd = _mfDrawer.end  ();
 433
 434     const Char8               *szTmpName   = NULL;
 435
 436     if(_sfAppDrawer.getValue() != NULL)
 437     {
 438         szTmpName = OSG::getName(_sfAppDrawer.getValue());
 439
 440         if(szTmpName != NULL && osgStringCmp(szTmpName, szName) == 0)
 441         {
 442             return _sfAppDrawer.getValue();
 443         }
 444         else
 445         {
 446             FieldContainer *tmpVal =
 447                 _sfAppDrawer.getValue()->findNamedComponent(szName);
 448
 449             if(tmpVal != NULL)
 450                 return tmpVal;
 451         }
 452     }
 453
 454     while(drawerIt != drawerEnd)
 455     {
 456         szTmpName = OSG::getName(*drawerIt);
 457
 458         if(szTmpName != NULL && osgStringCmp(szTmpName, szName) == 0)
 459         {
 460             return *drawerIt;
 461         }
 462         else
 463         {
 464             FieldContainer *tmpVal = (*drawerIt)->findNamedComponent(szName);
 465
 466             if(tmpVal != NULL)
 467                 return tmpVal;
 468         }
 469
 470         ++drawerIt;
 471     }
 472
 473     return NULL;
 474 }
 475
 476 OSG_END_NAMESPACE