org.jgroups.protocols.pbcast
Class STATE.StateOutputStream

java.lang.Object
  extended by java.io.OutputStream
      extended by org.jgroups.protocols.pbcast.STATE.StateOutputStream
All Implemented Interfaces:
java.io.Closeable, java.io.Flushable
Enclosing class:
STATE

protected class STATE.StateOutputStream
extends java.io.OutputStream


Field Summary
protected  long bytesWrittenCounter
           
protected  java.util.concurrent.atomic.AtomicBoolean closed
           
protected  Address stateRequester
           
 
Constructor Summary
STATE.StateOutputStream(Address stateRequester)
           
 
Method Summary
 void close()
           
protected  java.io.InterruptedIOException interrupted(int cnt)
           
protected  void sendMessage(byte[] b, int off, int len)
           
 void write(byte[] b)
           
 void write(byte[] b, int off, int len)
           
 void write(int b)
           
 
Methods inherited from class java.io.OutputStream
flush
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

stateRequester

protected final Address stateRequester

closed

protected final java.util.concurrent.atomic.AtomicBoolean closed

bytesWrittenCounter

protected long bytesWrittenCounter
Constructor Detail

STATE.StateOutputStream

public STATE.StateOutputStream(Address stateRequester)
Method Detail

close

public void close()
           throws java.io.IOException
Specified by:
close in interface java.io.Closeable
Overrides:
close in class java.io.OutputStream
Throws:
java.io.IOException

write

public void write(byte[] b,
                  int off,
                  int len)
           throws java.io.IOException
Overrides:
write in class java.io.OutputStream
Throws:
java.io.IOException

write

public void write(byte[] b)
           throws java.io.IOException
Overrides:
write in class java.io.OutputStream
Throws:
java.io.IOException

write

public void write(int b)
           throws java.io.IOException
Specified by:
write in class java.io.OutputStream
Throws:
java.io.IOException

sendMessage

protected void sendMessage(byte[] b,
                           int off,
                           int len)
                    throws java.io.IOException
Throws:
java.io.IOException

interrupted

protected java.io.InterruptedIOException interrupted(int cnt)


Copyright © 1998-2012 Bela Ban / Red Hat. All Rights Reserved.