src/sourcegroup.cpp

   1
   2 #include "sourcegroup.h"
   3
   4 #include <algorithm>
   5
   6 #include "source.h"
   7 #include "context.h"
   8
   9 namespace alure
  10 {
  11
  12 void SourceGroupImpl::insertSubGroup(SourceGroupImpl *group)
  13 {
  14     auto iter = std::lower_bound(mSubGroups.begin(), mSubGroups.end(), group);
  15     if(iter == mSubGroups.end() || *iter != group)
  16         mSubGroups.insert(iter, group);
  17 }
  18
  19 void SourceGroupImpl::eraseSubGroup(SourceGroupImpl *group)
  20 {
  21     auto iter = std::lower_bound(mSubGroups.begin(), mSubGroups.end(), group);
  22     if(iter != mSubGroups.end() && *iter == group) mSubGroups.erase(iter);
  23 }
  24
  25
  26 void SourceGroupImpl::unsetParent()
  27 {
  28     mParent = nullptr;
  29     update(1.0f, 1.0f);
  30 }
  31
  32 void SourceGroupImpl::update(ALfloat gain, ALfloat pitch)
  33 {
  34     mParentProps.mGain = gain;
  35     mParentProps.mPitch = pitch;
  36
  37     gain *= mGain;
  38     pitch *= mPitch;
  39     for(SourceImpl *alsrc : mSources)
  40         alsrc->groupPropUpdate(gain, pitch);
  41     for(SourceGroupImpl *group : mSubGroups)
  42         group->update(gain, pitch);
  43 }
  44
  45
  46 bool SourceGroupImpl::findInSubGroups(SourceGroupImpl *group) const
  47 {
  48     auto iter = std::lower_bound(mSubGroups.begin(), mSubGroups.end(), group);
  49     if(iter != mSubGroups.end() && *iter == group) return true;
  50
  51     for(SourceGroupImpl *grp : mSubGroups)
  52     {
  53         if(grp->findInSubGroups(group))
  54             return true;
  55     }
  56     return false;
  57 }
  58
  59
  60 void SourceGroupImpl::insertSource(SourceImpl *source)
  61 {
  62     auto iter = std::lower_bound(mSources.begin(), mSources.end(), source);
  63     if(iter == mSources.end() || *iter != source)
  64         mSources.insert(iter, source);
  65 }
  66
  67 void SourceGroupImpl::eraseSource(SourceImpl *source)
  68 {
  69     auto iter = std::lower_bound(mSources.begin(), mSources.end(), source);
  70     if(iter != mSources.end() && *iter == source)
  71         mSources.erase(iter);
  72 }
  73
  74
  75 DECL_THUNK1(void, SourceGroup, setParentGroup,, SourceGroup)
  76 void SourceGroupImpl::setParentGroup(SourceGroup group)
  77 {
  78     CheckContext(mContext);
  79
  80     SourceGroupImpl *parent = group.getHandle();
  81     if(!parent)
  82     {
  83         if(mParent)
  84             mParent->eraseSubGroup(this);
  85         mParent = nullptr;
  86         update(1.0f, 1.0f);
  87     }
  88     else
  89     {
  90         if(this == parent || findInSubGroups(parent))
  91             throw std::runtime_error("Attempted circular group chain");
  92
  93         parent->insertSubGroup(this);
  94
  95         Batcher batcher = mContext.getBatcher();
  96         if(mParent)
  97             mParent->eraseSubGroup(this);
  98         mParent = parent;
  99         update(mParent->getAppliedGain(), mParent->getAppliedPitch());
 100     }
 101 }
 102
 103
 104 DECL_THUNK0(Vector<Source>, SourceGroup, getSources, const)
 105 Vector<Source> SourceGroupImpl::getSources() const
 106 {
 107     Vector<Source> ret;
 108     ret.reserve(mSources.size());
 109     for(SourceImpl *src : mSources)
 110         ret.emplace_back(src);
 111     return ret;
 112 }
 113
 114 DECL_THUNK0(Vector<SourceGroup>, SourceGroup, getSubGroups, const)
 115 Vector<SourceGroup> SourceGroupImpl::getSubGroups() const
 116 {
 117     Vector<SourceGroup> ret;
 118     ret.reserve(mSubGroups.size());
 119     for(SourceGroupImpl *grp : mSubGroups)
 120         ret.emplace_back(grp);
 121     return ret;
 122 }
 123
 124
 125 DECL_THUNK1(void, SourceGroup, setGain,, ALfloat)
 126 void SourceGroupImpl::setGain(ALfloat gain)
 127 {
 128     if(!(gain >= 0.0f))
 129         throw std::out_of_range("Gain out of range");
 130     CheckContext(mContext);
 131     mGain = gain;
 132     gain *= mParentProps.mGain;
 133     ALfloat pitch = mPitch * mParentProps.mPitch;
 134     Batcher batcher = mContext.getBatcher();
 135     for(SourceImpl *alsrc : mSources)
 136         alsrc->groupPropUpdate(gain, pitch);
 137     for(SourceGroupImpl *group : mSubGroups)
 138         group->update(gain, pitch);
 139 }
 140
 141 DECL_THUNK1(void, SourceGroup, setPitch,, ALfloat)
 142 void SourceGroupImpl::setPitch(ALfloat pitch)
 143 {
 144     if(!(pitch > 0.0f))
 145         throw std::out_of_range("Pitch out of range");
 146     CheckContext(mContext);
 147     mPitch = pitch;
 148     ALfloat gain = mGain * mParentProps.mGain;
 149     pitch *= mParentProps.mPitch;
 150     Batcher batcher = mContext.getBatcher();
 151     for(SourceImpl *alsrc : mSources)
 152         alsrc->groupPropUpdate(gain, pitch);
 153     for(SourceGroupImpl *group : mSubGroups)
 154         group->update(gain, pitch);
 155 }
 156
 157
 158 void SourceGroupImpl::collectPlayingSourceIds(Vector<ALuint> &sourceids) const
 159 {
 160     for(SourceImpl *alsrc : mSources)
 161     {
 162         if(ALuint id = alsrc->getId())
 163             sourceids.push_back(id);
 164     }
 165     for(SourceGroupImpl *group : mSubGroups)
 166         group->collectPlayingSourceIds(sourceids);
 167 }
 168
 169 void SourceGroupImpl::updatePausedStatus() const
 170 {
 171     for(SourceImpl *alsrc : mSources)
 172         alsrc->checkPaused();
 173     for(SourceGroupImpl *group : mSubGroups)
 174         group->updatePausedStatus();
 175 }
 176
 177 DECL_THUNK0(void, SourceGroup, pauseAll, const)
 178 void SourceGroupImpl::pauseAll() const
 179 {
 180     CheckContext(mContext);
 181     auto lock = mContext.getSourceStreamLock();
 182
 183     Vector<ALuint> sourceids;
 184     sourceids.reserve(16);
 185     collectPlayingSourceIds(sourceids);
 186     if(!sourceids.empty())
 187     {
 188         alSourcePausev(sourceids.size(), sourceids.data());
 189         updatePausedStatus();
 190     }
 191     lock.unlock();
 192 }
 193
 194
 195 void SourceGroupImpl::collectPausedSourceIds(Vector<ALuint> &sourceids) const
 196 {
 197     for(SourceImpl *alsrc : mSources)
 198     {
 199         if(alsrc->isPaused())
 200             sourceids.push_back(alsrc->getId());
 201     }
 202     for(SourceGroupImpl *group : mSubGroups)
 203         group->collectPausedSourceIds(sourceids);
 204 }
 205
 206 void SourceGroupImpl::updatePlayingStatus() const
 207 {
 208     for(SourceImpl *alsrc : mSources)
 209         alsrc->unsetPaused();
 210     for(SourceGroupImpl *group : mSubGroups)
 211         group->updatePlayingStatus();
 212 }
 213
 214 DECL_THUNK0(void, SourceGroup, resumeAll, const)
 215 void SourceGroupImpl::resumeAll() const
 216 {
 217     CheckContext(mContext);
 218     auto lock = mContext.getSourceStreamLock();
 219
 220     Vector<ALuint> sourceids;
 221     sourceids.reserve(16);
 222     collectPausedSourceIds(sourceids);
 223     if(!sourceids.empty())
 224     {
 225         alSourcePlayv(sourceids.size(), sourceids.data());
 226         updatePlayingStatus();
 227     }
 228     lock.unlock();
 229 }
 230
 231
 232 void SourceGroupImpl::collectSourceIds(Vector<ALuint> &sourceids) const
 233 {
 234     for(SourceImpl *alsrc : mSources)
 235     {
 236         if(ALuint id = alsrc->getId())
 237             sourceids.push_back(id);
 238     }
 239     for(SourceGroupImpl *group : mSubGroups)
 240         group->collectSourceIds(sourceids);
 241 }
 242
 243 void SourceGroupImpl::updateStoppedStatus() const
 244 {
 245     for(SourceImpl *alsrc : mSources)
 246     {
 247         mContext.removePendingSource(alsrc);
 248         mContext.removeFadingSource(alsrc);
 249         mContext.removePlayingSource(alsrc);
 250         alsrc->makeStopped(false);
 251         mContext.send(&MessageHandler::sourceForceStopped, alsrc);
 252     }
 253     for(SourceGroupImpl *group : mSubGroups)
 254         group->updateStoppedStatus();
 255 }
 256
 257 DECL_THUNK0(void, SourceGroup, stopAll, const)
 258 void SourceGroupImpl::stopAll() const
 259 {
 260     CheckContext(mContext);
 261
 262     Vector<ALuint> sourceids;
 263     sourceids.reserve(16);
 264     collectSourceIds(sourceids);
 265     if(!sourceids.empty())
 266     {
 267         auto lock = mContext.getSourceStreamLock();
 268         alSourceRewindv(sourceids.size(), sourceids.data());
 269         updateStoppedStatus();
 270     }
 271 }
 272
 273
 274 void SourceGroup::release()
 275 {
 276     SourceGroupImpl *i = pImpl;
 277     pImpl = nullptr;
 278     i->release();
 279 }
 280 void SourceGroupImpl::release()
 281 {
 282     CheckContext(mContext);
 283     Batcher batcher = mContext.getBatcher();
 284     for(SourceImpl *source : mSources)
 285         source->unsetGroup();
 286     mSources.clear();
 287     for(SourceGroupImpl *group : mSubGroups)
 288         group->unsetParent();
 289     mSubGroups.clear();
 290     if(mParent)
 291         mParent->eraseSubGroup(this);
 292     mParent = nullptr;
 293
 294     mContext.freeSourceGroup(this);
 295 }
 296
 297
 298 DECL_THUNK0(SourceGroup, SourceGroup, getParentGroup, const)
 299 DECL_THUNK0(ALfloat, SourceGroup, getGain, const)
 300 DECL_THUNK0(ALfloat, SourceGroup, getPitch, const)
 301
 302 } // namespace alure