Skip to content

Commit

Permalink
Adding @deprecated for proxy put param + cosmetic debug msg fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
vinothchandar committed Apr 22, 2013
1 parent 881d7b3 commit 736ccc8
Show file tree
Hide file tree
Showing 7 changed files with 14 additions and 12 deletions.
2 changes: 2 additions & 0 deletions src/java/voldemort/server/VoldemortConfig.java
Expand Up @@ -223,6 +223,8 @@ public class VoldemortConfig implements Serializable {
private int maxParallelStoresRebalancing;
private boolean rebalancingOptimization;
private boolean usePartitionScanForRebalance;
@Deprecated
// Should be removed once the proxy put implementation is stable.
private boolean proxyPutsDuringRebalance;

public VoldemortConfig(Properties props) {
Expand Down
Expand Up @@ -38,7 +38,7 @@ public void transfer() throws Exception {
while(cursor.getNext(keyEntry, valueEntry, LockMode.READ_UNCOMMITTED) == OperationStatus.SUCCESS) {
scanCount++;
if(scanCount % 1000000 == 0)
logger.info("Converted " + scanCount + "entries in "
logger.info("Converted " + scanCount + " entries in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");

// read the value as a versioned Object
Expand Down Expand Up @@ -80,7 +80,7 @@ public void transfer() throws Exception {
}
keyCount++;
}
logger.info("Completed " + scanCount + "entries and " + keyCount + " keys in "
logger.info("Completed " + scanCount + " entries and " + keyCount + " keys in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}

Expand Down
Expand Up @@ -42,7 +42,7 @@ public void transfer() throws Exception {
while(cursor.getNext(keyEntry, valueEntry, LockMode.READ_UNCOMMITTED) == OperationStatus.SUCCESS) {
scanCount++;
if(scanCount % 1000000 == 0)
logger.info("Converted " + scanCount + "entries in "
logger.info("Converted " + scanCount + " entries in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");

// read the value as a versioned Object
Expand Down Expand Up @@ -90,7 +90,7 @@ public void transfer() throws Exception {
}
keyCount++;
}
logger.info("Completed " + scanCount + "entries and " + keyCount + " keys in "
logger.info("Completed " + scanCount + " entries and " + keyCount + " keys in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}

Expand Down
Expand Up @@ -55,10 +55,10 @@ public void transfer() throws Exception {
}

if(scanCount % 1000000 == 0)
logger.info("Reverted " + scanCount + "entries in "
logger.info("Reverted " + scanCount + " entries in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}
logger.info("Converted " + scanCount + "entries and " + keyCount + " keys in "
logger.info("Converted " + scanCount + " entries and " + keyCount + " keys in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}

Expand Down
Expand Up @@ -52,10 +52,10 @@ public void transfer() throws Exception {
scanCount++;
}
if(scanCount % 1000000 == 0)
logger.info("Reverted " + scanCount + "entries in "
logger.info("Reverted " + scanCount + " entries in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}
logger.info("Reverted " + scanCount + "entries and " + keyCount + " keys in "
logger.info("Reverted " + scanCount + " entries and " + keyCount + " keys in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}

Expand Down
Expand Up @@ -54,10 +54,10 @@ public void transfer() throws Exception {
scanCount++;
}
if(scanCount % 1000000 == 0)
logger.info("Reverted " + scanCount + "entries in "
logger.info("Reverted " + scanCount + " entries in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}
logger.info("Reverted " + scanCount + "entries and " + keyCount + " keys in "
logger.info("Reverted " + scanCount + " entries and " + keyCount + " keys in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}

Expand Down
Expand Up @@ -47,10 +47,10 @@ public void transfer() throws Exception {
}

if(scanCount % 1000000 == 0)
logger.info("Reverted " + scanCount + "entries in "
logger.info("Reverted " + scanCount + " entries in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}
logger.info("Reverted " + scanCount + "entries and " + keyCount + " keys in "
logger.info("Reverted " + scanCount + " entries and " + keyCount + " keys in "
+ (System.currentTimeMillis() - startTime) / 1000 + " secs");
}

Expand Down

0 comments on commit 736ccc8

Please sign in to comment.