public class RemoteSource extends java.lang.Object implements Source
Modifier and Type | Field and Description |
---|---|
(package private) java.lang.String |
areaId |
(package private) java.io.File |
cwd |
(package private) SourceFS |
fsync |
(package private) java.util.concurrent.atomic.AtomicBoolean |
running |
private Sink |
sink |
private java.lang.Appendable |
stderr |
private java.lang.Appendable |
stdout |
private java.lang.Thread |
thread |
(package private) Welcome |
welcome |
Constructor and Description |
---|
RemoteSource() |
Modifier and Type | Method and Description |
---|---|
void |
add(java.io.File file) |
void |
cancel() |
void |
close()
Close
|
void |
event(Event e,
Area area) |
private void |
exit() |
byte[] |
getData(java.lang.String sha)
Called from the remote sink to get the data when it lacks the given sha.
|
Sink |
getSink() |
void |
join() |
void |
launch(java.util.Map<java.lang.String,java.lang.String> env,
java.util.List<java.lang.String> args,
java.io.InputStream stdin,
java.lang.Appendable stdout,
java.lang.Appendable stderr) |
void |
open(Sink sink,
java.io.File cwd,
java.lang.String areaId) |
void |
output(java.lang.String areaId,
java.lang.CharSequence text,
boolean err) |
void |
sync() |
void |
update(java.io.File f) |
private Sink sink
private java.lang.Appendable stdout
private java.lang.Appendable stderr
private java.lang.Thread thread
volatile java.util.concurrent.atomic.AtomicBoolean running
Welcome welcome
SourceFS fsync
java.lang.String areaId
java.io.File cwd
public void open(Sink sink, java.io.File cwd, java.lang.String areaId)
public byte[] getData(java.lang.String sha) throws java.lang.Exception
public void close() throws java.io.IOException
java.io.IOException
private void exit()
public void output(java.lang.String areaId, java.lang.CharSequence text, boolean err) throws java.io.IOException
public Sink getSink()
public void launch(java.util.Map<java.lang.String,java.lang.String> env, java.util.List<java.lang.String> args, java.io.InputStream stdin, java.lang.Appendable stdout, java.lang.Appendable stderr) throws java.lang.Exception
java.lang.Exception
public void cancel() throws java.lang.Exception
java.lang.Exception
public void update(java.io.File f) throws java.lang.Exception
java.lang.Exception
public void sync() throws java.lang.Exception
java.lang.Exception
public void add(java.io.File file) throws java.lang.Exception
java.lang.Exception
public void join() throws java.lang.InterruptedException
java.lang.InterruptedException