Class TranscodePipe

    • Field Detail

      • paused

        protected volatile boolean paused
      • destroyed

        protected volatile boolean destroyed
      • bytes_available

        protected volatile int bytes_available
      • max_bytes_per_sec

        protected volatile int max_bytes_per_sec
      • sockets

        protected java.util.List<java.net.Socket> sockets
      • server_socket

        java.net.ServerSocket server_socket
      • buffer_cache_size

        int buffer_cache_size
      • connection_speed

        Average connection_speed
    • Constructor Detail

      • TranscodePipe

        protected TranscodePipe​(TranscodePipe.errorListener _error_listener)
                         throws java.io.IOException
        Throws:
        java.io.IOException
    • Method Detail

      • getConnectionRate

        public long getConnectionRate()
      • getWriteSpeed

        public long getWriteSpeed()
      • handleSocket

        protected abstract void handleSocket​(java.net.Socket socket)
      • handlePipe

        protected void handlePipe​(java.io.InputStream is,
                                  java.io.OutputStream os)
      • reserveRAF

        protected java.io.RandomAccessFile reserveRAF()
                                               throws java.io.IOException
        Throws:
        java.io.IOException
      • releaseRAF

        protected void releaseRAF​(java.io.RandomAccessFile raf)
      • handleRAF

        protected void handleRAF​(java.io.OutputStream os,
                                 long position,
                                 long length)
      • pause

        protected void pause()
      • resume

        protected void resume()
      • setMaxBytesPerSecond

        public void setMaxBytesPerSecond​(int max)
      • getPort

        protected int getPort()
      • destroy

        protected boolean destroy()
      • reportError

        protected void reportError​(java.lang.Throwable error)