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

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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()