serverscanning/capnproto-java-rpc
16
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

finish implementation of transferPointer

Browse source
This commit is contained in:
David Renshaw 2014-11-17 18:42:44 -05:00
parent 57f8a5cdfc
commit 9ba6f3970c
2 changed files with 37 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
runtime/src/main/java/org/capnproto/WireHelpers.java
View file

@ -343,7 +343,39 @@ final class WireHelpers {
//# Need to create a far pointer. Try to allocate it in the same segment as the source,
//# so that it doesn't need to be a double-far.
throw new Error("unimplemented");
int landingPadOffset = srcSegment.allocate(1);
if (landingPadOffset == SegmentBuilder.FAILED_ALLOCATION) {
//# Darn, need a double-far.
BuilderArena.AllocateResult allocation = srcSegment.getArena().allocate(2);
SegmentBuilder farSegment = allocation.segment;
landingPadOffset = allocation.offset;
FarPointer.set(farSegment.buffer, landingPadOffset, false, srcTargetOffset);
FarPointer.setSegmentId(farSegment.buffer, landingPadOffset, srcSegment.id);
WirePointer.setKindWithZeroOffset(farSegment.buffer, landingPadOffset + 1,
WirePointer.kind(srcTarget));
farSegment.buffer.putInt((landingPadOffset + 1) * Constants.BYTES_PER_WORD + 4,
srcSegment.buffer.getInt(srcOffset * Constants.BYTES_PER_WORD + 4));
FarPointer.set(dstSegment.buffer, dstOffset,
true, landingPadOffset);
FarPointer.setSegmentId(dstSegment.buffer, dstOffset,
farSegment.id);
} else {
//# Simple landing pad is just a pointer.
WirePointer.setKindAndTarget(srcSegment.buffer, landingPadOffset,
WirePointer.kind(srcTarget), srcTargetOffset);
srcSegment.buffer.putInt(landingPadOffset * Constants.BYTES_PER_WORD + 4,
srcSegment.buffer.getInt(srcOffset * Constants.BYTES_PER_WORD + 4));
FarPointer.set(dstSegment.buffer, dstOffset,
false, landingPadOffset);
FarPointer.setSegmentId(dstSegment.buffer, dstOffset,
srcSegment.id);
}
}
}

4
runtime/src/main/java/org/capnproto/WirePointer.java
View file

@ -50,6 +50,10 @@ final class WirePointer {
(((targetOffset - offset) - 1) << 2) | kind);
}
public static void setKindWithZeroOffset(ByteBuffer buffer, int offset, byte kind) {
buffer.putInt(offset * Constants.BYTES_PER_WORD, kind);
}
public static void setKindAndTargetForEmptyStruct(ByteBuffer buffer, int offset) {
//# This pointer points at an empty struct. Assuming the
//# WirePointer itself is in-bounds, we can set the target to