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 and Description
FileSyncService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
void	acknowledgeFiles(OutgoingBatch outgoingBatch)
void	clearCache()
void	deleteAllFileTriggerRouters()
void	deleteFileTrigger(FileTrigger fileTrigger)
void	deleteFileTriggerRouter(FileTriggerRouter fileTriggerRouter)
void	deleteFileTriggerRouter(java.lang.String triggerId, java.lang.String routerId)
protected void	deleteFromFileIncoming()
void	execute(NodeCommunication nodeCommunication, RemoteNodeStatus status)
protected java.lang.String	findSourceNodeIdFromFileIncoming(java.lang.String filePath, java.lang.String fileName, long lastUpdateDate)
protected java.util.List<OutgoingBatch>	getBatchesToProcess(Node targetNode)
java.io.File	getControleFile(java.io.File file)
DirectorySnapshot	getDirectorySnapshot(FileTriggerRouter fileTriggerRouter)
DirectorySnapshot	getDirectorySnapshot(FileTriggerRouter fileTriggerRouter, java.lang.String relativeDir)
protected java.lang.String	getEffectiveBaseDir(java.lang.String baseDir)
FileTrigger	getFileTrigger(java.lang.String triggerId)
FileTriggerRouter	getFileTriggerRouter(java.lang.String triggerId, java.lang.String routerId, boolean refreshCache)
java.util.List<FileTriggerRouter>	getFileTriggerRouters(boolean refreshCache)
java.util.List<FileTriggerRouter>	getFileTriggerRoutersForCurrentNode(boolean refreshCache)
java.util.List<FileTrigger>	getFileTriggers()
protected org.jumpmind.symmetric.io.stage.IStagedResource	getStagedResource(OutgoingBatch currentBatch)
java.lang.Object[]	getStagingPathComponents(OutgoingBatch fileSyncBatch)
void	loadFilesFromPush(java.lang.String nodeId, java.io.InputStream in, java.io.OutputStream out)
protected java.util.List<IncomingBatch>	processZip(java.io.InputStream is, java.lang.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, java.lang.String clusterLock, NodeCommunication.CommunicationType type)
boolean	refreshFromDatabase()
void	save(org.jumpmind.db.sql.ISqlTransaction sqlTransaction, FileSnapshot snapshot)
void	save(java.util.List<FileSnapshot> changes)
void	save(java.util.List<FileSnapshot> changes, boolean shouldIgnore)
protected long	saveDirectorySnapshot(FileTriggerRouter fileTriggerRouter, DirectorySnapshot dirSnapshot, boolean shouldIgnore)
void	saveFileTrigger(FileTrigger fileTrigger)
void	saveFileTriggerRouter(FileTriggerRouter fileTriggerRouter)
java.util.List<OutgoingBatch>	sendFiles(ProcessInfo processInfo, Node targetNode, IOutgoingTransport outgoingTransport)
protected void	setInterpreterVariables(ISymmetricEngine engine, java.lang.String sourceNodeId, java.io.File batchDir, bsh.Interpreter interpreter)
protected boolean	shouldIgnoreInitialFiles(FileTriggerRouter router, FileTrigger trigger, java.util.Date contextDate)
void	trackChanges(boolean force)
protected void	trackChanges(ProcessInfo processInfo, boolean useCrc)
protected void	trackChangesFastScan(ProcessInfo processInfo, boolean useCrc)
protected void	updateFileIncoming(java.lang.String nodeId, java.util.Map<java.lang.String,java.lang.String> filesToEventType)

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

fireOffline, fireOnline, getHttpException, getRootCause, isAuthenticationExpired, isBusy, isNoReservation, isNotAuthenticated, isOffline, isRegistrationNotOpen, isRegistrationPending, isRegistrationRequired, isServiceUnavailable, isSyncDisabled, shouldLogTransportError

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

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, 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 Detail

FileSyncService

public FileSyncService(ISymmetricEngine engine)

Method Detail

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)

shouldIgnoreInitialFiles

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

saveDirectorySnapshot

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

findSourceNodeIdFromFileIncoming

protected java.lang.String findSourceNodeIdFromFileIncoming(java.lang.String filePath,
                                                            java.lang.String fileName,
                                                            long lastUpdateDate)

deleteFromFileIncoming

protected void deleteFromFileIncoming()

getFileTriggers

public java.util.List<FileTrigger> getFileTriggers()

Specified by:

getFileTriggers in interface IFileSyncService

getFileTrigger

public FileTrigger getFileTrigger(java.lang.String triggerId)

Specified by:

getFileTrigger in interface IFileSyncService

getFileTriggerRoutersForCurrentNode

public java.util.List<FileTriggerRouter> getFileTriggerRoutersForCurrentNode(boolean refreshCache)

Specified by:

getFileTriggerRoutersForCurrentNode in interface IFileSyncService

getFileTriggerRouters

public java.util.List<FileTriggerRouter> getFileTriggerRouters(boolean refreshCache)

Specified by:

getFileTriggerRouters in interface IFileSyncService

getFileTriggerRouter

public FileTriggerRouter getFileTriggerRouter(java.lang.String triggerId,
                                              java.lang.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

saveFileTriggerRouter

public void saveFileTriggerRouter(FileTriggerRouter fileTriggerRouter)

Specified by:

saveFileTriggerRouter in interface IFileSyncService

deleteFileTriggerRouter

public void deleteFileTriggerRouter(java.lang.String triggerId,
                                    java.lang.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

getDirectorySnapshot

public DirectorySnapshot getDirectorySnapshot(FileTriggerRouter fileTriggerRouter)

Specified by:

getDirectorySnapshot in interface IFileSyncService

getDirectorySnapshot

public DirectorySnapshot getDirectorySnapshot(FileTriggerRouter fileTriggerRouter,
                                              java.lang.String relativeDir)

save

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

save

public void save(org.jumpmind.db.sql.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 java.lang.Object[] getStagingPathComponents(OutgoingBatch fileSyncBatch)

Specified by:

getStagingPathComponents in interface IFileSyncService

sendFiles

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

Specified by:

sendFiles in interface IFileSyncService

getBatchesToProcess

protected java.util.List<OutgoingBatch> getBatchesToProcess(Node targetNode)

acknowledgeFiles

public void acknowledgeFiles(OutgoingBatch outgoingBatch)

Specified by:

acknowledgeFiles in interface IFileSyncService

loadFilesFromPush

public void loadFilesFromPush(java.lang.String nodeId,
                              java.io.InputStream in,
                              java.io.OutputStream out)

Specified by:

loadFilesFromPush in interface IFileSyncService

getStagedResource

protected org.jumpmind.symmetric.io.stage.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 java.util.List<IncomingBatch> processZip(java.io.InputStream is,
                                                   java.lang.String sourceNodeId,
                                                   ProcessInfo processInfo)
                                            throws java.io.IOException

Throws:

java.io.IOException

setInterpreterVariables

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

Throws:

bsh.EvalError

updateFileIncoming

protected void updateFileIncoming(java.lang.String nodeId,
                                  java.util.Map<java.lang.String,java.lang.String> filesToEventType)

pullFilesFromNode

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

queueJob

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

getEffectiveBaseDir

protected java.lang.String getEffectiveBaseDir(java.lang.String baseDir)

getControleFile

public java.io.File getControleFile(java.io.File file)

Specified by:

getControleFile in interface IFileSyncService

save

public void save(java.util.List<FileSnapshot> changes)

Specified by:

save in interface IFileSyncService