VFS_tcp_client.h

Go to the documentation of this file.

#ifndef VFS_TCP_CLIENT_H
#define VFS_TCP_CLIENT_H
 
#include <QTcpSocket>
#include <QHostAddress>
#include <QSslError>
#include <QSslSocket>
#include <QSslConfiguration>
 
#include "VFS_base/VFS_node.h"
 
class VFS_tcp_server;
 
typedef quint32 MESSAGE_SIZE;
//#define MAX_MESSAGE_SIZE 65000
#define MAX_MESSAGE_SIZE 2147483648     //max = 2^31, which is like 2 gigabytes
 
class VFS_tcp_client : public VFS_node
{
        Q_OBJECT
 
        friend class VFS_tcp_server;
 
        public:
                explicit VFS_tcp_client(QTcpSocket *socket, bool ssl=false, QSslConfiguration sslConfiguration=QSslConfiguration());
                explicit VFS_tcp_client(QTcpSocket *socket, bool ssl=false, QString sslCertPath="");
                explicit VFS_tcp_client(QString address, quint16 port, bool ssl=false, QString sslCertPath="");
                virtual ~VFS_tcp_client();
 
                virtual void write(VFS_request *r);
 
                virtual bool isContainer();
 
                virtual QString reportDetails();
 
                virtual void writeMessage(QByteArray data);
 
                //FIXME: should be made protected with an access function
                //QMap<VFS_node *, QString> _subscriptionPaths;
                //QString       _subscriptionPath;              //the path leading to the other side of this endpoint
 
        protected:
                QTcpSocket      *_socket;                       
                MESSAGE_SIZE    _messageSize;                   
 
                bool            _initialized;                   
                QString         _address;                       
                quint16         _port;                          
                bool            _ssl;                           
                QString         _sslCertPath;                   
 
        signals:
                void connected();                               
                void disconnected();                            
                void readyMessage(QByteArray message);          
                void moreToRead();                              
                void error(QAbstractSocket::SocketError);       
 
        public slots:
                virtual void init();
                virtual void close();
                void readyRead();
                void initSSL();
 
        protected slots:
                void peerVerifyError(const QSslError &error);
                void sslErrors(const QList<QSslError> &errors);
                void modeChanged(QSslSocket::SslMode mode);
                void sslReady();
};
 
#endif // VFS_TCP_CONNECTION_H