Package org.openjdk.jmh.runner.link
Class BinaryLinkServer
- java.lang.Object
-
- org.openjdk.jmh.runner.link.BinaryLinkServer
-
public final class BinaryLinkServer extends java.lang.Object
Accepts the binary data from the forked VM and pushes it to parent VM as appropriate. This server assumes there is only the one and only client at any given point of time.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
BinaryLinkServer.Acceptor
private class
BinaryLinkServer.Handler
-
Field Summary
Fields Modifier and Type Field Description private BinaryLinkServer.Acceptor
acceptor
private static int
BUFFER_SIZE
private long
clientPid
private java.util.concurrent.atomic.AtomicReference<BenchmarkException>
exception
private java.util.Set<java.lang.String>
forbidden
private java.util.concurrent.atomic.AtomicReference<BinaryLinkServer.Handler>
handler
private java.util.concurrent.atomic.AtomicReference<BenchmarkResultMetaData>
metadata
private java.util.Map<java.lang.String,java.lang.reflect.Method>
methods
private Options
opts
private OutputFormat
out
private java.util.concurrent.atomic.AtomicReference<ActionPlan>
plan
private java.util.concurrent.atomic.AtomicReference<java.util.List<IterationResult>>
results
-
Constructor Summary
Constructors Constructor Description BinaryLinkServer(Options opts, OutputFormat out)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
getClientPid()
BenchmarkException
getException()
java.lang.String
getHost()
private java.net.InetAddress
getListenAddress()
private int
getListenPort()
BenchmarkResultMetaData
getMetadata()
int
getPort()
java.util.List<IterationResult>
getResults()
void
setPlan(ActionPlan actionPlan)
void
terminate()
void
waitFinish()
-
-
-
Field Detail
-
BUFFER_SIZE
private static final int BUFFER_SIZE
-
opts
private final Options opts
-
out
private final OutputFormat out
-
methods
private final java.util.Map<java.lang.String,java.lang.reflect.Method> methods
-
forbidden
private final java.util.Set<java.lang.String> forbidden
-
acceptor
private final BinaryLinkServer.Acceptor acceptor
-
handler
private final java.util.concurrent.atomic.AtomicReference<BinaryLinkServer.Handler> handler
-
results
private final java.util.concurrent.atomic.AtomicReference<java.util.List<IterationResult>> results
-
metadata
private final java.util.concurrent.atomic.AtomicReference<BenchmarkResultMetaData> metadata
-
exception
private final java.util.concurrent.atomic.AtomicReference<BenchmarkException> exception
-
plan
private final java.util.concurrent.atomic.AtomicReference<ActionPlan> plan
-
clientPid
private volatile long clientPid
-
-
Constructor Detail
-
BinaryLinkServer
public BinaryLinkServer(Options opts, OutputFormat out) throws java.io.IOException
- Throws:
java.io.IOException
-
-
Method Detail
-
terminate
public void terminate()
-
waitFinish
public void waitFinish()
-
getException
public BenchmarkException getException()
-
getResults
public java.util.List<IterationResult> getResults()
-
getMetadata
public BenchmarkResultMetaData getMetadata()
-
setPlan
public void setPlan(ActionPlan actionPlan)
-
getListenAddress
private java.net.InetAddress getListenAddress()
-
getListenPort
private int getListenPort()
-
getClientPid
public long getClientPid()
-
getHost
public java.lang.String getHost()
-
getPort
public int getPort()
-
-