data_thread.hh
No OneTemporary
Actions

Subscribers

None

File Metadata

	#ifndef DATA_THREAD_H
	#define DATA_THREAD_H

	#include <QThread>
	#include <QTcpSocket>

	class Grid;

	class DataThread : public QThread {
	Q_OBJECT
	public:
	DataThread(int socket_desc, Grid & grid, QObject *parent);
	~DataThread();
	void run() Q_DECL_OVERRIDE;

	signals:
	void error(QTcpSocket::SocketError socketError);
	void dataReady();

	protected slots:
	void readFrame();

	private:
	QTcpSocket * socket;
	int socket_desc;
	Grid & grid;

	int prank, psize;
	int lsize[2];
	int gsize[2];
	int offset[2];
	int ghost;

	bool lock_write;

	int partial_read;
	int i;
	int j;
	char command;
	};

	#endif /* DATA_THREAD_H */