DirectoryDeltaTransfer.h

Go to the documentation of this file.

#include "NativeFeatureIncludes.h"
#if _RAKNET_SUPPORT_DirectoryDeltaTransfer==1 && _RAKNET_SUPPORT_FileOperations==1

#ifndef __DIRECTORY_DELTA_TRANSFER_H
#define __DIRECTORY_DELTA_TRANSFER_H

#include "RakMemoryOverride.h"
#include "RakNetTypes.h"
#include "Export.h"
#include "PluginInterface2.h"
#include "DS_Map.h"
#include "PacketPriority.h"



namespace RakNet
{
class RakPeerInterface;
class FileList;
struct Packet;
struct InternalPacket;
struct DownloadRequest;
class FileListTransfer;
class FileListTransferCBInterface;
class FileListProgress;
class IncrementalReadInterface;

class RAK_DLL_EXPORT DirectoryDeltaTransfer : public PluginInterface2
{
public:
    // GetInstance() and DestroyInstance(instance*)
    STATIC_FACTORY_DECLARATIONS(DirectoryDeltaTransfer)

    // Constructor
    DirectoryDeltaTransfer();

    // Destructor
    virtual ~DirectoryDeltaTransfer();

    void SetFileListTransferPlugin(FileListTransfer *flt);

    void SetApplicationDirectory(const char *pathToApplication);

    void SetUploadSendParameters(PacketPriority _priority, char _orderingChannel);

    void AddUploadsFromSubdirectory(const char *subdir);

    unsigned short DownloadFromSubdirectory(const char *subdir, const char *outputSubdir, bool prependAppDirToOutputSubdir, SystemAddress host, FileListTransferCBInterface *onFileCallback, PacketPriority _priority, char _orderingChannel, FileListProgress *cb);

    void ClearUploads(void);

    unsigned GetNumberOfFilesForUpload(void) const;

    void SetDownloadRequestIncrementalReadInterface(IncrementalReadInterface *_incrementalReadInterface, unsigned int _chunkSize);
    
    virtual PluginReceiveResult OnReceive(Packet *packet);
protected:
    void OnDownloadRequest(Packet *packet);

    char applicationDirectory[512];
    FileListTransfer *fileListTransfer;
    FileList *availableUploads;
    PacketPriority priority;
    char orderingChannel;
    IncrementalReadInterface *incrementalReadInterface;
    unsigned int chunkSize;
};

} // namespace RakNet

#endif

#endif // _RAKNET_SUPPORT_*