com.rackspace.jenkins_nodepool

Class KazooLock

java.lang.Object

com.rackspace.jenkins_nodepool.KazooLock

public class KazooLock
extends Object

Partial Java implementation of the Python module kazoo.recipe.lock

Author:

hughsaunders

Constructor Summary

Constructors

Constructor and Description
KazooLock(String path, long timeout, TimeUnit unit, NodePool nodePool, NodePoolJob npj) Create a new lock object.
KazooLock(String path, NodePool nodePool, NodePoolJob npj) Create a new lock object.

Method Summary

Modifier and Type	Method and Description
void	acquire() Acquire the lock for the current process
void	release() Release the lock

Methods inherited from class java.lang.Object

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

Constructor Detail

KazooLock

public KazooLock(String path,
                 NodePool nodePool,
                 NodePoolJob npj)

Create a new lock object.

Parameters:

path - the path to the lock ZNode that will be created upon acquiring the lock

nodePool - node pool object containing ZooKeeper connection information

npj - the nodepool job representing the build that requested this node/lock

KazooLock

public KazooLock(String path,
                 long timeout,
                 TimeUnit unit,
                 NodePool nodePool,
                 NodePoolJob npj)

Create a new lock object.

Parameters:

path - the path to the lock ZNode that will be created upon acquiring the lock

timeout - time to wait until lock acquisition is deemed a failure

unit - unit of time for the timeout

nodePool - node pool object containing ZooKeeper connection information

npj - NodePoolJob representing the build this node/lock was created for

Method Detail

acquire

public void acquire()
             throws Exception

Acquire the lock for the current process

Throws:

Exception - if any ZooKeeper error occurs

release

public void release()
             throws Exception

Release the lock

Throws:

Exception - on ZooKeeper error or lock state error.