Method enterEventLoop

common/cmaclient.cpp:221–264

}

void CmaClient::enterEventLoop(vita_device_t *device)
{
    vita_event_t obj_event;

    qDebug("Starting event loop");

    CmaEvent eventLoop(m_db, device);
    QThread obj_thread;
    obj_thread.setObjectName("event_thread");

    eventLoop.moveToThread(&obj_thread);
    connect(&obj_thread, &QThread::started, &eventLoop, &CmaEvent::process);
    connect(&eventLoop, &CmaEvent::refreshDatabase, this, &CmaClient::refreshDatabase, Qt::DirectConnection);
    connect(&eventLoop, &CmaEvent::finishedEventLoop, &obj_thread, &QThread::quit, Qt::DirectConnection);
    connect(&eventLoop, &CmaEvent::messageSent, this, &CmaClient::messageSent, Qt::DirectConnection);
    obj_thread.start();

    while(isActive()) {
        if(VitaMTP_Read_Event(device, &obj_event) < 0) {
            qWarning("Error reading event from Vita.");
            break;
        }

        // do not create a event for this since there aren't more events to read
        if(obj_event.Code == PTP_EC_VITA_RequestTerminate) {
            qDebug("Terminating event thread");
            break;

            // this one shuold be processed inmediately
        } else if(obj_event.Code == PTP_EC_VITA_RequestCancelTask) {
            eventLoop.vitaEventCancelTask(&obj_event, obj_event.Param1);
            qDebug("Ended event, code: 0x%x, id: %d", obj_event.Code, obj_event.Param1);
            continue;
        }

        // the events are processed synchronously except for cancel/terminate
        qDebug("Sending new event");
        eventLoop.setEvent(obj_event);
    }

    eventLoop.stop();
    obj_thread.wait();
    qDebug("Finishing event loop");
}

int CmaClient::stop()
{