00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034
00035
00036 #ifndef INCL_FILE_SYNC_SOURCE
00037 #define INCL_FILE_SYNC_SOURCE
00038
00042 #include "base/fscapi.h"
00043 #include "spds/constants.h"
00044 #include "spds/SyncItem.h"
00045 #include "spds/SyncMap.h"
00046 #include "spds/SyncStatus.h"
00047 #include "spds/SyncSource.h"
00048 #include "spdm/ManagementNode.h"
00049 #include "base/util/ItemContainer.h"
00050
00051
00052 #define ERR_FILE_SYSTEM 1
00053 #define ERR_NO_FILES_TO_SYNC 2
00054 #define ERR_BAD_FILE_CONTENT 3
00055 #include "base/globalsdef.h"
00056
00057 BEGIN_NAMESPACE
00058
00067 class FileSyncSource : public SyncSource {
00068
00069 protected:
00070
00071
00072 char* dir;
00073
00074
00075 FileSyncSource(SyncSource& s);
00076
00077
00078
00079
00080 virtual bool setItemData(SyncItem* syncItem);
00081
00089 int addedItem(SyncItem& item, const WCHAR* key);
00090
00091 public:
00092 FileSyncSource(const WCHAR* name, AbstractSyncSourceConfig* sc);
00093 virtual ~FileSyncSource();
00094
00100 void setDir(const char* p);
00101 const char* getDir();
00102
00113 void setFileNode(ManagementNode *mn) { fileNode = mn; }
00114 ManagementNode *getFileNode() { return fileNode; }
00115
00116
00117
00118 SyncItem* getFirstItem() { return getFirst(allItems); }
00119 SyncItem* getNextItem() { return getNext(allItems); }
00120 SyncItem* getFirstNewItem() { return getFirst(newItems); }
00121 SyncItem* getNextNewItem() { return getNext(newItems); }
00122 SyncItem* getFirstUpdatedItem() { return getFirst(updatedItems); }
00123 SyncItem* getNextUpdatedItem() { return getNext(updatedItems); }
00124 SyncItem* getFirstDeletedItem() { return getFirst(deletedItems, false); }
00125 SyncItem* getNextDeletedItem() { return getNext(deletedItems, false); }
00126 SyncItem* getFirstItemKey() { return getFirst(allItems, false); }
00127 SyncItem* getNextItemKey() { return getNext(allItems, false); }
00128 int addItem(SyncItem& item);
00129 int updateItem(SyncItem& item);
00130 int deleteItem(SyncItem& item);
00131 void setItemStatus(const WCHAR* key, int status);
00132 int removeAllItems();
00133 int beginSync();
00134 int endSync();
00135 void assign(FileSyncSource& s);
00136
00137 private:
00138
00139
00140 struct ItemIteratorContainer {
00141 ArrayList items;
00142 int index;
00143 } allItems, newItems, updatedItems, deletedItems;
00144
00145
00146 ManagementNode* fileNode;
00147
00149 unsigned long getServerModTime(const char* keystr);
00150
00151 SyncItem* getFirst(ItemIteratorContainer& container, bool getData = true);
00152 SyncItem* getNext(ItemIteratorContainer& container, bool getData = true);
00153 };
00154
00155
00156 END_NAMESPACE
00157
00160 #endif