Package utils.communication.groupConstitution

Class Process

java.lang.Object

utils.communication.groupConstitution.Process

All Implemented Interfaces:

ProcessInterface, Closeable, AutoCloseable, AsynchronousChannel, Channel

Direct Known Subclasses:

ProcessStatus

public class Process
extends Object
implements ProcessInterface

Constructor Summary

Constructors

Constructor	Description
Process()
Process(AsynchronousSocketChannel clientChannel)
Process(Process other)

Method Summary

Modifier and Type	Method	Description
void	close()
<A> void	connect(SocketAddress remote, A attachment, CompletionHandler<Void,? super A> handler)	Asynchronous connect.
InetSocketAddress	getRemoteAddress()
boolean	isFaulty()	Whether this GroupMember is known/suspected faulty or not.
boolean	isOpen()
boolean	isOther()	Whether this GroupMember represents another process or ourselves.
boolean	isReadable()	Whether a read operation can be completed successfully.
boolean	isWriteable()	Whether a write operation can be completed successfully.
void	markAsFaulty()	Mark a process as being faulty
void	markAsFaulty(boolean isFaulty)	Change a process's faultiness.
<A> void	safeRead(ByteBuffer bf, A attachment, CompletionHandler<Integer,? super A> handler)	Asynchronous thread-safe read method.
void	safeWrite(ByteBuffer bf)	Blocking thread-safe write method.
<A> void	safeWrite(ByteBuffer bf, A attachment, CompletionHandler<Integer,? super A> handler)	Asynchronous thread-safe write method.
Process	shallowClone()

Methods inherited from class java.lang.Object

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

Constructor Details

Process

public Process()

Process

public Process(AsynchronousSocketChannel clientChannel)

Process

public Process(Process other)

Method Details

isOther

public boolean isOther()

Description copied from interface: ProcessInterface

Whether this GroupMember represents another process or ourselves.

Specified by:

isOther in interface ProcessInterface

Returns:

True if it is not the calling process, false otherwise

isFaulty

public boolean isFaulty()

Description copied from interface: ProcessInterface

Whether this GroupMember is known/suspected faulty or not.

Specified by:

isFaulty in interface ProcessInterface

Returns:

True if at least suspected faulty, false otherwise

markAsFaulty

public void markAsFaulty()

Description copied from interface: ProcessInterface

Mark a process as being faulty

Specified by:

markAsFaulty in interface ProcessInterface

markAsFaulty

public void markAsFaulty(boolean isFaulty)

Description copied from interface: ProcessInterface

Change a process's faultiness.

Specified by:

markAsFaulty in interface ProcessInterface

Parameters:

isFaulty - Whether the process is faulty or not.

connect

public <A> void connect(SocketAddress remote,
 A attachment,
 CompletionHandler<Void,? super A> handler)

Description copied from interface: ProcessInterface

Asynchronous connect.

Specified by:

connect in interface ProcessInterface

Type Parameters:

A - Type of attachment

Parameters:

remote - Address of the remote entity to connect to.

attachment - The object to attach to the I/O operation

handler - The handler for consuming the result

safeWrite

public <A> void safeWrite(ByteBuffer bf,
 A attachment,
 CompletionHandler<Integer,? super A> handler)

Description copied from interface: ProcessInterface

Asynchronous thread-safe write method. Guarantees no WritePendingException occurs. Does nothing in the case that isOther is false.

Specified by:

safeWrite in interface ProcessInterface

Type Parameters:

A - Type of attachment

Parameters:

bf - The buffer from which bytes are to be transferred

attachment - The object to attach to the I/O operation

handler - The handler for consuming the result

safeWrite

public void safeWrite(ByteBuffer bf)

Description copied from interface: ProcessInterface

Blocking thread-safe write method. Guarantees no WritePendingException occurs. Does nothing in the case that isOther is false.

Specified by:

safeWrite in interface ProcessInterface

Parameters:

bf - The buffer from which bytes are to be transferred

safeRead

public <A> void safeRead(ByteBuffer bf,
 A attachment,
 CompletionHandler<Integer,? super A> handler)

Description copied from interface: ProcessInterface

Asynchronous thread-safe read method. Does nothing in the case that isOther is false.

Specified by:

safeRead in interface ProcessInterface

Type Parameters:

A - Type of attachment

Parameters:

bf - The buffer to which bytes are to be transferred

attachment - The object to attach to the I/O operation

handler - The handler for consuming the result

close

public void close()
           throws IOException

Specified by:

close in interface AsynchronousChannel

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Specified by:

close in interface Closeable

Throws:

IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Channel

isReadable

public boolean isReadable()

Description copied from interface: ProcessInterface

Whether a read operation can be completed successfully.

Specified by:

isReadable in interface ProcessInterface

Returns:

True is a read operation can be completed, false otherwise.

isWriteable

public boolean isWriteable()

Description copied from interface: ProcessInterface

Whether a write operation can be completed successfully.

Specified by:

isWriteable in interface ProcessInterface

Returns:

True is a write operation can be completed, false otherwise.

getRemoteAddress

public InetSocketAddress getRemoteAddress()

Specified by:

getRemoteAddress in interface ProcessInterface

shallowClone

public Process shallowClone()