org.dataone.cn.batch.synchronization.tasks

Class V2TransferObjectTask

java.lang.Object

org.dataone.cn.batch.synchronization.tasks.V2TransferObjectTask

All Implemented Interfaces:

Callable<SyncObjectState>

public class V2TransferObjectTask
extends Object
implements Callable<SyncObjectState>

Transfer an object from a MemberNode(MN) to a CoordinatingNode(CN). Executes as a thread that is executed by the SyncObjectTask class This class will download SystemMetadata from a MN and process the SystemMetadata. It will then take actions based on the information in the SystemMetadata. If the SystemMetadata describes a new Science Metadata object, it will download the object and perform a create If the SystemMetadata describes a new Science Data Object, it will register itself with the CN leaving the Data on the MN If the SystemMetadata already exists on the CN, then based on the state of the SystemMetadata it will either be ignored, updated, or throw an exception.

Author:

waltz

Constructor Summary

Constructors

Constructor and Description
V2TransferObjectTask(NodeComm nodeCommunications, org.dataone.cn.synchronization.types.SyncObject task)

Method Summary

Modifier and Type	Method and Description
protected String	buildStandardLogMessage(Throwable th, String introMessage)
SyncObjectState	call() Attempts to process the item to be synchronized.
protected static void	extractRetryableException(org.dataone.service.exceptions.ServiceFailure sf) This method is used to re-wrap the Exceptions that affect the processing of a TransferObjectTask, particularly various types of time out exceptions that we would want to retry instead of ending in SynchronizationFailed.

Methods inherited from class java.lang.Object

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

Constructor Detail

V2TransferObjectTask

public V2TransferObjectTask(NodeComm nodeCommunications,
                            org.dataone.cn.synchronization.types.SyncObject task)

Method Detail

call

public SyncObjectState call()

Attempts to process the item to be synchronized. Retry logic is implemented here such that the object is requeued for whatever reason. (failure of the thread to get a lock on the PID, sync waiting for v1 MN to incorporate sysmeta updates made via v1 CN API, or client timeouts)

Specified by:

call in interface Callable<SyncObjectState>

Returns:

null

Throws:

Exception

extractRetryableException

protected static void extractRetryableException(org.dataone.service.exceptions.ServiceFailure sf)
                                         throws RetryableException

This method is used to re-wrap the Exceptions that affect the processing of a TransferObjectTask, particularly various types of time out exceptions that we would want to retry instead of ending in SynchronizationFailed.

Parameters:

sf -

Throws:

RetryableException

buildStandardLogMessage

protected String buildStandardLogMessage(Throwable th,
                                         String introMessage)