org.openorb.orb.util

Class DebugSocketInputStream

java.lang.Object

java.io.InputStream

org.openorb.orb.util.DebugSocketInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class DebugSocketInputStream
extends java.io.InputStream

This class can be used for debugging IIOP traffic on the socket layer. Analyzing the network traffic with tools like Ethereal make it hard to keep track of the traffic on the GIOP/IIOP layer. Especially in a multi-threaded application where multiple threads write on the same socket. The class creates a folder in the os default temp directory: ${java.io.tmp}/${user.name}/<TIMESTAMP>/input which contains the socket traffic files: [localhost].[localport]-[remotehost].[remoteport].[TIMESTAMP].log Each files contains a history of which bytes have been read by which thread from the stream.

Author:

Michael Rumpf

Constructor Summary

Constructors

Constructor and Description
DebugSocketInputStream(java.io.InputStream parent, long timestamp, java.lang.String description) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
int	read()
int	read(byte[] buf)
int	read(byte[] buf, int off, int len)

Methods inherited from class java.io.InputStream

available, mark, markSupported, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

DebugSocketInputStream

public DebugSocketInputStream(java.io.InputStream parent,
                      long timestamp,
                      java.lang.String description)
                       throws java.io.IOException

Constructor.

Parameters:

parent - The parent input stream.

timestamp - The VM wide timestamp to identify this process.

description - The socket description generated from the socket.

Throws:

java.io.IOException

Method Detail

read

public int read()
         throws java.io.IOException

Specified by:

read in class java.io.InputStream

Throws:

java.io.IOException

read

public int read(byte[] buf)
         throws java.io.IOException

Overrides:

read in class java.io.InputStream

Throws:

java.io.IOException

read

public int read(byte[] buf,
       int off,
       int len)
         throws java.io.IOException

Overrides:

read in class java.io.InputStream

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class java.io.InputStream

Throws:

java.io.IOException