pegasus.mapreduce.common.coordination

Class MutexBarrier

java.lang.Object

pegasus.mapreduce.common.coordination.MutexBarrier

All Implemented Interfaces:

org.apache.zookeeper.Watcher, Barrier

public class MutexBarrier
extends java.lang.Object
implements org.apache.zookeeper.Watcher, Barrier

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event

Constructor Summary

Constructors

Constructor and Description
MutexBarrier(org.apache.zookeeper.ZooKeeper zk, java.lang.String name, int mutexId, boolean isMine)

Method Summary

Modifier and Type	Method and Description
void	cleanup() Cleanups this barrier.
void	markCompleted() Marks this barrier completed.
void	process(org.apache.zookeeper.WatchedEvent event)
void	setup() Initializes the barrier.
java.lang.String	toString()
void	waitBarrier() Waits until this barrier is marked as completed.

Methods inherited from class java.lang.Object

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

Constructor Detail

MutexBarrier

public MutexBarrier(org.apache.zookeeper.ZooKeeper zk,
                    java.lang.String name,
                    int mutexId,
                    boolean isMine)

Method Detail

setup

public final void setup()

Description copied from interface: Barrier

Initializes the barrier.

Specified by:

setup in interface Barrier

markCompleted

public final void markCompleted()

Description copied from interface: Barrier

Marks this barrier completed.

Specified by:

markCompleted in interface Barrier

waitBarrier

public final void waitBarrier()

Description copied from interface: Barrier

Waits until this barrier is marked as completed.

Specified by:

waitBarrier in interface Barrier

cleanup

public void cleanup()

Description copied from interface: Barrier

Cleanups this barrier.

Specified by:

cleanup in interface Barrier

process

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

Specified by:

process in interface org.apache.zookeeper.Watcher

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object