TransferState (omero-blitz 5.5.5 API)

java.lang.Object
- ome.formats.importer.transfers.TransferState

All Implemented Interfaces:

TimeEstimator
```
public class TransferState
extends java.lang.Object
implements TimeEstimator
```
Non-thread-safe argument holder for FileTransfer implementations. A single instance will be created per invocation of FileTransfer.transfer(TransferState). Several instance methods are provided for common reporting actions (See usage in existing FileTransfer implementations.

Since:

5.0

Constructor Summary

Constructors
Constructor and Description
`TransferState(java.io.File file, int index, int total, ImportProcessPrx proc, ImportLibrary library, TimeEstimator estimator, ome.util.checksum.ChecksumProvider cp, byte[] buf)` State of the current file transfer.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`closeUploader()` Call `StatefulServiceInterfacePrx.close()` on the cached uploader instance if non-null and null the instance.
`byte[]`	`getBuffer()` (Not thread safe) Get a moderately large buffer for use in reading/writing data.
`java.lang.String`	`getChecksum()` Get the digest string for the local file.
`ome.util.checksum.ChecksumProvider`	`getChecksumProvider()` Get the `ChecksumProvider` passed to the constructor.
`java.io.File`	`getFile()` Return the target file passed to the constructor.
`long`	`getLength()` Return the length of the `target file`.
`OriginalFile`	`getOriginalFile()` Find original file as defined by the ID in the `RawFileStorePrx` regardless of group.
`OriginalFile`	`getRootFile()` Find original file represented by the managed repository that import is taking place to.
`RawFileStorePrx`	`getUploader()`
`RawFileStorePrx`	`getUploader(java.lang.String mode)` Return the `RawFileStorePrx` instance for this index setting the mode if not null.
`long`	`getUploadTimeLeft()` Return the estimated time left in milliseconds based on the calls to `start` and `stop` methods.
`void`	`save()` Calls `RawFileStorePrx.save()` and stores the resultant `OriginalFile` for future inspection along with the local checksum.
`void`	`start()` Starts the time counting.
`void`	`stop()` Stops the time counting and updates the internal time counter.
`void`	`stop(long uploadedBytes)` Stops the time counting and updates the internal updates the internal time counter and counter of total number of transmitted bytes.
`void`	`uploadBytes(long offset)` Raise the `ImportEvent.FILE_UPLOAD_BYTES` event to all observers.
`void`	`uploadComplete(long offset)` Raise the `ImportEvent.FILE_UPLOAD_COMPLETE` event to all observers.
`void`	`uploadStarted()` Raise the `ImportEvent.FILE_UPLOAD_STARTED` event to all observers.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - TransferState
```
public TransferState(java.io.File file,
                     int index,
                     int total,
                     ImportProcessPrx proc,
                     ImportLibrary library,
                     TimeEstimator estimator,
                     ome.util.checksum.ChecksumProvider cp,
                     byte[] buf)
              throws java.io.IOException,
                     ServerError
```
    State of the current file transfer.
    
    Parameters:
    
    file - Source file which is to be transferred.
    
    index - Which of the total files to upload this is.
    
    total - Total number of files to upload.
    
    proc - ImportProcessPrx which is being imported to.
    
    library - ImportLibrary to use for notifications.
    
    estimator - a time-to-completion estimator.
    
    cp - a checksum provider, for calculating file content checksums.
    
    buf - optional buffer. Need not be used or updated.
    
    Throws:
    
    java.io.IOException - I/O exception
    
    ServerError - server error
- Method Detail
  - save
```
public void save()
          throws ServerError
```
    Calls RawFileStorePrx.save() and stores the resultant OriginalFile for future inspection along with the local checksum. (The remote checksum is available from the OriginalFile.
    
    Throws:
    
    ServerError - server error
  - getBuffer
```
public byte[] getBuffer()
```
    (Not thread safe) Get a moderately large buffer for use in reading/writing data. To prevent the creation of many MB-sized byte arrays, this value can be re-used but requires external synchronization.
    
    Returns:
    
    the buffer
  - getChecksum
```
public java.lang.String getChecksum()
```
    Get the digest string for the local file. This will only be available, i.e. non-null, after save() has been called.
    
    Returns:
    
    the checksum
  - getChecksumProvider
```
public ome.util.checksum.ChecksumProvider getChecksumProvider()
```
    Get the ChecksumProvider passed to the constructor. Since the ChecksumProvider has a number of different usage styles, TransferState doesn't attempt to delegate but just returns the instance.
    
    Returns:
    
    the checksum provider used for calculating the checksum
  - getFile
```
public java.io.File getFile()
```
    Return the target file passed to the constructor.
    
    Returns:
    
    the source file
  - getLength
```
public long getLength()
```
    Return the length of the target file.
    
    Returns:
    
    the length of the source file
  - getOriginalFile
```
public OriginalFile getOriginalFile()
                             throws ServerError
```
    Find original file as defined by the ID in the RawFileStorePrx regardless of group.
    
    Returns:
    
    the original file from the upload process
    
    Throws:
    
    ServerError - server error
  - getRootFile
```
public OriginalFile getRootFile()
                         throws ServerError
```
    Find original file represented by the managed repository that import is taking place to.
    
    Returns:
    
    the original file at the root of the repository targeted by the upload process
    
    Throws:
    
    ServerError - server error
  - getUploader
```
public RawFileStorePrx getUploader()
                            throws ServerError
```
    Returns:
    
    the RawFileStorePrx instance for this index
    
    Throws:
    
    ServerError - server error
  - getUploader
```
public RawFileStorePrx getUploader(java.lang.String mode)
                            throws ServerError
```
    Return the RawFileStorePrx instance for this index setting the mode if not null. Valid values include "r" and "rw". If a non-null uploader is available, it will be returned instead. Every instance which is returned from this method should eventually have StatefulServiceInterfacePrx.close() called on it. StatefulServiceInterfacePrx.close() can be used to facilitate this.
    
    Parameters:
    
    mode - the mode as understood by PublicRepositoryI.file(String, String, Ice.Current)
    
    Returns:
    
    the RawFileStorePrx instance
    
    Throws:
    
    ServerError - server error
  - closeUploader
```
public void closeUploader()
```
    Call StatefulServiceInterfacePrx.close() on the cached uploader instance if non-null and null the instance. If ObjectNotExistException is thrown, the service is assumed closed. All other exceptions will be printed at WARN.
  - uploadStarted
```
public void uploadStarted()
```
    Raise the ImportEvent.FILE_UPLOAD_STARTED event to all observers.
  - uploadBytes
```
public void uploadBytes(long offset)
```
    Raise the ImportEvent.FILE_UPLOAD_BYTES event to all observers.
    
    Parameters:
    
    offset - how many bytes are uploaded
  - uploadComplete
```
public void uploadComplete(long offset)
```
    Raise the ImportEvent.FILE_UPLOAD_COMPLETE event to all observers.
    
    Parameters:
    
    offset - how many bytes are uploaded
  - start
```
public void start()
```
    Description copied from interface: TimeEstimator
    
    Starts the time counting.
    
    Specified by:
    
    start in interface TimeEstimator
  - stop
```
public void stop()
```
    Description copied from interface: TimeEstimator
    
    Stops the time counting and updates the internal time counter.
    
    Specified by:
    
    stop in interface TimeEstimator
  - stop
```
public void stop(long uploadedBytes)
```
    Description copied from interface: TimeEstimator
    
    Stops the time counting and updates the internal updates the internal time counter and counter of total number of transmitted bytes.
    
    Specified by:
    
    stop in interface TimeEstimator
    
    Parameters:
    
    uploadedBytes - Number of bytes uploaded in a single time frame that is being sampled.
  - getUploadTimeLeft
```
public long getUploadTimeLeft()
```
    Description copied from interface: TimeEstimator
    
    Return the estimated time left in milliseconds based on the calls to start and stop methods.
    
    Specified by:
    
    getUploadTimeLeft in interface TimeEstimator
    
    Returns:
    
    The estimated time remaining. The value 0 is returned if stop hasn't been called at least once before calling this method.

Class TransferState

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

TransferState

Method Detail

save

getBuffer

getChecksum

getChecksumProvider

getFile

getLength

getOriginalFile

getRootFile

getUploader

getUploader

closeUploader

uploadStarted

uploadBytes

uploadComplete

start

stop

stop

getUploadTimeLeft