/* dtkDistributedSlave.h ---
 *
 * Author: Julien Wintz
 * Copyright (C) 2008 - Julien Wintz, Inria.
 * Created: Wed May 25 14:13:03 2011 (+0200)
 * Version: $Id: 719e5e0f112f7ebb6e741f9284be7abddc5b5676 $
 * Last-Updated: mer. avril 11 16:49:46 2012 (+0200)
 *           By: Nicolas Niclausse
 *     Update #: 82
 */

/* Commentary:
 *
 */

/* Change log:
 *
 */

#ifndef DTKDISTRIBUTEDSLAVE_H
#define DTKDISTRIBUTEDSLAVE_H

#include <dtkDistributedSupportExport.h>
#include "dtkDistributedCommunicatorTcp.h"

#include <QtCore>
#include <QtNetwork>

class dtkDistributedCommunicatorTcp;
class dtkDistributedSlavePrivate;

class DTKDISTRIBUTEDSUPPORT_EXPORT dtkDistributedSlave : public QObject
{
    Q_OBJECT

public:
    dtkDistributedSlave(void);
    dtkDistributedSlave(dtkDistributedCommunicatorTcp *communicator);
    ~dtkDistributedSlave(void);

    QString jobId(void);

public:
    virtual int run(void);

public:
    bool    isConnected(void);
    bool isDisconnected(void);

    bool flush(void);
    void close(void);

signals:
    void    connected(const QUrl& server);
    void disconnected(const QUrl& server);

    void started(void);
    void   ended(void);

public slots:
    void    connect(const QUrl& server);
    void disconnect(const QUrl& server);

protected:
    virtual int exec(void) = 0;

public:
    dtkDistributedCommunicatorTcp *communicator();

protected slots:
    void      read(void);
    void onStarted(void);
    void   onEnded(void);

protected slots:
    void error(QAbstractSocket::SocketError error);

private:
    dtkDistributedSlavePrivate *d;
};

#endif