Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

fixed compilation issues after merge.

  • Loading branch information...
commit 61b01fa729a244d05ba48afb0277e6f1c17727e3 1 parent df82452
@bbansal bbansal authored
View
7 src/java/voldemort/client/protocol/admin/AdminClient.java
@@ -193,7 +193,7 @@ protected abstract void doUpdateRemoteMetadata(int remoteNodeId,
* @return True if task finished in
* @param maxWait , false otherwise
*/
- public boolean waitForCompletion(int nodeId, int requestId, long maxWait, TimeUnit timeUnit) {
+ public void waitForCompletion(int nodeId, int requestId, long maxWait, TimeUnit timeUnit) {
long delay = 250;
// don't do exponential back off past a certain limit
long maxDelay = 1000 * 60;
@@ -203,7 +203,7 @@ public boolean waitForCompletion(int nodeId, int requestId, long maxWait, TimeUn
while(System.currentTimeMillis() < waitUntil) {
AsyncOperationStatus status = getAsyncRequestStatus(nodeId, requestId);
if(status.isComplete())
- return true;
+ return;
if(delay < maxDelay)
// keep doubling the wait period until we rach maxDelay
delay <<= 2;
@@ -213,8 +213,7 @@ public boolean waitForCompletion(int nodeId, int requestId, long maxWait, TimeUn
Thread.currentThread().interrupt();
}
}
-
- return false;
+ throw new VoldemortException("Task requestId:" + requestId + " failed to complete in " + maxWait + " " + timeUnit.toString()) ;
}
/* Helper functions */
View
4 src/java/voldemort/store/configuration/ConfigurationStorageEngine.java
@@ -275,4 +275,8 @@ private void writeVersion(String key, VectorClock version) {
throw new VoldemortException("Failed to write Version for Key:" + key, e);
}
}
+
+ public ClosableIterator<String> keys() {
+ throw new VoldemortException("Keys Iteration not supported in ConfigurationStorageEngine");
+ }
}
Please sign in to comment.
Something went wrong with that request. Please try again.