Package aQute.libg.remote.source

Class RemoteSource

java.lang.Object

aQute.libg.remote.source.RemoteSource

All Implemented Interfaces:

Source

public class RemoteSource
extends Object
implements Source

Controls a different file system trough a Sink. It can translate files with local absolute file paths to remote absolute file paths (also if it is a windows system). It also detects changes in the local file system and will update the remote. Updates are checked for SHAs so we only transfer the files when they really are not there, even allowing a remote SHA cache to do its magic.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) String	areaId
(package private) File	cwd
(package private) SourceFS	fsync
(package private) AtomicBoolean	running
private Sink	sink
private Appendable	stderr
private Appendable	stdout
private Thread	thread
(package private) Welcome	welcome

Constructor Summary

Constructors

Constructor	Description
RemoteSource()

Method Summary

Modifier and Type	Method	Description
void	add(File file)
void	cancel()
void	close()	Close
void	event(Event e, Area area)
private void	exit()
byte[]	getData(String sha)	Called from the remote sink to get the data when it lacks the given sha.
Sink	getSink()
void	join()
void	launch(Map<String,String> env, List<String> args, InputStream stdin, Appendable stdout, Appendable stderr)
void	open(Sink sink, File cwd, String areaId)
void	output(String areaId, CharSequence text, boolean err)
void	sync()
void	update(File f)

Methods inherited from class java.lang.Object

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

Field Details

sink

private Sink sink

stdout

private Appendable stdout

stderr

private Appendable stderr

thread

private Thread thread

running

volatile AtomicBoolean running

welcome

Welcome welcome

fsync

SourceFS fsync

areaId

String areaId

cwd

File cwd

Constructor Details

RemoteSource

public RemoteSource()

Method Details

open

public void open(Sink sink,
 File cwd,
 String areaId)

getData

public byte[] getData(String sha)
               throws Exception

Called from the remote sink to get the data when it lacks the given sha.

Specified by:

getData in interface Source

Throws:

Exception

close

public void close()
           throws IOException

Close

Throws:

IOException

event

public void event(Event e,
 Area area)
           throws Exception

Specified by:

event in interface Source

Throws:

Exception

exit

private void exit()

output

public void output(String areaId,
 CharSequence text,
 boolean err)
            throws IOException

Specified by:

output in interface Source

Throws:

IOException

getSink

public Sink getSink()

launch

public void launch(Map<String,String> env,
 List<String> args,
 InputStream stdin,
 Appendable stdout,
 Appendable stderr)
            throws Exception

Throws:

Exception

cancel

public void cancel()
            throws Exception

Throws:

Exception

update

public void update(File f)
            throws Exception

Throws:

Exception

sync

public void sync()
          throws Exception

Throws:

Exception

add

public void add(File file)
         throws Exception

Throws:

Exception

join

public void join()
          throws InterruptedException

Throws:

InterruptedException