/* @(#)main.cpp ---
 *
 * Author: Nicolas Niclausse
 * Copyright (C) 2014 - Nicolas Niclausse, Inria.
 * Created: 2014/04/25 16:28:19
 */

/* Commentary:
 *
 */

/* Change log:
 *
 */




#include <dtkDistributed>
#include <dtkLog>
#include <dtkWidgets/dtkDistributedGuiApplication.h>

#include <QtCore>

class slaveWork : public QRunnable
{
public:
    QString server;

public:
    void run(void) {
        QTime time;
        dtkDistributedCommunicator *comm = dtkDistributed::communicator::instance();
        dtkDebug() << comm->wid();
        dtkDebug() << comm->size();
        dtkDistributedSlave slave;

        if (comm->rank() == 0) {
            slave.connectFromJob(server);
        }

        QThread::sleep(5);

        if (comm->rank() == 0) {
            QString hello = "I'm the master slave, we are " + QString::number(comm->size()) + " slaves";
            QVariant v(hello);
            dtkDistributedMessage msg(dtkDistributedMessage::DATA, slave.jobId(), dtkDistributedMessage::CONTROLLER_RANK, v);

            msg.send(slave.socket());
            slave.socket()->flush();
            qDebug() << "message sent to controller";
        }

        QThread::sleep(5);

        slave.disconnectFromJob(server);
    }
};

int main(int argc, char **argv)
{
    dtkDistributedGuiApplication *app = dtkDistributedGuiApplication::create(argc, argv);
    app->setApplicationName("dtkDistributedSlave");
    app->setApplicationVersion("1.5.1");
    app->setOrganizationName("inria");

    QCommandLineParser *parser = app->parser();
    parser->setApplicationDescription("DTK distributed slave example application: it connect to the DTK distributed server and waits for 1 minute before exiting.");

    QCommandLineOption serverOption("server", "DTK distributed server URL", "URL");
    parser->addOption(serverOption);

    app->initialize();
    dtkDistributed::communicator::setInstance(app->communicator());
    if (!parser->isSet(serverOption)) {
        qCritical() << "Error: no server set ! Use --server <url> " ;
        return 1;
    }


    // work
    slaveWork work;
    work.server = parser->value(serverOption);

    app->spawn();
    app->exec(&work);
    app->unspawn();

    return 0;
}