Uses of Class
org.jets3t.service.multi.ThreadWatcher

Packages that use ThreadWatcher

Package	Description
org.jets3t.service.multi
org.jets3t.service.multi.event
org.jets3t.service.multi.s3
org.jets3t.service.multithread	A multi-threading utility that manages multiple S3 interactions at once by wrapping an S3Service implementation and running this service with multiple threads.

Uses of ThreadWatcher in org.jets3t.service.multi

Methods in org.jets3t.service.multi with parameters of type ThreadWatcher

Modifier and Type	Method and Description
abstract void	ThreadedStorageService.ThreadGroupManager.fireIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors)
abstract void	ThreadedStorageService.ThreadGroupManager.fireProgressEvent(ThreadWatcher threadWatcher, List completedResults)
abstract void	ThreadedStorageService.ThreadGroupManager.fireStartEvent(ThreadWatcher threadWatcher)

Constructors in org.jets3t.service.multi with parameters of type ThreadWatcher

Constructor and Description
ThreadGroupManager(ThreadedStorageService.AbstractRunnable[] runnables, ThreadWatcher threadWatcher, Jets3tProperties jets3tProperties, boolean isAdminTask)

Uses of ThreadWatcher in org.jets3t.service.multi.event

Methods in org.jets3t.service.multi.event that return ThreadWatcher

Modifier and Type	Method and Description
ThreadWatcher	ServiceEvent.getThreadWatcher()

Methods in org.jets3t.service.multi.event with parameters of type ThreadWatcher

Modifier and Type	Method and Description
static CreateBucketsEvent	CreateBucketsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors, Object uniqueOperationId)
static LookupACLEvent	LookupACLEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors, Object uniqueOperationId)
static UpdateACLEvent	UpdateACLEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors, Object uniqueOperationId)
static DeleteObjectsEvent	DeleteObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors, Object uniqueOperationId)
static DownloadObjectsEvent	DownloadObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors, Object uniqueOperationId)
static GetObjectHeadsEvent	GetObjectHeadsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors, Object uniqueOperationId)
static GetObjectsEvent	GetObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors, Object uniqueOperationId)
static CreateObjectsEvent	CreateObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors, Object uniqueOperationId)
static ListObjectsEvent	ListObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors, Object uniqueOperationId)
static CopyObjectsEvent	CopyObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors, Object uniqueOperationId)
static ListObjectsEvent	ListObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher, List<StorageObjectsChunk> chunkList, Object uniqueOperationId)
static CopyObjectsEvent	CopyObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher, Map[] completedResults, Object uniqueOperationId)
static CreateBucketsEvent	CreateBucketsEvent.newInProgressEvent(ThreadWatcher threadWatcher, StorageBucket[] completedBuckets, Object uniqueOperationId)
static LookupACLEvent	LookupACLEvent.newInProgressEvent(ThreadWatcher threadWatcher, StorageObject[] completedObjects, Object uniqueOperationId)
static UpdateACLEvent	UpdateACLEvent.newInProgressEvent(ThreadWatcher threadWatcher, StorageObject[] completedObjects, Object uniqueOperationId)
static DeleteObjectsEvent	DeleteObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher, StorageObject[] deletedObjects, Object uniqueOperationId)
static DownloadObjectsEvent	DownloadObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher, StorageObject[] completedObjects, Object uniqueOperationId)
static GetObjectHeadsEvent	GetObjectHeadsEvent.newInProgressEvent(ThreadWatcher threadWatcher, StorageObject[] completedObjects, Object uniqueOperationId)
static GetObjectsEvent	GetObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher, StorageObject[] completedObjects, Object uniqueOperationId)
static CreateObjectsEvent	CreateObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher, StorageObject[] completedObjects, Object uniqueOperationId)
static CreateBucketsEvent	CreateBucketsEvent.newStartedEvent(ThreadWatcher threadWatcher, Object uniqueOperationId)
static LookupACLEvent	LookupACLEvent.newStartedEvent(ThreadWatcher threadWatcher, Object uniqueOperationId)
static UpdateACLEvent	UpdateACLEvent.newStartedEvent(ThreadWatcher threadWatcher, Object uniqueOperationId)
static DeleteObjectsEvent	DeleteObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher, Object uniqueOperationId)
static DownloadObjectsEvent	DownloadObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher, Object uniqueOperationId)
static GetObjectHeadsEvent	GetObjectHeadsEvent.newStartedEvent(ThreadWatcher threadWatcher, Object uniqueOperationId)
static GetObjectsEvent	GetObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher, Object uniqueOperationId)
static CreateObjectsEvent	CreateObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher, Object uniqueOperationId)
static ListObjectsEvent	ListObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher, Object uniqueOperationId)
static CopyObjectsEvent	CopyObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher, Object uniqueOperationId)
protected void	ServiceEvent.setThreadWatcher(ThreadWatcher threadWatcher)

Uses of ThreadWatcher in org.jets3t.service.multi.s3

Methods in org.jets3t.service.multi.s3 with parameters of type ThreadWatcher

Modifier and Type	Method and Description
static MultipartUploadsEvent	MultipartUploadsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors, Object uniqueOperationId)
static MultipartStartsEvent	MultipartStartsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors, Object uniqueOperationId)
static MultipartCompletesEvent	MultipartCompletesEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher, Throwable[] ignoredErrors, Object uniqueOperationId)
static MultipartCompletesEvent	MultipartCompletesEvent.newInProgressEvent(ThreadWatcher threadWatcher, MultipartCompleted[] completedUploads, Object uniqueOperationId)
static MultipartStartsEvent	MultipartStartsEvent.newInProgressEvent(ThreadWatcher threadWatcher, MultipartUpload[] completedMultipartUploads, Object uniqueOperationId)
static MultipartUploadsEvent	MultipartUploadsEvent.newInProgressEvent(ThreadWatcher threadWatcher, StorageObject[] completedObjects, Object uniqueOperationId)
static MultipartUploadsEvent	MultipartUploadsEvent.newStartedEvent(ThreadWatcher threadWatcher, Object uniqueOperationId)
static MultipartStartsEvent	MultipartStartsEvent.newStartedEvent(ThreadWatcher threadWatcher, Object uniqueOperationId)
static MultipartCompletesEvent	MultipartCompletesEvent.newStartedEvent(ThreadWatcher threadWatcher, Object uniqueOperationId)

Uses of ThreadWatcher in org.jets3t.service.multithread

Subclasses of ThreadWatcher in org.jets3t.service.multithread

Modifier and Type	Class and Description
class	ThreadWatcher Deprecated. 0.8.0 use ThreadWatcher instead.