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 java.lang.Object
implements MetastoreCallback<T>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) java.util.concurrent.CountDownLatch	doneLatch
(package private) java.util.concurrent.atomic.AtomicInteger	numFinished
(package private) 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, java.lang.Object ctx)
void	waitUntilAllFinished()

Methods inherited from class java.lang.Object

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

Field Detail

rc

int rc

numOps

final int numOps

numFinished

final java.util.concurrent.atomic.AtomicInteger numFinished

doneLatch

final java.util.concurrent.CountDownLatch doneLatch

Constructor Detail

MultiMetastoreCallback

MultiMetastoreCallback(int numOps)

Method Detail

complete

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

Specified by:

complete in interface MetastoreCallback<T>

See Also:

MSException.Code

waitUntilAllFinished

public void waitUntilAllFinished()
                          throws MSException,
                                 java.lang.InterruptedException

Throws:

MSException

java.lang.InterruptedException