From ea3d83da451d2378d8dad403b55d754f425f9dcc Mon Sep 17 00:00:00 2001 From: ticktock Date: Sat, 6 Nov 2010 11:15:55 -0400 Subject: [PATCH] freeing up a few more bytes for memcached keys, reserving a slightly less common key to hold map keysets --- .../src/main/scala/CommonStorageBackend.scala | 2 +- .../src/main/scala/MemcachedStorageBackend.scala | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/akka-persistence/akka-persistence-common/src/main/scala/CommonStorageBackend.scala b/akka-persistence/akka-persistence-common/src/main/scala/CommonStorageBackend.scala index 17502903f0..42e5fa8819 100644 --- a/akka-persistence/akka-persistence-common/src/main/scala/CommonStorageBackend.scala +++ b/akka-persistence/akka-persistence-common/src/main/scala/CommonStorageBackend.scala @@ -215,7 +215,7 @@ private[akka] object KVStorageBackend { private[akka] trait CommonStorageBackend extends MapStorageBackend[Array[Byte], Array[Byte]] with VectorStorageBackend[Array[Byte]] with RefStorageBackend[Array[Byte]] with QueueStorageBackend[Array[Byte]] with Logging { import CommonStorageBackend._ - val mapKeysIndex = IntSerializer.toBytes(-1) + val mapKeysIndex:Array[Byte] = new Array[Byte](1).padTo(1,1.asInstanceOf[Byte]) val vectorHeadIndex = IntSerializer.toBytes(-1) val vectorTailIndex = IntSerializer.toBytes(-2) val queueHeadIndex = IntSerializer.toBytes(-1) diff --git a/akka-persistence/akka-persistence-memcached/src/main/scala/MemcachedStorageBackend.scala b/akka-persistence/akka-persistence-memcached/src/main/scala/MemcachedStorageBackend.scala index 83e056900f..b84b99adbd 100644 --- a/akka-persistence/akka-persistence-memcached/src/main/scala/MemcachedStorageBackend.scala +++ b/akka-persistence/akka-persistence-memcached/src/main/scala/MemcachedStorageBackend.scala @@ -25,13 +25,13 @@ private[akka] object MemcachedStorageBackend extends CommonStorageBackend { val client = new MemcachedClient(factory, AddrUtil.getAddresses(clientAddresses)) val base64 = new Base64(76, Array.empty[Byte], true) - def queueAccess = new MemcachedAccess("que") + def queueAccess = new MemcachedAccess("Q") - def mapAccess = new MemcachedAccess("map") + def mapAccess = new MemcachedAccess("M") - def vectorAccess = new MemcachedAccess("vec") + def vectorAccess = new MemcachedAccess("V") - def refAccess = new MemcachedAccess("ref") + def refAccess = new MemcachedAccess("R") private[akka] class MemcachedAccess(val accessType: String) extends KVStorageBackendAccess {