com.rackspace.jenkins_nodepool

Class NodePoolRequestStateWatcher

java.lang.Object

com.rackspace.jenkins_nodepool.NodePoolRequestStateWatcher

All Implemented Interfaces:

org.apache.curator.framework.api.CuratorWatcher

public class NodePoolRequestStateWatcher
extends Object
implements org.apache.curator.framework.api.CuratorWatcher

A zookeeper watcher for node pool activity.

Author:

Rackspace

Method Summary

Modifier and Type	Method and Description
void	process(org.apache.zookeeper.WatchedEvent event) Our event callback method.
void	waitUntilDone(long timeout, TimeUnit unit) Waits until event fires or until the specified timeout.

Methods inherited from class java.lang.Object

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

Method Detail

process

public void process(org.apache.zookeeper.WatchedEvent event)

Our event callback method. When something changes and the request is fulfilled, we'll adjust our latch and the blocking call to waitUntilDone() will return.

Specified by:

process in interface org.apache.curator.framework.api.CuratorWatcher

Parameters:

event - the watch event value provided by the callback

waitUntilDone

public void waitUntilDone(long timeout,
                          TimeUnit unit)
                   throws InterruptedException,
                          NodePoolException

Waits until event fires or until the specified timeout.

Parameters:

timeout - the timeout value

unit - the unit of the timeout value, typically TimeUnit.SECONDS

Throws:

InterruptedException - if the current thread is interrupted while waiting

NodePoolException - if the initial state check fails