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.

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)
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 Object

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

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

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