ryzom/client/src/streamable_entity_composite.cpp

   1 // Ryzom - MMORPG Framework <http://dev.ryzom.com/projects/ryzom/>
   2 // Copyright (C) 2010  Winch Gate Property Limited
   3 //
   4 // This program is free software: you can redistribute it and/or modify
   5 // it under the terms of the GNU Affero General Public License as
   6 // published by the Free Software Foundation, either version 3 of the
   7 // License, or (at your option) any later version.
   8 //
   9 // This program is distributed in the hope that it will be useful,
  10 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  11 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12 // GNU Affero General Public License for more details.
  13 //
  14 // You should have received a copy of the GNU Affero General Public License
  15 // along with this program.  If not, see <http://www.gnu.org/licenses/>.
  16
  17
  18
  19 #include "stdpch.h"
  20
  21 #include "streamable_entity_composite.h"
  22 #include "nel/misc/progress_callback.h"
  23
  24 #ifdef DEBUG_NEW
  25 #define new DEBUG_NEW
  26 #endif
  27
  28 H_AUTO_DECL(RZ_StremableEntityComposite)
  29
  30 //===============================================================================
  31 CStreamableEntityComposite::~CStreamableEntityComposite()
  32 {
  33         H_AUTO_USE(RZ_StremableEntityComposite)
  34         for(TStreambleEntities::iterator it = _Entities.begin(); it != _Entities.end(); ++it)
  35         {
  36                 delete *it;
  37         }
  38 }
  39
  40 //===============================================================================
  41 void CStreamableEntityComposite::add(IStreamableEntity *entity)
  42 {
  43         H_AUTO_USE(RZ_StremableEntityComposite)
  44         nlassert (entity);
  45         nlassert(std::find(_Entities.begin(), _Entities.end(), entity) == _Entities.end());
  46         _Entities.push_back(entity);
  47 }
  48
  49 //===============================================================================
  50 void CStreamableEntityComposite::remove(IStreamableEntity *entity)
  51 {
  52         H_AUTO_USE(RZ_StremableEntityComposite)
  53         TStreambleEntities::iterator it = std::find(_Entities.begin(), _Entities.end(), entity);
  54         nlassert(it != _Entities.end());
  55         _Entities.erase(it);
  56         delete entity;
  57 }
  58
  59 //===============================================================================
  60 /*virtual*/ bool CStreamableEntityComposite::needCompleteLoading(const NLMISC::CVector &pos) const
  61 {
  62         H_AUTO_USE(RZ_StremableEntityComposite)
  63         for(TStreambleEntities::const_iterator it = _Entities.begin(); it != _Entities.end(); ++it)
  64         {
  65                 if ((*it)->needCompleteLoading(pos)) return true;
  66         }
  67         return false;
  68 }
  69
  70 //===============================================================================
  71 /*virtual*/ void CStreamableEntityComposite::update(const NLMISC::CVector &pos)
  72 {
  73         H_AUTO_USE(RZ_StremableEntityComposite)
  74         for(TStreambleEntities::iterator it = _Entities.begin(); it != _Entities.end(); ++it)
  75         {
  76                 (*it)->update(pos);
  77         }
  78 }
  79
  80 //===============================================================================
  81 /*virtual*/ void CStreamableEntityComposite::forceUpdate(const NLMISC::CVector &pos, NLMISC::IProgressCallback &progress)
  82 {
  83         H_AUTO_USE(RZ_StremableEntityComposite)
  84         const uint size = (uint)_Entities.size();
  85         uint count = 0;
  86         for(TStreambleEntities::iterator it = _Entities.begin(); it != _Entities.end(); ++it)
  87         {
  88                 // Progress
  89                 progress.progress((float)count/(float)size);
  90                 progress.pushCropedValues((float)count/(float)size, (float)(count+1)/(float)size);
  91
  92                 (*it)->forceUpdate(pos, progress);
  93                 count++;
  94
  95                 progress.popCropedValues();
  96         }
  97 }
  98
  99 //===============================================================================
 100 void CStreamableEntityComposite::reserve(uint size)
 101 {
 102         H_AUTO_USE(RZ_StremableEntityComposite)
 103         _Entities.reserve(size);
 104 }
 105
 106 //===============================================================================
 107 void CStreamableEntityComposite::removeAll()
 108 {
 109         H_AUTO_USE(RZ_StremableEntityComposite)
 110         for(TStreambleEntities::iterator it = _Entities.begin(); it != _Entities.end(); ++it)
 111         {
 112                 delete *it;
 113         }
 114         NLMISC::contReset(_Entities);
 115 }
 116
 117
 118 //===============================================================================
 119 void CStreamableEntityComposite::forceUnload()
 120 {
 121         H_AUTO_USE(RZ_StremableEntityComposite)
 122         for(TStreambleEntities::iterator it = _Entities.begin(); it != _Entities.end(); ++it)
 123         {
 124                 (*it)->forceUnload();
 125         }
 126 }
 127
 128