add two-party RPC protocol
This commit is contained in:
Vaci Koblizek
parent
7713316683
commit
385746dc4f
2 changed files with 651 additions and 1 deletions
635
runtime/src/main/java/org/capnproto/RpcTwoPartyProtocol.java
Normal file
635
runtime/src/main/java/org/capnproto/RpcTwoPartyProtocol.java
Normal file
|
|
@ -0,0 +1,635 @@
|
||||||
|
// Generated by Cap'n Proto compiler, DO NOT EDIT
|
||||||
|
// source: rpc-twoparty.capnp
|
||||||
|
|
||||||
|
package org.capnproto;
|
||||||
|
|
||||||
|
public final class RpcTwoPartyProtocol {
|
||||||
|
public enum Side {
|
||||||
|
SERVER,
|
||||||
|
CLIENT,
|
||||||
|
_NOT_IN_SCHEMA,
|
||||||
|
}
|
||||||
|
|
||||||
|
public static class VatId {
|
||||||
|
public static final org.capnproto.StructSize STRUCT_SIZE = new org.capnproto.StructSize((short)1,(short)0);
|
||||||
|
public static final class Factory extends org.capnproto.StructFactory<Builder, Reader> {
|
||||||
|
public Factory() {
|
||||||
|
}
|
||||||
|
public final Reader constructReader(org.capnproto.SegmentReader segment, int data,int pointers, int dataSize, short pointerCount, int nestingLimit) {
|
||||||
|
return new Reader(segment,data,pointers,dataSize,pointerCount,nestingLimit);
|
||||||
|
}
|
||||||
|
public final Builder constructBuilder(org.capnproto.SegmentBuilder segment, int data,int pointers, int dataSize, short pointerCount) {
|
||||||
|
return new Builder(segment, data, pointers, dataSize, pointerCount);
|
||||||
|
}
|
||||||
|
public final org.capnproto.StructSize structSize() {
|
||||||
|
return VatId.STRUCT_SIZE;
|
||||||
|
}
|
||||||
|
public final Reader asReader(Builder builder) {
|
||||||
|
return builder.asReader();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
public static final Factory factory = new Factory();
|
||||||
|
public static final org.capnproto.StructList.Factory<Builder,Reader> listFactory =
|
||||||
|
new org.capnproto.StructList.Factory<Builder, Reader>(factory);
|
||||||
|
public static final class Builder extends org.capnproto.StructBuilder {
|
||||||
|
Builder(org.capnproto.SegmentBuilder segment, int data, int pointers,int dataSize, short pointerCount){
|
||||||
|
super(segment, data, pointers, dataSize, pointerCount);
|
||||||
|
}
|
||||||
|
public final Reader asReader() {
|
||||||
|
return new Reader(segment, data, pointers, dataSize, pointerCount, 0x7fffffff);
|
||||||
|
}
|
||||||
|
public final RpcTwoPartyProtocol.Side getSide() {
|
||||||
|
switch(_getShortField(0)) {
|
||||||
|
case 0 : return RpcTwoPartyProtocol.Side.SERVER;
|
||||||
|
case 1 : return RpcTwoPartyProtocol.Side.CLIENT;
|
||||||
|
default: return RpcTwoPartyProtocol.Side._NOT_IN_SCHEMA;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
public final void setSide(RpcTwoPartyProtocol.Side value) {
|
||||||
|
_setShortField(0, (short)value.ordinal());
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
public static final class Reader extends org.capnproto.StructReader {
|
||||||
|
Reader(org.capnproto.SegmentReader segment, int data, int pointers,int dataSize, short pointerCount, int nestingLimit){
|
||||||
|
super(segment, data, pointers, dataSize, pointerCount, nestingLimit);
|
||||||
|
}
|
||||||
|
|
||||||
|
public final RpcTwoPartyProtocol.Side getSide() {
|
||||||
|
switch(_getShortField(0)) {
|
||||||
|
case 0 : return RpcTwoPartyProtocol.Side.SERVER;
|
||||||
|
case 1 : return RpcTwoPartyProtocol.Side.CLIENT;
|
||||||
|
default: return RpcTwoPartyProtocol.Side._NOT_IN_SCHEMA;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public static class ProvisionId {
|
||||||
|
public static final org.capnproto.StructSize STRUCT_SIZE = new org.capnproto.StructSize((short)1,(short)0);
|
||||||
|
public static final class Factory extends org.capnproto.StructFactory<Builder, Reader> {
|
||||||
|
public Factory() {
|
||||||
|
}
|
||||||
|
public final Reader constructReader(org.capnproto.SegmentReader segment, int data,int pointers, int dataSize, short pointerCount, int nestingLimit) {
|
||||||
|
return new Reader(segment,data,pointers,dataSize,pointerCount,nestingLimit);
|
||||||
|
}
|
||||||
|
public final Builder constructBuilder(org.capnproto.SegmentBuilder segment, int data,int pointers, int dataSize, short pointerCount) {
|
||||||
|
return new Builder(segment, data, pointers, dataSize, pointerCount);
|
||||||
|
}
|
||||||
|
public final org.capnproto.StructSize structSize() {
|
||||||
|
return ProvisionId.STRUCT_SIZE;
|
||||||
|
}
|
||||||
|
public final Reader asReader(Builder builder) {
|
||||||
|
return builder.asReader();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
public static final Factory factory = new Factory();
|
||||||
|
public static final org.capnproto.StructList.Factory<Builder,Reader> listFactory =
|
||||||
|
new org.capnproto.StructList.Factory<Builder, Reader>(factory);
|
||||||
|
public static final class Builder extends org.capnproto.StructBuilder {
|
||||||
|
Builder(org.capnproto.SegmentBuilder segment, int data, int pointers,int dataSize, short pointerCount){
|
||||||
|
super(segment, data, pointers, dataSize, pointerCount);
|
||||||
|
}
|
||||||
|
public final Reader asReader() {
|
||||||
|
return new Reader(segment, data, pointers, dataSize, pointerCount, 0x7fffffff);
|
||||||
|
}
|
||||||
|
public final int getJoinId() {
|
||||||
|
return _getIntField(0);
|
||||||
|
}
|
||||||
|
public final void setJoinId(int value) {
|
||||||
|
_setIntField(0, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
public static final class Reader extends org.capnproto.StructReader {
|
||||||
|
Reader(org.capnproto.SegmentReader segment, int data, int pointers,int dataSize, short pointerCount, int nestingLimit){
|
||||||
|
super(segment, data, pointers, dataSize, pointerCount, nestingLimit);
|
||||||
|
}
|
||||||
|
|
||||||
|
public final int getJoinId() {
|
||||||
|
return _getIntField(0);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public static class RecipientId {
|
||||||
|
public static final org.capnproto.StructSize STRUCT_SIZE = new org.capnproto.StructSize((short)0,(short)0);
|
||||||
|
public static final class Factory extends org.capnproto.StructFactory<Builder, Reader> {
|
||||||
|
public Factory() {
|
||||||
|
}
|
||||||
|
public final Reader constructReader(org.capnproto.SegmentReader segment, int data,int pointers, int dataSize, short pointerCount, int nestingLimit) {
|
||||||
|
return new Reader(segment,data,pointers,dataSize,pointerCount,nestingLimit);
|
||||||
|
}
|
||||||
|
public final Builder constructBuilder(org.capnproto.SegmentBuilder segment, int data,int pointers, int dataSize, short pointerCount) {
|
||||||
|
return new Builder(segment, data, pointers, dataSize, pointerCount);
|
||||||
|
}
|
||||||
|
public final org.capnproto.StructSize structSize() {
|
||||||
|
return RecipientId.STRUCT_SIZE;
|
||||||
|
}
|
||||||
|
public final Reader asReader(Builder builder) {
|
||||||
|
return builder.asReader();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
public static final Factory factory = new Factory();
|
||||||
|
public static final org.capnproto.StructList.Factory<Builder,Reader> listFactory =
|
||||||
|
new org.capnproto.StructList.Factory<Builder, Reader>(factory);
|
||||||
|
public static final class Builder extends org.capnproto.StructBuilder {
|
||||||
|
Builder(org.capnproto.SegmentBuilder segment, int data, int pointers,int dataSize, short pointerCount){
|
||||||
|
super(segment, data, pointers, dataSize, pointerCount);
|
||||||
|
}
|
||||||
|
public final Reader asReader() {
|
||||||
|
return new Reader(segment, data, pointers, dataSize, pointerCount, 0x7fffffff);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public static final class Reader extends org.capnproto.StructReader {
|
||||||
|
Reader(org.capnproto.SegmentReader segment, int data, int pointers,int dataSize, short pointerCount, int nestingLimit){
|
||||||
|
super(segment, data, pointers, dataSize, pointerCount, nestingLimit);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public static class ThirdPartyCapId {
|
||||||
|
public static final org.capnproto.StructSize STRUCT_SIZE = new org.capnproto.StructSize((short)0,(short)0);
|
||||||
|
public static final class Factory extends org.capnproto.StructFactory<Builder, Reader> {
|
||||||
|
public Factory() {
|
||||||
|
}
|
||||||
|
public final Reader constructReader(org.capnproto.SegmentReader segment, int data,int pointers, int dataSize, short pointerCount, int nestingLimit) {
|
||||||
|
return new Reader(segment,data,pointers,dataSize,pointerCount,nestingLimit);
|
||||||
|
}
|
||||||
|
public final Builder constructBuilder(org.capnproto.SegmentBuilder segment, int data,int pointers, int dataSize, short pointerCount) {
|
||||||
|
return new Builder(segment, data, pointers, dataSize, pointerCount);
|
||||||
|
}
|
||||||
|
public final org.capnproto.StructSize structSize() {
|
||||||
|
return ThirdPartyCapId.STRUCT_SIZE;
|
||||||
|
}
|
||||||
|
public final Reader asReader(Builder builder) {
|
||||||
|
return builder.asReader();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
public static final Factory factory = new Factory();
|
||||||
|
public static final org.capnproto.StructList.Factory<Builder,Reader> listFactory =
|
||||||
|
new org.capnproto.StructList.Factory<Builder, Reader>(factory);
|
||||||
|
public static final class Builder extends org.capnproto.StructBuilder {
|
||||||
|
Builder(org.capnproto.SegmentBuilder segment, int data, int pointers,int dataSize, short pointerCount){
|
||||||
|
super(segment, data, pointers, dataSize, pointerCount);
|
||||||
|
}
|
||||||
|
public final Reader asReader() {
|
||||||
|
return new Reader(segment, data, pointers, dataSize, pointerCount, 0x7fffffff);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public static final class Reader extends org.capnproto.StructReader {
|
||||||
|
Reader(org.capnproto.SegmentReader segment, int data, int pointers,int dataSize, short pointerCount, int nestingLimit){
|
||||||
|
super(segment, data, pointers, dataSize, pointerCount, nestingLimit);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public static class JoinKeyPart {
|
||||||
|
public static final org.capnproto.StructSize STRUCT_SIZE = new org.capnproto.StructSize((short)1,(short)0);
|
||||||
|
public static final class Factory extends org.capnproto.StructFactory<Builder, Reader> {
|
||||||
|
public Factory() {
|
||||||
|
}
|
||||||
|
public final Reader constructReader(org.capnproto.SegmentReader segment, int data,int pointers, int dataSize, short pointerCount, int nestingLimit) {
|
||||||
|
return new Reader(segment,data,pointers,dataSize,pointerCount,nestingLimit);
|
||||||
|
}
|
||||||
|
public final Builder constructBuilder(org.capnproto.SegmentBuilder segment, int data,int pointers, int dataSize, short pointerCount) {
|
||||||
|
return new Builder(segment, data, pointers, dataSize, pointerCount);
|
||||||
|
}
|
||||||
|
public final org.capnproto.StructSize structSize() {
|
||||||
|
return JoinKeyPart.STRUCT_SIZE;
|
||||||
|
}
|
||||||
|
public final Reader asReader(Builder builder) {
|
||||||
|
return builder.asReader();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
public static final Factory factory = new Factory();
|
||||||
|
public static final org.capnproto.StructList.Factory<Builder,Reader> listFactory =
|
||||||
|
new org.capnproto.StructList.Factory<Builder, Reader>(factory);
|
||||||
|
public static final class Builder extends org.capnproto.StructBuilder {
|
||||||
|
Builder(org.capnproto.SegmentBuilder segment, int data, int pointers,int dataSize, short pointerCount){
|
||||||
|
super(segment, data, pointers, dataSize, pointerCount);
|
||||||
|
}
|
||||||
|
public final Reader asReader() {
|
||||||
|
return new Reader(segment, data, pointers, dataSize, pointerCount, 0x7fffffff);
|
||||||
|
}
|
||||||
|
public final int getJoinId() {
|
||||||
|
return _getIntField(0);
|
||||||
|
}
|
||||||
|
public final void setJoinId(int value) {
|
||||||
|
_setIntField(0, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public final short getPartCount() {
|
||||||
|
return _getShortField(2);
|
||||||
|
}
|
||||||
|
public final void setPartCount(short value) {
|
||||||
|
_setShortField(2, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public final short getPartNum() {
|
||||||
|
return _getShortField(3);
|
||||||
|
}
|
||||||
|
public final void setPartNum(short value) {
|
||||||
|
_setShortField(3, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
public static final class Reader extends org.capnproto.StructReader {
|
||||||
|
Reader(org.capnproto.SegmentReader segment, int data, int pointers,int dataSize, short pointerCount, int nestingLimit){
|
||||||
|
super(segment, data, pointers, dataSize, pointerCount, nestingLimit);
|
||||||
|
}
|
||||||
|
|
||||||
|
public final int getJoinId() {
|
||||||
|
return _getIntField(0);
|
||||||
|
}
|
||||||
|
|
||||||
|
public final short getPartCount() {
|
||||||
|
return _getShortField(2);
|
||||||
|
}
|
||||||
|
|
||||||
|
public final short getPartNum() {
|
||||||
|
return _getShortField(3);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public static class JoinResult {
|
||||||
|
public static final org.capnproto.StructSize STRUCT_SIZE = new org.capnproto.StructSize((short)1,(short)1);
|
||||||
|
public static final class Factory extends org.capnproto.StructFactory<Builder, Reader> {
|
||||||
|
public Factory() {
|
||||||
|
}
|
||||||
|
public final Reader constructReader(org.capnproto.SegmentReader segment, int data,int pointers, int dataSize, short pointerCount, int nestingLimit) {
|
||||||
|
return new Reader(segment,data,pointers,dataSize,pointerCount,nestingLimit);
|
||||||
|
}
|
||||||
|
public final Builder constructBuilder(org.capnproto.SegmentBuilder segment, int data,int pointers, int dataSize, short pointerCount) {
|
||||||
|
return new Builder(segment, data, pointers, dataSize, pointerCount);
|
||||||
|
}
|
||||||
|
public final org.capnproto.StructSize structSize() {
|
||||||
|
return JoinResult.STRUCT_SIZE;
|
||||||
|
}
|
||||||
|
public final Reader asReader(Builder builder) {
|
||||||
|
return builder.asReader();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
public static final Factory factory = new Factory();
|
||||||
|
public static final org.capnproto.StructList.Factory<Builder,Reader> listFactory =
|
||||||
|
new org.capnproto.StructList.Factory<Builder, Reader>(factory);
|
||||||
|
public static final class Builder extends org.capnproto.StructBuilder {
|
||||||
|
Builder(org.capnproto.SegmentBuilder segment, int data, int pointers,int dataSize, short pointerCount){
|
||||||
|
super(segment, data, pointers, dataSize, pointerCount);
|
||||||
|
}
|
||||||
|
public final Reader asReader() {
|
||||||
|
return new Reader(segment, data, pointers, dataSize, pointerCount, 0x7fffffff);
|
||||||
|
}
|
||||||
|
public final int getJoinId() {
|
||||||
|
return _getIntField(0);
|
||||||
|
}
|
||||||
|
public final void setJoinId(int value) {
|
||||||
|
_setIntField(0, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public final boolean getSucceeded() {
|
||||||
|
return _getBooleanField(32);
|
||||||
|
}
|
||||||
|
public final void setSucceeded(boolean value) {
|
||||||
|
_setBooleanField(32, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
public final boolean hasCap() {
|
||||||
|
return !_pointerFieldIsNull(0);
|
||||||
|
}
|
||||||
|
public org.capnproto.AnyPointer.Builder getCap() {
|
||||||
|
return _getPointerField(org.capnproto.AnyPointer.factory, 0);
|
||||||
|
}
|
||||||
|
public org.capnproto.AnyPointer.Builder initCap() {
|
||||||
|
return _initPointerField(org.capnproto.AnyPointer.factory, 0, 0);
|
||||||
|
}
|
||||||
|
public org.capnproto.AnyPointer.Builder initCap(int size) {
|
||||||
|
return _initPointerField(org.capnproto.AnyPointer.factory, 0, size);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
public static final class Reader extends org.capnproto.StructReader {
|
||||||
|
Reader(org.capnproto.SegmentReader segment, int data, int pointers,int dataSize, short pointerCount, int nestingLimit){
|
||||||
|
super(segment, data, pointers, dataSize, pointerCount, nestingLimit);
|
||||||
|
}
|
||||||
|
|
||||||
|
public final int getJoinId() {
|
||||||
|
return _getIntField(0);
|
||||||
|
}
|
||||||
|
|
||||||
|
public final boolean getSucceeded() {
|
||||||
|
return _getBooleanField(32);
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean hasCap() {
|
||||||
|
return !_pointerFieldIsNull(0);
|
||||||
|
}
|
||||||
|
public org.capnproto.AnyPointer.Reader getCap() {
|
||||||
|
return _getPointerField(org.capnproto.AnyPointer.factory, 0);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
public static final class Schemas {
|
||||||
|
public static final org.capnproto.SegmentReader b_9fd69ebc87b9719c =
|
||||||
|
org.capnproto.GeneratedClassSupport.decodeRawBytes(
|
||||||
|
"\u0000\u0000\u0000\u0000\u0005\u0000\u0006\u0000" +
|
||||||
|
"\u009c\u0071\u00b9\u0087\u00bc\u009e\u00d6\u009f" +
|
||||||
|
"\u0019\u0000\u0000\u0000\u0002\u0000\u0000\u0000" +
|
||||||
|
"\u00a1\u00f2\u00da\\\u0088\u00c7\u0084\u00a1" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0015\u0000\u0000\u0000\u00f2\u0000\u0000\u0000" +
|
||||||
|
"\u0021\u0000\u0000\u0000\u0007\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u001d\u0000\u0000\u0000\u0037\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0063\u0061\u0070\u006e\u0070\u002f\u0072\u0070" +
|
||||||
|
"\u0063\u002d\u0074\u0077\u006f\u0070\u0061\u0072" +
|
||||||
|
"\u0074\u0079\u002e\u0063\u0061\u0070\u006e\u0070" +
|
||||||
|
"\u003a\u0053\u0069\u0064\u0065\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0001\u0000\u0001\u0000" +
|
||||||
|
"\u0008\u0000\u0000\u0000\u0001\u0000\u0002\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0011\u0000\u0000\u0000\u003a\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0001\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0009\u0000\u0000\u0000\u003a\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0073\u0065\u0072\u0076\u0065\u0072\u0000\u0000" +
|
||||||
|
"\u0063\u006c\u0069\u0065\u006e\u0074\u0000\u0000" + "");
|
||||||
|
public static final org.capnproto.SegmentReader b_d20b909fee733a8e =
|
||||||
|
org.capnproto.GeneratedClassSupport.decodeRawBytes(
|
||||||
|
"\u0000\u0000\u0000\u0000\u0005\u0000\u0006\u0000" +
|
||||||
|
"\u008e\u003a\u0073\u00ee\u009f\u0090\u000b\u00d2" +
|
||||||
|
"\u0019\u0000\u0000\u0000\u0001\u0000\u0001\u0000" +
|
||||||
|
"\u00a1\u00f2\u00da\\\u0088\u00c7\u0084\u00a1" +
|
||||||
|
"\u0000\u0000\u0007\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0015\u0000\u0000\u0000\u00fa\u0000\u0000\u0000" +
|
||||||
|
"\u0021\u0000\u0000\u0000\u0007\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u001d\u0000\u0000\u0000\u003f\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0063\u0061\u0070\u006e\u0070\u002f\u0072\u0070" +
|
||||||
|
"\u0063\u002d\u0074\u0077\u006f\u0070\u0061\u0072" +
|
||||||
|
"\u0074\u0079\u002e\u0063\u0061\u0070\u006e\u0070" +
|
||||||
|
"\u003a\u0056\u0061\u0074\u0049\u0064\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0001\u0000\u0001\u0000" +
|
||||||
|
"\u0004\u0000\u0000\u0000\u0003\u0000\u0004\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0001\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\r\u0000\u0000\u0000\u002a\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0008\u0000\u0000\u0000\u0003\u0000\u0001\u0000" +
|
||||||
|
"\u0014\u0000\u0000\u0000\u0002\u0000\u0001\u0000" +
|
||||||
|
"\u0073\u0069\u0064\u0065\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u000f\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u009c\u0071\u00b9\u0087\u00bc\u009e\u00d6\u009f" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u000f\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" + "");
|
||||||
|
public static final org.capnproto.SegmentReader b_b88d09a9c5f39817 =
|
||||||
|
org.capnproto.GeneratedClassSupport.decodeRawBytes(
|
||||||
|
"\u0000\u0000\u0000\u0000\u0005\u0000\u0006\u0000" +
|
||||||
|
"\u0017\u0098\u00f3\u00c5\u00a9\u0009\u008d\u00b8" +
|
||||||
|
"\u0019\u0000\u0000\u0000\u0001\u0000\u0001\u0000" +
|
||||||
|
"\u00a1\u00f2\u00da\\\u0088\u00c7\u0084\u00a1" +
|
||||||
|
"\u0000\u0000\u0007\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0015\u0000\u0000\u0000\u002a\u0001\u0000\u0000" +
|
||||||
|
"\u0025\u0000\u0000\u0000\u0007\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0021\u0000\u0000\u0000\u003f\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0063\u0061\u0070\u006e\u0070\u002f\u0072\u0070" +
|
||||||
|
"\u0063\u002d\u0074\u0077\u006f\u0070\u0061\u0072" +
|
||||||
|
"\u0074\u0079\u002e\u0063\u0061\u0070\u006e\u0070" +
|
||||||
|
"\u003a\u0050\u0072\u006f\u0076\u0069\u0073\u0069" +
|
||||||
|
"\u006f\u006e\u0049\u0064\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0001\u0000\u0001\u0000" +
|
||||||
|
"\u0004\u0000\u0000\u0000\u0003\u0000\u0004\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0001\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\r\u0000\u0000\u0000\u003a\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0008\u0000\u0000\u0000\u0003\u0000\u0001\u0000" +
|
||||||
|
"\u0014\u0000\u0000\u0000\u0002\u0000\u0001\u0000" +
|
||||||
|
"\u006a\u006f\u0069\u006e\u0049\u0064\u0000\u0000" +
|
||||||
|
"\u0008\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0008\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" + "");
|
||||||
|
public static final org.capnproto.SegmentReader b_89f389b6fd4082c1 =
|
||||||
|
org.capnproto.GeneratedClassSupport.decodeRawBytes(
|
||||||
|
"\u0000\u0000\u0000\u0000\u0005\u0000\u0006\u0000" +
|
||||||
|
"\u00c1\u0082\u0040\u00fd\u00b6\u0089\u00f3\u0089" +
|
||||||
|
"\u0019\u0000\u0000\u0000\u0001\u0000\u0000\u0000" +
|
||||||
|
"\u00a1\u00f2\u00da\\\u0088\u00c7\u0084\u00a1" +
|
||||||
|
"\u0000\u0000\u0007\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0015\u0000\u0000\u0000\u002a\u0001\u0000\u0000" +
|
||||||
|
"\u0025\u0000\u0000\u0000\u0007\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0063\u0061\u0070\u006e\u0070\u002f\u0072\u0070" +
|
||||||
|
"\u0063\u002d\u0074\u0077\u006f\u0070\u0061\u0072" +
|
||||||
|
"\u0074\u0079\u002e\u0063\u0061\u0070\u006e\u0070" +
|
||||||
|
"\u003a\u0052\u0065\u0063\u0069\u0070\u0069\u0065" +
|
||||||
|
"\u006e\u0074\u0049\u0064\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0001\u0000\u0001\u0000" + "");
|
||||||
|
public static final org.capnproto.SegmentReader b_b47f4979672cb59d =
|
||||||
|
org.capnproto.GeneratedClassSupport.decodeRawBytes(
|
||||||
|
"\u0000\u0000\u0000\u0000\u0005\u0000\u0006\u0000" +
|
||||||
|
"\u009d\u00b5\u002c\u0067\u0079\u0049\u007f\u00b4" +
|
||||||
|
"\u0019\u0000\u0000\u0000\u0001\u0000\u0000\u0000" +
|
||||||
|
"\u00a1\u00f2\u00da\\\u0088\u00c7\u0084\u00a1" +
|
||||||
|
"\u0000\u0000\u0007\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0015\u0000\u0000\u0000\u004a\u0001\u0000\u0000" +
|
||||||
|
"\u0029\u0000\u0000\u0000\u0007\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0063\u0061\u0070\u006e\u0070\u002f\u0072\u0070" +
|
||||||
|
"\u0063\u002d\u0074\u0077\u006f\u0070\u0061\u0072" +
|
||||||
|
"\u0074\u0079\u002e\u0063\u0061\u0070\u006e\u0070" +
|
||||||
|
"\u003a\u0054\u0068\u0069\u0072\u0064\u0050\u0061" +
|
||||||
|
"\u0072\u0074\u0079\u0043\u0061\u0070\u0049\u0064" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0001\u0000\u0001\u0000" + "");
|
||||||
|
public static final org.capnproto.SegmentReader b_95b29059097fca83 =
|
||||||
|
org.capnproto.GeneratedClassSupport.decodeRawBytes(
|
||||||
|
"\u0000\u0000\u0000\u0000\u0005\u0000\u0006\u0000" +
|
||||||
|
"\u0083\u00ca\u007f\u0009\u0059\u0090\u00b2\u0095" +
|
||||||
|
"\u0019\u0000\u0000\u0000\u0001\u0000\u0001\u0000" +
|
||||||
|
"\u00a1\u00f2\u00da\\\u0088\u00c7\u0084\u00a1" +
|
||||||
|
"\u0000\u0000\u0007\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0015\u0000\u0000\u0000\u002a\u0001\u0000\u0000" +
|
||||||
|
"\u0025\u0000\u0000\u0000\u0007\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0021\u0000\u0000\u0000\u00af\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0063\u0061\u0070\u006e\u0070\u002f\u0072\u0070" +
|
||||||
|
"\u0063\u002d\u0074\u0077\u006f\u0070\u0061\u0072" +
|
||||||
|
"\u0074\u0079\u002e\u0063\u0061\u0070\u006e\u0070" +
|
||||||
|
"\u003a\u004a\u006f\u0069\u006e\u004b\u0065\u0079" +
|
||||||
|
"\u0050\u0061\u0072\u0074\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0001\u0000\u0001\u0000" +
|
||||||
|
"\u000c\u0000\u0000\u0000\u0003\u0000\u0004\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0001\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0045\u0000\u0000\u0000\u003a\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0040\u0000\u0000\u0000\u0003\u0000\u0001\u0000" +
|
||||||
|
"\u004c\u0000\u0000\u0000\u0002\u0000\u0001\u0000" +
|
||||||
|
"\u0001\u0000\u0000\u0000\u0002\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0001\u0000\u0001\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0049\u0000\u0000\u0000\u0052\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0048\u0000\u0000\u0000\u0003\u0000\u0001\u0000" +
|
||||||
|
"\u0054\u0000\u0000\u0000\u0002\u0000\u0001\u0000" +
|
||||||
|
"\u0002\u0000\u0000\u0000\u0003\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0001\u0000\u0002\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0051\u0000\u0000\u0000\u0042\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u004c\u0000\u0000\u0000\u0003\u0000\u0001\u0000" +
|
||||||
|
"\u0058\u0000\u0000\u0000\u0002\u0000\u0001\u0000" +
|
||||||
|
"\u006a\u006f\u0069\u006e\u0049\u0064\u0000\u0000" +
|
||||||
|
"\u0008\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0008\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0070\u0061\u0072\u0074\u0043\u006f\u0075\u006e" +
|
||||||
|
"\u0074\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0007\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0007\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0070\u0061\u0072\u0074\u004e\u0075\u006d\u0000" +
|
||||||
|
"\u0007\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0007\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" + "");
|
||||||
|
public static final org.capnproto.SegmentReader b_9d263a3630b7ebee =
|
||||||
|
org.capnproto.GeneratedClassSupport.decodeRawBytes(
|
||||||
|
"\u0000\u0000\u0000\u0000\u0005\u0000\u0006\u0000" +
|
||||||
|
"\u00ee\u00eb\u00b7\u0030\u0036\u003a\u0026\u009d" +
|
||||||
|
"\u0019\u0000\u0000\u0000\u0001\u0000\u0001\u0000" +
|
||||||
|
"\u00a1\u00f2\u00da\\\u0088\u00c7\u0084\u00a1" +
|
||||||
|
"\u0001\u0000\u0007\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0015\u0000\u0000\u0000\"\u0001\u0000\u0000" +
|
||||||
|
"\u0025\u0000\u0000\u0000\u0007\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0021\u0000\u0000\u0000\u00af\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0063\u0061\u0070\u006e\u0070\u002f\u0072\u0070" +
|
||||||
|
"\u0063\u002d\u0074\u0077\u006f\u0070\u0061\u0072" +
|
||||||
|
"\u0074\u0079\u002e\u0063\u0061\u0070\u006e\u0070" +
|
||||||
|
"\u003a\u004a\u006f\u0069\u006e\u0052\u0065\u0073" +
|
||||||
|
"\u0075\u006c\u0074\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0001\u0000\u0001\u0000" +
|
||||||
|
"\u000c\u0000\u0000\u0000\u0003\u0000\u0004\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0001\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0045\u0000\u0000\u0000\u003a\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0040\u0000\u0000\u0000\u0003\u0000\u0001\u0000" +
|
||||||
|
"\u004c\u0000\u0000\u0000\u0002\u0000\u0001\u0000" +
|
||||||
|
"\u0001\u0000\u0000\u0000\u0020\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0001\u0000\u0001\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0049\u0000\u0000\u0000\u0052\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0048\u0000\u0000\u0000\u0003\u0000\u0001\u0000" +
|
||||||
|
"\u0054\u0000\u0000\u0000\u0002\u0000\u0001\u0000" +
|
||||||
|
"\u0002\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0001\u0000\u0002\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0051\u0000\u0000\u0000\"\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u004c\u0000\u0000\u0000\u0003\u0000\u0001\u0000" +
|
||||||
|
"\u0058\u0000\u0000\u0000\u0002\u0000\u0001\u0000" +
|
||||||
|
"\u006a\u006f\u0069\u006e\u0049\u0064\u0000\u0000" +
|
||||||
|
"\u0008\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0008\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0073\u0075\u0063\u0063\u0065\u0065\u0064\u0065" +
|
||||||
|
"\u0064\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0001\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0001\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0063\u0061\u0070\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0012\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0012\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" +
|
||||||
|
"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000" + "");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
@ -8,9 +8,24 @@ public class TwoPartyVatNetwork implements VatNetwork, VatNetwork.Connection {
|
||||||
|
|
||||||
private CompletableFuture<?> writeCompleted = CompletableFuture.completedFuture(null);
|
private CompletableFuture<?> writeCompleted = CompletableFuture.completedFuture(null);
|
||||||
private final AsynchronousByteChannel channel;
|
private final AsynchronousByteChannel channel;
|
||||||
|
private final RpcTwoPartyProtocol.Side side;
|
||||||
|
private final MessageBuilder peerVatId = new MessageBuilder(4);
|
||||||
|
|
||||||
public TwoPartyVatNetwork(AsynchronousByteChannel channel) {
|
public TwoPartyVatNetwork(AsynchronousByteChannel channel, RpcTwoPartyProtocol.Side side) {
|
||||||
this.channel = channel;
|
this.channel = channel;
|
||||||
|
this.side = side;
|
||||||
|
this.peerVatId.initRoot(RpcTwoPartyProtocol.VatId.factory).setSide(
|
||||||
|
side == RpcTwoPartyProtocol.Side.CLIENT
|
||||||
|
? RpcTwoPartyProtocol.Side.SERVER
|
||||||
|
: RpcTwoPartyProtocol.Side.CLIENT);
|
||||||
|
}
|
||||||
|
|
||||||
|
public RpcTwoPartyProtocol.Side getSide() {
|
||||||
|
return side;
|
||||||
|
}
|
||||||
|
|
||||||
|
public RpcTwoPartyProtocol.VatId.Reader getPeerVatId() {
|
||||||
|
return peerVatId.getRoot(RpcTwoPartyProtocol.VatId.factory).asReader();
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue