Class BinaryLinkClient


  • public final class BinaryLinkClient
    extends java.lang.Object
    • Field Detail

      • RESET_EACH

        private static final int RESET_EACH
      • BUFFER_SIZE

        private static final int BUFFER_SIZE
      • lock

        private final java.lang.Object lock
      • clientSocket

        private final java.net.Socket clientSocket
      • oos

        private final java.io.ObjectOutputStream oos
      • ois

        private final java.io.ObjectInputStream ois
      • failed

        private volatile boolean failed
      • resetToGo

        private int resetToGo
      • delayedFrames

        private final java.util.List<java.io.Serializable> delayedFrames
      • inFrame

        private boolean inFrame
    • Constructor Detail

      • BinaryLinkClient

        public BinaryLinkClient​(java.lang.String hostName,
                                int hostPort)
                         throws java.io.IOException
        Throws:
        java.io.IOException
    • Method Detail

      • pushFrame

        private void pushFrame​(java.io.Serializable frame)
                        throws java.io.IOException
        Throws:
        java.io.IOException
      • readFrame

        private java.lang.Object readFrame()
                                    throws java.io.IOException,
                                           java.lang.ClassNotFoundException
        Throws:
        java.io.IOException
        java.lang.ClassNotFoundException
      • close

        public void close()
                   throws java.io.IOException
        Throws:
        java.io.IOException
      • handshake

        public Options handshake()
                          throws java.io.IOException,
                                 java.lang.ClassNotFoundException
        Throws:
        java.io.IOException
        java.lang.ClassNotFoundException
      • requestPlan

        public ActionPlan requestPlan()
                               throws java.io.IOException,
                                      java.lang.ClassNotFoundException
        Throws:
        java.io.IOException
        java.lang.ClassNotFoundException
      • pushResults

        public void pushResults​(IterationResult res)
                         throws java.io.IOException
        Throws:
        java.io.IOException
      • pushException

        public void pushException​(BenchmarkException error)
                           throws java.io.IOException
        Throws:
        java.io.IOException
      • pushResultMetadata

        public void pushResultMetadata​(BenchmarkResultMetaData res)
                                throws java.io.IOException
        Throws:
        java.io.IOException
      • getOutStream

        public java.io.PrintStream getOutStream()
      • getErrStream

        public java.io.PrintStream getErrStream()