This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
protected Class<? extends AvroSerializer> findSerializer(Class<?> type) { | |
if (type.isAnnotationPresent(AvroUseSerializer.class)) | |
return type.getAnnotation(AvroUseSerializer.class).value(); | |
return null; | |
} | |
// Later on | |
Class<? extends AvroSerializer> serializerClazz; | |
if ((serializerClazz = findSerializer(type)) != null) { | |
try { | |
@SuppressWarnings("unchecked") |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
public class DelayedHttpRequest implements Delayed, HttpRequest { | |
private final HttpRequest request; | |
protected long delay; // in milliseconds | |
public DelayedHttpRequest(HttpRequest request) { | |
this.request = request; | |
} | |
public void setDelay(Long delay) { | |
this.delay = delay; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/src/java/voldemort/client/DefaultStoreClient.java b/src/java/voldemort/client/DefaultStoreClient.java | |
index 5f5b72f..3b08228 100644 | |
--- a/src/java/voldemort/client/DefaultStoreClient.java | |
+++ b/src/java/voldemort/client/DefaultStoreClient.java | |
@@ -94,7 +94,7 @@ public class DefaultStoreClient<K, V> implements StoreClient<K, V> { | |
public V getValue(K key, V defaultValue) { | |
Versioned<V> versioned = get(key); | |
if(versioned == null) | |
- return null; | |
+ return defaultValue; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package voldemort.performance; | |
import voldemort.VoldemortException; | |
import voldemort.utils.pool.KeyedResourcePool; | |
import voldemort.utils.pool.ResourceFactory; | |
import voldemort.utils.pool.ResourcePoolConfig; | |
import java.util.Random; | |
import java.util.concurrent.ExecutorService; | |
import java.util.concurrent.Executors; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/src/java/voldemort/store/stats/StatTrackingStore.java b/src/java/voldemort/store/stats/StatTrackingStore.java | |
index 7b62e2d..d1b62cb 100644 | |
--- a/src/java/voldemort/store/stats/StatTrackingStore.java | |
+++ b/src/java/voldemort/store/stats/StatTrackingStore.java | |
@@ -24,6 +24,7 @@ import voldemort.annotations.jmx.JmxGetter; | |
import voldemort.annotations.jmx.JmxOperation; | |
import voldemort.store.DelegatingStore; | |
import voldemort.store.Store; | |
+import voldemort.versioning.ObsoleteVersionException; | |
import voldemort.versioning.Version; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/src/java/voldemort/store/routed/RoutedStore.java b/src/java/voldemort/store/routed/RoutedStore.java | |
index cb5b78b..f95abec 100644 | |
--- a/src/java/voldemort/store/routed/RoutedStore.java | |
+++ b/src/java/voldemort/store/routed/RoutedStore.java | |
@@ -694,7 +694,10 @@ public class RoutedStore implements Store<ByteArray, byte[]> { | |
} catch(UnreachableStoreException e) { | |
markUnavailable(node, e); | |
failures.add(e); | |
- } catch(Exception e) { | |
+ } catch (ObsoleteVersionException e) { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/src/java/voldemort/store/routed/RoutedStore.java b/src/java/voldemo | |
index f95abec..01168b1 100644 | |
--- a/src/java/voldemort/store/routed/RoutedStore.java | |
+++ b/src/java/voldemort/store/routed/RoutedStore.java | |
@@ -695,7 +695,7 @@ public class RoutedStore implements Store<ByteArray, byte[]> | |
markUnavailable(node, e); | |
failures.add(e); | |
} catch (ObsoleteVersionException e) { | |
- // Do not log or consider an obsoleteVersionException a | |
+ failures.add(e); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Release 0.57 on 11/16/2009 | |
The following changes were made since 0.55: | |
* Fix for issue 164: Changed default bdb.max.logfile.size to 60MB | |
* Make deletes asynchronous | |
* Fix for issue 163 (lock mode during get) | |
* Fixed an issue in ReadOnlyEngine's close() method | |
* Fixed hidden logging in StorageService | |
* Added debug logs for bdb stats |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/contrib/ec2-testing/test/voldemort/utils/Ec2SmokeTest.java b/contrib/ec2-testing/test/voldemort/utils/Ec2SmokeTest.java | |
index 789c5c0..8900da4 100644 | |
--- a/contrib/ec2-testing/test/voldemort/utils/Ec2SmokeTest.java | |
+++ b/contrib/ec2-testing/test/voldemort/utils/Ec2SmokeTest.java | |
@@ -29,7 +29,8 @@ import static voldemort.utils.RemoteTestUtils.stopClusterQuiet; | |
import static voldemort.utils.RemoteTestUtils.toHostNames; | |
import java.io.File; | |
-import java.io.FileReader; | |
+import java.io.InputStream; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
(require 'protobuf-mode) | |
(add-to-list 'auto-mode-alist ' | |
("\\.proto" . protobuf-mode)) | |
(defun af-protobuf-mode-hook () | |
"Protocol buffers hook." | |
(interactive "*P") | |
(setq | |
tab-width 2 |
OlderNewer