Package fr.gouv.vitam.storage.offers.tape.pool

Class TapeLibraryPoolImpl

java.lang.Object

fr.gouv.vitam.storage.offers.tape.pool.TapeLibraryPoolImpl

All Implemented Interfaces:

TapeDrivePool, TapeLibraryPool, TapeRobotPool

public class TapeLibraryPoolImpl
extends Object
implements TapeLibraryPool

Constructor Summary

Constructors

Constructor	Description
TapeLibraryPoolImpl(String libraryIdentifier, BlockingQueue<TapeRobotService> tapeRobotServicePool, ConcurrentHashMap<Integer,TapeDriveService> tapeDriveServicePool)

Method Summary

Modifier and Type	Method	Description
TapeDriveService	checkoutDriveService(Integer driveIndex)	Retrieves and removes the head of this pool, waiting if necessary until an element becomes available.
TapeRobotService	checkoutRobotService()	Retrieves and removes the head of this pool, waiting if necessary until an element becomes available.
TapeRobotService	checkoutRobotService(long timeout, TimeUnit unit)	Retrieves and removes the head of this queue, waiting up to the specified wait time if necessary for an element to become available.
Set<Map.Entry<Integer,TapeDriveService>>	drives()
String	getLibraryIdentifier()
void	pushDriveService(TapeDriveService tapeDriveService)	Return or add TapeDriveService to the pool
void	pushRobotService(TapeRobotService tapeRobotService)	Return or add TapeRobotService to the pool

Methods inherited from class java.lang.Object

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

Constructor Details

TapeLibraryPoolImpl

public TapeLibraryPoolImpl(String libraryIdentifier,
 BlockingQueue<TapeRobotService> tapeRobotServicePool,
 ConcurrentHashMap<Integer,TapeDriveService> tapeDriveServicePool)

Method Details

checkoutRobotService

public TapeRobotService checkoutRobotService()
                                      throws InterruptedException

Description copied from interface: TapeRobotPool

Retrieves and removes the head of this pool, waiting if necessary until an element becomes available.

Specified by:

checkoutRobotService in interface TapeRobotPool

Returns:

TapeRobotService

Throws:

InterruptedException

checkoutRobotService

public TapeRobotService checkoutRobotService(long timeout,
 TimeUnit unit)
                                      throws InterruptedException

Description copied from interface: TapeRobotPool

Retrieves and removes the head of this queue, waiting up to the specified wait time if necessary for an element to become available.

Specified by:

checkoutRobotService in interface TapeRobotPool

Returns:

TapeRobotService

Throws:

InterruptedException

checkoutDriveService

public TapeDriveService checkoutDriveService(Integer driveIndex)

Description copied from interface: TapeDrivePool

Retrieves and removes the head of this pool, waiting if necessary until an element becomes available.

Specified by:

checkoutDriveService in interface TapeDrivePool

Returns:

TapeDriveService

pushRobotService

public void pushRobotService(TapeRobotService tapeRobotService)
                      throws InterruptedException

Description copied from interface: TapeRobotPool

Return or add TapeRobotService to the pool

Specified by:

pushRobotService in interface TapeRobotPool

Throws:

InterruptedException

pushDriveService

public void pushDriveService(TapeDriveService tapeDriveService)

Description copied from interface: TapeDrivePool

Return or add TapeDriveService to the pool

Specified by:

pushDriveService in interface TapeDrivePool

drives

public Set<Map.Entry<Integer,TapeDriveService>> drives()

Specified by:

drives in interface TapeDrivePool

getLibraryIdentifier

public String getLibraryIdentifier()

Specified by:

getLibraryIdentifier in interface TapeRobotPool