Package org.jumpmind.symmetric.service.impl

Class FileSyncService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.AbstractOfflineDetectorService

org.jumpmind.symmetric.service.impl.FileSyncService

All Implemented Interfaces:

IFileSyncService, INodeCommunicationService.INodeCommunicationExecutor, IOfflineDetectorService, IService

public class FileSyncService
extends AbstractOfflineDetectorService
implements IFileSyncService, INodeCommunicationService.INodeCommunicationExecutor

Field Summary

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractOfflineDetectorService

extensionService

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor	Description
FileSyncService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
void	acknowledgeFiles(OutgoingBatch outgoingBatch)
protected boolean	checkSourceDir(FileTriggerRouter fileTriggerRouter)
void	clearCache()
void	deleteAllFileTriggerRouters()
void	deleteAllFileTriggers()
void	deleteFileTrigger(FileTrigger fileTrigger)
void	deleteFileTriggerRouter(String triggerId, String routerId)
void	deleteFileTriggerRouter(FileTriggerRouter fileTriggerRouter)
protected void	deleteFromFileIncoming()
void	execute(NodeCommunication nodeCommunication, RemoteNodeStatus status)
protected String	findSourceNodeIdFromFileIncoming(String filePath, String fileName, long lastUpdateDate)
protected List<OutgoingBatch>	getBatchesToProcess(Node targetNode)
File	getControleFile(File file)
DirectorySnapshot	getDirectorySnapshot(FileTriggerRouter fileTriggerRouter)
DirectorySnapshot	getDirectorySnapshot(FileTriggerRouter fileTriggerRouter, String relativeDir)
protected String	getEffectiveBaseDir(String baseDir)
FileTrigger	getFileTrigger(String triggerId)
FileTriggerRouter	getFileTriggerRouter(String triggerId, String routerId, boolean refreshCache)
List<FileTriggerRouter>	getFileTriggerRouters(boolean refreshCache)
List<FileTriggerRouter>	getFileTriggerRoutersForCurrentNode(boolean refreshCache)
List<FileTriggerRouter>	getFileTriggerRoutersFromDb()
List<FileTrigger>	getFileTriggers()
protected IStagedResource	getStagedResource(OutgoingBatch currentBatch)
Object[]	getStagingPathComponents(OutgoingBatch fileSyncBatch)
void	loadFilesFromPush(String nodeId, InputStream in, OutputStream out)
protected List<IncomingBatch>	processZip(InputStream is, String sourceNodeId, ProcessInfo processInfo)
protected void	pullFilesFromNode(NodeCommunication nodeCommunication, RemoteNodeStatus status, Node identity, NodeSecurity security)
RemoteNodeStatuses	pullFilesFromNodes(boolean force)
protected void	pushFilesToNode(NodeCommunication nodeCommunication, RemoteNodeStatus status, Node identity, NodeSecurity security)
RemoteNodeStatuses	pushFilesToNodes(boolean force)
protected RemoteNodeStatuses	queueJob(boolean force, long minimumPeriodMs, String clusterLock, NodeCommunication.CommunicationType type)
boolean	refreshFromDatabase()
void	renameFileTrigger(String oldId, FileTrigger fileTrigger)
void	renameFileTriggerRouter(String oldTriggerId, String oldRouterId, FileTriggerRouter fileTriggerRouter)
void	save(List<FileSnapshot> changes)
void	save(List<FileSnapshot> changes, boolean shouldIgnore)
void	save(ISqlTransaction sqlTransaction, FileSnapshot snapshot)
protected long	saveDirectorySnapshot(FileTriggerRouter fileTriggerRouter, DirectorySnapshot dirSnapshot, boolean shouldIgnore)
void	saveFileTrigger(FileTrigger fileTrigger)
void	saveFileTriggerAsCopy(String originalId, FileTrigger fileTrigger)
void	saveFileTriggerRouter(FileTriggerRouter fileTriggerRouter)
List<OutgoingBatch>	sendFiles(ProcessInfo processInfo, Node targetNode, IOutgoingTransport outgoingTransport)
protected void	setInterpreterVariables(ISymmetricEngine engine, String sourceNodeId, File batchDir, bsh.Interpreter interpreter)
protected boolean	shouldIgnoreInitialFiles(FileTriggerRouter router, FileTrigger trigger, Date contextDate)
void	trackChanges(boolean force)
protected void	trackChanges(ProcessInfo processInfo, boolean useCrc)
protected void	trackChangesFastScan(ProcessInfo processInfo, boolean useCrc)
protected void	updateFileIncoming(String nodeId, Map<String,String> filesToEventType)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractOfflineDetectorService

fireOffline, fireOnline, getExceptionMessage, getHttpException, is, isAuthenticationExpired, isBusy, isDuplicateConnection, isInitialLoadPending, isNoReservation, isNotAuthenticated, isOffline, isRegistrationNotOpen, isRegistrationPending, isRegistrationRequired, isServiceNotReady, isServiceUnavailable, isSyncDisabled, logTransportMessage, shouldLogTransportError

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchOrderBy, buildBatchParams, buildBatchWhere, buildBatchWhereFromFilter, close, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

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

Constructor Details

FileSyncService

public FileSyncService(ISymmetricEngine engine)

Method Details

refreshFromDatabase

public boolean refreshFromDatabase()

Specified by:

refreshFromDatabase in interface IFileSyncService

trackChanges

public void trackChanges(boolean force)

Specified by:

trackChanges in interface IFileSyncService

trackChanges

protected void trackChanges(ProcessInfo processInfo,
 boolean useCrc)

trackChangesFastScan

protected void trackChangesFastScan(ProcessInfo processInfo,
 boolean useCrc)

checkSourceDir

protected boolean checkSourceDir(FileTriggerRouter fileTriggerRouter)

shouldIgnoreInitialFiles

protected boolean shouldIgnoreInitialFiles(FileTriggerRouter router,
 FileTrigger trigger,
 Date contextDate)

saveDirectorySnapshot

protected long saveDirectorySnapshot(FileTriggerRouter fileTriggerRouter,
 DirectorySnapshot dirSnapshot,
 boolean shouldIgnore)

findSourceNodeIdFromFileIncoming

protected String findSourceNodeIdFromFileIncoming(String filePath,
 String fileName,
 long lastUpdateDate)

deleteFromFileIncoming

protected void deleteFromFileIncoming()

getFileTriggers

public List<FileTrigger> getFileTriggers()

Specified by:

getFileTriggers in interface IFileSyncService

getFileTrigger

public FileTrigger getFileTrigger(String triggerId)

Specified by:

getFileTrigger in interface IFileSyncService

getFileTriggerRoutersForCurrentNode

public List<FileTriggerRouter> getFileTriggerRoutersForCurrentNode(boolean refreshCache)

Specified by:

getFileTriggerRoutersForCurrentNode in interface IFileSyncService

getFileTriggerRouters

public List<FileTriggerRouter> getFileTriggerRouters(boolean refreshCache)

Specified by:

getFileTriggerRouters in interface IFileSyncService

getFileTriggerRoutersFromDb

public List<FileTriggerRouter> getFileTriggerRoutersFromDb()

Specified by:

getFileTriggerRoutersFromDb in interface IFileSyncService

getFileTriggerRouter

public FileTriggerRouter getFileTriggerRouter(String triggerId,
 String routerId,
 boolean refreshCache)

Specified by:

getFileTriggerRouter in interface IFileSyncService

clearCache

public void clearCache()

Specified by:

clearCache in interface IFileSyncService

saveFileTrigger

public void saveFileTrigger(FileTrigger fileTrigger)

Specified by:

saveFileTrigger in interface IFileSyncService

saveFileTriggerAsCopy

public void saveFileTriggerAsCopy(String originalId,
 FileTrigger fileTrigger)

Specified by:

saveFileTriggerAsCopy in interface IFileSyncService

renameFileTrigger

public void renameFileTrigger(String oldId,
 FileTrigger fileTrigger)

Specified by:

renameFileTrigger in interface IFileSyncService

saveFileTriggerRouter

public void saveFileTriggerRouter(FileTriggerRouter fileTriggerRouter)

Specified by:

saveFileTriggerRouter in interface IFileSyncService

renameFileTriggerRouter

public void renameFileTriggerRouter(String oldTriggerId,
 String oldRouterId,
 FileTriggerRouter fileTriggerRouter)

