org.jgroups.blocks.cs

Class NioConnection.Reader

java.lang.Object

org.jgroups.blocks.cs.NioConnection.Reader

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Runnable, Condition

Enclosing class:

NioConnection

protected class NioConnection.Reader
extends java.lang.Object
implements java.lang.Runnable, java.io.Closeable, Condition

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	data_available
protected CondVar	data_available_cond
protected java.util.concurrent.locks.Lock	lock
protected boolean	running
protected NioConnection.State	state
protected java.lang.Thread	thread

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Reader()

Method Summary

Modifier and Type	Method and Description
protected void	_run()
protected void	clear(int op)
void	close()
boolean	isMet() Return true if the condition is met and false otherwise
boolean	isRunning()
void	receive() Called by the selector when data is ready to be read from the SocketChannel
protected void	register(int op)
void	run()
protected void	start()
protected void	state(NioConnection.State st)
protected void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

lock

protected final java.util.concurrent.locks.Lock lock

state

protected NioConnection.State state

data_available

protected volatile boolean data_available

data_available_cond

protected final CondVar data_available_cond

thread

protected volatile java.lang.Thread thread

running

protected volatile boolean running

Constructor Detail

Reader

protected Reader()

Method Detail

start

protected void start()

stop

protected void stop()

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

isMet

public boolean isMet()

Description copied from interface: Condition

Return true if the condition is met and false otherwise

Specified by:

isMet in interface Condition

isRunning

public boolean isRunning()

receive

public void receive()

Called by the selector when data is ready to be read from the SocketChannel

run

public void run()

Specified by:

run in interface java.lang.Runnable

_run

protected void _run()

register

protected void register(int op)

clear

protected void clear(int op)

state

protected void state(NioConnection.State st)