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

a start on syncServer and syncClient

Browse source
This commit is contained in:
David Renshaw 2014-09-05 11:09:29 -04:00
parent 5f5cb24241
commit 45f3dc4d23
1 changed files with 30 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
benchmark/src/main/java/org/capnproto/benchmark/TestCase.java
View file

@ -3,10 +3,14 @@ package org.capnproto.benchmark;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.io.FileInputStream;
import java.io.FileDescriptor;
import org.capnproto.FromStructReader;
import org.capnproto.FromStructBuilder;
import org.capnproto.StructFactory;
import org.capnproto.MessageBuilder;
import org.capnproto.MessageReader;
public abstract class TestCase<RequestFactory extends StructFactory<RequestBuilder, RequestReader>,
RequestBuilder, RequestReader,
@ -77,6 +81,28 @@ public abstract class TestCase<RequestFactory extends StructFactory<RequestBuild
}
}
public void syncClient(RequestFactory requestFactory, ResponseFactory responseFactory,
long iters) throws IOException {
throw new Error("unimplemented");
}
public void syncServer(RequestFactory requestFactory, ResponseFactory responseFactory,
long iters) throws IOException {
for (int ii = 0; ii < iters; ++ii) {
MessageBuilder responseMessage = new MessageBuilder();
{
ResponseBuilder response = responseMessage.initRoot(responseFactory);
MessageReader messageReader = org.capnproto.ByteChannelMessageReader.create(
(new FileInputStream(FileDescriptor.in)).getChannel());
RequestReader request = messageReader.getRoot(requestFactory);
this.handleRequest(request, response);
}
throw new Error("unimplemented");
}
}
public void execute(String[] args, RequestFactory requestFactory, ResponseFactory responseFactory) {
@ -95,6 +121,10 @@ public abstract class TestCase<RequestFactory extends StructFactory<RequestBuild
passByObject(requestFactory, responseFactory, iters);
} else if (mode.equals("bytes")) {
passByBytes(requestFactory, responseFactory, iters);
} else if (mode.equals("client")) {
syncClient(requestFactory, responseFactory, iters);
} else if (mode.equals("server")) {
syncServer(requestFactory, responseFactory, iters);
} else {
System.out.println("unknown mode: " + mode);
}