Package org.apache.felix.gogo.runtime

Class Pipe

java.lang.Object

org.apache.felix.gogo.runtime.Pipe

All Implemented Interfaces:

Callable<Pipe.Result>, Process

public class Pipe
extends Object
implements Callable<Pipe.Result>, Process

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	Pipe.MultiChannel
private class	Pipe.RefByteChannel
static class	Pipe.Result

Nested classes/interfaces inherited from interface org.apache.felix.service.command.Process

Process.Utils

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Closure	closure
private static final ThreadLocal<Pipe>	CURRENT
(package private) final boolean	endOfPipe
(package private) PrintStream	err
(package private) int	error
(package private) InputStream	in
(package private) final Job	job
(package private) PrintStream	out
private static final int	READ
(package private) final Parser.Statement	statement
(package private) final Channel[]	streams
(package private) final boolean[]	toclose
private static final int	WRITE

Constructor Summary

Constructors

Constructor	Description
Pipe(Closure closure, CommandSessionImpl.JobImpl job, Parser.Statement statement, Channel[] streams, boolean[] toclose, boolean endOfPipe)

Method Summary

Modifier and Type	Method	Description
Pipe.Result	call()
private Pipe.Result	doCall()
PrintStream	err()
void	error(int error)	Set the error code for the currently running pipe.
static Pipe	getCurrentPipe()
InputStream	in()
boolean	isTty(int fd)	Check if the given descriptor for the currently running pipe is the terminal or not.
Job	job()	Get the job controlling this process
PrintStream	out()
private static Pipe	setCurrentPipe(Pipe pipe)
private void	setStream(Channel ch, int fd, int readWrite)
private Path	toPath(Object o)
private List<Path>	toPaths(Object val)
String	toString()
private Channel	wrap(Channel channel)

Methods inherited from class java.lang.Object

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

Field Details

CURRENT

private static final ThreadLocal<Pipe> CURRENT

closure

final Closure closure

job

final Job job

statement

final Parser.Statement statement

streams

final Channel[] streams

toclose

final boolean[] toclose

endOfPipe

final boolean endOfPipe

error

int error

in

InputStream in

out

PrintStream out

err

PrintStream err

READ

private static final int READ

See Also:

• Constant Field Values

WRITE

private static final int WRITE

See Also:

• Constant Field Values

Constructor Details

Pipe

public Pipe(Closure closure,
 CommandSessionImpl.JobImpl job,
 Parser.Statement statement,
 Channel[] streams,
 boolean[] toclose,
 boolean endOfPipe)

Method Details

getCurrentPipe

public static Pipe getCurrentPipe()

setCurrentPipe

private static Pipe setCurrentPipe(Pipe pipe)

toString

public String toString()

Overrides:

toString in class Object

setStream

private void setStream(Channel ch,
 int fd,
 int readWrite)

in

public InputStream in()

Specified by:

in in interface Process

out

public PrintStream out()

Specified by:

out in interface Process

err

public PrintStream err()

Specified by:

err in interface Process

job

public Job job()

Description copied from interface: Process

Get the job controlling this process

Specified by:

job in interface Process

Returns:

Job

isTty

public boolean isTty(int fd)

Description copied from interface: Process

Check if the given descriptor for the currently running pipe is the terminal or not.

Specified by:

isTty in interface Process

Parameters:

fd - the fd

Returns:

boolean

error

public void error(int error)

Description copied from interface: Process

Set the error code for the currently running pipe.

Specified by:

error in interface Process

Parameters:

error - the error

call

public Pipe.Result call()

Specified by:

call in interface Callable<Pipe.Result>

doCall

private Pipe.Result doCall()

toPaths

private List<Path> toPaths(Object val)
                    throws IOException

Throws:

IOException

toPath

private Path toPath(Object o)

wrap

private Channel wrap(Channel channel)