Function echo_thread

internal/tests/core/test/test_notify.cpp:153–196

}

void echo_thread(int count, NotifyBus* bus, int my_event, int peer_event)
{
    int i = 0;

    EventHandle handle;
    SyncData sync_data;

    sync_data.sync.lock();

    handle.func = handle_event;
    handle.argument = &sync_data;

    bus->Book(my_event, handle);

    EventData data;

    data.event = peer_event;

    if(my_event == 0)
    {
        // make sure other threads have initialized already
        sleep(1);
        data.data = -1;
        bus->Send(peer_event, &data);
    }

    std::cout << "My event: " << my_event << "\n";

    while(true)
    {
        sync_data.sync.lock();

        std::cout << "send event to: " << peer_event << " # " << i << "\n";

        data.data = i;

        bus->Send(peer_event, &data);

        if(i++ == count)
            break;
    }

    std::cout << "Total received: " << count << " events\n";
}

void test_threads(void)
{