WorkerRepresentative.h

Go to the documentation of this file.

#ifndef SIMPT_PAREX_WORKER_REPRESENTATIVE_H_INCLUDED
#define SIMPT_PAREX_WORKER_REPRESENTATIVE_H_INCLUDED
/*
 * Copyright 2011-2016 Universiteit Antwerpen
 *
 * Licensed under the EUPL, Version 1.1 or  as soon they will be approved by
 * the European Commission - subsequent versions of the EUPL (the "Licence");
 * You may not use this work except in compliance with the Licence.
 * You may obtain a copy of the Licence at: http://ec.europa.eu/idabc/eupl5
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the Licence is distributed on an "AS IS" basis,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the Licence for the specific language governing
 * permissions and limitations under the Licence.
 */
#include "parex_protocol/ServerNodeProtocol.h"
#include "parex_protocol/SimResult.h"
#include "parex_protocol/SimTask.h"

#include <QObject>
#include <QHostAddress>
#include <QTcpSocket>
#include <iostream>

namespace SimPT_Parex {

class WorkerRepresentative: public QObject
{
        Q_OBJECT
public:
        WorkerRepresentative(const QHostAddress &addr, quint16 port);

        WorkerRepresentative(const QHostAddress &addr, quint16 port, int taskId, std::string taskName);

        virtual ~WorkerRepresentative();

        const QHostAddress* GetSenderAddress() const;

        int GetSenderPort() const;

        std::string GetExplName() const;

        int GetTaskId() const;

        void StopTask();

        void Delete(const std::string name);

signals:
        void ReadyToWork();

        void FinishedWork(const SimResult&);

        void Disconnected();

public slots:
        void Setup();

        void DoWork(const SimTask&);

private slots:
        void Connected();
        void Finished(const SimResult&);
        void DisplayError(QAbstractSocket::SocketError error) const;
        void DisplayError(const std::string &s) const;

private:
        void Init();

private:
        QHostAddress*           m_addr;
        quint16                 m_port;
        QTcpSocket*             m_socket;
        ServerNodeProtocol*     m_protocol;
        int                     m_currentTaskId;
        std::string             m_currentTaskName;
};

} // namespace

#endif // end-of-include-guard