notifier.cc

Go to the documentation of this file.

#include "ion/base/notifier.h"

namespace ion {
namespace base {

Notifier::~Notifier() {}

void Notifier::AddReceiver(Notifier* receiver) {
  if (receiver) {
    NotifierPtr ptr(receiver);
    WriteLock lock(&mutex_);
    WriteGuard guard(&lock);
    const size_t count = receivers_.size();
    for (size_t i = 0; i < count; ++i)
      if (ptr == receivers_[i])
        return;
    receivers_.push_back(ptr);
  }
}

void Notifier::RemoveReceiver(Notifier* receiver) {
  if (receiver) {
    WriteLock lock(&mutex_);
    WriteGuard guard(&lock);
    const size_t count = receivers_.size();
    if (receiver->GetRefCount()) {
      NotifierPtr ptr(receiver);
      for (size_t i = 0; i < count; ++i) {
        if (receivers_[i] == ptr) {
          receivers_[i] = receivers_[receivers_.size() - 1U];
          receivers_.pop_back();
          break;
        }
      }
    } else {
      for (size_t i = 0; i < receivers_.size();) {
        if (receivers_[i].GetUnderlyingRefCountUnsynchronized()) {
          ++i;
        } else {
          receivers_[i] = receivers_[receivers_.size() - 1U];
          receivers_.pop_back();
          break;
        }
      }
    }
  }
}

size_t Notifier::GetReceiverCount() const {
  ReadLock lock(&mutex_);
  ReadGuard guard(&lock);
  return receivers_.size();
}

const Notifier::NotifierPtrVector& Notifier::GetReceivers() const {
  return receivers_;
}

void Notifier::Notify() const {
  ReadLock lock(&mutex_);
  ReadGuard guard(&lock);
  for (size_t i = 0; i < receivers_.size();) {
    ReferentPtr<Notifier>::Type receiver = receivers_[i].Acquire();
    if (receiver.Get()) {
      receiver->OnNotify(this);
      ++i;
    } else {
      receivers_[i] = receivers_[receivers_.size() - 1U];
      receivers_.pop_back();
    }
  }
}

void Notifier::OnNotify(const Notifier* notifier) {}

}  // namespace base
}  // namespace ion