Method run

Server/Source/ProcessorClient.cpp:265–325

}

void ProcessorClient::run() {
    traceScope();
    MessageFactory msgFactory(this);

    bool lastOk = true;

    while (!threadShouldExit()) {
        if (!isOk()) {
            if (lastOk) {
                lastOk = false;
                if (onStatusChange) {
                    onStatusChange(false, m_error);
                }
            }
            if (!init()) {
                return;
            }
            if (!isOk()) {
                sleepExitAware(1000);
                continue;
            }
            if (m_loaded) {
                String err;
                if (!load(m_lastSettings, m_lastLayout, m_lastMonoChannels, err)) {
                    setAndLogError("reload failed: " + err);
                }
            }
        }

        if (!lastOk) {
            lastOk = true;
            if (onStatusChange) {
                onStatusChange(m_error.isEmpty(), m_error);
            }
        }

        TimeStatistic::Timeout timeout(1000);
        while (timeout.getMillisecondsLeft() > 0 && !threadShouldExit()) {
            MessageHelper::Error err;
            auto msg = msgFactory.getNextMessage(m_sockCmdIn.get(), &err, 100);
            if (nullptr != msg) {
                switch (msg->getType()) {
                    case Key::Type:
                        handleMessage(Message<Any>::convert<Key>(msg));
                        break;
                    case ParameterValue::Type:
                        handleMessage(Message<Any>::convert<ParameterValue>(msg));
                        break;
                    case ParameterGesture::Type:
                        handleMessage(Message<Any>::convert<ParameterGesture>(msg));
                        break;
                    case ScreenBounds::Type:
                        handleMessage(Message<Any>::convert<ScreenBounds>(msg));
                        break;
                    default:
                        logln("unknown message type " << msg->getType());
                }
            }