kc3-lang/angle/src/libANGLE/Observer.cpp

• Show log

  Commit

• Hash : 956ab4d9
  Author :
  Date : 2018-10-10T16:13:03
  

  Optimize several functions for the Program perf test.
  
  This gives the same or slightly better performance in the ProgramDraw
  perf test. Also only set the Program object as dirty when there are
  dirty bits set in the Program itself.
  
  Bug: angleproject:2877
  Change-Id: I07b428b40d3e3c24e0a42c970524756b6dc3a30e
  Reviewed-on: https://chromium-review.googlesource.com/c/1271475
  Reviewed-by: Geoff Lang <geofflang@chromium.org>
  Commit-Queue: Jamie Madill <jmadill@chromium.org>
  

Download

• src/libANGLE/Observer.cpp

• //
  // Copyright 2018 The ANGLE Project Authors. All rights reserved.
  // Use of this source code is governed by a BSD-style license that can be
  // found in the LICENSE file.
  //
  // Observer:
  //   Implements the Observer pattern for sending state change notifications
  //   from Subject objects to dependent Observer objects.
  //
  //   See design document:
  //   https://docs.google.com/document/d/15Edfotqg6_l1skTEL8ADQudF_oIdNa7i8Po43k6jMd4/
  
  #include "libANGLE/Observer.h"
  
  #include <algorithm>
  
  #include "common/debug.h"
  
  namespace angle
  {
  namespace
  {
  template <typename HaystackT, typename NeedleT>
  bool IsInContainer(const HaystackT &haystack, const NeedleT &needle)
  {
      return std::find(haystack.begin(), haystack.end(), needle) != haystack.end();
  }
  }  // anonymous namespace
  
  // Observer implementation.
  ObserverInterface::~ObserverInterface() = default;
  
  // Subject implementation.
  Subject::Subject()
  {
  }
  
  Subject::~Subject()
  {
      resetObservers();
  }
  
  bool Subject::hasObservers() const
  {
      return !mObservers.empty();
  }
  
  ANGLE_INLINE void Subject::addObserver(ObserverBinding *observer)
  {
      ASSERT(!IsInContainer(mObservers, observer));
      mObservers.push_back(observer);
  }
  
  ANGLE_INLINE void Subject::removeObserver(ObserverBinding *observer)
  {
      ASSERT(IsInContainer(mObservers, observer));
      size_t len = mObservers.size() - 1;
      for (size_t index = 0; index < len; ++index)
      {
          if (mObservers[index] == observer)
          {
              mObservers[index] = mObservers[len];
              break;
          }
      }
      mObservers.pop_back();
  }
  
  void Subject::onStateChange(const gl::Context *context, SubjectMessage message) const
  {
      if (mObservers.empty())
          return;
  
      for (const angle::ObserverBinding *receiver : mObservers)
      {
          receiver->onStateChange(context, message);
      }
  }
  
  void Subject::resetObservers()
  {
      for (angle::ObserverBinding *observer : mObservers)
      {
          observer->onSubjectReset();
      }
      mObservers.clear();
  }
  
  // ObserverBinding implementation.
  ObserverBinding::ObserverBinding(ObserverInterface *observer, SubjectIndex index)
      : mSubject(nullptr), mObserver(observer), mIndex(index)
  {
      ASSERT(observer);
  }
  
  ObserverBinding::~ObserverBinding()
  {
      reset();
  }
  
  ObserverBinding::ObserverBinding(const ObserverBinding &other) = default;
  
  ObserverBinding &ObserverBinding::operator=(const ObserverBinding &other) = default;
  
  void ObserverBinding::bind(Subject *subject)
  {
      ASSERT(mObserver);
      if (mSubject)
      {
          mSubject->removeObserver(this);
      }
  
      mSubject = subject;
  
      if (mSubject)
      {
          mSubject->addObserver(this);
      }
  }
  
  void ObserverBinding::onStateChange(const gl::Context *context, SubjectMessage message) const
  {
      mObserver->onSubjectStateChange(context, mIndex, message);
  }
  
  void ObserverBinding::onSubjectReset()
  {
      mSubject = nullptr;
  }
  
  const Subject *ObserverBinding::getSubject() const
  {
      return mSubject;
  }
  }  // namespace angle
  

Download