Package fr.gouv.vitam.storage.cold.server.simulator.service

Class InaIoService

java.lang.Object

fr.gouv.vitam.storage.cold.server.simulator.service.InaIoService

public class InaIoService
extends Object

I/O Service for INA Handles write and read operations with simple file copy

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	InaIoService.ThrowingRunnable	Functional interface for actions that may throw checked exceptions.

Constructor Summary

Constructors

Constructor	Description
InaIoService(InaTapeProxyConfiguration configuration, FileSystemManager fsManager, MarkerManager markerManager, TapeCatalogRepository tapeCatalogRepository, TapeDriveRepository tapeDriveRepository, InaTapeHelper inaTapeHelper)

Method Summary

Modifier and Type	Method	Description
void	readFromTape(int driveIndex, String outputPath)	Read from tape: Check if file is already in read directory or prepare it asynchronously
void	writeToTape(int driveIndex, String inputPath)	Writes a file to tape (exchange directory).

Methods inherited from class java.lang.Object

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

Constructor Details

InaIoService

public InaIoService(InaTapeProxyConfiguration configuration,
 FileSystemManager fsManager,
 MarkerManager markerManager,
 TapeCatalogRepository tapeCatalogRepository,
 TapeDriveRepository tapeDriveRepository,
 InaTapeHelper inaTapeHelper)

Method Details

writeToTape

public void writeToTape(int driveIndex,
 String inputPath)
                 throws InaTapeProxyException

Writes a file to tape (exchange directory). If the file already exists in destination, checksums are compared to avoid unnecessary copy. Checks tape capacity before writing and increments size after successful write.

Throws:

InaTapeProxyException

readFromTape

public void readFromTape(int driveIndex,
 String outputPath)
                  throws InaTapeProxyException

Read from tape: Check if file is already in read directory or prepare it asynchronously

Throws:

InaTapeProxyException