raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

freeing up a few more bytes for memcached keys, reserving a slightly less common key to hold map keysets

Browse source
This commit is contained in:
ticktock 2010-11-06 11:15:55 -04:00
parent 1b0fdf34e3
commit ea3d83da45
2 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-persistence/akka-persistence-common/src/main/scala/CommonStorageBackend.scala
View file

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

8
akka-persistence/akka-persistence-memcached/src/main/scala/MemcachedStorageBackend.scala
View file

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