Method Send

core/lib/notify_instance.cpp:239–273

}

bool NotifyBus::Send(int event, EventData* data, int priority)
{
    EventNode* node = GetNode(event);

    if(node == nullptr)
        return false;

    int count = GetPendingCount(node);

    if(count >= max_pending_num_)
    {
        node->send_fail_count++;
        PutNode(node);
        return false;
    }

    node->event_tree[priority].emplace(*data);

    node->send_count++;

    if(!node->active)
    {
        node->active = true;

        pending_queue_mutex.lock();

        pending_queue.push(node);

        pending_queue_mutex.unlock();
    }

    PutNode(node);

    return true;
}

bool NotifyBus::Send(const std::string& event_name, EventData* data, int priority)
{