|
Project JXTA | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.io.OutputStream
net.jxta.impl.util.pipe.reliable.ReliableOutputStream
Accepts data and packages it into messages for sending to the remote. The messages are kept in a retry queue until the remote peer acknowledges receipt of the message.
Field Summary | |
(package private) List |
retrQ
The collection of messages available for re-transmission. |
Constructor Summary | |
ReliableOutputStream(Outgoing outgoing)
|
|
ReliableOutputStream(Outgoing outgoing,
FlowControl fc)
|
Method Summary | |
void |
ackReceived(int seqnum,
int[] sackList)
Process an ACK Message. |
void |
close()
We don't current support linger. |
int |
getMaxAck()
|
int |
getSeqNumber()
|
boolean |
isQueueEmpty()
|
boolean |
isQueueFull()
|
void |
recv(Message msg)
Receive this incoming message. |
int |
send(Message msg)
|
void |
setClosing()
indicate that we're in the process of closing. |
void |
waitQueueEvent(long timeout)
|
void |
write(byte[] b,
int off,
int len)
|
void |
write(int c)
|
Methods inherited from class java.io.OutputStream |
flush, write |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
List retrQ
RetrQElt
Constructor Detail |
public ReliableOutputStream(Outgoing outgoing)
public ReliableOutputStream(Outgoing outgoing, FlowControl fc)
Method Detail |
public void close() throws IOException
IOException
public void setClosing()
public void write(int c) throws IOException
IOException
public void write(byte[] b, int off, int len) throws IOException
IOException
public int send(Message msg) throws IOException
IOException
public int getMaxAck()
public int getSeqNumber()
public boolean isQueueFull()
public boolean isQueueEmpty()
public void waitQueueEvent(long timeout) throws InterruptedException
InterruptedException
public void recv(Message msg)
Incoming
recv
in interface Incoming
public void ackReceived(int seqnum, int[] sackList)
|
JXTA J2SE | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |