Inheritance diagram for fr.dyade.aaa.agent.MessageOutputStream:
Public Member Functions | |
| MessageOutputStream () throws IOException | |
| MessageOutputStream (int size) throws IOException | |
| abstract void | write (int b) throws IOException |
| final void | write (byte b[]) throws IOException |
| abstract void | write (byte b[], int off, int len) throws IOException |
Protected Member Functions | |
| final void | writeShort (short s) |
| final void | writeInt (int i) |
| abstract void | writeHeader () throws IOException |
| final void | writeMessageHeader (Message msg) |
| final void | writeMessage (Message msg, long time) throws IOException |
Static Protected Member Functions | |
| static Logger | getLogger () |
Protected Attributes | |
| ObjectOutputStream | oos |
| byte | buf [] |
| int | count |
| boolean | compressedFlows = false |
Static Protected Attributes | |
| static Logger | logmon = null |
This OutputStream is a combination between a ByteArrayOutputStream and a BufferedOutputStream. It allows the replacement of the underlying stream and the serialization of object through an internal ObjectOutputStream.
Be careful this OutputStream is not synchronized.
Definition at line 40 of file MessageOutputStream.java.
| fr.dyade.aaa.agent.MessageOutputStream.MessageOutputStream | ( | ) | throws IOException |
Creates a new output stream to write data to an unspecified underlying output stream through a buffer with default size.
Definition at line 87 of file MessageOutputStream.java.
| fr.dyade.aaa.agent.MessageOutputStream.MessageOutputStream | ( | int | size | ) | throws IOException |
Creates a new output stream to write data to an unspecified underlying output stream through a buffer with specified size.
| size | the buffer size. |
| IllegalArgumentException | if size is less than 0. | |
| IOException | if the internal ObjectOutputStream cannot be correctly initialized. |
Definition at line 100 of file MessageOutputStream.java.
References fr.dyade.aaa.agent.MessageOutputStream.buf, fr.dyade.aaa.agent.MessageOutputStream.compressedFlows, fr.dyade.aaa.agent.MessageOutputStream.count, and fr.dyade.aaa.agent.MessageOutputStream.oos.
| static Logger fr.dyade.aaa.agent.MessageOutputStream.getLogger | ( | ) | [static, protected] |
Returns default logger for MessageOutputStream.
Definition at line 67 of file MessageOutputStream.java.
References fr.dyade.aaa.agent.MessageOutputStream.logmon.
Referenced by fr.dyade.aaa.agent.BufferedMessageOutputStream.write(), fr.dyade.aaa.agent.UDPNetwork.DatagramOutputStream.writeMessage(), fr.dyade.aaa.agent.MessageOutputStream.writeMessage(), and fr.dyade.aaa.agent.MessageOutputStream.writeMessageHeader().
| abstract void fr.dyade.aaa.agent.MessageOutputStream.write | ( | int | b | ) | throws IOException [pure virtual] |
Writes the specified byte to this output stream.
| b | the byte to be written. |
| IOException | if an I/O error occurs. |
Implemented in fr.dyade.aaa.agent.BufferedMessageOutputStream, fr.dyade.aaa.agent.ByteArrayMessageOutputStream, and fr.dyade.aaa.agent.UDPNetwork.DatagramOutputStream.
Referenced by fr.dyade.aaa.agent.MessageOutputStream.write().
| final void fr.dyade.aaa.agent.MessageOutputStream.write | ( | byte | b[] | ) | throws IOException |
Writes b.length bytes to this output stream.
This method calls its write method of three arguments with the arguments b, 0, and b.length.
| b | the data to be written. |
| IOException | if an I/O error occurs. |
Definition at line 128 of file MessageOutputStream.java.
References fr.dyade.aaa.agent.MessageOutputStream.write().
Here is the call graph for this function:
| abstract void fr.dyade.aaa.agent.MessageOutputStream.write | ( | byte | b[], | |
| int | off, | |||
| int | len | |||
| ) | throws IOException [pure virtual] |
Writes len bytes from the specified byte array starting at offset off to this output stream.
| b | the data. | |
| off | the start offset in the data. | |
| len | the number of bytes to write. |
| IOException | if an I/O error occurs. |
Implemented in fr.dyade.aaa.agent.BufferedMessageOutputStream, and fr.dyade.aaa.agent.ByteArrayMessageOutputStream.
| final void fr.dyade.aaa.agent.MessageOutputStream.writeShort | ( | short | s | ) | [protected] |
Writes a short directly to the buffer. Be careful, the buffer must be large enough to contain the short.
| s | the data. |
Definition at line 149 of file MessageOutputStream.java.
References fr.dyade.aaa.agent.MessageOutputStream.buf, and fr.dyade.aaa.agent.MessageOutputStream.count.
Referenced by fr.dyade.aaa.agent.MessageOutputStream.writeMessageHeader().
| final void fr.dyade.aaa.agent.MessageOutputStream.writeInt | ( | int | i | ) | [protected] |
Writes an int directly to the buffer. Be careful, the buffer must be large enough to contain the int.
| i | the data. |
Definition at line 160 of file MessageOutputStream.java.
References fr.dyade.aaa.agent.MessageOutputStream.buf, and fr.dyade.aaa.agent.MessageOutputStream.count.
Referenced by fr.dyade.aaa.agent.SimpleNetwork.NetworkOutputStream.writeHeader(), fr.dyade.aaa.agent.HttpNetwork.NetworkOutputStream.writeHeader(), fr.dyade.aaa.agent.MessageOutputStream.writeMessage(), and fr.dyade.aaa.agent.MessageOutputStream.writeMessageHeader().
| abstract void fr.dyade.aaa.agent.MessageOutputStream.writeHeader | ( | ) | throws IOException [protected, pure virtual] |
Writes the protocol header to this output stream. This method must be overloaded in subclass.
Implemented in fr.dyade.aaa.agent.HttpNetwork.NetworkOutputStream, fr.dyade.aaa.agent.PoolNetwork.NetSession.NetworkOutputStream, fr.dyade.aaa.agent.SimpleNetwork.NetworkOutputStream, and fr.dyade.aaa.agent.UDPNetwork.DatagramOutputStream.
Referenced by fr.dyade.aaa.agent.MessageOutputStream.writeMessage().
| final void fr.dyade.aaa.agent.MessageOutputStream.writeMessageHeader | ( | Message | msg | ) | [protected] |
Writes the message header datas to the buffer.
| msg | The message to write out. |
Definition at line 178 of file MessageOutputStream.java.
References fr.dyade.aaa.agent.MessageOutputStream.getLogger(), fr.dyade.aaa.agent.MessageOutputStream.writeInt(), and fr.dyade.aaa.agent.MessageOutputStream.writeShort().
Referenced by fr.dyade.aaa.agent.MessageOutputStream.writeMessage().
Here is the call graph for this function:
| final void fr.dyade.aaa.agent.MessageOutputStream.writeMessage | ( | Message | msg, | |
| long | time | |||
| ) | throws IOException [protected] |
Writes a message to this output stream. This method can be overloaded in subclass.
| msg | The message to write out. | |
| time | The current time in milliseconds, this parameter is used to the handling of notification expiration. |
Definition at line 209 of file MessageOutputStream.java.
References fr.dyade.aaa.agent.MessageOutputStream.buf, fr.dyade.aaa.agent.MessageOutputStream.compressedFlows, fr.dyade.aaa.agent.MessageOutputStream.count, fr.dyade.aaa.agent.MessageOutputStream.getLogger(), fr.dyade.aaa.agent.MessageOutputStream.oos, fr.dyade.aaa.agent.MessageOutputStream.writeHeader(), fr.dyade.aaa.agent.MessageOutputStream.writeInt(), and fr.dyade.aaa.agent.MessageOutputStream.writeMessageHeader().
Referenced by fr.dyade.aaa.agent.PoolNetwork.NetSession.send().
Here is the call graph for this function:
ObjectOutputStream fr.dyade.aaa.agent.MessageOutputStream.oos [protected] |
The internal ObjectOutputStream needed to serialize the notification.
Definition at line 44 of file MessageOutputStream.java.
Referenced by fr.dyade.aaa.agent.MessageOutputStream.MessageOutputStream(), and fr.dyade.aaa.agent.MessageOutputStream.writeMessage().
byte fr.dyade.aaa.agent.MessageOutputStream.buf[] [protected] |
The internal buffer where data is stored.
Definition at line 49 of file MessageOutputStream.java.
Referenced by fr.dyade.aaa.agent.MessageOutputStream.MessageOutputStream(), fr.dyade.aaa.agent.UDPNetwork.DatagramOutputStream.write(), fr.dyade.aaa.agent.ByteArrayMessageOutputStream.write(), fr.dyade.aaa.agent.BufferedMessageOutputStream.write(), fr.dyade.aaa.agent.MessageOutputStream.writeInt(), fr.dyade.aaa.agent.MessageOutputStream.writeMessage(), fr.dyade.aaa.agent.MessageOutputStream.writeShort(), and fr.dyade.aaa.agent.ByteArrayMessageOutputStream.writeTo().
int fr.dyade.aaa.agent.MessageOutputStream.count [protected] |
The number of valid bytes in the buffer.
Definition at line 54 of file MessageOutputStream.java.
Referenced by fr.dyade.aaa.agent.UDPNetwork.DatagramOutputStream.DatagramOutputStream(), fr.dyade.aaa.agent.MessageOutputStream.MessageOutputStream(), fr.dyade.aaa.agent.ByteArrayMessageOutputStream.reset(), fr.dyade.aaa.agent.ByteArrayMessageOutputStream.size(), fr.dyade.aaa.agent.UDPNetwork.DatagramOutputStream.write(), fr.dyade.aaa.agent.ByteArrayMessageOutputStream.write(), fr.dyade.aaa.agent.BufferedMessageOutputStream.write(), fr.dyade.aaa.agent.MessageOutputStream.writeInt(), fr.dyade.aaa.agent.MessageOutputStream.writeMessage(), fr.dyade.aaa.agent.MessageOutputStream.writeShort(), and fr.dyade.aaa.agent.ByteArrayMessageOutputStream.writeTo().
Logger fr.dyade.aaa.agent.MessageOutputStream.logmon = null [static, protected] |
Default logger for MessageOutputStream.
Definition at line 61 of file MessageOutputStream.java.
Referenced by fr.dyade.aaa.agent.MessageOutputStream.getLogger().
1.5.0