Specified by:

renameFileTriggerRouter in interface IFileSyncService

deleteFileTriggerRouter

public void deleteFileTriggerRouter(String triggerId,
 String routerId)

Specified by:

deleteFileTriggerRouter in interface IFileSyncService

deleteAllFileTriggerRouters

public void deleteAllFileTriggerRouters()

Specified by:

deleteAllFileTriggerRouters in interface IFileSyncService

deleteFileTriggerRouter

public void deleteFileTriggerRouter(FileTriggerRouter fileTriggerRouter)

Specified by:

deleteFileTriggerRouter in interface IFileSyncService

deleteFileTrigger

public void deleteFileTrigger(FileTrigger fileTrigger)

Specified by:

deleteFileTrigger in interface IFileSyncService

deleteAllFileTriggers

public void deleteAllFileTriggers()

Specified by:

deleteAllFileTriggers in interface IFileSyncService

getDirectorySnapshot

public DirectorySnapshot getDirectorySnapshot(FileTriggerRouter fileTriggerRouter)

Specified by:

getDirectorySnapshot in interface IFileSyncService

getDirectorySnapshot

public DirectorySnapshot getDirectorySnapshot(FileTriggerRouter fileTriggerRouter,
 String relativeDir)

save

public void save(List<FileSnapshot> changes,
 boolean shouldIgnore)

save

public void save(ISqlTransaction sqlTransaction,
 FileSnapshot snapshot)

pullFilesFromNodes

public RemoteNodeStatuses pullFilesFromNodes(boolean force)

Specified by:

pullFilesFromNodes in interface IFileSyncService

pushFilesToNodes

public RemoteNodeStatuses pushFilesToNodes(boolean force)

Specified by:

pushFilesToNodes in interface IFileSyncService

getStagingPathComponents

public Object[] getStagingPathComponents(OutgoingBatch fileSyncBatch)

Specified by:

getStagingPathComponents in interface IFileSyncService

sendFiles

public List<OutgoingBatch> sendFiles(ProcessInfo processInfo,
 Node targetNode,
 IOutgoingTransport outgoingTransport)

Specified by:

sendFiles in interface IFileSyncService

getBatchesToProcess

protected List<OutgoingBatch> getBatchesToProcess(Node targetNode)

acknowledgeFiles

public void acknowledgeFiles(OutgoingBatch outgoingBatch)

Specified by:

acknowledgeFiles in interface IFileSyncService

loadFilesFromPush

public void loadFilesFromPush(String nodeId,
 InputStream in,
 OutputStream out)

Specified by:

loadFilesFromPush in interface IFileSyncService

getStagedResource

protected IStagedResource getStagedResource(OutgoingBatch currentBatch)

execute

public void execute(NodeCommunication nodeCommunication,
 RemoteNodeStatus status)

Specified by:

execute in interface INodeCommunicationService.INodeCommunicationExecutor

pushFilesToNode

protected void pushFilesToNode(NodeCommunication nodeCommunication,
 RemoteNodeStatus status,
 Node identity,
 NodeSecurity security)

processZip

protected List<IncomingBatch> processZip(InputStream is,
 String sourceNodeId,
 ProcessInfo processInfo)
                                  throws IOException

Throws:

IOException

setInterpreterVariables

protected void setInterpreterVariables(ISymmetricEngine engine,
 String sourceNodeId,
 File batchDir,
 bsh.Interpreter interpreter)
                                throws bsh.EvalError

Throws:

bsh.EvalError

updateFileIncoming

protected void updateFileIncoming(String nodeId,
 Map<String,String> filesToEventType)

pullFilesFromNode

protected void pullFilesFromNode(NodeCommunication nodeCommunication,
 RemoteNodeStatus status,
 Node identity,
 NodeSecurity security)

queueJob

protected RemoteNodeStatuses queueJob(boolean force,
 long minimumPeriodMs,
 String clusterLock,
 NodeCommunication.CommunicationType type)

getEffectiveBaseDir

protected String getEffectiveBaseDir(String baseDir)

getControleFile

public File getControleFile(File file)

Specified by:

getControleFile in interface IFileSyncService

save

public void save(List<FileSnapshot> changes)

Specified by:

save in interface IFileSyncService