org.fusesource.hawtdispatch.transport

Class TcpTransport.RateLimitingChannel

java.lang.Object

org.fusesource.hawtdispatch.transport.TcpTransport.RateLimitingChannel

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel, java.nio.channels.GatheringByteChannel, java.nio.channels.ReadableByteChannel, java.nio.channels.ScatteringByteChannel, java.nio.channels.WritableByteChannel

Enclosing class:

TcpTransport

class TcpTransport.RateLimitingChannel
extends java.lang.Object
implements java.nio.channels.ScatteringByteChannel, java.nio.channels.GatheringByteChannel

Field Summary

Fields

Modifier and Type	Field and Description
(package private) int	read_allowance
(package private) boolean	read_suspended
(package private) int	write_allowance
(package private) boolean	write_suspended

Constructor Summary

Constructors

Constructor and Description
RateLimitingChannel()

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	isOpen()
int	read(java.nio.ByteBuffer dst)
long	read(java.nio.ByteBuffer[] dsts)
long	read(java.nio.ByteBuffer[] dsts, int offset, int length)
void	resetAllowance()
void	resumeRead()
int	write(java.nio.ByteBuffer src)
long	write(java.nio.ByteBuffer[] srcs)
long	write(java.nio.ByteBuffer[] srcs, int offset, int length)

Methods inherited from class java.lang.Object

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

Field Detail

read_allowance

int read_allowance

read_suspended

boolean read_suspended

write_allowance

int write_allowance

write_suspended

boolean write_suspended

Constructor Detail

RateLimitingChannel

RateLimitingChannel()

Method Detail

resetAllowance

public void resetAllowance()

read

public int read(java.nio.ByteBuffer dst)
         throws java.io.IOException

Specified by:

read in interface java.nio.channels.ReadableByteChannel

Throws:

java.io.IOException

write

public int write(java.nio.ByteBuffer src)
          throws java.io.IOException

Specified by:

write in interface java.nio.channels.WritableByteChannel

Throws:

java.io.IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface java.nio.channels.Channel

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.nio.channels.Channel

Throws:

java.io.IOException

resumeRead

public void resumeRead()

read

public long read(java.nio.ByteBuffer[] dsts,
                 int offset,
                 int length)
          throws java.io.IOException

Specified by:

read in interface java.nio.channels.ScatteringByteChannel

Throws:

java.io.IOException

read

public long read(java.nio.ByteBuffer[] dsts)
          throws java.io.IOException

Specified by:

read in interface java.nio.channels.ScatteringByteChannel

Throws:

java.io.IOException

write

public long write(java.nio.ByteBuffer[] srcs,
                  int offset,
                  int length)
           throws java.io.IOException

Specified by:

write in interface java.nio.channels.GatheringByteChannel

Throws:

java.io.IOException

write

public long write(java.nio.ByteBuffer[] srcs)
           throws java.io.IOException

Specified by:

write in interface java.nio.channels.GatheringByteChannel

Throws:

java.io.IOException