Ported Ruby's memcached client hashing algorithm. WARNING: This might break other stuff\!\!

Author: Wouter de Bie

src/com/meetup/memcached/AeSimpleSHA1.java

@@ -0,0 +1,34 @@
+package com.meetup.memcached;
+
+import java.io.UnsupportedEncodingException;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+
+public class AeSimpleSHA1 {
+
+    private static String convertToHex(byte[] data) {
+        StringBuffer buf = new StringBuffer();
+        for (int i = 0; i < data.length; i++) {
+            int halfbyte = (data[i] >>> 4) & 0x0F;
+            int two_halfs = 0;
+            do {
+                if ((0 <= halfbyte) && (halfbyte <= 9))
+                    buf.append((char) ('0' + halfbyte));
+                else
+                    buf.append((char) ('a' + (halfbyte - 10)));
+                halfbyte = data[i] & 0x0F;
+            } while(two_halfs++ < 1);
+        }
+        return buf.toString();
+    }
+
+    public static String SHA1(String text)
+    throws NoSuchAlgorithmException, UnsupportedEncodingException  {
+    MessageDigest md;
+    md = MessageDigest.getInstance("SHA-1");
+    byte[] sha1hash = new byte[40];
+    md.update(text.getBytes("iso-8859-1"), 0, text.length());
+    sha1hash = md.digest();
+    return convertToHex(sha1hash);
+    }
+}

src/com/meetup/memcached/Continuum.java

@@ -0,0 +1,54 @@
+package com.meetup.memcached;
+
+import java.util.ArrayList;
+
+/**
+ * Created by IntelliJ IDEA.
+ * User: wouter
+ * Date: Jun 11, 2010
+ * Time: 1:14:04 PM
+ * To change this template use File | Settings | File Templates.
+ */
+public class Continuum {
+    /*
+    upper = ary.size - 1
+    lower = 0
+    idx = 0
+
+    while(lower <= upper) do
+      idx = (lower + upper) / 2
+      comp = ary[idx].value <=> value
+
+      if comp == 0
+        return idx
+      elsif comp > 0
+        upper = idx - 1
+      else
+        lower = idx + 1
+      end
+    end
+    return upper*/
+
+    public static int binarySearch(ArrayList<ContinuumEntry> buckets, long value) {
+        int upper = buckets.size() - 1;
+        int lower = 0;
+        int idx = 0;
+        while(lower <= upper){
+            idx = (lower + upper) / 2;
+
+            long bucket_value = buckets.get(idx).getValue();
+
+            if(bucket_value == value){
+              return idx;
+            } else if(bucket_value > value){
+              upper = idx - 1;
+            } else {
+              lower = idx + 1;
+            }
+        }
+        if(upper == -1){
+            return buckets.size() - 1;
+        }
+        return upper;  //To change body of created methods use File | Settings | File Templates.
+    }
+}

src/com/meetup/memcached/ContinuumEntry.java

@@ -0,0 +1,61 @@
+package com.meetup.memcached;
+
+/**
+ * Created by IntelliJ IDEA.
+ * User: wouter
+ * Date: Jun 11, 2010
+ * Time: 12:31:13 PM
+ * To change this template use File | Settings | File Templates.
+ * <p/>
+ * class Entry
+ * attr_reader :value
+ * attr_reader :server
+ * <p/>
+ * def initialize(val, srv)
+ *
+ * @value = val
+ * @server = srv
+ * end
+ * <p/>
+ * def inspect
+ * "<#{value}, #{server.host}:#{server.port}>"
+ * end
+ * end
+ */
+public class ContinuumEntry implements Comparable<ContinuumEntry>{
+
+
+    private Long value;
+    private String server;
+
+    public ContinuumEntry(Long value, String server) {
+
+        this.value = value;
+        this.server = server;
+    }
+
+    public Long getValue() {
+        return value;
+    }
+
+    public void setValue(Long value) {
+        this.value = value;
+    }
+
+    public String getServer() {
+        return server;
+    }
+
+    public void setServer(String server) {
+        this.server = server;
+    }
+
+    public int compareTo(ContinuumEntry o) {
+        if(this.getValue() > o.getValue()) {
+            return 1;
+        } else if(this.getValue() < o.getValue()) {
+            return -1;
+        }
+        return 0;
+    }
+}

src/com/meetup/memcached/MemcachedClient.java

@@ -1635,7 +1635,7 @@ public Map<String,Object> getMulti( String[] keys, Integer[] hashCodes, boolean
 	 * Pass a SockIO object which is ready to receive data and a HashMap<br/>
 	 * to store the results.
 	 * 
-	 * @param sock socket waiting to pass back data
+	 * @param input socket waiting to pass back data
 	 * @param hm hashmap to store data into
 	 * @param asString if true, and if we are using NativehHandler, return string val
 	 * @throws IOException if io exception happens while reading from socket