Package org.apache.manifoldcf.crawler.system

Class ManifoldCF

java.lang.Object

org.apache.manifoldcf.core.system.ManifoldCF

org.apache.manifoldcf.agents.system.ManifoldCF

org.apache.manifoldcf.crawler.system.ManifoldCF

public class ManifoldCF
extends ManifoldCF

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	ManifoldCF.PipelineStage

Nested classes/interfaces inherited from class org.apache.manifoldcf.core.system.ManifoldCF

ManifoldCF.CachePoll, ManifoldCF.DatabaseConnectionReleaseThread, ManifoldCF.DatabaseShutdown, ManifoldCF.FileTrack, ManifoldCF.OverrideableManifoldCFConfiguration, ManifoldCF.ShutdownThread

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	_rcsid
protected static java.lang.String	API_ACTIVITYNODE
protected static java.lang.String	API_AUTHORITYCONNECTIONNODE
protected static java.lang.String	API_AUTHORITYCONNECTORNODE
protected static java.lang.String	API_AUTHORITYGROUPNODE
protected static java.lang.String	API_AUTHORIZATIONDOMAINNODE
protected static java.lang.String	API_CHECKRESULTNODE
protected static java.lang.String	API_COLUMNNODE
protected static java.lang.String	API_CONNECTIONNAMENODE
protected static java.lang.String	API_JOBIDNODE
protected static java.lang.String	API_JOBNODE
protected static java.lang.String	API_JOBSTATUSNODE
protected static java.lang.String	API_MAPPINGCONNECTIONNODE
protected static java.lang.String	API_MAPPINGCONNECTORNODE
protected static java.lang.String	API_NAMENODE
protected static java.lang.String	API_NOTIFICATIONCONNECTIONNODE
protected static java.lang.String	API_NOTIFICATIONCONNECTORNODE
protected static java.lang.String	API_OUTPUTCONNECTIONNODE
protected static java.lang.String	API_OUTPUTCONNECTORNODE
protected static java.lang.String	API_REPOSITORYCONNECTIONNODE
protected static java.lang.String	API_REPOSITORYCONNECTORNODE
protected static java.lang.String	API_ROWNODE
protected static java.lang.String	API_TRANSFORMATIONCONNECTIONNODE
protected static java.lang.String	API_TRANSFORMATIONCONNECTORNODE
protected static java.lang.String	API_VALUENODE
protected static java.lang.String	ATTRIBUTE_CLASS
protected static java.lang.String	ATTRIBUTE_DOMAIN
protected static java.lang.String	ATTRIBUTE_NAME
protected static java.lang.String	AUTHGROUPNODE_DESCRIPTION
protected static java.lang.String	AUTHGROUPNODE_ISNEW
protected static java.lang.String	AUTHGROUPNODE_NAME
protected static java.lang.String	AUTHORIZATIONDOMAINNODE_DESCRIPTION
protected static java.lang.String	AUTHORIZATIONDOMAINNODE_DOMAINNAME
protected static java.lang.String	cleanupThreadCountProperty
protected static java.lang.String	CONNECTIONNODE_ACLAUTHORITY
protected static java.lang.String	CONNECTIONNODE_AUTHDOMAIN
protected static java.lang.String	CONNECTIONNODE_AUTHGROUP
protected static java.lang.String	CONNECTIONNODE_CLASSNAME
protected static java.lang.String	CONNECTIONNODE_CONFIGURATION
protected static java.lang.String	CONNECTIONNODE_DESCRIPTION
protected static java.lang.String	CONNECTIONNODE_ISNEW
protected static java.lang.String	CONNECTIONNODE_MATCH
protected static java.lang.String	CONNECTIONNODE_MATCHDESCRIPTION
protected static java.lang.String	CONNECTIONNODE_MAXCONNECTIONS
protected static java.lang.String	CONNECTIONNODE_NAME
protected static java.lang.String	CONNECTIONNODE_PREREQUISITE
protected static java.lang.String	CONNECTIONNODE_RATE
protected static java.lang.String	CONNECTIONNODE_THROTTLE
protected static java.lang.String	CONNECTORNODE_CLASSNAME
protected static java.lang.String	CONNECTORNODE_DESCRIPTION
protected static java.lang.String	connectorsConfigurationFileProperty
protected static boolean	crawlerInitialized
protected static java.lang.String	databaseSuperuserNameProperty
protected static java.lang.String	databaseSuperuserPasswordProperty
static int	DELETERESULT_FOUND
static int	DELETERESULT_NOTALLOWED
static int	DELETERESULT_NOTFOUND
protected static java.lang.String	deleteThreadCountProperty
protected static java.util.Map<java.lang.String,java.lang.Integer>	docState
protected static java.util.Map<java.lang.String,java.lang.Integer>	docStatus
protected static java.lang.String	expireThreadCountProperty
protected static java.lang.String	JOBNODE_CONNECTIONNAME
protected static java.lang.String	JOBNODE_COUNT
protected static java.lang.String	JOBNODE_DAYOFMONTH
protected static java.lang.String	JOBNODE_DAYOFWEEK
protected static java.lang.String	JOBNODE_DESCRIPTION
protected static java.lang.String	JOBNODE_DOCUMENTSPECIFICATION
protected static java.lang.String	JOBNODE_DURATION
protected static java.lang.String	JOBNODE_ENUMVALUE
protected static java.lang.String	JOBNODE_EXPIRATIONINTERVAL
protected static java.lang.String	JOBNODE_HOPCOUNT
protected static java.lang.String	JOBNODE_HOPCOUNTMODE
protected static java.lang.String	JOBNODE_HOUROFDAY
protected static java.lang.String	JOBNODE_ID
protected static java.lang.String	JOBNODE_LINKTYPE
protected static java.lang.String	JOBNODE_MAXRECRAWLINTERVAL
protected static java.lang.String	JOBNODE_MINUTESOFHOUR
protected static java.lang.String	JOBNODE_MONTHOFYEAR
protected static java.lang.String	JOBNODE_NOTIFICATIONSTAGE
protected static java.lang.String	JOBNODE_PARAMNAME
protected static java.lang.String	JOBNODE_PARAMVALUE
protected static java.lang.String	JOBNODE_PIPELINESTAGE
protected static java.lang.String	JOBNODE_PRIORITY
protected static java.lang.String	JOBNODE_RECRAWLINTERVAL
protected static java.lang.String	JOBNODE_REQUESTMINIMUM
protected static java.lang.String	JOBNODE_RESEEDINTERVAL
protected static java.lang.String	JOBNODE_RUNMODE
protected static java.lang.String	JOBNODE_SCHEDULE
protected static java.lang.String	JOBNODE_STAGECONNECTIONNAME
protected static java.lang.String	JOBNODE_STAGEDESCRIPTION
protected static java.lang.String	JOBNODE_STAGEID
protected static java.lang.String	JOBNODE_STAGEISOUTPUT
protected static java.lang.String	JOBNODE_STAGEPREREQUISITE
protected static java.lang.String	JOBNODE_STAGESPECIFICATION
protected static java.lang.String	JOBNODE_STARTMODE
protected static java.lang.String	JOBNODE_TIMEZONE
protected static java.lang.String	JOBNODE_YEAR
protected static java.lang.String	JOBSTATUSNODE_DOCUMENTSINQUEUE
protected static java.lang.String	JOBSTATUSNODE_DOCUMENTSOUTSTANDING
protected static java.lang.String	JOBSTATUSNODE_DOCUMENTSPROCESSED
protected static java.lang.String	JOBSTATUSNODE_ENDTIME
protected static java.lang.String	JOBSTATUSNODE_ERRORTEXT
protected static java.lang.String	JOBSTATUSNODE_JOBID
protected static java.lang.String	JOBSTATUSNODE_OUTSTANDINGEXACT
protected static java.lang.String	JOBSTATUSNODE_PROCESSEDEXACT
protected static java.lang.String	JOBSTATUSNODE_QUEUEEXACT
protected static java.lang.String	JOBSTATUSNODE_STARTTIME
protected static java.lang.String	JOBSTATUSNODE_STATUS
protected static java.lang.String	lowWaterFactorProperty
protected static java.lang.String	NODE_AUTHORITYCONNECTOR
protected static java.lang.String	NODE_AUTHORIZATIONDOMAIN
protected static java.lang.String	NODE_MAPPINGCONNECTOR
protected static java.lang.String	NODE_NOTIFICATIONCONNECTOR
protected static java.lang.String	NODE_OUTPUTCONNECTOR
protected static java.lang.String	NODE_REPOSITORYCONNECTOR
protected static java.lang.String	NODE_TRANSFORMATIONCONNECTOR
static int	POSTRESULT_CREATED
static int	POSTRESULT_FOUND
static int	POSTRESULT_NOTALLOWED
static int	POSTRESULT_NOTFOUND
static int	READRESULT_FOUND
static int	READRESULT_NOTALLOWED
static int	READRESULT_NOTFOUND
protected static java.lang.String	stuffAmtFactorProperty
protected static java.lang.String	workerThreadCountProperty
static int	WRITERESULT_CREATED
static int	WRITERESULT_FOUND
static int	WRITERESULT_NOTALLOWED
static int	WRITERESULT_NOTFOUND

Fields inherited from class org.apache.manifoldcf.agents.system.ManifoldCF

agentShutdownSignal, agentsInitialized, API_ERRORNODE, API_SERVICEINTERRUPTIONNODE

Fields inherited from class org.apache.manifoldcf.core.system.ManifoldCF

