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

tidy up Builder refs in AnyPointer.Pipeline

Browse source
This commit is contained in:
Vaci Koblizek 2020-11-24 15:38:07 +00:00
parent 9465ffde5b
commit 5a27b4b860
1 changed files with 9 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
runtime/src/main/java/org/capnproto/AnyPointer.java
View file

@ -90,7 +90,6 @@ public final class AnyPointer {
case GET_POINTER_FIELD: case GET_POINTER_FIELD:
var index = op.pointerIndex; var index = op.pointerIndex;
var reader = WireHelpers.readStructPointer(any.segment, any.capTable, any.pointer, null, 0, any.nestingLimit); var reader = WireHelpers.readStructPointer(any.segment, any.capTable, any.pointer, null, 0, any.nestingLimit);
// TODO getpointerfield
any = reader._getPointerField(AnyPointer.factory, op.pointerIndex); any = reader._getPointerField(AnyPointer.factory, op.pointerIndex);
break; break;
} }
@ -148,10 +147,11 @@ public final class AnyPointer {
} }
} }
public static class Pipeline implements org.capnproto.Pipeline { public static final class Pipeline
implements org.capnproto.Pipeline {
protected final PipelineHook hook; final PipelineHook hook;
protected final PipelineOp[] ops; private final PipelineOp[] ops;
public Pipeline(PipelineHook hook) { public Pipeline(PipelineHook hook) {
this(hook, new PipelineOp[0]); this(hook, new PipelineOp[0]);
@ -182,9 +182,7 @@ public final class AnyPointer {
public Pipeline getPointerField(short pointerIndex) { public Pipeline getPointerField(short pointerIndex) {
var newOps = new PipelineOp[this.ops.length + 1]; var newOps = new PipelineOp[this.ops.length + 1];
for (int ii = 0; ii < this.ops.length; ++ii) { System.arraycopy(this.ops, 0, newOps, 0, this.ops.length);
newOps[ii] = this.ops[ii];
}
newOps[this.ops.length] = PipelineOp.PointerField(pointerIndex); newOps[this.ops.length] = PipelineOp.PointerField(pointerIndex);
return new Pipeline(this.hook, newOps); return new Pipeline(this.hook, newOps);
} }
@ -193,16 +191,16 @@ public final class AnyPointer {
public static final class Request public static final class Request
implements org.capnproto.Request<Builder> { implements org.capnproto.Request<Builder> {
private final AnyPointer.Builder params; private final Builder params;
private final RequestHook requestHook; private final RequestHook requestHook;
Request(AnyPointer.Builder params, RequestHook requestHook) { Request(Builder params, RequestHook requestHook) {
this.params = params; this.params = params;
this.requestHook = requestHook; this.requestHook = requestHook;
} }
@Override @Override
public AnyPointer.Builder getParams() { public Builder getParams() {
return this.params; return this.params;
} }
@ -227,7 +225,7 @@ public final class AnyPointer {
} }
public RemotePromise<Reader> send() { public RemotePromise<Reader> send() {
return this.getHook().send(); return this.requestHook.send();
} }
} }
} }