weblogic.wtc.jatmi

Class TpeIn

java.lang.Object

java.io.InputStream

weblogic.wtc.jatmi.TpeIn

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public final class TpeIn
extends java.io.InputStream

Excluded in public API Reference.

This class represents a Input Decryption Stream for TDomain Session. The default behavior is no decryption, but with the setup of tplle object and the decryption level the encrytion will be enabled. Decryption technology can be changed if tplle object is replaced with a different object.

Field Summary

Fields

Modifier and Type	Field and Description
private int	elevel
private boolean	gotEOF
private java.io.InputStream	in
private tplle	lle
private int	myMark
private weblogic.socket.MuxableSocket	myMuxableSocket
private int	myNeedToRead
private int	myOffset
private int	myProtocol
private byte[]	myTuxBuf
private boolean	opened
private boolean	parsedMetahdr

Constructor Summary

Constructors

Constructor and Description
TpeIn()
TpeIn(java.io.InputStream io)

Method Summary

Modifier and Type	Method and Description
int	available()
void	close()
void	mark(int readlimit)
boolean	markSupported()
int	read()
int	read(byte[] b) Reads some number of bytes from the input stream and stores them into the buffer array b.
int	read(byte[] b, int off, int len)
private boolean	readTuxedoMessage(boolean doBlock)
void	reset()
int	setElevel(int level)
void	setInputStream(java.io.InputStream i)
void	setLLE(tplle l)
void	setMuxableSocket(weblogic.socket.MuxableSocket sock)
void	setProtocol(int protocol)
long	skip(long n)

Methods inherited from class java.lang.Object

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

Field Detail

elevel

private int elevel

in

private java.io.InputStream in

lle

private tplle lle

opened

private boolean opened

myTuxBuf

private byte[] myTuxBuf

myMark

private int myMark

myOffset

private int myOffset

myNeedToRead

private int myNeedToRead

myProtocol

private int myProtocol

parsedMetahdr

private boolean parsedMetahdr

gotEOF

private boolean gotEOF

myMuxableSocket

private weblogic.socket.MuxableSocket myMuxableSocket

Constructor Detail

TpeIn

public TpeIn()

Excluded in public API Reference.

default constructor.

TpeIn

public TpeIn(java.io.InputStream io)

Parameters:

io - the input stream this decryption stream going to read from.

Excluded in public API Reference.

TpeIn constructor.

Method Detail

setElevel

public int setElevel(int level)

Parameters:

level - The desired decryption level.

Excluded in public API Reference.

Set up the decryption level. The valid decryption level is described in metahdr.java. They are GPE128, GPE56, GPE40, and GPE0. The GPE56 only available when communicate with TDOMAIN protocol level 15 and above. GPE 0 effectively means no decryption.

setLLE

public void setLLE(tplle l)

Parameters:

l - The tplle object which does the decryption.

Excluded in public API Reference.

Set up the encryption object used to do the decryption.

setInputStream

public void setInputStream(java.io.InputStream i)

Parameters:

i - The input stream.

Excluded in public API Reference.

The method works with the default constructor to setup the which input stream this stream going to read from.

setProtocol

public void setProtocol(int protocol)

Excluded in public API Reference.

Sets the protocol of the release we are speaking with

setMuxableSocket

public void setMuxableSocket(weblogic.socket.MuxableSocket sock)

Excluded in public API Reference.

Sets the real MuxableSocket we are reading from

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 - - if an I/O error occurs.

Excluded in public API Reference.

Closes this input stream and releses any system resources associated with the stream.

readTuxedoMessage

private boolean readTuxedoMessage(boolean doBlock)
                           throws java.io.IOException

Parameters:

doBlock - is true if this call should block

Returns:

false if EOF was reached

Throws:

java.io.IOException

Excluded in public API Reference.

This reads as much of the next Tuxedo buffer as it can without blocking.

read

public int read()
         throws java.io.IOException

Specified by:

read in class java.io.InputStream

Returns:

the next byte of data, or -1 if the end of stream is reached.

Throws:

java.io.IOException - - if an I/O occurs.

Excluded in public API Reference.

