All Packages  Class Hierarchy  This Package  Previous  Next  Index

Class guinea.ui.remote.RemotePipe

java.lang.Object
   |
   +----guinea.ui.remote.RemotePipe

public class RemotePipe

extends Object

implements Runnable

Variable Index

· verbose

Constructor Index

· RemotePipe(ObjectInputStream, ObjectOutputStream)

Create a new remote pipe.

· RemotePipe(Socket)

Create a new remote pipe.

Method Index

· close()

Close the remote pipe.

· doCommand(RemoteCommand)

Do a remote command.

· getNewSerial()

Allocate a new serial number for a command.

· isPipeOpen()

Test whether the pipe is open.

· printerr(int, String)

· processCommand(RemoteCommand)

· receiveCommandReply(int)

Get a remote command reply for a command with a given serial number.

· receiveMessage()

Get an object that has been sent to this pipe.

· receiveMessageWait()

Get an object that has been sent to this pipe.

· removeProcessorCommand(String)

· run()

· sendCommand(RemoteCommand)

Send a remote command.

· sendMessage(Object)

Send an object to the pipe.

· sendReply(RemoteCommandReply)

Send a remote command reply.

· setProcessorCommand(String, ProcessRemoteCommand)

· startServer()

Start remote pipe.

· waitEnd()

Wait for the remote pipe to be closed.

Variables

 public static final int verbose

Constructors

 public RemotePipe(Socket socket) throws IOException

Create a new remote pipe.

Parameters:

socket - the socket used to talk with remote end.

Throws: IOException

cannot create object output/input from the socket.

 public RemotePipe(ObjectInputStream revc,
                   ObjectOutputStream send)

Create a new remote pipe.

Parameters:

revc - An ObjectInputStream used to receive messages.

send - An ObjectOutputStream used to send messages.

Throws: IOException

cannot create object output/input from the socket.

Methods

 public static final void printerr(int pri,
                                   String message)

 public synchronized void startServer()

Start remote pipe. Creates a thread that reads messages from the pipe and dispatches commands to receivers.

 public void run()

 public synchronized void close() throws InterruptedException

Close the remote pipe.

Throws: InterruptedException

An exception may be thrown if waiting for the closing of the pipe was interrupted.

 public synchronized void waitEnd() throws InterruptedException

Wait for the remote pipe to be closed.

Throws: InterruptedException

An exception may be thrown if waiting for the closing of the pipe was interrupted.

 public synchronized boolean isPipeOpen()

Test whether the pipe is open.

Returns:

true if pipe is open and active.

 public void sendMessage(Object message)

Send an object to the pipe.

Parameters:

message - an object to send to remote end.

 public Object receiveMessage()

Get an object that has been sent to this pipe. If no messages have been received, returns null.

Returns:

an object received by the pipe or null if no unprocessed messages have been received.

 public Object receiveMessageWait() throws InterruptedException

 public RemoteCommandReply receiveCommandReply(int serial)

 public synchronized int getNewSerial()

 public int sendCommand(RemoteCommand c)

 public void sendReply(RemoteCommandReply c)

 public RemoteCommandReply doCommand(RemoteCommand c)

 public synchronized void setProcessorCommand(String target,
                                              ProcessRemoteCommand p)

 public synchronized ProcessRemoteCommand removeProcessorCommand(String target)

 public void processCommand(RemoteCommand com)

All Packages  Class Hierarchy  This Package  Previous  Next  Index