Package com.killcoding.file

Class RemoteFile

java.lang.Object

com.killcoding.file.BaseFile

com.killcoding.file.RemoteFile

All Implemented Interfaces:

RemoteFileSQL

public class RemoteFile
extends BaseFile
implements RemoteFileSQL

Field Summary

Fields

Modifier and Type	Field	Description
private static File	appRemoteFile
static Integer	BATCH_SIZE
static Long	BEFORE_THE_QUEUE_TIME
static Integer	CACHE_SECONDS
private static final Map<String,ConfigProperties>	CONFIG_PROPS_REMOTE_FILE
protected ConfigProperties	configProperties
static boolean	COPY_STRUCTURE_ONLY
private static final Map<String,ConfigProperties>	DATA_MAPPING
private static final Map<String,Integer>	DATA_MAPPING_INDEX
private static final Map<String,List<String>>	DATA_MAPPING_LIST
protected DriverDataSource	dataMappingDataSourceReader
protected DriverDataSource	dataMappingDataSourceWriter
protected String	dataMappingDs
protected Integer	dataMappingTable
private static final Map<String,DriverDataSource>	DATASOURCE_REMOTE_FILE
private DriverDataSource	dataSourceReader
private String	dataSourceReaderPath
private DriverDataSource	dataSourceWriter
private String	dataSourceWriterPath
static String	DEFAULE_MODIFY_USER_ID
static Date	DELETE_CUTOFF_TIME
protected String	dsKey
protected String	fileId
private Integer	filePartSize
protected static boolean	FIRST_LOADED
private static IdentityCard	identityCard
private Boolean	identityCardEnable
private String	identityCardName
private String	identityCardPrefix
private Integer	identityCardSuffix
private Logger	log
static Double	MAX_CONNECT_USAGE
static Integer	MAX_FILE_NAME_LENGTH
static Integer	MAX_FILE_PARENT_PATH_LENGTH
static Long	MAX_FILE_SZIE
static Double	MAX_MEMORY_USAGE
static Integer	MAX_POOL_SIZE
static Integer	MAX_QUEUE_SIZE
private static ExecutorService	mergePool
private Timestamp	modifyTime
private String	modifyUserId
private static final Map<String,Long>	QUEUE_PATH_MAPPING
static boolean	SHOW_HIDDEN
static boolean	SHOW_LINK
static Date	SYNC_CUTOFF_TIME
protected String	tableName

Fields inherited from class com.killcoding.file.BaseFile

CACHE_ARRAY_FILTER_TIMER, CHARSET, LOGIC_ACCESS_TIMEOUT_MS, LOGIC_CHECK_TIMEOUT_MS, LOGIC_TIMEOUT_MS, origin, stopSync, SYNC_PATH_ALLOWED, SYNC_PATH_IGNORED, syncRoot, TEMP_DIR, TMP_EXT_ACCESS_FILE, TMP_EXT_CHECK_FILE, TMP_EXT_MODIFY_FILE, TMP_MATCHES_EDIT, TMP_MATCHES_VI_SWP, TMP_WRITING_FILE, TMP_WRITING_FOR_REPLACE, TMP_WRITING_SWP

Fields inherited from interface com.killcoding.file.RemoteFileSQL

