Method ProcessAllEvents

core/lib/notify_instance.cpp:397–440

}

int NotifyBus::ProcessAllEvents(void)
{
    batch_count_ = 0;

    /* first, move Node from pending queue to active queue */
    pending_queue_mutex.lock();

    while(!pending_queue.empty())
    {
        EventNode* node = pending_queue.front();
        active_queue.push(node);
        pending_queue.pop();
    }

    pending_queue_mutex.unlock();

    while(!active_queue.empty())
    {
        EventNode* node = active_queue.front();

        active_queue.pop();

        if(!GetNode(node))
            continue;

        HandlePendingEvent(node);

        if(node->event_tree.size())
        {
            active_queue.push(node);
        }
        else
        {
            node->active = false;
        }

        PutNode(node);

        if(batch_count_ >= batch_budget_)
            break;
    }

    return batch_count_;
}

void NotifyBus::SetBatchNum(int budget)
{