com.nhncorp.neptune.changelog.pipe
Class Bulk

java.lang.Object
  com.nhncorp.neptune.changelog.pipe.Bulk

All Implemented Interfaces:

BulkTestIF

public class Bulk
extends java.lang.Object
implements BulkTestIF

Field Summary

static int

DEFAULT_BUFFER_SIZE

Constructor Summary

Bulk()

Method Summary

void	clear()
void	close()
java.nio.ByteBuffer[]	getBufferArray()
boolean	isWrittingDone()
com.nhncorp.neptune.changelog.pipe.Bulk.OperationResult	read(java.nio.channels.SocketChannel ch)
int	readFromChannel(java.nio.channels.SocketChannel ch, java.nio.ByteBuffer buf)
com.nhncorp.neptune.changelog.pipe.Bulk.OperationResult	write(java.nio.channels.SocketChannel ch)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_BUFFER_SIZE

public static final int DEFAULT_BUFFER_SIZE

See Also:

Constant Field Values

Constructor Detail

Bulk

public Bulk()

Method Detail

read

public com.nhncorp.neptune.changelog.pipe.Bulk.OperationResult read(java.nio.channels.SocketChannel ch)
                                                             throws java.io.IOException

Throws:

java.io.IOException

readFromChannel

public int readFromChannel(java.nio.channels.SocketChannel ch,
                           java.nio.ByteBuffer buf)
                    throws java.io.IOException

Specified by:

readFromChannel in interface BulkTestIF

Throws:

java.io.IOException

write

public com.nhncorp.neptune.changelog.pipe.Bulk.OperationResult write(java.nio.channels.SocketChannel ch)
                                                              throws java.io.IOException

Throws:

java.io.IOException

getBufferArray

public java.nio.ByteBuffer[] getBufferArray()

clear

public void clear()

close

public void close()

isWrittingDone

public boolean isWrittingDone()