alreadyClosed, alreadyShutdown, applicationName, ATTRIBUTE_PATH, authImplementation, cleanupHooks, configSignalCommandProperty, databaseConnectionTrackingProperty, databaseHandleMaxcountProperty, databaseHandleTimeoutProperty, databaseImplementation, databaseQueryMaxTimeProperty, dbShutdown, fileResourcesProperty, initializeFlagLock, initializeLevel, IV_LENGTH, lcfConfigFileProperty, localConfiguration, lockManagerImplementation, logConfigFileProperty, maintenanceFileSignalProperty, masterDatabaseName, masterDatabaseNameProperty, masterDatabasePassword, masterDatabasePasswordProperty, masterDatabaseUsername, masterDatabaseUsernameProperty, mcfVersion, NODE_LIBDIR, pollingHooks, processID, processIDProperty, propertyFilelastMod, propertyFilePath, resourceLoader, saltProperty, shutdownThread, tracker, versionProperty, workingDirectory

Constructor Summary

Constructors

Constructor	Description
ManifoldCF()

Method Summary

Modifier and Type	Method	Description
protected static void	addStage(java.lang.String stageName, java.util.List<java.lang.String> orderedStageNames, java.util.Set<java.lang.String> keysSeen, java.util.Map<java.lang.String,ManifoldCF.PipelineStage> pipelineStages)
protected static int	apiDeleteAuthorityConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Delete authority connection.
protected static int	apiDeleteAuthorityGroup(IThreadContext tc, Configuration output, java.lang.String groupName, IAuthorizer authorizer)	Delete authority group.
protected static int	apiDeleteJob(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer)	Delete a job.
protected static int	apiDeleteMappingConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Delete mapping connection.
protected static int	apiDeleteNotificationConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Delete notification connection.
protected static int	apiDeleteOutputConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Delete output connection.
protected static int	apiDeleteRepositoryConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Delete repository connection.
protected static int	apiDeleteTransformationConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Delete transformation connection.
protected static int	apiPostJob(IThreadContext tc, Configuration output, Configuration input, IAuthorizer authorizer)	Post job.
protected static int	apiReadAuthorityConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Read authority connection
protected static int	apiReadAuthorityConnections(IThreadContext tc, Configuration output, IAuthorizer authorizer)	Get authority connections
protected static int	apiReadAuthorityConnectionStatus(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Read an authority connection status
protected static int	apiReadAuthorityConnectors(IThreadContext tc, Configuration output, IAuthorizer authorizer)	List authority connectors
protected static int	apiReadAuthorityGroup(IThreadContext tc, Configuration output, java.lang.String groupName, IAuthorizer authorizer)	Read authority group
protected static int	apiReadAuthorityGroups(IThreadContext tc, Configuration output, IAuthorizer authorizer)	Get authority groups
protected static int	apiReadAuthorizationDomains(IThreadContext tc, Configuration output, IAuthorizer authorizer)	List authorization domains
protected static int	apiReadJob(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer)	Read a job
protected static int	apiReadJobs(IThreadContext tc, Configuration output, IAuthorizer authorizer)	Read jobs
protected static int	apiReadJobStatus(IThreadContext tc, Configuration output, java.lang.Long jobID, java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters, IAuthorizer authorizer)	Get api job status
protected static int	apiReadJobStatuses(IThreadContext tc, Configuration output, java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters, IAuthorizer authorizer)	Get api job statuses
protected static int	apiReadJobStatusesNoCounts(IThreadContext tc, Configuration output, IAuthorizer authorizer)	Get api job statuses
protected static int	apiReadJobStatusNoCounts(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer)	Get api job status with no counts
protected static int	apiReadMappingConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Read mapping connection
protected static int	apiReadMappingConnections(IThreadContext tc, Configuration output, IAuthorizer authorizer)	Get mapping connections
protected static int	apiReadMappingConnectionStatus(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Read a mapping connection status
protected static int	apiReadMappingConnectors(IThreadContext tc, Configuration output, IAuthorizer authorizer)	List mapping connectors
protected static int	apiReadNotificationConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Read notification connection
protected static int	apiReadNotificationConnectionInfo(IThreadContext tc, Configuration output, java.lang.String connectionName, java.lang.String command, IAuthorizer authorizer)	Read a notification connection's info
protected static int	apiReadNotificationConnections(IThreadContext tc, Configuration output, IAuthorizer authorizer)	Get notification connections
protected static int	apiReadNotificationConnectionStatus(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Read a notification connection status
protected static int	apiReadNotificationConnectors(IThreadContext tc, Configuration output, IAuthorizer authorizer)	List notification connectors
protected static int	apiReadOutputConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Read output connection
protected static int	apiReadOutputConnectionInfo(IThreadContext tc, Configuration output, java.lang.String connectionName, java.lang.String command, IAuthorizer authorizer)	Read an output connection's info
protected static int	apiReadOutputConnections(IThreadContext tc, Configuration output, IAuthorizer authorizer)	Get output connections
protected static int	apiReadOutputConnectionStatus(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Read an output connection status
protected static int	apiReadOutputConnectors(IThreadContext tc, Configuration output, IAuthorizer authorizer)	List output connectors
protected static int	apiReadRepositoryConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Read repository connection
protected static int	apiReadRepositoryConnectionActivities(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Read the activity list for a given connection name.
protected static int	apiReadRepositoryConnectionHistory(IThreadContext tc, Configuration output, java.lang.String connectionName, java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters, IAuthorizer authorizer)	History reports
protected static int	apiReadRepositoryConnectionInfo(IThreadContext tc, Configuration output, java.lang.String connectionName, java.lang.String command, IAuthorizer authorizer)	Read a repository connection's info
protected static int	apiReadRepositoryConnectionJobs(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Get jobs for connection
protected static int	apiReadRepositoryConnectionQueue(IThreadContext tc, Configuration output, java.lang.String connectionName, java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters, IAuthorizer authorizer)	Queue reports
protected static int	apiReadRepositoryConnections(IThreadContext tc, Configuration output, IAuthorizer authorizer)	Get repository connections
protected static int	apiReadRepositoryConnectionStatus(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Read a repository connection status
protected static int	apiReadRepositoryConnectors(IThreadContext tc, Configuration output, IAuthorizer authorizer)	List repository connectors
protected static int	apiReadTransformationConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Read transformation connection
protected static int	apiReadTransformationConnectionInfo(IThreadContext tc, Configuration output, java.lang.String connectionName, java.lang.String command, IAuthorizer authorizer)	Read a transformation connection's info
protected static int	apiReadTransformationConnections(IThreadContext tc, Configuration output, IAuthorizer authorizer)	Get transformation connections
protected static int	apiReadTransformationConnectionStatus(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Read a transformation connection status
protected static int	apiReadTransformationConnectors(IThreadContext tc, Configuration output, IAuthorizer authorizer)	List transformation connectors
protected static int	apiWriteAbortJob(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer)	Abort a job.
protected static int	apiWriteAuthorityConnection(IThreadContext tc, Configuration output, Configuration input, java.lang.String connectionName, IAuthorizer authorizer)	Write authority connection.
protected static int	apiWriteAuthorityGroup(IThreadContext tc, Configuration output, Configuration input, java.lang.String groupName, IAuthorizer authorizer)	Write authority group.
protected static int	apiWriteClearHistoryRepositoryConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Clear repository connection history.
protected static int	apiWriteClearOutputConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Clear output connection (remove all recorded documents).
protected static int	apiWriteClearVersionsOutputConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer)	Reset output connection (reset version of all recorded documents).
protected static int	apiWriteJob(IThreadContext tc, Configuration output, Configuration input, java.lang.Long jobID, IAuthorizer authorizer)	Write job.
protected static int	apiWriteMappingConnection(IThreadContext tc, Configuration output, Configuration input, java.lang.String connectionName, IAuthorizer authorizer)	Write mapping connection.
protected static int	apiWriteNotificationConnection(IThreadContext tc, Configuration output, Configuration input, java.lang.String connectionName, IAuthorizer authorizer)	Write notification connection.
protected static int	apiWriteOutputConnection(IThreadContext tc, Configuration output, Configuration input, java.lang.String connectionName, IAuthorizer authorizer)	Write output connection.
protected static int	apiWritePauseJob(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer)	Pause a job.
protected static int	apiWriteRepositoryConnection(IThreadContext tc, Configuration output, Configuration input, java.lang.String connectionName, IAuthorizer authorizer)	Write repository connection.
protected static int	apiWriteReseedJob(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer)	Reset incremental seeding for a job.
protected static int	apiWriteRestartJob(IThreadContext tc, Configuration output, java.lang.Long jobID, boolean requestMinimum, IAuthorizer authorizer)	Restart a job.
protected static int	apiWriteResumeJob(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer)	Resume a job.
protected static int	apiWriteStartJob(IThreadContext tc, Configuration output, java.lang.Long jobID, boolean requestMinimum, IAuthorizer authorizer)	Start a job.
protected static int	apiWriteTransformationConnection(IThreadContext tc, Configuration output, Configuration input, java.lang.String connectionName, IAuthorizer authorizer)	Write transformation connection.
static java.lang.String[]	calculateBins(IRepositoryConnector connector, java.lang.String documentIdentifier)	Given a connector object and a document identifier, calculate its bins.
static void	cleanUpEnvironment(IThreadContext tc)
static java.lang.String	colonStuff(java.lang.String input)	Stuff colons so we can't have conflicts.
static java.lang.String	createConnectionSpecificString(java.lang.String connectionName, java.lang.String simpleString)	Create a connection-specific string
static java.lang.String	createGlobalString(java.lang.String simpleString)	Create a global string
static java.lang.String	createJobSpecificString(java.lang.Long jobID, java.lang.String simpleString)	Create a job-specific string
protected static void	createResultsetNode(Configuration output, IResultSet result, java.lang.String[] resultColumns)	Add a resultset node to the output.
static void	createSystemDatabase(IThreadContext threadContext)	Create system database using superuser properties from properties.xml.
static java.lang.String	decodeAPIPathElement(java.lang.String startingPathElement)	Decode path element.
static void	deinstallSystemTables(IThreadContext threadcontext)	Uninstall all the crawler system tables.
static int	executeDeleteCommand(IThreadContext tc, Configuration output, java.lang.String path, IAuthorizer authorizer)	Execute specified delete command.
static int	executePostCommand(IThreadContext tc, Configuration output, java.lang.String path, Configuration input, IAuthorizer authorizer)	Execute specified post command.
static int	executeReadCommand(IThreadContext tc, Configuration output, java.lang.String path, java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters, IAuthorizer authorizer)	Execute specified read command.
static int	executeWriteCommand(IThreadContext tc, Configuration output, java.lang.String path, Configuration input, IAuthorizer authorizer)	Execute specified write command.
static void	exportConfiguration(IThreadContext threadContext, java.lang.String exportFilename, java.lang.String passCode)	Atomically export the crawler configuration
protected static void	formatAuthorityConnection(ConfigurationNode connectionNode, IAuthorityConnection connection)	Format an authority connection.
protected static void	formatAuthorityGroup(ConfigurationNode groupNode, IAuthorityGroup group)	Format an authority group.
protected static void	formatEnumeratedValues(ConfigurationNode recordNode, java.lang.String childType, EnumeratedValues value)
protected static void	formatJobDescription(ConfigurationNode jobNode, IJobDescription job)	Convert a job description into a ConfigurationNode.
protected static void	formatJobStatus(ConfigurationNode jobStatusNode, JobStatus jobStatus)	Format a job status.
protected static void	formatMappingConnection(ConfigurationNode connectionNode, IMappingConnection connection)	Format a mapping connection.
protected static void	formatNotificationConnection(ConfigurationNode connectionNode, INotificationConnection connection)	Format a notification connection.
protected static void	formatOutputConnection(ConfigurationNode connectionNode, IOutputConnection connection)	Format an output connection.
protected static void	formatRepositoryConnection(ConfigurationNode connectionNode, IRepositoryConnection connection)	Format a repository connection.
protected static void	formatTransformationConnection(ConfigurationNode connectionNode, ITransformationConnection connection)	Format a transformation connection.
static java.lang.String[]	getActivitiesList(IThreadContext threadContext, java.lang.String connectionName)	Get the activities list for a given repository connection.
static int	getMaxCleanupThreads(IThreadContext threadContext)	Get the maximum number of cleanup threads.
static int	getMaxDeleteThreads(IThreadContext threadContext)	Get the maximum number of delete threads.
static int	getMaxExpireThreads(IThreadContext threadContext)	Get the maximum number of expire threads.
static int	getMaxWorkerThreads(IThreadContext threadContext)	Get the maximum number of worker threads.
protected static java.lang.String	hopcountModeMap(int mode)
static void	importConfiguration(IThreadContext threadContext, java.lang.String importFilename, java.lang.String passCode)	Atomically import a crawler configuration
static void	initializeEnvironment(IThreadContext tc)	Initialize environment.
static void	installSystemTables(IThreadContext threadcontext)	Install all the crawler system tables.
protected static java.lang.Long	interpretInterval(java.lang.String interval)
static void	localCleanup(IThreadContext tc)
static void	localInitialize(IThreadContext tc)
protected static int	mapToHopcountMode(java.lang.String mode)
protected static int	mapToRunMode(java.lang.String mode)
protected static int	mapToStartMode(java.lang.String startMethod)
protected static java.lang.String	presentInterval(java.lang.Long interval)
protected static void	processAuthorityConnection(AuthorityConnection connection, ConfigurationNode connectionNode)	Convert input hierarchy into an AuthorityConnection object.
protected static void	processAuthorityGroup(AuthorityGroup group, ConfigurationNode groupNode)	Convert input hierarchy into an AuthorityGroup object.
protected static EnumeratedValues	processEnumeratedValues(ConfigurationNode fieldNode)
protected static void	processJobDescription(JobDescription jobDescription, ConfigurationNode jobNode)	Convert a node into a job description.
protected static void	processMappingConnection(MappingConnection connection, ConfigurationNode connectionNode)	Convert input hierarchy into an MappingConnection object.
protected static void	processNotificationConnection(NotificationConnection connection, ConfigurationNode connectionNode)	Convert input hierarchy into a NotificationConnection object.
protected static void	processOutputConnection(OutputConnection connection, ConfigurationNode connectionNode)	Convert input hierarchy into an OutputConnection object.
protected static void	processRepositoryConnection(RepositoryConnection connection, ConfigurationNode connectionNode)	Convert input hierarchy into a RepositoryConnection object.
protected static void	processTransformationConnection(TransformationConnection connection, ConfigurationNode connectionNode)	Convert input hierarchy into a TransformationConnection object.
static Connectors	readConnectorDeclarations(java.io.File connectorConfigFile)	Read connectors configuration file.
static void	registerConnectors(IThreadContext tc, Connectors c)	Register all connectors as specified by a Connectors structure, usually read from the connectors.xml file.
static void	registerThisAgent(IThreadContext tc)	Register this agent
static void	requeueDocumentsDueToCarrydown(IJobManager jobManager, DocumentDescription[] requeueCandidates, IRepositoryConnector connector, IRepositoryConnection connection, IReprioritizationTracker rt, long currentTime)	Requeue documents due to carrydown.
static void	reregisterAllConnectors(IThreadContext tc)	Register or re-register all connectors, based on a connectors.xml file.
static void	resetAllDocumentPriorities(IThreadContext threadContext, java.lang.String processID)	Reset all (active) document priorities.
protected static java.lang.String	runModeMap(int type)
protected static java.lang.String	startModeMap(int startMethod)
protected static java.lang.String	statusMap(int status)
static void	unregisterAllConnectors(IThreadContext tc)	Unregister all connectors.
static void	unregisterAllConnectors(IThreadContext tc, Connectors c)	Unregister all connectors which don't match a specified connector list.
static void	writeDocumentPriorities(IThreadContext threadContext, DocumentDescription[] descs, java.util.Map<java.lang.String,IRepositoryConnection> connectionMap, java.util.Map<java.lang.Long,IJobDescription> jobDescriptionMap)	Write a set of document priorities, based on the current queue tracker.

Methods inherited from class org.apache.manifoldcf.agents.system.ManifoldCF

createErrorNode, createErrorNode, createServiceInterruptionNode, deinstallTables, findConfigurationNode, getRootArgument, installTables, qualifyOutputActivityName, qualifyTransformationActivityName, resetEnvironment, signalOutputConnectionRedo, signalOutputConnectionRemoved

Methods inherited from class org.apache.manifoldcf.core.system.ManifoldCF

addFile, addPollingHook, addShutdownHook, addToHash, checkMaintenanceUnderway, checkProperties, cleanUpEnvironment, createResourceLoader, createSystemDatabase, createTempDir, decrypt, deleteFile, deleteFolder, deobfuscate, dropSystemDatabase, encrypt, ensureFolder, findClass, getBooleanProperty, getChildDatabaseName, getCipher, getCipher, getConfiguration, getDoubleProperty, getFileProperty, getHashValue, getIntProperty, getLongProperty, getMasterDatabaseName, getMasterDatabasePassword, getMasterDatabaseUsername, getMcfVersion, getProcessID, getProperty, getSaltValue, getSecureRandom, getStringProperty, hash, initializeEnvironment, isFolder, noteConfigurationChange, obfuscate, pollAll, readByte, readByteArray, readBytes, readDword, readfloat, readLong, readNibble, readSdword, readString, readWord, recursiveDelete, registerConnectorServices, resetEnvironment, resolvePath, safeFileName, sleep, startHash, systemExit, writeByte, writeByteArray, writeBytes, writeDword, writefloat, writeLong, writeNibble, writeSdword, writeString, writeWord

Methods inherited from class java.lang.Object

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

Field Detail

_rcsid

public static final java.lang.String _rcsid

See Also:

Constant Field Values

crawlerInitialized

protected static boolean crawlerInitialized

workerThreadCountProperty

protected static final java.lang.String workerThreadCountProperty

See Also:

Constant Field Values

deleteThreadCountProperty

protected static final java.lang.String deleteThreadCountProperty

See Also:

Constant Field Values

cleanupThreadCountProperty

protected static final java.lang.String cleanupThreadCountProperty

See Also:

Constant Field Values

expireThreadCountProperty

protected static final java.lang.String expireThreadCountProperty

See Also:

Constant Field Values

lowWaterFactorProperty

protected static final java.lang.String lowWaterFactorProperty

See Also:

Constant Field Values

stuffAmtFactorProperty

protected static final java.lang.String stuffAmtFactorProperty

See Also:

Constant Field Values

connectorsConfigurationFileProperty

protected static final java.lang.String connectorsConfigurationFileProperty

See Also:

Constant Field Values

databaseSuperuserNameProperty

protected static final java.lang.String databaseSuperuserNameProperty

See Also:

Constant Field Values

databaseSuperuserPasswordProperty

protected static final java.lang.String databaseSuperuserPasswordProperty

See Also:

Constant Field Values

NODE_AUTHORIZATIONDOMAIN

protected static final java.lang.String NODE_AUTHORIZATIONDOMAIN

See Also:

Constant Field Values

NODE_OUTPUTCONNECTOR

protected static final java.lang.String NODE_OUTPUTCONNECTOR

See Also:

Constant Field Values

NODE_TRANSFORMATIONCONNECTOR

protected static final java.lang.String NODE_TRANSFORMATIONCONNECTOR

See Also:

Constant Field Values

NODE_MAPPINGCONNECTOR

protected static final java.lang.String NODE_MAPPINGCONNECTOR

See Also:

Constant Field Values

NODE_AUTHORITYCONNECTOR

protected static final java.lang.String NODE_AUTHORITYCONNECTOR

See Also:

Constant Field Values

NODE_NOTIFICATIONCONNECTOR

protected static final java.lang.String NODE_NOTIFICATIONCONNECTOR

See Also:

Constant Field Values

NODE_REPOSITORYCONNECTOR

protected static final java.lang.String NODE_REPOSITORYCONNECTOR

See Also:

Constant Field Values

ATTRIBUTE_NAME

protected static final java.lang.String ATTRIBUTE_NAME

See Also:

Constant Field Values

ATTRIBUTE_CLASS

protected static final java.lang.String ATTRIBUTE_CLASS

See Also:

Constant Field Values

ATTRIBUTE_DOMAIN

protected static final java.lang.String ATTRIBUTE_DOMAIN

See Also:

Constant Field Values

API_JOBNODE

protected static final java.lang.String API_JOBNODE

See Also:

Constant Field Values

API_JOBSTATUSNODE

protected static final java.lang.String API_JOBSTATUSNODE

See Also:

Constant Field Values

API_AUTHORIZATIONDOMAINNODE

protected static final java.lang.String API_AUTHORIZATIONDOMAINNODE

See Also:

Constant Field Values

API_AUTHORITYGROUPNODE

protected static final java.lang.String API_AUTHORITYGROUPNODE

See Also:

Constant Field Values

API_REPOSITORYCONNECTORNODE

protected static final java.lang.String API_REPOSITORYCONNECTORNODE

See Also:

Constant Field Values

API_NOTIFICATIONCONNECTORNODE

protected static final java.lang.String API_NOTIFICATIONCONNECTORNODE

See Also:

Constant Field Values

API_OUTPUTCONNECTORNODE

protected static final java.lang.String API_OUTPUTCONNECTORNODE

See Also:

Constant Field Values

API_TRANSFORMATIONCONNECTORNODE

protected static final java.lang.String API_TRANSFORMATIONCONNECTORNODE

See Also:

Constant Field Values

API_AUTHORITYCONNECTORNODE

protected static final java.lang.String API_AUTHORITYCONNECTORNODE

See Also:

Constant Field Values

API_MAPPINGCONNECTORNODE

protected static final java.lang.String API_MAPPINGCONNECTORNODE

See Also:

Constant Field Values

API_REPOSITORYCONNECTIONNODE

protected static final java.lang.String API_REPOSITORYCONNECTIONNODE

See Also:

Constant Field Values

API_NOTIFICATIONCONNECTIONNODE

protected static final java.lang.String API_NOTIFICATIONCONNECTIONNODE

See Also:

Constant Field Values

API_OUTPUTCONNECTIONNODE

protected static final java.lang.String API_OUTPUTCONNECTIONNODE

See Also:

Constant Field Values

API_TRANSFORMATIONCONNECTIONNODE

protected static final java.lang.String API_TRANSFORMATIONCONNECTIONNODE

See Also:

Constant Field Values

API_AUTHORITYCONNECTIONNODE

protected static final java.lang.String API_AUTHORITYCONNECTIONNODE

See Also:

Constant Field Values

API_MAPPINGCONNECTIONNODE

protected static final java.lang.String API_MAPPINGCONNECTIONNODE

See Also:

Constant Field Values

API_CHECKRESULTNODE

protected static final java.lang.String API_CHECKRESULTNODE

See Also:

Constant Field Values

API_JOBIDNODE

protected static final java.lang.String API_JOBIDNODE

See Also:

Constant Field Values

API_CONNECTIONNAMENODE

protected static final java.lang.String API_CONNECTIONNAMENODE

See Also:

Constant Field Values

API_ROWNODE

protected static final java.lang.String API_ROWNODE

See Also:

Constant Field Values

API_COLUMNNODE

protected static final java.lang.String API_COLUMNNODE

See Also:

Constant Field Values

API_NAMENODE

protected static final java.lang.String API_NAMENODE

See Also:

Constant Field Values

API_VALUENODE

protected static final java.lang.String API_VALUENODE

See Also:

Constant Field Values

API_ACTIVITYNODE

protected static final java.lang.String API_ACTIVITYNODE

See Also:

Constant Field Values

CONNECTORNODE_DESCRIPTION

protected static final java.lang.String CONNECTORNODE_DESCRIPTION

See Also:

Constant Field Values

CONNECTORNODE_CLASSNAME

protected static final java.lang.String CONNECTORNODE_CLASSNAME

See Also:

Constant Field Values

AUTHORIZATIONDOMAINNODE_DESCRIPTION

protected static final java.lang.String AUTHORIZATIONDOMAINNODE_DESCRIPTION

See Also:

Constant Field Values

AUTHORIZATIONDOMAINNODE_DOMAINNAME

protected static final java.lang.String AUTHORIZATIONDOMAINNODE_DOMAINNAME

See Also:

Constant Field Values

READRESULT_NOTFOUND

public static final int READRESULT_NOTFOUND

See Also:

Constant Field Values

READRESULT_FOUND

public static final int READRESULT_FOUND

See Also:

Constant Field Values

READRESULT_NOTALLOWED

public static final int READRESULT_NOTALLOWED

See Also:

Constant Field Values

docState

protected static final java.util.Map<java.lang.String,java.lang.Integer> docState

docStatus

protected static final java.util.Map<java.lang.String,java.lang.Integer> docStatus

POSTRESULT_NOTFOUND

public static final int POSTRESULT_NOTFOUND

See Also:

Constant Field Values

POSTRESULT_FOUND

public static final int POSTRESULT_FOUND

See Also:

Constant Field Values

POSTRESULT_CREATED

public static final int POSTRESULT_CREATED

See Also:

Constant Field Values

POSTRESULT_NOTALLOWED

public static final int POSTRESULT_NOTALLOWED

See Also:

Constant Field Values

WRITERESULT_NOTFOUND

public static final int WRITERESULT_NOTFOUND

See Also:

Constant Field Values

WRITERESULT_FOUND

public static final int WRITERESULT_FOUND

See Also:

Constant Field Values

WRITERESULT_CREATED

public static final int WRITERESULT_CREATED

See Also:

Constant Field Values

WRITERESULT_NOTALLOWED

public static final int WRITERESULT_NOTALLOWED

See Also:

Constant Field Values

DELETERESULT_NOTFOUND

public static final int DELETERESULT_NOTFOUND

See Also:

Constant Field Values

DELETERESULT_FOUND

public static final int DELETERESULT_FOUND

See Also:

Constant Field Values

DELETERESULT_NOTALLOWED

public static final int DELETERESULT_NOTALLOWED

See Also:

Constant Field Values

JOBNODE_ID

protected static final java.lang.String JOBNODE_ID

See Also:

Constant Field Values

JOBNODE_DESCRIPTION

protected static final java.lang.String JOBNODE_DESCRIPTION

See Also:

Constant Field Values

JOBNODE_CONNECTIONNAME

protected static final java.lang.String JOBNODE_CONNECTIONNAME

See Also:

Constant Field Values

JOBNODE_DOCUMENTSPECIFICATION

protected static final java.lang.String JOBNODE_DOCUMENTSPECIFICATION

See Also:

Constant Field Values

JOBNODE_STARTMODE

protected static final java.lang.String JOBNODE_STARTMODE

See Also:

Constant Field Values

JOBNODE_RUNMODE

protected static final java.lang.String JOBNODE_RUNMODE

See Also:

Constant Field Values

JOBNODE_HOPCOUNTMODE

protected static final java.lang.String JOBNODE_HOPCOUNTMODE

See Also:

Constant Field Values

JOBNODE_PRIORITY

protected static final java.lang.String JOBNODE_PRIORITY

See Also:

Constant Field Values

JOBNODE_RECRAWLINTERVAL

protected static final java.lang.String JOBNODE_RECRAWLINTERVAL

See Also:

Constant Field Values

JOBNODE_MAXRECRAWLINTERVAL

protected static final java.lang.String JOBNODE_MAXRECRAWLINTERVAL

See Also:

Constant Field Values

JOBNODE_EXPIRATIONINTERVAL

protected static final java.lang.String JOBNODE_EXPIRATIONINTERVAL

See Also:

Constant Field Values

JOBNODE_RESEEDINTERVAL

protected static final java.lang.String JOBNODE_RESEEDINTERVAL

See Also:

Constant Field Values

JOBNODE_HOPCOUNT

protected static final java.lang.String JOBNODE_HOPCOUNT

See Also:

Constant Field Values

JOBNODE_SCHEDULE

protected static final java.lang.String JOBNODE_SCHEDULE

See Also:

Constant Field Values

JOBNODE_LINKTYPE

protected static final java.lang.String JOBNODE_LINKTYPE

See Also:

Constant Field Values

JOBNODE_COUNT

protected static final java.lang.String JOBNODE_COUNT

See Also:

Constant Field Values

JOBNODE_REQUESTMINIMUM

protected static final java.lang.String JOBNODE_REQUESTMINIMUM

See Also:

Constant Field Values

JOBNODE_TIMEZONE

protected static final java.lang.String JOBNODE_TIMEZONE

See Also:

Constant Field Values

JOBNODE_DURATION

protected static final java.lang.String JOBNODE_DURATION

See Also:

Constant Field Values

JOBNODE_DAYOFWEEK

protected static final java.lang.String JOBNODE_DAYOFWEEK

See Also:

Constant Field Values

JOBNODE_MONTHOFYEAR

protected static final java.lang.String JOBNODE_MONTHOFYEAR

See Also:

Constant Field Values

JOBNODE_DAYOFMONTH

protected static final java.lang.String JOBNODE_DAYOFMONTH

See Also:

Constant Field Values

JOBNODE_YEAR

protected static final java.lang.String JOBNODE_YEAR

See Also:

Constant Field Values

JOBNODE_HOUROFDAY

protected static final java.lang.String JOBNODE_HOUROFDAY

See Also:

Constant Field Values

JOBNODE_MINUTESOFHOUR

protected static final java.lang.String JOBNODE_MINUTESOFHOUR

See Also:

Constant Field Values

JOBNODE_ENUMVALUE

protected static final java.lang.String JOBNODE_ENUMVALUE

See Also:

Constant Field Values

JOBNODE_PARAMNAME

protected static final java.lang.String JOBNODE_PARAMNAME

See Also:

Constant Field Values

JOBNODE_PARAMVALUE

protected static final java.lang.String JOBNODE_PARAMVALUE

See Also:

Constant Field Values

JOBNODE_PIPELINESTAGE

protected static final java.lang.String JOBNODE_PIPELINESTAGE

See Also:

Constant Field Values

JOBNODE_STAGEID

protected static final java.lang.String JOBNODE_STAGEID

See Also:

Constant Field Values

JOBNODE_STAGEPREREQUISITE

protected static final java.lang.String JOBNODE_STAGEPREREQUISITE

See Also:

Constant Field Values

JOBNODE_STAGEISOUTPUT

protected static final java.lang.String JOBNODE_STAGEISOUTPUT

See Also:

Constant Field Values

JOBNODE_STAGECONNECTIONNAME

protected static final java.lang.String JOBNODE_STAGECONNECTIONNAME

See Also:

Constant Field Values

JOBNODE_STAGEDESCRIPTION

protected static final java.lang.String JOBNODE_STAGEDESCRIPTION

See Also:

Constant Field Values

JOBNODE_STAGESPECIFICATION

protected static final java.lang.String JOBNODE_STAGESPECIFICATION

See Also:

Constant Field Values

JOBNODE_NOTIFICATIONSTAGE

protected static final java.lang.String JOBNODE_NOTIFICATIONSTAGE

See Also:

Constant Field Values

JOBSTATUSNODE_JOBID

protected static final java.lang.String JOBSTATUSNODE_JOBID

See Also:

Constant Field Values

JOBSTATUSNODE_STATUS

protected static final java.lang.String JOBSTATUSNODE_STATUS

See Also:

Constant Field Values

JOBSTATUSNODE_ERRORTEXT

protected static final java.lang.String JOBSTATUSNODE_ERRORTEXT

See Also:

Constant Field Values

JOBSTATUSNODE_STARTTIME

protected static final java.lang.String JOBSTATUSNODE_STARTTIME

See Also:

Constant Field Values

JOBSTATUSNODE_ENDTIME

protected static final java.lang.String JOBSTATUSNODE_ENDTIME

See Also:

Constant Field Values

JOBSTATUSNODE_DOCUMENTSINQUEUE

protected static final java.lang.String JOBSTATUSNODE_DOCUMENTSINQUEUE

See Also:

Constant Field Values

JOBSTATUSNODE_DOCUMENTSOUTSTANDING

protected static final java.lang.String JOBSTATUSNODE_DOCUMENTSOUTSTANDING

See Also:

Constant Field Values

JOBSTATUSNODE_DOCUMENTSPROCESSED

protected static final java.lang.String JOBSTATUSNODE_DOCUMENTSPROCESSED

See Also:

Constant Field Values

JOBSTATUSNODE_QUEUEEXACT

protected static final java.lang.String JOBSTATUSNODE_QUEUEEXACT

See Also:

Constant Field Values

JOBSTATUSNODE_OUTSTANDINGEXACT

protected static final java.lang.String JOBSTATUSNODE_OUTSTANDINGEXACT

See Also:

Constant Field Values

JOBSTATUSNODE_PROCESSEDEXACT

protected static final java.lang.String JOBSTATUSNODE_PROCESSEDEXACT

See Also:

Constant Field Values

AUTHGROUPNODE_ISNEW

protected static final java.lang.String AUTHGROUPNODE_ISNEW

See Also:

Constant Field Values

AUTHGROUPNODE_NAME

protected static final java.lang.String AUTHGROUPNODE_NAME

See Also:

Constant Field Values

AUTHGROUPNODE_DESCRIPTION

protected static final java.lang.String AUTHGROUPNODE_DESCRIPTION

See Also:

Constant Field Values

CONNECTIONNODE_ISNEW

protected static final java.lang.String CONNECTIONNODE_ISNEW

See Also:

Constant Field Values

CONNECTIONNODE_NAME

protected static final java.lang.String CONNECTIONNODE_NAME

See Also:

Constant Field Values

CONNECTIONNODE_CLASSNAME

protected static final java.lang.String CONNECTIONNODE_CLASSNAME

See Also:

Constant Field Values

CONNECTIONNODE_MAXCONNECTIONS

protected static final java.lang.String CONNECTIONNODE_MAXCONNECTIONS

See Also:

Constant Field Values

CONNECTIONNODE_DESCRIPTION

protected static final java.lang.String CONNECTIONNODE_DESCRIPTION

See Also:

Constant Field Values

CONNECTIONNODE_PREREQUISITE

protected static final java.lang.String CONNECTIONNODE_PREREQUISITE

See Also:

Constant Field Values

CONNECTIONNODE_CONFIGURATION

protected static final java.lang.String CONNECTIONNODE_CONFIGURATION

See Also:

Constant Field Values

CONNECTIONNODE_ACLAUTHORITY

protected static final java.lang.String CONNECTIONNODE_ACLAUTHORITY

See Also:

Constant Field Values

CONNECTIONNODE_THROTTLE

protected static final java.lang.String CONNECTIONNODE_THROTTLE

See Also:

Constant Field Values

CONNECTIONNODE_MATCH

protected static final java.lang.String CONNECTIONNODE_MATCH

See Also:

Constant Field Values

CONNECTIONNODE_MATCHDESCRIPTION

protected static final java.lang.String CONNECTIONNODE_MATCHDESCRIPTION

See Also:

Constant Field Values

CONNECTIONNODE_RATE

protected static final java.lang.String CONNECTIONNODE_RATE

See Also:

Constant Field Values

CONNECTIONNODE_AUTHDOMAIN

protected static final java.lang.String CONNECTIONNODE_AUTHDOMAIN

See Also:

Constant Field Values

CONNECTIONNODE_AUTHGROUP

protected static final java.lang.String CONNECTIONNODE_AUTHGROUP

See Also:

Constant Field Values

Constructor Detail

ManifoldCF

public ManifoldCF()

Method Detail

initializeEnvironment

public static void initializeEnvironment(IThreadContext tc)
                                  throws ManifoldCFException

Initialize environment.

Throws:

ManifoldCFException

cleanUpEnvironment

public static void cleanUpEnvironment(IThreadContext tc)

localInitialize

public static void localInitialize(IThreadContext tc)
                            throws ManifoldCFException

Throws:

ManifoldCFException

localCleanup

public static void localCleanup(IThreadContext tc)

createSystemDatabase

public static void createSystemDatabase(IThreadContext threadContext)
                                 throws ManifoldCFException

Create system database using superuser properties from properties.xml.

Throws:

ManifoldCFException

registerThisAgent

public static void registerThisAgent(IThreadContext tc)
                              throws ManifoldCFException

Register this agent

Throws:

ManifoldCFException

reregisterAllConnectors

public static void reregisterAllConnectors(IThreadContext tc)
                                    throws ManifoldCFException

Register or re-register all connectors, based on a connectors.xml file.

Throws:

ManifoldCFException

readConnectorDeclarations

public static Connectors readConnectorDeclarations(java.io.File connectorConfigFile)
                                            throws ManifoldCFException

Read connectors configuration file.

Throws:

ManifoldCFException

unregisterAllConnectors

public static void unregisterAllConnectors(IThreadContext tc)
                                    throws ManifoldCFException

Unregister all connectors.

Throws:

ManifoldCFException

unregisterAllConnectors

public static void unregisterAllConnectors(IThreadContext tc,
                                           Connectors c)
                                    throws ManifoldCFException

Unregister all connectors which don't match a specified connector list.

Throws:

ManifoldCFException

registerConnectors

public static void registerConnectors(IThreadContext tc,
                                      Connectors c)
                               throws ManifoldCFException

Register all connectors as specified by a Connectors structure, usually read from the connectors.xml file.

Throws:

ManifoldCFException

installSystemTables

public static void installSystemTables(IThreadContext threadcontext)
                                throws ManifoldCFException

Install all the crawler system tables.

Parameters:

threadcontext - is the thread context.

Throws:

ManifoldCFException

deinstallSystemTables

public static void deinstallSystemTables(IThreadContext threadcontext)
                                  throws ManifoldCFException

Uninstall all the crawler system tables.

Parameters:

threadcontext - is the thread context.

Throws:

ManifoldCFException

exportConfiguration

public static void exportConfiguration(IThreadContext threadContext,
                                       java.lang.String exportFilename,
                                       java.lang.String passCode)
                                throws ManifoldCFException

Atomically export the crawler configuration

Throws:

ManifoldCFException

importConfiguration

public static void importConfiguration(IThreadContext threadContext,
                                       java.lang.String importFilename,
                                       java.lang.String passCode)
                                throws ManifoldCFException

Atomically import a crawler configuration

Throws:

ManifoldCFException

getMaxWorkerThreads

public static int getMaxWorkerThreads(IThreadContext threadContext)
                               throws ManifoldCFException

Get the maximum number of worker threads.

Throws:

ManifoldCFException

getMaxDeleteThreads

public static int getMaxDeleteThreads(IThreadContext threadContext)
                               throws ManifoldCFException

Get the maximum number of delete threads.

Throws:

ManifoldCFException

getMaxExpireThreads

public static int getMaxExpireThreads(IThreadContext threadContext)
                               throws ManifoldCFException

Get the maximum number of expire threads.

Throws:

ManifoldCFException

getMaxCleanupThreads

public static int getMaxCleanupThreads(IThreadContext threadContext)
                                throws ManifoldCFException

Get the maximum number of cleanup threads.

Throws:

ManifoldCFException

requeueDocumentsDueToCarrydown

public static void requeueDocumentsDueToCarrydown(IJobManager jobManager,
                                                  DocumentDescription[] requeueCandidates,
                                                  IRepositoryConnector connector,
                                                  IRepositoryConnection connection,
                                                  IReprioritizationTracker rt,
                                                  long currentTime)
                                           throws ManifoldCFException

Requeue documents due to carrydown.

Throws:

ManifoldCFException

colonStuff

public static java.lang.String colonStuff(java.lang.String input)

Stuff colons so we can't have conflicts.

createGlobalString

public static java.lang.String createGlobalString(java.lang.String simpleString)

Create a global string

createConnectionSpecificString

public static java.lang.String createConnectionSpecificString(java.lang.String connectionName,
                                                              java.lang.String simpleString)

Create a connection-specific string

createJobSpecificString

public static java.lang.String createJobSpecificString(java.lang.Long jobID,
                                                       java.lang.String simpleString)

Create a job-specific string

calculateBins

public static java.lang.String[] calculateBins(IRepositoryConnector connector,
                                               java.lang.String documentIdentifier)

Given a connector object and a document identifier, calculate its bins.

resetAllDocumentPriorities

public static void resetAllDocumentPriorities(IThreadContext threadContext,
                                              java.lang.String processID)
                                       throws ManifoldCFException

Reset all (active) document priorities. This operation may occur due to various externally-triggered events, such a job abort, pause, resume, wait, or unwait.

Throws:

ManifoldCFException

writeDocumentPriorities

public static void writeDocumentPriorities(IThreadContext threadContext,
                                           DocumentDescription[] descs,
                                           java.util.Map<java.lang.String,IRepositoryConnection> connectionMap,
                                           java.util.Map<java.lang.Long,IJobDescription> jobDescriptionMap)
                                    throws ManifoldCFException

Write a set of document priorities, based on the current queue tracker.

Throws:

ManifoldCFException

getActivitiesList

public static java.lang.String[] getActivitiesList(IThreadContext threadContext,
                                                   java.lang.String connectionName)
                                            throws ManifoldCFException

Get the activities list for a given repository connection.

Throws:

ManifoldCFException

decodeAPIPathElement

public static java.lang.String decodeAPIPathElement(java.lang.String startingPathElement)
                                             throws ManifoldCFException

Decode path element. Path elements in the API world cannot have "/" characters, or they become impossible to parse. This method undoes escaping that prevents "/" from appearing.

Throws:

ManifoldCFException

apiReadJobs

protected static int apiReadJobs(IThreadContext tc,
                                 Configuration output,
                                 IAuthorizer authorizer)
                          throws ManifoldCFException

Read jobs

Throws:

ManifoldCFException

apiReadJob

protected static int apiReadJob(IThreadContext tc,
                                Configuration output,
                                java.lang.Long jobID,
                                IAuthorizer authorizer)
                         throws ManifoldCFException

Read a job

Throws:

ManifoldCFException

apiReadOutputConnectionStatus

protected static int apiReadOutputConnectionStatus(IThreadContext tc,
                                                   Configuration output,
                                                   java.lang.String connectionName,
                                                   IAuthorizer authorizer)
                                            throws ManifoldCFException

Read an output connection status

Throws:

ManifoldCFException

apiReadTransformationConnectionStatus

protected static int apiReadTransformationConnectionStatus(IThreadContext tc,
                                                           Configuration output,
                                                           java.lang.String connectionName,
                                                           IAuthorizer authorizer)
                                                    throws ManifoldCFException

Read a transformation connection status

Throws:

ManifoldCFException

apiReadAuthorityConnectionStatus

protected static int apiReadAuthorityConnectionStatus(IThreadContext tc,
                                                      Configuration output,
                                                      java.lang.String connectionName,
                                                      IAuthorizer authorizer)
                                               throws ManifoldCFException

Read an authority connection status

Throws:

ManifoldCFException

apiReadMappingConnectionStatus

protected static int apiReadMappingConnectionStatus(IThreadContext tc,
                                                    Configuration output,
                                                    java.lang.String connectionName,
                                                    IAuthorizer authorizer)
                                             throws ManifoldCFException

Read a mapping connection status

Throws:

ManifoldCFException

apiReadRepositoryConnectionStatus

protected static int apiReadRepositoryConnectionStatus(IThreadContext tc,
                                                       Configuration output,
                                                       java.lang.String connectionName,
                                                       IAuthorizer authorizer)
                                                throws ManifoldCFException

Read a repository connection status

Throws:

ManifoldCFException

apiReadNotificationConnectionStatus

protected static int apiReadNotificationConnectionStatus(IThreadContext tc,
                                                         Configuration output,
                                                         java.lang.String connectionName,
                                                         IAuthorizer authorizer)
                                                  throws ManifoldCFException

Read a notification connection status

Throws:

ManifoldCFException

apiReadOutputConnectionInfo

protected static int apiReadOutputConnectionInfo(IThreadContext tc,
                                                 Configuration output,
                                                 java.lang.String connectionName,
                                                 java.lang.String command,
                                                 IAuthorizer authorizer)
                                          throws ManifoldCFException

Read an output connection's info

Throws:

ManifoldCFException

apiReadTransformationConnectionInfo

protected static int apiReadTransformationConnectionInfo(IThreadContext tc,
                                                         Configuration output,
                                                         java.lang.String connectionName,
                                                         java.lang.String command,
                                                         IAuthorizer authorizer)
                                                  throws ManifoldCFException

Read a transformation connection's info

Throws:

ManifoldCFException

apiReadRepositoryConnectionInfo

protected static int apiReadRepositoryConnectionInfo(IThreadContext tc,
                                                     Configuration output,
                                                     java.lang.String connectionName,
                                                     java.lang.String command,
                                                     IAuthorizer authorizer)
                                              throws ManifoldCFException

Read a repository connection's info

Throws:

ManifoldCFException

apiReadNotificationConnectionInfo

protected static int apiReadNotificationConnectionInfo(IThreadContext tc,
                                                       Configuration output,
                                                       java.lang.String connectionName,
                                                       java.lang.String command,
                                                       IAuthorizer authorizer)
                                                throws ManifoldCFException

Read a notification connection's info

Throws:

ManifoldCFException

apiReadJobStatuses

protected static int apiReadJobStatuses(IThreadContext tc,
                                        Configuration output,
                                        java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters,
                                        IAuthorizer authorizer)
                                 throws ManifoldCFException

Get api job statuses

Throws:

ManifoldCFException

apiReadJobStatusesNoCounts

protected static int apiReadJobStatusesNoCounts(IThreadContext tc,
                                                Configuration output,
                                                IAuthorizer authorizer)
                                         throws ManifoldCFException

Get api job statuses

Throws:

ManifoldCFException

apiReadJobStatus

protected static int apiReadJobStatus(IThreadContext tc,
                                      Configuration output,
                                      java.lang.Long jobID,
                                      java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters,
                                      IAuthorizer authorizer)
                               throws ManifoldCFException

Get api job status

Throws:

ManifoldCFException

apiReadJobStatusNoCounts

protected static int apiReadJobStatusNoCounts(IThreadContext tc,
                                              Configuration output,
                                              java.lang.Long jobID,
                                              IAuthorizer authorizer)
                                       throws ManifoldCFException

Get api job status with no counts

Throws:

ManifoldCFException

apiReadAuthorityGroups

protected static int apiReadAuthorityGroups(IThreadContext tc,
                                            Configuration output,
                                            IAuthorizer authorizer)
                                     throws ManifoldCFException

Get authority groups

Throws:

ManifoldCFException

apiReadAuthorityGroup

protected static int apiReadAuthorityGroup(IThreadContext tc,
                                           Configuration output,
                                           java.lang.String groupName,
                                           IAuthorizer authorizer)
                                    throws ManifoldCFException

Read authority group

Throws:

ManifoldCFException

apiReadOutputConnections

protected static int apiReadOutputConnections(IThreadContext tc,
                                              Configuration output,
                                              IAuthorizer authorizer)
                                       throws ManifoldCFException

Get output connections

Throws:

ManifoldCFException

apiReadOutputConnection

protected static int apiReadOutputConnection(IThreadContext tc,
                                             Configuration output,
                                             java.lang.String connectionName,
                                             IAuthorizer authorizer)
                                      throws ManifoldCFException

Read output connection

Throws:

ManifoldCFException

apiReadTransformationConnections

protected static int apiReadTransformationConnections(IThreadContext tc,
                                                      Configuration output,
                                                      IAuthorizer authorizer)
                                               throws ManifoldCFException

Get transformation connections

Throws:

ManifoldCFException

apiReadTransformationConnection

protected static int apiReadTransformationConnection(IThreadContext tc,
                                                     Configuration output,
                                                     java.lang.String connectionName,
                                                     IAuthorizer authorizer)
                                              throws ManifoldCFException

Read transformation connection

Throws:

ManifoldCFException

apiReadAuthorityConnections

protected static int apiReadAuthorityConnections(IThreadContext tc,
                                                 Configuration output,
                                                 IAuthorizer authorizer)
                                          throws ManifoldCFException

Get authority connections

Throws:

ManifoldCFException

apiReadMappingConnections

protected static int apiReadMappingConnections(IThreadContext tc,
                                               Configuration output,
                                               IAuthorizer authorizer)
                                        throws ManifoldCFException

Get mapping connections

Throws:

ManifoldCFException

apiReadAuthorityConnection

protected static int apiReadAuthorityConnection(IThreadContext tc,
                                                Configuration output,
                                                java.lang.String connectionName,
                                                IAuthorizer authorizer)
                                         throws ManifoldCFException

Read authority connection

Throws:

ManifoldCFException

apiReadMappingConnection

protected static int apiReadMappingConnection(IThreadContext tc,
                                              Configuration output,
                                              java.lang.String connectionName,
                                              IAuthorizer authorizer)
                                       throws ManifoldCFException

Read mapping connection

Throws:

ManifoldCFException

apiReadRepositoryConnections

protected static int apiReadRepositoryConnections(IThreadContext tc,
                                                  Configuration output,
                                                  IAuthorizer authorizer)
                                           throws ManifoldCFException

Get repository connections

Throws:

ManifoldCFException

apiReadRepositoryConnection

protected static int apiReadRepositoryConnection(IThreadContext tc,
                                                 Configuration output,
                                                 java.lang.String connectionName,
                                                 IAuthorizer authorizer)
                                          throws ManifoldCFException

Read repository connection

Throws:

ManifoldCFException

apiReadNotificationConnections

protected static int apiReadNotificationConnections(IThreadContext tc,
                                                    Configuration output,
                                                    IAuthorizer authorizer)
                                             throws ManifoldCFException

Get notification connections

Throws:

ManifoldCFException

apiReadNotificationConnection

protected static int apiReadNotificationConnection(IThreadContext tc,
                                                   Configuration output,
                                                   java.lang.String connectionName,
                                                   IAuthorizer authorizer)
                                            throws ManifoldCFException

Read notification connection

Throws:

ManifoldCFException

apiReadOutputConnectors

protected static int apiReadOutputConnectors(IThreadContext tc,
                                             Configuration output,
                                             IAuthorizer authorizer)
                                      throws ManifoldCFException

List output connectors

Throws:

ManifoldCFException

apiReadTransformationConnectors

protected static int apiReadTransformationConnectors(IThreadContext tc,
                                                     Configuration output,
                                                     IAuthorizer authorizer)
                                              throws ManifoldCFException

List transformation connectors

Throws:

ManifoldCFException

apiReadAuthorityConnectors

protected static int apiReadAuthorityConnectors(IThreadContext tc,
                                                Configuration output,
                                                IAuthorizer authorizer)
                                         throws ManifoldCFException

List authority connectors

Throws:

ManifoldCFException

apiReadMappingConnectors

protected static int apiReadMappingConnectors(IThreadContext tc,
                                              Configuration output,
                                              IAuthorizer authorizer)
                                       throws ManifoldCFException

List mapping connectors

Throws:

ManifoldCFException

apiReadAuthorizationDomains

protected static int apiReadAuthorizationDomains(IThreadContext tc,
                                                 Configuration output,
                                                 IAuthorizer authorizer)
                                          throws ManifoldCFException

List authorization domains

Throws:

ManifoldCFException

apiReadRepositoryConnectors

protected static int apiReadRepositoryConnectors(IThreadContext tc,
                                                 Configuration output,
                                                 IAuthorizer authorizer)
                                          throws ManifoldCFException

List repository connectors

Throws:

ManifoldCFException

apiReadNotificationConnectors

protected static int apiReadNotificationConnectors(IThreadContext tc,
                                                   Configuration output,
                                                   IAuthorizer authorizer)
                                            throws ManifoldCFException

List notification connectors

Throws:

ManifoldCFException

apiReadRepositoryConnectionQueue

protected static int apiReadRepositoryConnectionQueue(IThreadContext tc,
                                                      Configuration output,
                                                      java.lang.String connectionName,
                                                      java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters,
                                                      IAuthorizer authorizer)
                                               throws ManifoldCFException

Queue reports

Throws:

ManifoldCFException

apiReadRepositoryConnectionJobs

protected static int apiReadRepositoryConnectionJobs(IThreadContext tc,
                                                     Configuration output,
                                                     java.lang.String connectionName,
                                                     IAuthorizer authorizer)
                                              throws ManifoldCFException

Get jobs for connection

Throws:

ManifoldCFException

apiReadRepositoryConnectionHistory

protected static int apiReadRepositoryConnectionHistory(IThreadContext tc,
                                                        Configuration output,
                                                        java.lang.String connectionName,
                                                        java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters,
                                                        IAuthorizer authorizer)
                                                 throws ManifoldCFException

History reports

Throws:

ManifoldCFException

createResultsetNode

protected static void createResultsetNode(Configuration output,
                                          IResultSet result,
                                          java.lang.String[] resultColumns)
                                   throws ManifoldCFException

Add a resultset node to the output.

Throws:

ManifoldCFException

apiReadRepositoryConnectionActivities

protected static int apiReadRepositoryConnectionActivities(IThreadContext tc,
                                                           Configuration output,
                                                           java.lang.String connectionName,
                                                           IAuthorizer authorizer)
                                                    throws ManifoldCFException

Read the activity list for a given connection name.

Throws:

ManifoldCFException

executeReadCommand

public static int executeReadCommand(IThreadContext tc,
                                     Configuration output,
                                     java.lang.String path,
                                     java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters,
                                     IAuthorizer authorizer)
                              throws ManifoldCFException

Execute specified read command.

Parameters:

tc - is the thread context.

output - is the output object, to be filled in.

path - is the object path.

Returns:

read status - either found, not found, or bad args

Throws:

ManifoldCFException

apiPostJob

protected static int apiPostJob(IThreadContext tc,
                                Configuration output,
                                Configuration input,
                                IAuthorizer authorizer)
                         throws ManifoldCFException

Post job.

Throws:

ManifoldCFException

executePostCommand

public static int executePostCommand(IThreadContext tc,
                                     Configuration output,
                                     java.lang.String path,
                                     Configuration input,
                                     IAuthorizer authorizer)
                              throws ManifoldCFException

Execute specified post command.

Parameters:

tc - is the thread context.

output - is the output object, to be filled in.

path - is the object path.

input - is the input object.

Returns:

write result - either "not found", "found", or "created".

Throws:

ManifoldCFException

apiWriteStartJob

protected static int apiWriteStartJob(IThreadContext tc,
                                      Configuration output,
                                      java.lang.Long jobID,
                                      boolean requestMinimum,
                                      IAuthorizer authorizer)
                               throws ManifoldCFException

Start a job.

Throws:

ManifoldCFException

apiWriteAbortJob

protected static int apiWriteAbortJob(IThreadContext tc,
                                      Configuration output,
                                      java.lang.Long jobID,
                                      IAuthorizer authorizer)
                               throws ManifoldCFException

Abort a job.

Throws:

ManifoldCFException

apiWriteRestartJob

protected static int apiWriteRestartJob(IThreadContext tc,
                                        Configuration output,
                                        java.lang.Long jobID,
                                        boolean requestMinimum,
                                        IAuthorizer authorizer)
                                 throws ManifoldCFException

Restart a job.

Throws:

ManifoldCFException

apiWritePauseJob

protected static int apiWritePauseJob(IThreadContext tc,
                                      Configuration output,
                                      java.lang.Long jobID,
                                      IAuthorizer authorizer)
                               throws ManifoldCFException

Pause a job.

Throws:

ManifoldCFException

apiWriteResumeJob

protected static int apiWriteResumeJob(IThreadContext tc,
                                       Configuration output,
                                       java.lang.Long jobID,
                                       IAuthorizer authorizer)
                                throws ManifoldCFException

Resume a job.

Throws:

ManifoldCFException

apiWriteReseedJob

protected static int apiWriteReseedJob(IThreadContext tc,
                                       Configuration output,
                                       java.lang.Long jobID,
                                       IAuthorizer authorizer)
                                throws ManifoldCFException

Reset incremental seeding for a job.

Throws:

ManifoldCFException

apiWriteJob

protected static int apiWriteJob(IThreadContext tc,
                                 Configuration output,
                                 Configuration input,
                                 java.lang.Long jobID,
                                 IAuthorizer authorizer)
                          throws ManifoldCFException

Write job.

Throws:

ManifoldCFException

apiWriteAuthorityGroup

protected static int apiWriteAuthorityGroup(IThreadContext tc,
                                            Configuration output,
                                            Configuration input,
                                            java.lang.String groupName,
                                            IAuthorizer authorizer)
                                     throws ManifoldCFException

Write authority group.

Throws:

ManifoldCFException

apiWriteOutputConnection

protected static int apiWriteOutputConnection(IThreadContext tc,
                                              Configuration output,
                                              Configuration input,
                                              java.lang.String connectionName,
                                              IAuthorizer authorizer)
                                       throws ManifoldCFException

Write output connection.

Throws:

ManifoldCFException

apiWriteTransformationConnection

protected static int apiWriteTransformationConnection(IThreadContext tc,
                                                      Configuration output,
                                                      Configuration input,
                                                      java.lang.String connectionName,
                                                      IAuthorizer authorizer)
                                               throws ManifoldCFException

Write transformation connection.

Throws:

ManifoldCFException

apiWriteAuthorityConnection

protected static int apiWriteAuthorityConnection(IThreadContext tc,
                                                 Configuration output,
                                                 Configuration input,
                                                 java.lang.String connectionName,
                                                 IAuthorizer authorizer)
                                          throws ManifoldCFException

Write authority connection.

Throws:

ManifoldCFException

apiWriteMappingConnection

protected static int apiWriteMappingConnection(IThreadContext tc,
                                               Configuration output,
                                               Configuration input,
                                               java.lang.String connectionName,
                                               IAuthorizer authorizer)
                                        throws ManifoldCFException

Write mapping connection.

Throws:

ManifoldCFException

apiWriteRepositoryConnection

protected static int apiWriteRepositoryConnection(IThreadContext tc,
                                                  Configuration output,
                                                  Configuration input,
                                                  java.lang.String connectionName,
                                                  IAuthorizer authorizer)
                                           throws ManifoldCFException

Write repository connection.

Throws:

ManifoldCFException

apiWriteClearHistoryRepositoryConnection

protected static int apiWriteClearHistoryRepositoryConnection(IThreadContext tc,
                                                              Configuration output,
                                                              java.lang.String connectionName,
                                                              IAuthorizer authorizer)
                                                       throws ManifoldCFException

Clear repository connection history.

Throws:

ManifoldCFException

apiWriteNotificationConnection

protected static int apiWriteNotificationConnection(IThreadContext tc,
                                                    Configuration output,
                                                    Configuration input,
                                                    java.lang.String connectionName,
                                                    IAuthorizer authorizer)
                                             throws ManifoldCFException

Write notification connection.

Throws:

ManifoldCFException

apiWriteClearVersionsOutputConnection

protected static int apiWriteClearVersionsOutputConnection(IThreadContext tc,
                                                           Configuration output,
                                                           java.lang.String connectionName,
                                                           IAuthorizer authorizer)
                                                    throws ManifoldCFException

Reset output connection (reset version of all recorded documents).

Throws:

ManifoldCFException

apiWriteClearOutputConnection

protected static int apiWriteClearOutputConnection(IThreadContext tc,
                                                   Configuration output,
                                                   java.lang.String connectionName,
                                                   IAuthorizer authorizer)
                                            throws ManifoldCFException

Clear output connection (remove all recorded documents).

Throws:

ManifoldCFException

executeWriteCommand

public static int executeWriteCommand(IThreadContext tc,
                                      Configuration output,
                                      java.lang.String path,
                                      Configuration input,
                                      IAuthorizer authorizer)
                               throws ManifoldCFException

Execute specified write command.

Parameters:

tc - is the thread context.

output - is the output object, to be filled in.

path - is the object path.

input - is the input object.

Returns:

write result - either "not found", "found", or "created".

Throws:

ManifoldCFException

apiDeleteJob

protected static int apiDeleteJob(IThreadContext tc,
                                  Configuration output,
                                  java.lang.Long jobID,
                                  IAuthorizer authorizer)
                           throws ManifoldCFException

Delete a job.

Throws:

ManifoldCFException

apiDeleteAuthorityGroup

protected static int apiDeleteAuthorityGroup(IThreadContext tc,
                                             Configuration output,
                                             java.lang.String groupName,
                                             IAuthorizer authorizer)
                                      throws ManifoldCFException

Delete authority group.

Throws:

ManifoldCFException

apiDeleteOutputConnection

protected static int apiDeleteOutputConnection(IThreadContext tc,
                                               Configuration output,
                                               java.lang.String connectionName,
                                               IAuthorizer authorizer)
                                        throws ManifoldCFException

Delete output connection.

Throws:

ManifoldCFException

apiDeleteAuthorityConnection

protected static int apiDeleteAuthorityConnection(IThreadContext tc,
                                                  Configuration output,
                                                  java.lang.String connectionName,
                                                  IAuthorizer authorizer)
                                           throws ManifoldCFException

Delete authority connection.

Throws:

ManifoldCFException

apiDeleteMappingConnection

protected static int apiDeleteMappingConnection(IThreadContext tc,
                                                Configuration output,
                                                java.lang.String connectionName,
                                                IAuthorizer authorizer)
                                         throws ManifoldCFException

Delete mapping connection.

Throws:

ManifoldCFException

apiDeleteTransformationConnection

protected static int apiDeleteTransformationConnection(IThreadContext tc,
                                                       Configuration output,
                                                       java.lang.String connectionName,
                                                       IAuthorizer authorizer)
                                                throws ManifoldCFException

Delete transformation connection.

Throws:

ManifoldCFException

apiDeleteRepositoryConnection

protected static int apiDeleteRepositoryConnection(IThreadContext tc,
                                                   Configuration output,
                                                   java.lang.String connectionName,
                                                   IAuthorizer authorizer)
                                            throws ManifoldCFException

Delete repository connection.

Throws:

ManifoldCFException

apiDeleteNotificationConnection

protected static int apiDeleteNotificationConnection(IThreadContext tc,
                                                     Configuration output,
                                                     java.lang.String connectionName,
                                                     IAuthorizer authorizer)
                                              throws ManifoldCFException

Delete notification connection.

Throws:

ManifoldCFException

executeDeleteCommand

public static int executeDeleteCommand(IThreadContext tc,
                                       Configuration output,
                                       java.lang.String path,
                                       IAuthorizer authorizer)
                                throws ManifoldCFException

Execute specified delete command.

Parameters:

tc - is the thread context.

output - is the output object, to be filled in.

path - is the object path.

Returns:

delete result code

Throws:

ManifoldCFException

processJobDescription

protected static void processJobDescription(JobDescription jobDescription,
                                            ConfigurationNode jobNode)
                                     throws ManifoldCFException

Convert a node into a job description.

Parameters:

jobDescription - is the job to be filled in.

jobNode - is the configuration node corresponding to the whole job itself.

Throws:

ManifoldCFException

addStage

protected static void addStage(java.lang.String stageName,
                               java.util.List<java.lang.String> orderedStageNames,
                               java.util.Set<java.lang.String> keysSeen,
                               java.util.Map<java.lang.String,ManifoldCF.PipelineStage> pipelineStages)
                        throws ManifoldCFException

Throws:

ManifoldCFException

formatJobDescription

protected static void formatJobDescription(ConfigurationNode jobNode,
                                           IJobDescription job)

Convert a job description into a ConfigurationNode.

Parameters:

jobNode - is the node to be filled in.

job - is the job description.

formatEnumeratedValues

protected static void formatEnumeratedValues(ConfigurationNode recordNode,
                                             java.lang.String childType,
                                             EnumeratedValues value)

processEnumeratedValues

protected static EnumeratedValues processEnumeratedValues(ConfigurationNode fieldNode)
                                                   throws ManifoldCFException

Throws:

ManifoldCFException

presentInterval

protected static java.lang.String presentInterval(java.lang.Long interval)

interpretInterval

protected static java.lang.Long interpretInterval(java.lang.String interval)
                                           throws ManifoldCFException

Throws:

ManifoldCFException

startModeMap

protected static java.lang.String startModeMap(int startMethod)

mapToStartMode

protected static int mapToStartMode(java.lang.String startMethod)
                             throws ManifoldCFException

Throws:

ManifoldCFException

runModeMap

protected static java.lang.String runModeMap(int type)

mapToRunMode

protected static int mapToRunMode(java.lang.String mode)
                           throws ManifoldCFException

Throws:

ManifoldCFException

hopcountModeMap

protected static java.lang.String hopcountModeMap(int mode)

mapToHopcountMode

protected static int mapToHopcountMode(java.lang.String mode)
                                throws ManifoldCFException

Throws:

ManifoldCFException

formatJobStatus

protected static void formatJobStatus(ConfigurationNode jobStatusNode,
                                      JobStatus jobStatus)

Format a job status.

statusMap

protected static java.lang.String statusMap(int status)

processAuthorityGroup

protected static void processAuthorityGroup(AuthorityGroup group,
                                            ConfigurationNode groupNode)
                                     throws ManifoldCFException

Convert input hierarchy into an AuthorityGroup object.

Throws:

ManifoldCFException

formatAuthorityGroup

protected static void formatAuthorityGroup(ConfigurationNode groupNode,
                                           IAuthorityGroup group)

Format an authority group.

processOutputConnection

protected static void processOutputConnection(OutputConnection connection,
                                              ConfigurationNode connectionNode)
                                       throws ManifoldCFException

Convert input hierarchy into an OutputConnection object.

Throws:

ManifoldCFException

formatOutputConnection

protected static void formatOutputConnection(ConfigurationNode connectionNode,
                                             IOutputConnection connection)

Format an output connection.

processTransformationConnection

protected static void processTransformationConnection(TransformationConnection connection,
                                                      ConfigurationNode connectionNode)
                                               throws ManifoldCFException

Convert input hierarchy into a TransformationConnection object.

Throws:

ManifoldCFException

formatTransformationConnection

protected static void formatTransformationConnection(ConfigurationNode connectionNode,
                                                     ITransformationConnection connection)

Format a transformation connection.

processAuthorityConnection

protected static void processAuthorityConnection(AuthorityConnection connection,
                                                 ConfigurationNode connectionNode)
                                          throws ManifoldCFException

Convert input hierarchy into an AuthorityConnection object.

Throws:

ManifoldCFException

formatAuthorityConnection

protected static void formatAuthorityConnection(ConfigurationNode connectionNode,
                                                IAuthorityConnection connection)

Format an authority connection.

processMappingConnection

protected static void processMappingConnection(MappingConnection connection,
                                               ConfigurationNode connectionNode)
                                        throws ManifoldCFException

Convert input hierarchy into an MappingConnection object.

Throws:

ManifoldCFException

formatMappingConnection

protected static void formatMappingConnection(ConfigurationNode connectionNode,
                                              IMappingConnection connection)

Format a mapping connection.

processRepositoryConnection

protected static void processRepositoryConnection(RepositoryConnection connection,
                                                  ConfigurationNode connectionNode)
                                           throws ManifoldCFException

Convert input hierarchy into a RepositoryConnection object.

Throws:

ManifoldCFException

formatRepositoryConnection

protected static void formatRepositoryConnection(ConfigurationNode connectionNode,
                                                 IRepositoryConnection connection)

Format a repository connection.

processNotificationConnection

protected static void processNotificationConnection(NotificationConnection connection,
                                                    ConfigurationNode connectionNode)
                                             throws ManifoldCFException

Convert input hierarchy into a NotificationConnection object.

Throws:

ManifoldCFException

formatNotificationConnection

protected static void formatNotificationConnection(ConfigurationNode connectionNode,
                                                   INotificationConnection connection)

Format a notification connection.