SQL_DELETE_BY_FILE_ID_FROM_FILE, SQL_DELETE_BY_RF_ID_FROM_FILE_DATA, SQL_INSERT_INTO_FILE, SQL_INSERT_INTO_FILE_DATA, SQL_SELECT_BY_PATH_FOR_CHECK_EXISTS, SQL_SELECT_BY_RF_ID_FROM_FILE_DATA, SQL_SELECT_CHECK_COMPLETED, SQL_SELECT_FILE, SQL_SELECT_FILE_HAVE_DATA, SQL_SELECT_FOR_ALL_TIMEOUT, SQL_SELECT_FOR_ARCHIVE_DELETED, SQL_SELECT_FOR_ARCHIVE_FILE_DELETED, SQL_SELECT_FOR_COMPLETED, SQL_SELECT_FOR_COUNT_ALL_SUB_FILES, SQL_SELECT_FOR_FIRST_CREATED_AT, SQL_SELECT_FOR_FIRST_FILE, SQL_SELECT_FOR_LAST_FILE_PART, SQL_SELECT_FOR_LAST_UPDATE, SQL_SELECT_FOR_LIST_ALL, SQL_SELECT_FOR_LIST_ALL_DELETE, SQL_SELECT_FOR_LIST_ALL_SCAN_DELETE, SQL_SELECT_FOR_LIST_ALL_SYNC, SQL_SELECT_FOR_MAX_DATA_TABLE, SQL_SELECT_FOR_SUM_FILE_PART_SIZE_INDEX, SQL_SELECT_FOR_TIMEOUT, SQL_SELECT_GET_RECORD_BY_FILE_ID, SQL_SELECT_GET_RECORD_BY_ID, SQL_UPDATE_BY_FILE_ID_FOR_CLEAR_FILE_DATA, SQL_UPDATE_FOR_COMPLETED, SQL_UPDATE_FOR_DELETE_ALL, SQL_UPDATE_FOR_DELETE_FILE_LINK, SQL_UPDATE_FOR_DELETED_TO_DISK, SQL_UPDATE_FOR_DELETED_TO_DISK_SUB_FILES, SQL_UPDATE_FOR_SYNCED_TO_DISK, SQL_UPDATE_FOR_TIMEOUT_DELETE

Constructor Summary

Constructors

Constructor	Description
RemoteFile(File origin)
RemoteFile(String path)

Method Summary

