VFS_tcp_mount.h

Go to the documentation of this file.

#ifndef VFS_TCP_MOUNT_H
#define VFS_TCP_MOUNT_H
 
#include <QTimer>
 
#include "VFS_tcp/VFS_tcp/VFS_tcp_client.h"
#include "VFS_tcp_mount_directory.h"
 
//every 5 minutes, send a pulse to keep the connection alive.
#define VFS_TCP_MOUNT_PING_TIME_MS (1000*60*5)
 
class VFS_tcp_mount : public VFS_tcp_client
{
        Q_OBJECT
 
        friend class VFS_tcp_mount_directory;
        friend class VFS_tcp_export_client;
        friend class aclEditor;
 
        public:
                Q_INVOKABLE VFS_tcp_mount(QString name, QString path, QString address, quint16 port, quint16 interval=3000,  bool ssl=false, QString sslCertPath="");
                virtual ~VFS_tcp_mount();
 
                virtual VFS_node *find(VFS_request *r);
 
                virtual bool isContainer();
 
                void refreshSubscriptions();
                bool isMounted();
                QString path();
 
        protected:
                QString                         _name;                          
                QString                         _path;                          
                int                             _attemptInterval;               
                int                             _timerID;                       
                bool                            _mounted;                       
 
                postID                          _currentID;                     
                QMap<postID, VFS_request *>     _requests;                      
                postID getNewRequestID();
 
                QList<VFS_request *>            _unmountedRequests;             
                void sendUnmountedRequests();
 
                void issueUnmounted();
                void issueMounted(QString path);
 
                VFS_tcp_mount_directory         _codeDirectory;                 
 
                QTimer                          _ping;                          
 
                static QMutex                   _mountsLock;                    
                static QList<VFS_tcp_mount *>   _mounts;                        
 
                void timerEvent(QTimerEvent *e=nullptr);
                void attemptConnection();
 
                virtual QByteArray icon();
 
        private:
        //      virtual void ls(VFS_request *r);
        //      virtual void read(VFS_request *r);
        //      virtual void write(VFS_request *r);
        //      virtual void metadata(VFS_request *r);
        //      virtual void report(VFS_request *r);
        //      virtual void submit(VFS_request *r);
        //      virtual void rm(VFS_request *r);
 
                void sendMessage( QByteArray message );
 
        signals:
 
        public slots:
                void init();
 
                virtual void executeRequest(VFS_request *r);
 
                virtual void unsubscribeAll(VFS_node *n);
 
        protected slots:
                virtual void startConnecting();
                virtual void stopConnecting();
 
                virtual void startPing();
                virtual void stopPing();
                virtual void sendPing();
 
                virtual void receiveMessage(QByteArray message);
};
 
#endif // VFS_TCP_MOUNT_H