Package hudson.remoting

Class SynchronousCommandTransport

java.lang.Object

hudson.remoting.CommandTransport

hudson.remoting.SynchronousCommandTransport

Direct Known Subclasses:

AbstractSynchronousByteArrayCommandTransport

public abstract class SynchronousCommandTransport
extends CommandTransport

CommandTransport that implements the read operation in a synchronous fashion.

This class uses a thread to pump commands and pass them to CommandTransport.CommandReceiver.

Author:

Kohsuke Kawaguchi

Nested Class Summary

Nested classes/interfaces inherited from class hudson.remoting.CommandTransport

CommandTransport.CommandReceiver

Field Summary

Fields

Modifier and Type	Field	Description
protected Channel	channel

Constructor Summary

Constructors

Constructor	Description
SynchronousCommandTransport()

Method Summary

Modifier and Type	Method	Description
abstract Command	read()	Called by Channel to read the next command to arrive from the stream.
void	setup(Channel channel, CommandTransport.CommandReceiver receiver)	Starts the transport.

Methods inherited from class hudson.remoting.CommandTransport

closeRead, closeWrite, getRemoteCapability, write

Methods inherited from class java.lang.Object

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

Field Detail

channel

protected Channel channel

Constructor Detail

SynchronousCommandTransport

public SynchronousCommandTransport()

Method Detail

read

public abstract Command read()
                      throws IOException,
                             ClassNotFoundException,
                             InterruptedException

Called by Channel to read the next command to arrive from the stream.

Throws:

IOException

ClassNotFoundException

InterruptedException

setup

public void setup(Channel channel,
                  CommandTransport.CommandReceiver receiver)

Description copied from class: CommandTransport

Starts the transport. This method is called once and only once at the end of the initialization of Channel, after the CommandTransport.getRemoteCapability() is invoked. The first purpose of this method is to provide a reference back to Channel, and the second purpose of this method is to allow CommandTransport to message pumping, where it starts receiving commands from the other side and pass them onto CommandTransport.CommandReceiver. This abstraction enables asynchronous processing — for example you can have a single thread serving a large number of Channels via NIO. For subtypes that prefer synchronous operation, extend from SynchronousCommandTransport.

Closing the read pump: Channel implements Channel.CloseCommand its own "end of command stream" marker, and therefore under the orderly shutdown scenario, it doesn't rely on the transport to provide EOF-like marker. Instead, Channel will call your CommandTransport.closeRead() (from the same thread that invoked CommandTransport.CommandReceiver.handle(Command)) to indicate that it is done with the reading.

If the transport encounters any error from the lower layer (say, the underlying TCP/IP socket encountered a REST), then call CommandTransport.CommandReceiver.terminate(IOException) to initiate the abnormal channel termination. This in turn calls CommandTransport.closeRead() to shutdown the reader side.

Specified by:

setup in class CommandTransport