Modifier and Type	Method	Description
protected static boolean	addQueuePathMapping(String path)
void	afterCreateLink(String target)
void	afterDelete(boolean realDeleted)
void	afterMkdirs()
void	afterWrite()
boolean	beforeCreateLink(String target)
boolean	beforeDelete(boolean realDeleted)
boolean	beforeMkdirs()
boolean	beforeWrite()
protected static void	calculateDataMappingDataSourceReader(RemoteFile rf, Map<String,Object> rfRecord)
protected static void	calculateDataMappingDataSourceWriter(RemoteFile rf)
static boolean	checkQueuePathMapping()
boolean	complete()
private boolean	complete(int filePartLastIndex, long fileSize)
protected void	copyFrom(boolean copyStructureOnly, DiskFile diskFile)
void	copyTo(String toPath)
private int	countAllSubFiles(String fileParentPath, String fileName)
private boolean	createEmptyFile()
boolean	createLink(String target)
private boolean	createStructureFile(long fileSize)
private static void	debugLog(String point, RemoteFile rf, CacheArrayFilter filter)
private byte[]	decrypt(byte[] encData)
boolean	delete()
boolean	delete(boolean realDeleted)
protected boolean	deletedToDiskAndSub(Object id)
private byte[]	encrypt(byte[] data)
private void	executeSyncRunnable(CacheArrayFilter filter, Map<String,Object> item, DiskFile df, RemoteFile rf)
boolean	exists()
boolean	exists(boolean refresh)
boolean	forceDelete()
boolean	forceDelete(boolean realDeleted, String fileType)
boolean	forceDeleteAll(boolean realDeleted)
boolean	forceDeleteDir(boolean realDeleted)
boolean	forceDeleteFile(boolean realDeleted)
boolean	forceDeleteLink(boolean realDeleted)
String	formatSql(String sql)
String	formatSqlForFilePartData(String sql)
private static String	generateDataId(boolean identityCardEnable, String identityCardName, int identityCardSuffix, RemoteFile theRf)
private static String	generateId(boolean identityCardEnable, String identityCardName, String identityCardPrefix, int identityCardSuffix)
Map<String,Object>	getCompletedRecord()
ConfigProperties	getConfigProperties()
protected static ConfigProperties	getDataMapping(RemoteFile rf, int index)
protected String	getDataMappingTableName()
DriverDataSource	getDataSourceReader()
DriverDataSource	getDataSourceWriter()
private String	getDefaultModifyUserId()
String	getDeletedOnHostnames()
static Map<String,DriverDataSource>	getDriverDataSourceMap()
protected Timestamp	getFirstCreatedAt()
private Map<String,Object>	getFirstFilePart()
private Map<String,Object>	getFirstFilePartRefresh()
private Map<String,Object>	getLastIndexRecord()
protected Timestamp	getLastModifyTime()
protected Timestamp	getLastOperateTime()
protected String	getLastSourceHostname()
Map<String,Object>	getLastUpdateRecord()
protected Integer	getMaxFilePartDataTable()
Timestamp	getModifyTime()
RemoteFile	getParentFile()
static Map<String,Long>	getQueuePathMapping()
Map<String,Object>	getRecordByFileId(Object fileId)
Map<String,Object>	getRecordById(Object id)
private Map<String,Object>	getSelectByPathForCheckExists()
String	getSourceHostname()
String	getSyncedOnHostnames()
private Runnable	getSyncRunnable(CacheArrayFilter filter, Map<String,Object> item, RemoteFile rf, DiskFile df)
private void	init()
private void	initGlobal()
static void	initPool(int poolSize)
boolean	isCompleted()
protected boolean	isDeletedOnHostname(Object id)
boolean	isDirectory()
boolean	isFile()
protected boolean	isLastOperateDelete()
protected boolean	isLastOperateRealDelete()
boolean	isLink()
protected boolean	isSyncedOnHostname()
protected boolean	isSyncedOnHostname(Object id)
boolean	isTimeout()
boolean	isTimeout(long timeoutMs)
List<Map<String,Object>>	list()
List<Map<String,Object>>	list(String likeFileName)
List<Map<String,Object>>	list(String likeFolderName, String likeFileName)
void	listAll(CacheArray rows)
void	listAll(String likeFileName, CacheArray rows)
void	listAll(String likeFolderName, String likeFileName, CacheArray rows)
protected void	listAllForDelete(String likeFolderName, String likeFileName, CacheArray rows)
protected void	listAllForScanDelete(Integer filePartDataTable, CacheArray rows)
protected void	listAllForSync(String likeFolderName, String likeFileName, CacheArray rows)
protected static void	loadDataMapping(RemoteFile rf)
void	merge(FilePart filePart)
boolean	mkdirs()
boolean	mkdirs(boolean checkSourceHostname)
void	moveTo(String toPath)
byte[]	readAllBytes()
private byte[]	readAllBytesFrom()
String	readAllString()
String	readLink()
private Map<String,Object>	readPart(Map<String,Object> rfRecord)
private void	reload()
protected static void	removeQueuePathMapping(String path)
void	setModifyTime(Timestamp modifyTime)
void	setModifyUserId(String modifyUserId)
long	size()
void	startArchiveForDeleted(long timerMs, long archiveMs)
void	startArchiveForDeleted(long timerMs, long archiveMs, Runnable completedCallback)
void	startArchiveForDeleted(long timerMs, String archiveTime)
void	startArchiveForDeleted(long timerMs, String archiveTime, Runnable completedCallback)
void	startArchiveForFileDeleted(long timerMs, long archiveMs)
void	startArchiveForFileDeleted(long timerMs, long archiveMs, Runnable completedCallback)
void	startArchiveForFileDeleted(long timerMs, String archiveTime)
void	startArchiveForFileDeleted(long timerMs, String archiveTime, Runnable completedCallback)
void	startArchiveForTimeout(long timerMs)
void	startArchiveForTimeout(long timerMs, Runnable completedCallback)
void	startFullAsync(long timerMs)
void	startFullAsync(long timerMs, Runnable completedCallback)
void	startFullAsync(long timerMs, String replaceTo)
void	startFullAsync(long timerMs, String replaceTo, Runnable completedCallback)
private void	startFullAsyncThread(boolean subFolders, long timerMs, String replaceTo, Runnable completedCallback)
private void	startFullAsyncThreadForDelete(boolean subFolders, long timerMs, String replaceTo, Runnable completedCallback)
protected boolean	syncedToDisk()
boolean	write(byte[] data)
boolean	write(byte[] data, boolean append)
boolean	write(String data)
boolean	write(String data, boolean append)
boolean	writeBlock(byte[] data, boolean append)
private boolean	writeTo(byte[] data, boolean append)
private boolean	writeToBatch(int currentFilePartStartIndex, List<byte[]> partDataList)
DiskFile	writeToDisk()
DiskFile	writeToDisk(DiskFile diskFile)
DiskFile	writeToDisk(String path)

