public final class BinaryLinkClient
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
(package private) class |
BinaryLinkClient.ForwardingPrintStream |
Modifier and Type | Field and Description |
---|---|
private static int |
BUFFER_SIZE |
private java.net.Socket |
clientSocket |
private boolean |
failed |
private java.lang.Object |
lock |
private java.io.ObjectInputStream |
ois |
private java.io.ObjectOutputStream |
oos |
private OutputFormat |
outputFormat |
private static int |
RESET_EACH |
private int |
resetToGo |
private BinaryLinkClient.ForwardingPrintStream |
streamErr |
private BinaryLinkClient.ForwardingPrintStream |
streamOut |
Constructor and Description |
---|
BinaryLinkClient(java.lang.String hostName,
int hostPort) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.io.PrintStream |
getErrStream() |
OutputFormat |
getOutputFormat() |
java.io.PrintStream |
getOutStream() |
Options |
handshake() |
void |
pushException(BenchmarkException error) |
private void |
pushFrame(java.io.Serializable frame) |
void |
pushResultMetadata(BenchmarkResultMetaData res) |
void |
pushResults(IterationResult res) |
private java.lang.Object |
readFrame() |
ActionPlan |
requestPlan() |
private static final int RESET_EACH
private static final int BUFFER_SIZE
private final java.lang.Object lock
private final java.net.Socket clientSocket
private final java.io.ObjectOutputStream oos
private final java.io.ObjectInputStream ois
private final BinaryLinkClient.ForwardingPrintStream streamErr
private final BinaryLinkClient.ForwardingPrintStream streamOut
private final OutputFormat outputFormat
private volatile boolean failed
private int resetToGo
public BinaryLinkClient(java.lang.String hostName, int hostPort) throws java.io.IOException
java.io.IOException
private void pushFrame(java.io.Serializable frame) throws java.io.IOException
java.io.IOException
private java.lang.Object readFrame() throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
public void close() throws java.io.IOException
java.io.IOException
public Options handshake() throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
public ActionPlan requestPlan() throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
public void pushResults(IterationResult res) throws java.io.IOException
java.io.IOException
public void pushException(BenchmarkException error) throws java.io.IOException
java.io.IOException
public void pushResultMetadata(BenchmarkResultMetaData res) throws java.io.IOException
java.io.IOException
public java.io.PrintStream getOutStream()
public java.io.PrintStream getErrStream()
public OutputFormat getOutputFormat()