Package fr.dyade.aaa.agent

Class UDPNetwork.DatagramOutputStream

java.lang.Object

java.io.OutputStream

fr.dyade.aaa.agent.MessageOutputStream

fr.dyade.aaa.agent.UDPNetwork.DatagramOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

Enclosing class:

UDPNetwork

final class UDPNetwork.DatagramOutputStream
extends MessageOutputStream

Class used to send messages with UDP packets.

Field Summary

Fields

Modifier and Type	Field	Description
private byte[]	ackBuf
private int	datagramStamp
private byte[]	handshakeBuf
private SocketAddress	serverAddr
private UDPNetwork.ServerInfo	serverInfo
private int	size

Fields inherited from class fr.dyade.aaa.agent.MessageOutputStream

buf, compressedFlows, count, oos

Constructor Summary

Constructors

Constructor	Description
DatagramOutputStream()

Method Summary

Modifier and Type	Method	Description
(package private) void	handShake(SocketAddress addr)
private void	sendPacket()
void	write(byte[] b, int off, int len)	Writes len bytes from the specified byte array starting at offset off to this output stream.
void	write(int b)	Writes the specified byte to this output stream.
(package private) void	writeAck(int ackNumber, SocketAddress addr)
protected void	writeHeader()	Writes the protocol header to this output stream.
(package private) void	writeMessage(UDPNetwork.ServerInfo serverInfo, SocketAddress addr, int startIndex, Message msg, long currentTimeMillis)
(package private) void	writeMessage(SocketAddress addr, Message msg, long currentTimeMillis)

Methods inherited from class fr.dyade.aaa.agent.MessageOutputStream

write, writeInt, writeMessage, writeMessageHeader, writeShort

Methods inherited from class java.io.OutputStream

close, flush, nullOutputStream

Methods inherited from class java.lang.Object

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

Field Detail

datagramStamp

private int datagramStamp

size

private int size

serverAddr

private SocketAddress serverAddr

serverInfo

private UDPNetwork.ServerInfo serverInfo

ackBuf

private byte[] ackBuf

handshakeBuf

private byte[] handshakeBuf

Constructor Detail

DatagramOutputStream

DatagramOutputStream()
              throws IOException

Throws:

IOException

Method Detail

writeMessage

void writeMessage(SocketAddress addr,
                  Message msg,
                  long currentTimeMillis)
           throws IOException

Throws:

IOException

writeAck

void writeAck(int ackNumber,
              SocketAddress addr)
       throws IOException

Throws:

IOException

write

public void write(int b)
           throws IOException

Description copied from class: MessageOutputStream

Writes the specified byte to this output stream.

Specified by:

write in class MessageOutputStream

Parameters:

b - the byte to be written.

Throws:

IOException - if an I/O error occurs.

sendPacket

private void sendPacket()
                 throws IOException

Throws:

IOException

writeMessage

void writeMessage(UDPNetwork.ServerInfo serverInfo,
                  SocketAddress addr,
                  int startIndex,
                  Message msg,
                  long currentTimeMillis)
           throws IOException

Throws:

IOException

handShake

void handShake(SocketAddress addr)
        throws IOException

Throws:

IOException

write

public void write(byte[] b,
                  int off,
                  int len)
           throws IOException

Description copied from class: MessageOutputStream

Writes len bytes from the specified byte array starting at offset off to this output stream.

Specified by:

write in class MessageOutputStream

Parameters:

b - the data.

off - the start offset in the data.

len - the number of bytes to write.

Throws:

IOException - if an I/O error occurs.

writeHeader

protected void writeHeader()

Description copied from class: MessageOutputStream

Writes the protocol header to this output stream. This method must be overloaded in subclass.

Specified by:

writeHeader in class MessageOutputStream