Methods inherited from class com.killcoding.file.BaseFile

checkSyncPathAvailable, checkUsage, debugLog, getOrigin, getParent, getParents, getPath, isDebug, isDir, isHidden, isStopSync, memoryUsage, memoryUsage, memoryUsing, parsePath, replacePath, setTmpDir, stopSync, timeZoneConver, toAccessTmpFilePath, toCheckTmpFilePath, toModifyTmpFilePath, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DATASOURCE_REMOTE_FILE

private static final Map<String,DriverDataSource> DATASOURCE_REMOTE_FILE

CONFIG_PROPS_REMOTE_FILE

private static final Map<String,ConfigProperties> CONFIG_PROPS_REMOTE_FILE

QUEUE_PATH_MAPPING

private static final Map<String,Long> QUEUE_PATH_MAPPING

DATA_MAPPING

private static final Map<String,ConfigProperties> DATA_MAPPING

DATA_MAPPING_LIST

private static final Map<String,List<String>> DATA_MAPPING_LIST

DATA_MAPPING_INDEX

private static final Map<String,Integer> DATA_MAPPING_INDEX

FIRST_LOADED

protected static boolean FIRST_LOADED

MAX_POOL_SIZE

public static Integer MAX_POOL_SIZE

MAX_CONNECT_USAGE

public static Double MAX_CONNECT_USAGE

MAX_MEMORY_USAGE

public static Double MAX_MEMORY_USAGE

MAX_QUEUE_SIZE

public static Integer MAX_QUEUE_SIZE

MAX_FILE_SZIE

public static Long MAX_FILE_SZIE

SHOW_LINK

public static boolean SHOW_LINK

SHOW_HIDDEN

public static boolean SHOW_HIDDEN

COPY_STRUCTURE_ONLY

public static boolean COPY_STRUCTURE_ONLY

MAX_FILE_PARENT_PATH_LENGTH

public static Integer MAX_FILE_PARENT_PATH_LENGTH

MAX_FILE_NAME_LENGTH

public static Integer MAX_FILE_NAME_LENGTH

CACHE_SECONDS

public static Integer CACHE_SECONDS

SYNC_CUTOFF_TIME

public static Date SYNC_CUTOFF_TIME

DELETE_CUTOFF_TIME

public static Date DELETE_CUTOFF_TIME

identityCard

private static IdentityCard identityCard

appRemoteFile

private static File appRemoteFile

dataSourceReader

private DriverDataSource dataSourceReader

dataSourceWriter

private DriverDataSource dataSourceWriter

dataSourceReaderPath

private String dataSourceReaderPath

dataSourceWriterPath

private String dataSourceWriterPath

modifyUserId

private String modifyUserId

filePartSize

private Integer filePartSize

identityCardEnable

private Boolean identityCardEnable

identityCardName

private String identityCardName

identityCardPrefix

private String identityCardPrefix

identityCardSuffix

private Integer identityCardSuffix

modifyTime

private Timestamp modifyTime

configProperties

protected ConfigProperties configProperties

fileId

protected String fileId

tableName

protected String tableName

dataMappingTable

protected Integer dataMappingTable

dataMappingDs

protected String dataMappingDs

