afeinberg

  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")

afeinberg

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;

afeinberg

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;

afeinberg

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;

afeinberg

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;

afeinberg

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) {

afeinberg

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);

afeinberg

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

afeinberg

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;

afeinberg

(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