diff options
author | Mark Spruiell <mes@zeroc.com> | 2014-08-07 16:08:30 -0700 |
---|---|---|
committer | Mark Spruiell <mes@zeroc.com> | 2014-08-07 16:08:30 -0700 |
commit | 9c4b185a6c83418caa5296f07ec1f08e4964867e (patch) | |
tree | dee966c65c144f20e02583110fac6569fe7680bc /java/src/Freeze/Index.java | |
parent | fix hello demo configuration unintended change (diff) | |
download | ice-9c4b185a6c83418caa5296f07ec1f08e4964867e.tar.bz2 ice-9c4b185a6c83418caa5296f07ec1f08e4964867e.tar.xz ice-9c4b185a6c83418caa5296f07ec1f08e4964867e.zip |
ICE-5311 - use ByteBuffer in Freeze maps
Diffstat (limited to 'java/src/Freeze/Index.java')
-rw-r--r-- | java/src/Freeze/Index.java | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/java/src/Freeze/Index.java b/java/src/Freeze/Index.java index 19dbf0d7c18..3b84522ea7d 100644 --- a/java/src/Freeze/Index.java +++ b/java/src/Freeze/Index.java @@ -9,6 +9,8 @@ package Freeze; +import java.nio.ByteBuffer; + public abstract class Index implements com.sleepycat.db.SecondaryKeyCreator { // @@ -26,11 +28,10 @@ public abstract class Index implements com.sleepycat.db.SecondaryKeyCreator Ice.EncodingVersion encoding = _store.encoding(); ObjectRecord rec = ObjectStore.unmarshalValue(value, communicator, encoding, _store.keepStats()); - byte[] secondaryKey = marshalKey(rec.servant); + ByteBuffer secondaryKey = marshalKey(rec.servant); if(secondaryKey != null) { - result.setData(secondaryKey); - result.setSize(secondaryKey.length); + result.setDataNIO(secondaryKey); return true; } else @@ -61,10 +62,10 @@ public abstract class Index implements com.sleepycat.db.SecondaryKeyCreator _facet = facet; } - protected abstract byte[] marshalKey(Ice.Object servant); + protected abstract ByteBuffer marshalKey(Ice.Object servant); protected Ice.Identity[] - untypedFindFirst(byte[] k, int firstN) + untypedFindFirst(ByteBuffer k, int firstN) { EvictorI.DeactivateController deactivateController = _store.evictor().deactivateController(); deactivateController.lock(); @@ -208,13 +209,13 @@ public abstract class Index implements com.sleepycat.db.SecondaryKeyCreator } protected Ice.Identity[] - untypedFind(byte[] key) + untypedFind(ByteBuffer key) { return untypedFindFirst(key, 0); } protected int - untypedCount(byte[] k) + untypedCount(ByteBuffer k) { EvictorI.DeactivateController deactivateController = _store.evictor().deactivateController(); deactivateController.lock(); |