com.google.enterprise.connector.util.diffing.testing

Class FakeDocumentSnapshotRepositoryMonitorManager

java.lang.Object

com.google.enterprise.connector.util.diffing.testing.FakeDocumentSnapshotRepositoryMonitorManager

All Implemented Interfaces:

DocumentSnapshotRepositoryMonitorManager

public class FakeDocumentSnapshotRepositoryMonitorManager
extends java.lang.Object
implements DocumentSnapshotRepositoryMonitorManager

A DocumentSnapshotRepositoryMonitorManager for testing.

Since:

2.8

Constructor Summary

Constructors

Constructor and Description
FakeDocumentSnapshotRepositoryMonitorManager(ChangeSource changeSource, junit.framework.TestCase testCase, DocumentHandleFactory internalFactory, DocumentHandleFactory clientFactory) Construct a FakeDocumentSnapshotRepositoryMonitorManager for testing.

Method Summary

Modifier and Type	Method and Description
void	acceptGuarantees(java.util.Map<java.lang.String,MonitorCheckpoint> guarantees) Receives information specifying what is guaranteed to be delivered to GSA.
void	clean() Removes persisted state for DocumentSnapshotRepositoryMonitor threads.
CheckpointAndChangeQueue	getCheckpointAndChangeQueue() Returns the CheckpointAndChangeQueue for this DocumentSnapshotRepositoryMonitorManager
int	getCleanCount() Returns the number of times clean() has been called.
int	getGuaranteeCount() Returns the number of times acceptGuarantees(java.util.Map<java.lang.String, com.google.enterprise.connector.util.diffing.MonitorCheckpoint>) has been called.
int	getStartCount() Returns the number of times start(String) has been called.
int	getStopCount() Returns the number of times stop() has been called.
int	getThreadCount() Returns the number of DocumentSnapshotRepositoryMonitor threads that are alive.
boolean	isRunning() Returns whether we are after a start() call and before a stop().
void	setTraversalSchedule(TraversalSchedule traversalSchedule) Receives TraversalSchedule from TraversalManager which is TraversalScheduleAware.
void	start(java.lang.String checkpoint) Ensures all monitor threads are running.
void	stop() Stops all the configured DocumentSnapshotRepositoryMonitor threads.

Methods inherited from class java.lang.Object

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

Constructor Detail

FakeDocumentSnapshotRepositoryMonitorManager

public FakeDocumentSnapshotRepositoryMonitorManager(ChangeSource changeSource,
                                                    junit.framework.TestCase testCase,
                                                    DocumentHandleFactory internalFactory,
                                                    DocumentHandleFactory clientFactory)
                                             throws java.io.IOException

Construct a FakeDocumentSnapshotRepositoryMonitorManager for testing.

Parameters:

changeSource - ChangeSource

testCase - a JUnit TestCase

internalFactory - a DocumentHandleFactory

clientFactory - a DocumentHandleFactory

Throws:

java.io.IOException

Method Detail

clean

public void clean()

Description copied from interface: DocumentSnapshotRepositoryMonitorManager

Removes persisted state for DocumentSnapshotRepositoryMonitor threads. After calling this DocumentSnapshotRepositoryMonitor threads will no longer be able to resume from where they left off last time.

Specified by:

clean in interface DocumentSnapshotRepositoryMonitorManager

getThreadCount

public int getThreadCount()

Description copied from interface: DocumentSnapshotRepositoryMonitorManager

Returns the number of DocumentSnapshotRepositoryMonitor threads that are alive. This method is for testing purposes.

Specified by:

getThreadCount in interface DocumentSnapshotRepositoryMonitorManager

start

public void start(java.lang.String checkpoint)

Description copied from interface: DocumentSnapshotRepositoryMonitorManager

Ensures all monitor threads are running.

Specified by:

start in interface DocumentSnapshotRepositoryMonitorManager

Parameters:

checkpoint - for the last completed document or null if none have been completed.

stop

public void stop()

Description copied from interface: DocumentSnapshotRepositoryMonitorManager

Stops all the configured DocumentSnapshotRepositoryMonitor threads.

Specified by:

stop in interface DocumentSnapshotRepositoryMonitorManager

getStartCount

public int getStartCount()

Returns the number of times start(String) has been called.

getStopCount

public int getStopCount()

Returns the number of times stop() has been called.

getCleanCount

public int getCleanCount()

Returns the number of times clean() has been called.

getGuaranteeCount

public int getGuaranteeCount()

Returns the number of times acceptGuarantees(java.util.Map<java.lang.String, com.google.enterprise.connector.util.diffing.MonitorCheckpoint>) has been called.

getCheckpointAndChangeQueue

public CheckpointAndChangeQueue getCheckpointAndChangeQueue()

Description copied from interface: DocumentSnapshotRepositoryMonitorManager

Returns the CheckpointAndChangeQueue for this DocumentSnapshotRepositoryMonitorManager

Specified by:

getCheckpointAndChangeQueue in interface DocumentSnapshotRepositoryMonitorManager

isRunning

public boolean isRunning()

Description copied from interface: DocumentSnapshotRepositoryMonitorManager

Returns whether we are after a start() call and before a stop().

Specified by:

isRunning in interface DocumentSnapshotRepositoryMonitorManager

acceptGuarantees

public void acceptGuarantees(java.util.Map<java.lang.String,MonitorCheckpoint> guarantees)

Description copied from interface: DocumentSnapshotRepositoryMonitorManager

Receives information specifying what is guaranteed to be delivered to GSA. Every entry in passed in Map is a monitor name and MonitorCheckpoint. The monitor of that name can expect that all documents before and including document related with MonitorCheckpoint will be delivered to GSA. This information is for the convenience and efficiency of the Monitor so that it knows how many changes it has to resend. It's valid for a monitor to ignore these updates if it feels like it for some good reason. FileConnectorSystemMonitor instances use this information to trim their file system snapshots.

Specified by:

acceptGuarantees in interface DocumentSnapshotRepositoryMonitorManager

setTraversalSchedule

public void setTraversalSchedule(TraversalSchedule traversalSchedule)

Description copied from interface: DocumentSnapshotRepositoryMonitorManager

Receives TraversalSchedule from TraversalManager which is TraversalScheduleAware.

Specified by:

setTraversalSchedule in interface DocumentSnapshotRepositoryMonitorManager