Package org.apache.bookkeeper.metastore

Class MetastoreUtils.MultiMetastoreCallback<T>

java.lang.Object

org.apache.bookkeeper.metastore.MetastoreUtils.MultiMetastoreCallback<T>

All Implemented Interfaces:

MetastoreCallback<T>

Enclosing class:

MetastoreUtils

static class MetastoreUtils.MultiMetastoreCallback<T>
extends Object
implements MetastoreCallback<T>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final CountDownLatch	doneLatch
(package private) final AtomicInteger	numFinished
(package private) final int	numOps
(package private) int	rc

Constructor Summary

Constructors

Constructor	Description
MultiMetastoreCallback(int numOps)

Method Summary

Modifier and Type	Method	Description
void	complete(int rc, T value, Object ctx)
void	waitUntilAllFinished()

Methods inherited from class java.lang.Object

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

Field Details

rc

int rc

numOps

final int numOps

numFinished

final AtomicInteger numFinished

doneLatch

final CountDownLatch doneLatch

Constructor Details

MultiMetastoreCallback

MultiMetastoreCallback(int numOps)

Method Details

complete

public void complete(int rc,
 T value,
 Object ctx)

Specified by:

complete in interface MetastoreCallback<T>

See Also:

• MSException.Code

waitUntilAllFinished

public void waitUntilAllFinished()
                          throws MSException,
InterruptedException

Throws:

MSException

InterruptedException