public class BlockUntilInitScriptStatusIsZeroThenReturnOutput extends com.google.common.util.concurrent.AbstractFuture<ExecResponse> implements Runnable
InitScript
Modifier and Type | Class and Description |
---|---|
static interface |
BlockUntilInitScriptStatusIsZeroThenReturnOutput.Factory |
Constructor and Description |
---|
BlockUntilInitScriptStatusIsZeroThenReturnOutput(com.google.common.util.concurrent.ListeningExecutorService userExecutor,
com.google.common.eventbus.EventBus eventBus,
ComputeServiceConstants.InitStatusProperties properties,
SudoAwareInitManager commandRunner) |
BlockUntilInitScriptStatusIsZeroThenReturnOutput(com.google.common.util.concurrent.ListeningExecutorService userExecutor,
com.google.common.eventbus.EventBus eventBus,
com.google.common.base.Predicate<String> notRunningAnymore,
SudoAwareInitManager commandRunner) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
ExecResponse |
get(long timeout,
TimeUnit unit) |
SudoAwareInitManager |
getCommandRunner() |
int |
hashCode() |
BlockUntilInitScriptStatusIsZeroThenReturnOutput |
init()
Submits a thread that will either set the result of the future or the exception that took
place
|
protected void |
interruptTask() |
void |
run() |
protected boolean |
set(ExecResponse value) |
String |
toString() |
protected Logger logger
@Inject public BlockUntilInitScriptStatusIsZeroThenReturnOutput(com.google.common.util.concurrent.ListeningExecutorService userExecutor, com.google.common.eventbus.EventBus eventBus, ComputeServiceConstants.InitStatusProperties properties, SudoAwareInitManager commandRunner)
public BlockUntilInitScriptStatusIsZeroThenReturnOutput(com.google.common.util.concurrent.ListeningExecutorService userExecutor, com.google.common.eventbus.EventBus eventBus, com.google.common.base.Predicate<String> notRunningAnymore, SudoAwareInitManager commandRunner)
public SudoAwareInitManager getCommandRunner()
public BlockUntilInitScriptStatusIsZeroThenReturnOutput init()
protected boolean set(ExecResponse value)
set
in class com.google.common.util.concurrent.AbstractFuture<ExecResponse>
protected void interruptTask()
interruptTask
in class com.google.common.util.concurrent.AbstractFuture<ExecResponse>
public ExecResponse get(long timeout, TimeUnit unit) throws InterruptedException, TimeoutException, ExecutionException
get
in interface Future<ExecResponse>
get
in class com.google.common.util.concurrent.AbstractFuture<ExecResponse>
InterruptedException
TimeoutException
ExecutionException
Copyright © 2009-2016 The Apache Software Foundation. All Rights Reserved.