org.apache.storm.localizer

Class LocalDownloadedResource

java.lang.Object

org.apache.storm.localizer.LocalDownloadedResource

public class LocalDownloadedResource
extends Object

Constructor Summary

Constructors

Constructor and Description
LocalDownloadedResource(Future<Void> pending)

Method Summary

Modifier and Type	Method and Description
boolean	isDone() Is this has been cleaned up completely.
boolean	release(int port, LocalAssignment la) Release a port from the reference count, and update isDone if all is done.
Future<Void>	reserve(int port, LocalAssignment la) Reserve the resources
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalDownloadedResource

public LocalDownloadedResource(Future<Void> pending)

Method Detail

reserve

public Future<Void> reserve(int port,
                            LocalAssignment la)

Reserve the resources

Parameters:

port - the port this is for

la - the assignment this is for

Returns:

a future that can be used to track it being downloaded.

release

public boolean release(int port,
                       LocalAssignment la)

Release a port from the reference count, and update isDone if all is done.

Parameters:

port - the port to release

la - the assignment to release

Returns:

true if the port was being counted else false

isDone

public boolean isDone()

Is this has been cleaned up completely.

Returns:

true if it is done else false

toString

public String toString()

Overrides:

toString in class Object