EP / tokyotyrant-java / changeset / f27906734222

 				<enabled>false</enabled>
 			</snapshots>
 		</repository>
 		<repository>
 			<id>spy</id>
 			<name>Spy Repository</name>
 			<layout>default</layout>
 			<url>http://bleu.west.spy.net/~dustin/m2repo/</url>
 			<snapshots>
 				<enabled>false</enabled>
 			</snapshots>
 		</repository>
 	</repositories>
 	<pluginRepositories>
 			<version>4.0.1</version>
 			<scope>test</scope>
 		</dependency>
 		<dependency>
 			<groupId>spy</groupId>
 			<artifactId>memcached</artifactId>
 			<version>2.4.2</version>
 		</dependency>
 	</dependencies>
 	<build>

…	…	@@ -27,7 +27,7 @@ public class MRDBBenchmark {
27	27	}
28	28	}
29	29	};
30		for (int c : new int[] {1, 10, 100}) {
	30	for (int c : new int[] {1, 10, 100, 200, 300}) {
31	31	System.out.println(c + ":" + (new Benchmark(c, 10000).run(task)) + "ms");
32	32	}
33	33	db.close();

@@ -9,14 +9,20 @@ import net.spy.memcached.transcoders.Tra
 public class MemcachedBenchmark {
 	public static void main(String[] args) throws Exception {
 		final MemcachedClient db = new MemcachedClient(AddrUtil.getAddresses(args[0]));
-		db.setTranscoder(new Transcoder<Object>() {
+		final Transcoder<Object> transcoder = new Transcoder<Object>() {
 			public CachedData encode(Object data) {
-				return new CachedData(0, (byte[]) data);
+				return new CachedData(0, (byte[]) data, getMaxSize());
+			}
 			public Object decode(CachedData cachedData) {
 				return cachedData.getData();
+			}
-		});
+			public boolean asyncDecode(CachedData arg0) {
 				return false;
+			}
 			public int getMaxSize() {
 				return CachedData.MAX_SIZE;
+			}
 		};
 		final String key = "key";
 		final byte[] value = new byte[128];
 		value[0] = 1;
@@ -26,13 +32,13 @@ public class MemcachedBenchmark {
 		Runnable task = new Runnable() {
 			public void run() {
 				try {
-					assertArrayEquals(value, (byte[]) db.asyncGet(key).get());
+					assertArrayEquals(value, (byte[]) db.asyncGet(key, transcoder).get());
 				} catch (Exception e) {
 					e.printStackTrace();
+				}
+			}
 		};
-		for (int c : new int[] {1, 10, 100}) {
+		for (int c : new int[] {1, 10, 100, 200, 300}) {
 			System.out.println(c + ":" + (new Benchmark(c, 10000).run(task)) + "ms");
+		}
 		db.shutdown();

…	…	@@ -25,7 +25,7 @@ public class RDBBenchmark {
25	25	}
26	26	}
27	27	};
28		for (int c : new int[] {1, 10, 100}) {
	28	for (int c : new int[] {1, 10, 100, 200, 300}) {
29	29	System.out.println(c + ":" + (new Benchmark(c, 10000).run(task)) + "ms");
30	30	}
31	31	db.close();