com.facebook.buck.worker

Class WorkerProcessProtocolZero.CommandSender

java.lang.Object

com.facebook.buck.worker.WorkerProcessProtocolZero.CommandSender

All Implemented Interfaces:

WorkerProcessProtocol.CommandSender, Closeable, AutoCloseable

Enclosing class:

WorkerProcessProtocolZero

public static class WorkerProcessProtocolZero.CommandSender
extends Object
implements WorkerProcessProtocol.CommandSender

Constructor Summary

Constructors

Constructor and Description
CommandSender(OutputStream processStdin, InputStream processStdout, Path stdErr, Runnable onClose, java.util.function.Supplier<Boolean> isAlive)

Method Summary

Modifier and Type	Method and Description
void	close() Instructs the CommandReceiver to shut itself down.
void	handshake(int messageId)
WorkerProcessProtocol.CommandResponse	receiveNextCommandResponse()
void	send(int messageId, com.facebook.buck.worker.WorkerProcessCommand command)

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandSender

public CommandSender(OutputStream processStdin,
                     InputStream processStdout,
                     Path stdErr,
                     Runnable onClose,
                     java.util.function.Supplier<Boolean> isAlive)

Method Detail

handshake

public void handshake(int messageId)
               throws IOException

Specified by:

handshake in interface WorkerProcessProtocol.CommandSender

Throws:

IOException

send

public void send(int messageId,
                 com.facebook.buck.worker.WorkerProcessCommand command)
          throws IOException

Specified by:

send in interface WorkerProcessProtocol.CommandSender

Throws:

IOException

receiveNextCommandResponse

public WorkerProcessProtocol.CommandResponse receiveNextCommandResponse()
                                                                 throws IOException

Specified by:

receiveNextCommandResponse in interface WorkerProcessProtocol.CommandSender

Throws:

IOException

close

public void close()
           throws IOException

Description copied from interface: WorkerProcessProtocol.CommandSender

Instructs the CommandReceiver to shut itself down.

Specified by:

close in interface WorkerProcessProtocol.CommandSender

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException