Package deltix.util.vsocket.util

Class SocketTestUtilities

  • public class SocketTestUtilities
extends java.lang.Object

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static void measureInputThroughput​(java.io.InputStream os, byte[] buffer, int cycles)  
      static void measureLatency​(java.io.OutputStream os, java.io.DataInputStream is, byte[] buffer, int cycles, boolean measure)  
      static void measureOutputThroughput​(java.io.OutputStream os, byte[] buffer, int cycles)  
      static int parsePacketSize​(java.lang.String[] args)  
      static int parsePacketSize​(java.lang.String[] args, int defaultPacketSize)  
      static int parsePort​(java.lang.String[] args)  
      static void proccessLatencyRequests​(java.io.DataOutputStream os, java.io.DataInputStream is, byte[] buffer, boolean measure)  

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • DEFAULT_PACKET_SIZE

        public static int DEFAULT_PACKET_SIZE

      • DEFAULT_PORT

        public static int DEFAULT_PORT

    • Constructor Detail

      • SocketTestUtilities

        public SocketTestUtilities()

    • Method Detail

      • parsePacketSize

        public static int parsePacketSize​(java.lang.String[] args)

      • parsePacketSize

        public static int parsePacketSize​(java.lang.String[] args,
                                  int defaultPacketSize)

      • parsePort

        public static int parsePort​(java.lang.String[] args)

      • measureInputThroughput

        public static void measureInputThroughput​(java.io.InputStream os,
                                          byte[] buffer,
                                          int cycles)
                                   throws java.io.IOException
        Throws:
        java.io.IOException

      • measureOutputThroughput

        public static void measureOutputThroughput​(java.io.OutputStream os,
                                           byte[] buffer,
                                           int cycles)
                                    throws java.io.IOException
        Throws:
        java.io.IOException

      • measureLatency

        public static void measureLatency​(java.io.OutputStream os,
                                  java.io.DataInputStream is,
                                  byte[] buffer,
                                  int cycles,
                                  boolean measure)
                           throws java.io.IOException,
                                  java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.lang.InterruptedException

      • proccessLatencyRequests

        public static void proccessLatencyRequests​(java.io.DataOutputStream os,
                                           java.io.DataInputStream is,
                                           byte[] buffer,
                                           boolean measure)