dataMappingDataSourceReader

protected DriverDataSource dataMappingDataSourceReader

dataMappingDataSourceWriter

protected DriverDataSource dataMappingDataSourceWriter

dsKey

protected String dsKey

BEFORE_THE_QUEUE_TIME

public static Long BEFORE_THE_QUEUE_TIME

BATCH_SIZE

public static Integer BATCH_SIZE

DEFAULE_MODIFY_USER_ID

public static String DEFAULE_MODIFY_USER_ID

log

private Logger log

mergePool

private static ExecutorService mergePool

Constructor Details

RemoteFile

public RemoteFile(String path)

RemoteFile

public RemoteFile(File origin)

Method Details

initPool

public static void initPool(int poolSize)

init

private void init()

initGlobal

private void initGlobal()

reload

private void reload()

formatSql

public String formatSql(String sql)

formatSqlForFilePartData

public String formatSqlForFilePartData(String sql)

writeToDisk

public DiskFile writeToDisk(DiskFile diskFile)
                     throws IOException

Throws:

IOException

writeToDisk

public DiskFile writeToDisk()
                     throws IOException

Throws:

IOException

writeToDisk

public DiskFile writeToDisk(String path)
                     throws IOException

Throws:

IOException

isCompleted

public boolean isCompleted()
                    throws IOException

Throws:

IOException

getCompletedRecord

public Map<String,Object> getCompletedRecord()
                                      throws IOException

Throws:

IOException

getRecordById

public Map<String,Object> getRecordById(Object id)
                                 throws IOException

Throws:

IOException

getRecordByFileId

public Map<String,Object> getRecordByFileId(Object fileId)
                                     throws IOException

Throws:

IOException

getLastUpdateRecord

public Map<String,Object> getLastUpdateRecord()
                                       throws IOException

Throws:

IOException

getFirstCreatedAt

protected Timestamp getFirstCreatedAt()
                               throws IOException

Throws:

IOException

getMaxFilePartDataTable

protected Integer getMaxFilePartDataTable()
                                   throws IOException

Throws:

IOException

getSelectByPathForCheckExists

private Map<String,Object> getSelectByPathForCheckExists()
                                                  throws IOException

Throws:

IOException

countAllSubFiles

private int countAllSubFiles(String fileParentPath,
 String fileName)
                      throws IOException

Throws:

IOException

getFirstFilePart

private Map<String,Object> getFirstFilePart()
                                     throws IOException

Throws:

IOException

getFirstFilePartRefresh

private Map<String,Object> getFirstFilePartRefresh()
                                            throws IOException

Throws:

IOException

getLastIndexRecord

private Map<String,Object> getLastIndexRecord()
                                       throws IOException

Throws:

IOException

isTimeout

public boolean isTimeout(long timeoutMs)
                  throws IOException

Throws:

IOException

readPart

private Map<String,Object> readPart(Map<String,Object> rfRecord)
                             throws IOException

Throws:

IOException

merge

public void merge(FilePart filePart)
           throws IOException

Throws:

IOException

copyFrom

protected void copyFrom(boolean copyStructureOnly,
 DiskFile diskFile)
                 throws IOException

Throws:

IOException

createEmptyFile

private boolean createEmptyFile()
                         throws IOException

Throws:

IOException

createStructureFile

private boolean createStructureFile(long fileSize)
                             throws IOException

Throws:

IOException

syncedToDisk

protected boolean syncedToDisk()
                        throws IOException

Throws:

IOException

deletedToDiskAndSub

protected boolean deletedToDiskAndSub(Object id)
                               throws IOException

Throws:

IOException

complete

private boolean complete(int filePartLastIndex,
 long fileSize)
                  throws IOException

Throws:

IOException

complete

public boolean complete()
                 throws IOException

Specified by:

complete in class BaseFile

Throws:

IOException

forceDelete

public boolean forceDelete()
                    throws IOException

Throws:

IOException

forceDeleteDir

