signal_utils.cpp

Branch :

Show log
Commit
Author : Jamie Madill
Date : 2016-07-28 16:20:21
Hash : 00d6796a
Message : Replace std::set with vector for signal receivers. This should make insertion much faster, which will improve the speed of many BindBuffer calls. BUG=angleproject:1458 Change-Id: I3f7ebc02cc481257be8b84773506b9ac9e3be677 Reviewed-on: https://chromium-review.googlesource.com/364221 Reviewed-by: Corentin Wallez <cwallez@chromium.org> Reviewed-by: Geoff Lang <geofflang@chromium.org> Commit-Queue: Jamie Madill <jmadill@chromium.org>

src/libANGLE/signal_utils.cpp

//
// Copyright 2016 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.
//
// signal_utils:
//   Helper classes for tracking dependent state changes between objects.
//   These changes are signaled to the dependent class via channels.

#include "libANGLE/signal_utils.h"

#include <algorithm>

#include "common/debug.h"

namespace angle
{

BroadcastChannel::BroadcastChannel()
{
}

BroadcastChannel::~BroadcastChannel()
{
    reset();
}

void BroadcastChannel::addReceiver(ChannelBinding *receiver)
{
    ASSERT(std::find(mReceivers.begin(), mReceivers.end(), receiver) == mReceivers.end());
    mReceivers.push_back(receiver);
}

void BroadcastChannel::removeReceiver(ChannelBinding *receiver)
{
    auto iter = std::find(mReceivers.begin(), mReceivers.end(), receiver);
    ASSERT(iter != mReceivers.end());
    mReceivers.erase(iter);
}

void BroadcastChannel::signal() const
{
    if (mReceivers.empty())
        return;

    for (const auto *receiver : mReceivers)
    {
        receiver->signal();
    }
}

void BroadcastChannel::reset()
{
    for (auto receiver : mReceivers)
    {
        receiver->onChannelClosed();
    }
    mReceivers.clear();
}

ChannelBinding::ChannelBinding(SignalReceiver *receiver, SignalToken token)
    : mChannel(nullptr), mReceiver(receiver), mToken(token)
{
    ASSERT(receiver);
}

ChannelBinding::~ChannelBinding()
{
    reset();
}

void ChannelBinding::bind(BroadcastChannel *channel)
{
    ASSERT(mReceiver);
    if (mChannel)
    {
        mChannel->removeReceiver(this);
    }

    mChannel = channel;

    if (mChannel)
    {
        mChannel->addReceiver(this);
    }
}

void ChannelBinding::reset()
{
    bind(nullptr);
}

void ChannelBinding::signal() const
{
    mReceiver->signal(mToken);
}

void ChannelBinding::onChannelClosed()
{
    mChannel = nullptr;
}

}  // namespace angle

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

Commit

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