Class FsAgent

java.lang.Object

org.jrd.backend.communication.FsAgent

All Implemented Interfaces:

DelegatingJrdAgent, JrdAgent

public final class FsAgent
extends Object
implements DelegatingJrdAgent

This class is doing agent-like based operations on filesystem

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static interface	FsAgent.CpOperator<T>
private static class	FsAgent.ListingCpOperator
private static class	FsAgent.OperateOnCp<T>
private static final class	FsAgent.ReadingCpOperator
private static class	FsAgent.WritingCpOperator

Nested classes/interfaces inherited from interface DelegatingJrdAgent

DelegatingJrdAgent.CommandDelegationOptions, DelegatingJrdAgent.DelegatingHelper

Field Summary

Fields

Modifier and Type	Field	Description
private static final Map<VmInfo,FsAgent>	AGENTS
private final List<File>	cp
private final DelegatingJrdAgent.DelegatingHelper	delegationCandidates
private final Map<String,String>	originals	This is exact oposite of how remote agent does this.
private final String	suffix

Constructor Summary

Constructors

Modifier	Constructor	Description
private	FsAgent(List<File> cp, String suffix)

Method Summary

Modifier and Type	Method	Description
JrdAgent	addDelegatingAgent(JrdAgent agent)
private static void	addJustClass(String s, List<String> classes, String root, boolean details, String detailsPath)
int	cleanDelegatingAgents()
private int	cleanOverrides(Pattern pattern)
static FsAgent	createAdditionalClassPathFsAgent(String cp)
static FsAgent	createAdditionalClassPathFsAgent(List<File> cp)
static FsAgent	createAdditionalSourcePathFsAgent(String cp)
static FsAgent	createAdditionalSourcePathFsAgent(List<File> cp)
static FsAgent	get(VmInfo vmInfo)
List<String>	getOverrides()
private String	readClasses(boolean details)
JrdAgent	removeDelegatingAgent(JrdAgent agent)
private static String	sanitize(String s)
private String	sendByteCode(String clazz)
String	submitRequest(String request)	Opens a socket and sends the request to the agent via socket.
static String	toClass(String s)
private Void	uploadByteCode(String clazz, String body)

Methods inherited from class Object

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

Field Details

AGENTS

private static final Map<VmInfo,FsAgent> AGENTS

cp

private final List<File> cp

suffix

private final String suffix

delegationCandidates

private final DelegatingJrdAgent.DelegatingHelper delegationCandidates

originals

private final Map<String,String> originals

This is exact oposite of how remote agent does this. Remote agent keeps all overrides, because when new class defintion is laoded original is plled, and is modifed (overvritten) by new deffnitio.

On contrary, in FS, the class is after writing immediately overriden in file FileSystem. So we keep original, saved during first override. If we keep original, we know class was overwritten. The removal of of override == restore of original (and remvoal of original from map

In addition, insted of byte[] we store base64 encoded String

Constructor Details

FsAgent

private FsAgent(List<File> cp,
 String suffix)

Method Details

get

public static FsAgent get(VmInfo vmInfo)

createAdditionalClassPathFsAgent

public static FsAgent createAdditionalClassPathFsAgent(String cp)

createAdditionalClassPathFsAgent

public static FsAgent createAdditionalClassPathFsAgent(List<File> cp)

createAdditionalSourcePathFsAgent

public static FsAgent createAdditionalSourcePathFsAgent(String cp)

createAdditionalSourcePathFsAgent

public static FsAgent createAdditionalSourcePathFsAgent(List<File> cp)

getOverrides

public List<String> getOverrides()

cleanOverrides

private int cleanOverrides(Pattern pattern)

submitRequest

public String submitRequest(String request)

Opens a socket and sends the request to the agent via socket.

Specified by:

submitRequest in interface DelegatingJrdAgent

Specified by:

submitRequest in interface JrdAgent

Parameters:

request - either "CLASSES" or "BYTES \n className", other formats are refused

Returns:

agents response or null

uploadByteCode

private Void uploadByteCode(String clazz,
 String body)

sendByteCode

private String sendByteCode(String clazz)

readClasses

private String readClasses(boolean details)
                    throws IOException

Throws:

IOException

addJustClass

private static void addJustClass(String s,
 List<String> classes,
 String root,
 boolean details,
 String detailsPath)

toClass

public static String toClass(String s)

sanitize

private static String sanitize(String s)

addDelegatingAgent

public JrdAgent addDelegatingAgent(JrdAgent agent)

Specified by:

addDelegatingAgent in interface DelegatingJrdAgent

removeDelegatingAgent

public JrdAgent removeDelegatingAgent(JrdAgent agent)

Specified by:

removeDelegatingAgent in interface DelegatingJrdAgent

cleanDelegatingAgents

public int cleanDelegatingAgents()

Specified by:

cleanDelegatingAgents in interface DelegatingJrdAgent