public boolean forceDeleteDir(boolean realDeleted)
                       throws IOException

Throws:

IOException

forceDeleteLink

public boolean forceDeleteLink(boolean realDeleted)
                        throws IOException

Throws:

IOException

forceDeleteFile

public boolean forceDeleteFile(boolean realDeleted)
                        throws IOException

Throws:

IOException

forceDelete

public boolean forceDelete(boolean realDeleted,
 String fileType)
                    throws IOException

Throws:

IOException

forceDeleteAll

public boolean forceDeleteAll(boolean realDeleted)
                       throws IOException

Throws:

IOException

delete

public boolean delete()
               throws IOException

Specified by:

delete in class BaseFile

Throws:

IOException

delete

public boolean delete(boolean realDeleted)
               throws IOException

Throws:

IOException

beforeDelete

public boolean beforeDelete(boolean realDeleted)

Specified by:

beforeDelete in class BaseFile

afterDelete

public void afterDelete(boolean realDeleted)

Specified by:

afterDelete in class BaseFile

beforeMkdirs

public boolean beforeMkdirs()

Specified by:

beforeMkdirs in class BaseFile

afterMkdirs

public void afterMkdirs()

Specified by:

afterMkdirs in class BaseFile

beforeCreateLink

public boolean beforeCreateLink(String target)

Specified by:

beforeCreateLink in class BaseFile

afterCreateLink

public void afterCreateLink(String target)

Specified by:

afterCreateLink in class BaseFile

beforeWrite

public boolean beforeWrite()

Specified by:

beforeWrite in class BaseFile

afterWrite

public void afterWrite()

Specified by:

afterWrite in class BaseFile

exists

public boolean exists()
               throws IOException

Specified by:

exists in class BaseFile

Throws:

IOException

exists

public boolean exists(boolean refresh)
               throws IOException

Throws:

IOException

mkdirs

public boolean mkdirs()
               throws IOException

Specified by:

mkdirs in class BaseFile

Throws:

IOException

mkdirs

public boolean mkdirs(boolean checkSourceHostname)
               throws IOException

Throws:

IOException

write

public boolean write(byte[] data,
 boolean append)
              throws IOException

Specified by:

write in class BaseFile

Throws:

IOException

writeBlock

public boolean writeBlock(byte[] data,
 boolean append)
                   throws IOException

Throws:

IOException

writeToBatch

private boolean writeToBatch(int currentFilePartStartIndex,
 List<byte[]> partDataList)
                      throws IOException

Throws:

IOException

writeTo

private boolean writeTo(byte[] data,
 boolean append)
                 throws IOException

Throws:

IOException

write

public boolean write(byte[] data)
              throws IOException

Specified by:

write in class BaseFile

Throws:

IOException

write

public boolean write(String data,
 boolean append)
              throws IOException

Specified by:

write in class BaseFile

Throws:

IOException

write

public boolean write(String data)
              throws IOException

Specified by:

write in class BaseFile

Throws:

IOException

createLink

public boolean createLink(String target)
                   throws IOException

Specified by:

createLink in class BaseFile

Throws:

IOException

readLink

public String readLink()
                throws IOException

Specified by:

readLink in class BaseFile

Throws:

IOException

readAllBytes

public byte[] readAllBytes()
                    throws IOException

Specified by:

readAllBytes in class BaseFile

Throws:

IOException

readAllBytesFrom

private byte[] readAllBytesFrom()
                         throws IOException

Throws:

IOException

isFile

public boolean isFile()
               throws IOException

Specified by:

isFile in class BaseFile

Throws:

IOException

isDirectory

public boolean isDirectory()
                    throws IOException

Specified by:

isDirectory in class BaseFile

Throws:

IOException

isLink

public boolean isLink()
               throws IOException

Specified by:

isLink in class BaseFile

Throws:

IOException

readAllString

public String readAllString()
                     throws IOException

Specified by:

readAllString in class BaseFile

Throws:

IOException

size