Reads the next byte of data from the input stream. The value byte is returned as an int in the range of 0 to 255. If no byte is available because the end of the stream has been reached, the value -1 is returned. This method blocks until input data is available, the end of stream is detected, or an exception is thrown.

This routine has a special trace level of JATMI_EX + 101. Furthermore, the trace level must be EXACTLY JATMI_EX + 101 in order to get trace from this function. That is because otherwise the trace of this function is way, way too much!

read

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

Reads some number of bytes from the input stream and stores them into the buffer array b. The number of bytes actually read is returned as an integer. This method blocks until input data is available, end of file detected, or an exception is thrown. If b is null, a NullPointerException is thrown. If the length of b is zero, then no bytes are read and 0 is returned; otherwise, there is an attempt to read at least one byte. If no byte is available because the stream is at end of file, the value -1 is returned; otherwise, at least one byte is read and stored into b. The first byte read is stored into element b[0], the next one into b[1], and so on. The number of bytes read is, at most, equals to the length of b. Let k be the number of bytes actually read; these bytes will be sotred in elements b[0] through b[k-1], leaving elements b[k] through b[b.length-1] unaffected. If the first byte cannot be read for any reason other than end of file, then an IOException is thrown. In particular, an IOException is thrown if the input stream has been closed.

Overrides:

read in class java.io.InputStream

Parameters:

b - - the buffer into which the data is read.

Returns:

the total number of bytes read into the buffer, or -1 if there is no more data because the end of the stream has been reached.

Throws:

java.io.IOException - - if an I/O error occurs.

Excluded in public API Reference.

read

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

Overrides:

read in class java.io.InputStream

Parameters:

b - - the buffer into which the data is read.

off - - the start offset in array b at which the data is written

len - - the maximum number of bytes to read.

Returns:

the total number of bytes read into the buffer, or -1 if there is no more data because the end of stream has been reached.

Throws:

java.io.IOException - - if an I/O error occurred.

Excluded in public API Reference.

Reads up to len bytes of data from the input stream into an array of bytes. An attempt is made to read as many as len bytes, but a smaller number may be read, possibly zero. The number of bytes actually read is returned as an integer. This method blocks until input data is available, end of file is detected, or an exception is thrown. If b is null, a NullPointerException is thrown. If off is negative, or len is negative, or off+len is greater than the length of the array b, then an IndexOutOfBoundsException is thrown. If len is zero, then no bytes are read and 0 is returned; otherwise, there is an attempt to read at least one byte.

skip

public long skip(long n)
          throws java.io.IOException

Overrides:

skip in class java.io.InputStream

Parameters:

n - - the number of bytes to be skipped.

Returns:

the actual number of bytes skipped.

Throws:

java.io.IOException - - if an I/O occurs.

Excluded in public API Reference.

Skips over and discards n bytes of data from this input stream.

available

public int available()
              throws java.io.IOException

Overrides:

available in class java.io.InputStream

Returns:

the number of bytes that can be read from this input stream without blocking.

Throws:

java.io.IOException - - if an I/O error occurs.

Excluded in public API Reference.

Returns the number of bytes that can be read or skipped over from this input stream without blocking by the next caller of a method for this input stream.

mark

public void mark(int readlimit)

Overrides:

mark in class java.io.InputStream

Parameters:

readlimit - the maximum limit of bytes that can be read before the mark position become invalid.

Excluded in public API Reference.

Marks the current position in this input stream. A subsequent call to the reset method repositions this stream at the last marked position so that the subsequent reads re-read the same bytes. The mark method of InputStream does nothing.

reset

public void reset()
           throws java.io.IOException

Overrides:

reset in class java.io.InputStream

Throws:

java.io.IOException - if this stream has not been marked or if the mark has been invalidated.

Excluded in public API Reference.

Repositions this stream to the position at the time the mark method was last called on this input stream.

markSupported

public boolean markSupported()

Overrides:

markSupported in class java.io.InputStream

Returns:

true if this true type supports the mark and reset method; false otherwise.

Excluded in public API Reference.

Tests if this input stream supports the mark and reset methods.