public long size()
          throws IOException

Specified by:

size in class BaseFile

Throws:

IOException

list

public List<Map<String,Object>> list()
                              throws IOException

Throws:

IOException

list

public List<Map<String,Object>> list(String likeFileName)
                              throws IOException

Throws:

IOException

list

public List<Map<String,Object>> list(String likeFolderName,
 String likeFileName)
                              throws IOException

Throws:

IOException

listAll

public void listAll(String likeFileName,
 CacheArray rows)
             throws IOException

Throws:

IOException

listAll

public void listAll(CacheArray rows)
             throws IOException

Throws:

IOException

listAll

public void listAll(String likeFolderName,
 String likeFileName,
 CacheArray rows)
             throws IOException

Throws:

IOException

listAllForDelete

protected void listAllForDelete(String likeFolderName,
 String likeFileName,
 CacheArray rows)
                         throws IOException

Throws:

IOException

listAllForSync

protected void listAllForSync(String likeFolderName,
 String likeFileName,
 CacheArray rows)
                       throws IOException

Throws:

IOException

setModifyUserId

public void setModifyUserId(String modifyUserId)

getDefaultModifyUserId

private String getDefaultModifyUserId()

setModifyTime

public void setModifyTime(Timestamp modifyTime)
                   throws IOException

Specified by:

setModifyTime in class BaseFile

Throws:

IOException

getModifyTime

public Timestamp getModifyTime()
                        throws IOException

Specified by:

getModifyTime in class BaseFile

Throws:

IOException

isTimeout

public boolean isTimeout()
                  throws IOException

Throws:

IOException

copyTo

public void copyTo(String toPath)
            throws IOException

Specified by:

copyTo in class BaseFile

Throws:

IOException

moveTo

public void moveTo(String toPath)
            throws IOException

Specified by:

moveTo in class BaseFile

Throws:

IOException

startFullAsyncThreadForDelete

private void startFullAsyncThreadForDelete(boolean subFolders,
 long timerMs,
 String replaceTo,
 Runnable completedCallback)

startFullAsyncThread

private void startFullAsyncThread(boolean subFolders,
 long timerMs,
 String replaceTo,
 Runnable completedCallback)

startFullAsync

public void startFullAsync(long timerMs)
                    throws IOException

Throws:

IOException

startFullAsync

public void startFullAsync(long timerMs,
 Runnable completedCallback)
                    throws IOException

Throws:

IOException

startFullAsync

public void startFullAsync(long timerMs,
 String replaceTo)
                    throws IOException

Throws:

IOException

startFullAsync

public void startFullAsync(long timerMs,
 String replaceTo,
 Runnable completedCallback)
                    throws IOException

Throws:

IOException

getDataSourceReader

public DriverDataSource getDataSourceReader()

getDataSourceWriter

public DriverDataSource getDataSourceWriter()

getConfigProperties

public ConfigProperties getConfigProperties()

encrypt

private byte[] encrypt(byte[] data)
                throws Exception

Throws:

Exception

decrypt

private byte[] decrypt(byte[] encData)
                throws Exception

Throws:

Exception

getSyncedOnHostnames

public String getSyncedOnHostnames()
                            throws IOException

Throws:

IOException

getDeletedOnHostnames

public String getDeletedOnHostnames()
                             throws IOException

Throws:

IOException

getSourceHostname

public String getSourceHostname()
                         throws IOException

Throws:

IOException

getLastSourceHostname

protected String getLastSourceHostname()
                                throws IOException

Throws:

IOException

getLastOperateTime

protected Timestamp getLastOperateTime()
                                throws IOException

Throws:

IOException

getLastModifyTime

protected Timestamp getLastModifyTime()
                               throws IOException

Throws:

IOException

isLastOperateDelete

protected boolean isLastOperateDelete()
                               throws IOException

Throws:

IOException

isLastOperateRealDelete

protected boolean isLastOperateRealDelete()
                                   throws IOException

Throws:

IOException

listAllForScanDelete

protected void listAllForScanDelete(Integer filePartDataTable,
 CacheArray rows)
                             throws IOException

Throws:

IOException

isSyncedOnHostname

protected boolean isSyncedOnHostname()
                              throws IOException

Throws:

IOException

isSyncedOnHostname

protected boolean isSyncedOnHostname(Object id)
                              throws IOException

Throws:

IOException

isDeletedOnHostname

protected boolean isDeletedOnHostname(Object id)
                               throws IOException

Throws:

IOException

getParentFile

public RemoteFile getParentFile()

executeSyncRunnable

private void executeSyncRunnable(CacheArrayFilter filter,
 Map<String,Object> item,
 DiskFile df,
 RemoteFile rf)

getSyncRunnable

private Runnable getSyncRunnable(CacheArrayFilter filter,
 Map<String,Object> item,
 RemoteFile rf,
 DiskFile df)

startArchiveForFileDeleted

public void startArchiveForFileDeleted(long timerMs,
 String archiveTime)
                                throws IOException

Throws:

IOException

startArchiveForFileDeleted

public void startArchiveForFileDeleted(long timerMs,
 long archiveMs)
                                throws IOException

Throws:

IOException

startArchiveForFileDeleted

public void startArchiveForFileDeleted(long timerMs,
 String archiveTime,
 Runnable completedCallback)
                                throws IOException

Throws:

IOException

startArchiveForFileDeleted

public void startArchiveForFileDeleted(long timerMs,
 long archiveMs,
 Runnable completedCallback)
                                throws IOException

Throws:

IOException

startArchiveForDeleted

public void startArchiveForDeleted(long timerMs,
 String archiveTime)
                            throws IOException

Throws:

IOException

startArchiveForDeleted

public void startArchiveForDeleted(long timerMs,
 long archiveMs)
                            throws IOException

Throws:

IOException

startArchiveForDeleted

public void startArchiveForDeleted(long timerMs,
 String archiveTime,
 Runnable completedCallback)
                            throws IOException

Throws:

IOException

startArchiveForDeleted

public void startArchiveForDeleted(long timerMs,
 long archiveMs,
 Runnable completedCallback)
                            throws IOException

Throws:

IOException

startArchiveForTimeout

public void startArchiveForTimeout(long timerMs)
                            throws IOException

Throws:

IOException

startArchiveForTimeout

public void startArchiveForTimeout(long timerMs,
 Runnable completedCallback)
                            throws IOException

Throws:

IOException

getDriverDataSourceMap

public static Map<String,DriverDataSource> getDriverDataSourceMap()

generateId

private static String generateId(boolean identityCardEnable,
 String identityCardName,
 String identityCardPrefix,
 int identityCardSuffix)
                          throws SQLException

Throws:

SQLException

generateDataId

private static String generateDataId(boolean identityCardEnable,
 String identityCardName,
 int identityCardSuffix,
 RemoteFile theRf)
                              throws SQLException

Throws:

SQLException

addQueuePathMapping

protected static boolean addQueuePathMapping(String path)

checkQueuePathMapping

public static boolean checkQueuePathMapping()

removeQueuePathMapping

protected static void removeQueuePathMapping(String path)

getQueuePathMapping

public static Map<String,Long> getQueuePathMapping()

loadDataMapping

protected static void loadDataMapping(RemoteFile rf)
                               throws Exception

Throws:

Exception

calculateDataMappingDataSourceReader

protected static void calculateDataMappingDataSourceReader(RemoteFile rf,
 Map<String,Object> rfRecord)

calculateDataMappingDataSourceWriter

protected static void calculateDataMappingDataSourceWriter(RemoteFile rf)

getDataMapping

protected static ConfigProperties getDataMapping(RemoteFile rf,
 int index)

getDataMappingTableName

protected String getDataMappingTableName()

debugLog

private static void debugLog(String point,
 RemoteFile rf,
 CacheArrayFilter filter)