Package | Description |
---|---|
org.ogf.saga.attributes |
There are various places in the SAGA API where attributes need to be
associated with objects, for instance for job descriptions and
metrics.
|
org.ogf.saga.buffer |
This package provides the
Buffer
interface. |
org.ogf.saga.context |
This package contains the
Context
interface, which provides a common interface for storing security information. |
org.ogf.saga.file |
This package provides classes to manipulate the contents of directories
or files.
|
org.ogf.saga.job |
The job package describes the API for submitting jobs to a grid resource.
|
org.ogf.saga.logicalfile |
This package provides classes to interact with replica systems.
|
org.ogf.saga.monitoring |
The monitoring package defines the
Monitorable interface,
which must be implemented by monitorable SAGA objects, and also
defines the
Steerable interface,
which extends the monitoring mechanism with the ability to push
values back to the monitored entity. |
org.ogf.saga.namespace |
This package provides classes to manipulate namespaces.
|
org.ogf.saga.resource.instance |
This package provides resources interfaces.
|
org.ogf.saga.resource.manager |
This package provides the Resource Manager class.
|
org.ogf.saga.resource.task |
This package provides the
ResourceTask interface that allows to manage
resources as tasks. |
org.ogf.saga.rpc |
The methods of the SAGA RPC package map with the methods as defined in
the GridRPC specification, as described in GFD.52, at least semantically,
with slight modifications for SAGA look and feel, SAGA error conventions,
SAGA task model, et cetera.
|
org.ogf.saga.stream |
The streams package provides a simple mechanism for setting up
connections to remote components.
|
org.ogf.saga.task |
This package provides classes and methods for manipulating tasks and
collections of tasks.
|
Modifier and Type | Method and Description |
---|---|
String |
Attributes.getAttribute(String key)
Gets the value of an attribute.
|
String[] |
Attributes.getVectorAttribute(String key)
Gets the array of values associated with an attribute.
|
void |
Attributes.setAttribute(String key,
String value)
Sets an attribute to a value.
|
void |
Attributes.setVectorAttribute(String key,
String[] values)
Sets an attribute to an array of values.
|
Modifier and Type | Method and Description |
---|---|
byte[] |
Buffer.getData()
Retrieves the buffer data.
|
int |
Buffer.getSize()
Retrieves the current value of the buffer size.
|
void |
Buffer.setData(byte[] data)
Sets the buffer data.
|
void |
Buffer.setSize()
Sets the size of the buffer.
|
void |
Buffer.setSize(int size)
Sets the size of the buffer.
|
Modifier and Type | Method and Description |
---|---|
static Context |
ContextFactory.createContext()
Constructs a security context.
|
static Context |
ContextFactory.createContext(String type)
Constructs a security context.
|
static Context |
ContextFactory.createContext(String sagaFactoryClassname,
String type)
Constructs a security context.
|
protected abstract Context |
ContextFactory.doCreateContext(String type)
Constructs a security context.
|
Modifier and Type | Method and Description |
---|---|
long |
File.getSize()
Returns the number of bytes in the file.
|
long |
Directory.getSize(URL name)
Returns the number of bytes in the specified file.
|
long |
Directory.getSize(URL name,
int flags)
Returns the number of bytes in the specified file.
|
boolean |
Directory.isFile(URL name)
Tests the name for being a directory entry.
|
List<String> |
File.modesE()
Lists the extended modes available in this implementation and/or on the
server side.
|
Directory |
Directory.openDirectory(URL name)
Creates a new
Directory instance. |
Directory |
Directory.openDirectory(URL name,
int flags)
Creates a new
Directory instance. |
File |
Directory.openFile(URL name)
Creates a new
File instance. |
File |
Directory.openFile(URL name,
int flags)
Creates a new
File instance. |
FileInputStream |
Directory.openFileInputStream(URL name)
Creates a new
FileInputStream instance. |
FileOutputStream |
Directory.openFileOutputStream(URL name)
Creates a new
FileOutputStream instance. |
FileOutputStream |
Directory.openFileOutputStream(URL name,
boolean append)
Creates a new
FileOutputStream instance. |
int |
File.read(Buffer buffer)
Reads up to the buffer's size from the file into the buffer.
|
int |
File.read(Buffer buffer,
int len)
Reads up to
len bytes from the file into the buffer. |
int |
File.read(Buffer buffer,
int offset,
int len)
Reads up to
len bytes from the file into the buffer, at
the specified offset . |
int |
File.readE(String emode,
String spec,
Buffer buffer)
Extended read.
|
int |
File.readP(String pattern,
Buffer buffer)
Pattern-based read.
|
void |
File.readV(IOVec[] iovecs)
Gather/scatter read.
|
long |
File.seek(long offset,
SeekMode whence)
Repositions the current file position as requested.
|
int |
File.sizeE(String emode,
String spec)
Determines the storage size required for an extended I/O operation.
|
int |
File.sizeP(String pattern)
Determines the storage size required for a pattern I/O operation.
|
int |
File.write(Buffer buffer)
Writes up to the buffer's size bytes from the buffer to the file at the
current file position.
|
int |
File.write(Buffer buffer,
int len)
Writes up to
len bytes from the buffer to the file at the
current file position. |
int |
File.write(Buffer buffer,
int offset,
int len)
Writes up to
len bytes from the buffer at the specified
buffer offset to the file at the current file position. |
int |
File.writeE(String emode,
String spec,
Buffer buffer)
Extended write.
|
int |
File.writeP(String pattern,
Buffer buffer)
Pattern-based write.
|
void |
File.writeV(IOVec[] iovecs)
Gather/scatter write.
|
Modifier and Type | Method and Description |
---|---|
void |
Job.checkpoint()
Asks the resource manager to initiate a checkpoint operation on a running
job.
|
InputStream |
Job.getStderr()
Returns the error stream of this job (which can be read).
|
OutputStream |
Job.getStdin()
Returns the input stream of this job (to which can be written).
|
InputStream |
Job.getStdout()
Returns the output stream of this job (which can be read).
|
void |
Job.migrate(JobDescription jd)
Asks the resource manager to migrate a job.
|
void |
Job.resume()
Asks the resource manager to perform a resume operation on a suspended
job.
|
void |
Job.signal(int signum)
Asks the resource manager to deliver an arbitrary signal to a dispatched
job.
|
void |
Job.suspend()
Asks the resource manager to perform a suspend operation on a running
job.
|
Modifier and Type | Method and Description |
---|---|
void |
LogicalFile.addLocation(URL name)
Adds a replica location to the replica set.
|
List<URL> |
LogicalDirectory.find(String namePattern,
String[] attrPattern)
Finds entries in the current directory and below, with matching names and
matching meta data.
|
List<URL> |
LogicalDirectory.find(String namePattern,
String[] attrPattern,
int flags)
Finds entries in the current directory and possibly below, with matching
names and matching meta data.
|
boolean |
LogicalDirectory.isFile(URL name)
Tests the name for being a logical file.
|
List<URL> |
LogicalFile.listLocations()
Lists the locations in this location set.
|
LogicalDirectory |
LogicalDirectory.openLogicalDir(URL name)
Creates a new
LogicalDirectory instance with read flag. |
LogicalDirectory |
LogicalDirectory.openLogicalDir(URL name,
int flags)
Creates a new
LogicalDirectory instance. |
LogicalFile |
LogicalDirectory.openLogicalFile(URL name)
Creates a new
LogicalFile instance with read flag. |
LogicalFile |
LogicalDirectory.openLogicalFile(URL name,
int flags)
Creates a new
LogicalFile instance. |
void |
LogicalFile.removeLocation(URL name)
Removes a replica location from the replica set.
|
void |
LogicalFile.replicate(URL name)
Replicates a file from any of the known locations to a new location, with
default flags NONE.
|
void |
LogicalFile.replicate(URL name,
int flags)
Replicates a file from any of the known locations to a new location.
|
void |
LogicalFile.updateLocation(URL nameOld,
URL nameNew)
Changes a replica location in the replica set.
|
Modifier and Type | Method and Description |
---|---|
int |
Metric.addCallback(Callback cb)
Adds the specified callback to the metric.
|
int |
Monitorable.addCallback(String name,
Callback cb)
Adds a callback to the specified metric.
|
boolean |
Steerable.addMetric(Metric metric)
Adds a metric instance to the application instance.
|
void |
Metric.fire()
Pushes a new metric value to the backend.
|
void |
Steerable.fireMetric(String name)
Pushes a new metric value to the backend.
|
void |
Steerable.removeMetric(String name)
Removes a metric instance.
|
Modifier and Type | Method and Description |
---|---|
void |
NSDirectory.changeDir(URL dir)
Changes the working directory.
|
void |
NSDirectory.copy(String source,
URL target)
Copies the source entry to another part of the namespace.
|
void |
NSDirectory.copy(String source,
URL target,
int flags)
Copies the source entry to another part of the namespace.
|
void |
NSEntry.copy(URL target)
Copies this entry to another part of the namespace.
|
void |
NSEntry.copy(URL target,
int flags)
Copies this entry to another part of the namespace.
|
void |
NSDirectory.copy(URL source,
URL target)
Copies the source entry to another part of the namespace.
|
void |
NSDirectory.copy(URL source,
URL target,
int flags)
Copies the source entry to another part of the namespace.
|
boolean |
NSDirectory.exists(URL name)
Queries for the existence of an entry.
|
List<URL> |
NSDirectory.find(String pattern)
Finds entries in the directory and below that match the specified
pattern.
|
List<URL> |
NSDirectory.find(String pattern,
int flags)
Finds entries in the directory and below that match the specified
pattern.
|
URL |
NSEntry.getCWD()
Obtains the current working directory for the entry.
|
URL |
NSDirectory.getEntry(int entry)
Gives the name of an entry in the directory based upon the enumeration
defined by
NSDirectory.getNumEntries() . |
long |
NSEntry.getMTime()
Returns the time of the last modification in seconds since epoch
(01.01.1970).
|
long |
NSDirectory.getMTime(URL name)
Returns the time of the last modification in seconds since epoch
(01.01.1970) of the specified name.
|
URL |
NSEntry.getName()
Obtains the name part of the URL of this entry.
|
int |
NSDirectory.getNumEntries()
Obtains the number of entries in this directory.
|
URL |
NSEntry.getURL()
Obtains the complete URL referring to the entry.
|
boolean |
NSEntry.isDir()
Tests this entry for being a directory.
|
boolean |
NSDirectory.isDir(URL name)
Tests the name for being a directory.
|
boolean |
NSEntry.isEntry()
Tests this entry for being a namespace entry.
|
boolean |
NSDirectory.isEntry(URL name)
Tests the name for being a namespace entry.
|
boolean |
NSEntry.isLink()
Tests this entry for being a link.
|
boolean |
NSDirectory.isLink(URL name)
Tests the name for being a link.
|
void |
NSDirectory.link(String source,
URL target)
Creates a symbolic link from the specified target to the specified
source.
|
void |
NSDirectory.link(String source,
URL target,
int flags)
Creates a symbolic link from the specified target to the specified
source.
|
void |
NSEntry.link(URL target)
Creates a symbolic link from the target to this entry.
|
void |
NSEntry.link(URL target,
int flags)
Creates a symbolic link from the target to this entry.
|
void |
NSDirectory.link(URL source,
URL target)
Creates a symbolic link from the specified target to the specified
source.
|
void |
NSDirectory.link(URL source,
URL target,
int flags)
Creates a symbolic link from the specified target to the specified
source.
|
List<URL> |
NSDirectory.list()
Lists entries in the directory.
|
List<URL> |
NSDirectory.list(int flags)
Lists entries in the directory.
|
List<URL> |
NSDirectory.list(String pattern)
Lists entries in the directory that match the specified pattern.
|
List<URL> |
NSDirectory.list(String pattern,
int flags)
Lists entries in the directory that match the specified pattern.
|
void |
NSDirectory.makeDir(URL target)
Creates a new directory.
|
void |
NSDirectory.makeDir(URL target,
int flags)
Creates a new directory.
|
void |
NSDirectory.move(String source,
URL target)
Renames the specified source to the specified target, or move the
specified source to the specified target if the target is a directory.
|
void |
NSDirectory.move(String source,
URL target,
int flags)
Renames the specified source to the specified target, or move the
specified source to the specified target if the target is a directory.
|
void |
NSEntry.move(URL target)
Renames this entry to the target, or moves this entry to the target if it
is a directory.
|
void |
NSEntry.move(URL target,
int flags)
Renames this entry to the target, or moves this entry to the target if it
is a directory.
|
void |
NSDirectory.move(URL source,
URL target)
Renames the specified source to the specified target, or move the
specified source to the specified target if the target is a directory.
|
void |
NSDirectory.move(URL source,
URL target,
int flags)
Renames the specified source to the specified target, or move the
specified source to the specified target if the target is a directory.
|
NSEntry |
NSDirectory.open(URL name)
Creates a new
NamespaceEntry instance. |
NSEntry |
NSDirectory.open(URL name,
int flags)
Creates a new
NamespaceEntry instance. |
NSDirectory |
NSDirectory.openDir(URL name)
Creates a new
NamespaceDirectory instance. |
NSDirectory |
NSDirectory.openDir(URL name,
int flags)
Creates a new
NamespaceDirectory instance. |
void |
NSEntry.permissionsAllow(String id,
int permissions,
int flags)
Allows the specified permissions for the specified id.
|
void |
NSDirectory.permissionsAllow(String target,
String id,
int permissions)
Allows the specified permissions for the specified id.
|
void |
NSDirectory.permissionsAllow(String target,
String id,
int permissions,
int flags)
Allows the specified permissions for the specified id.
|
void |
NSDirectory.permissionsAllow(URL target,
String id,
int permissions)
Allows the specified permissions for the specified id.
|
void |
NSDirectory.permissionsAllow(URL target,
String id,
int permissions,
int flags)
Allows the specified permissions for the specified id.
|
void |
NSEntry.permissionsDeny(String id,
int permissions,
int flags)
Denies the specified permissions for the specified id.
|
void |
NSDirectory.permissionsDeny(String target,
String id,
int permissions)
Denies the specified permissions for the specified id.
|
void |
NSDirectory.permissionsDeny(String target,
String id,
int permissions,
int flags)
Denies the specified permissions for the specified id.
|
void |
NSDirectory.permissionsDeny(URL target,
String id,
int permissions)
Denies the specified permissions for the specified id.
|
void |
NSDirectory.permissionsDeny(URL target,
String id,
int permissions,
int flags)
Denies the specified permissions for the specified id.
|
URL |
NSEntry.readLink()
Returns the URL representing the link target.
|
URL |
NSDirectory.readLink(URL name)
Returns the URL representing the link target.
|
void |
NSEntry.remove()
Removes this entry and closes it.
|
void |
NSEntry.remove(int flags)
Removes this entry and closes it.
|
void |
NSDirectory.remove(String target)
Removes the specified entry.
|
void |
NSDirectory.remove(String target,
int flags)
Removes the specified entry.
|
void |
NSDirectory.remove(URL target)
Removes the specified entry.
|
void |
NSDirectory.remove(URL target,
int flags)
Removes the specified entry.
|
Modifier and Type | Method and Description |
---|---|
void |
Resource.release()
Release resource
|
void |
Compute.release(boolean drain)
Release resource
|
Modifier and Type | Method and Description |
---|---|
void |
ResourceManager.releaseCompute(String id)
Close compute resource, even if it is not drained.
|
void |
ResourceManager.releaseCompute(String id,
boolean drain)
Close compute resource
|
void |
ResourceManager.releaseNetwork(String id)
Close network resource
|
void |
ResourceManager.releaseStorage(String id)
Close storage resource
|
Modifier and Type | Method and Description |
---|---|
void |
ResourceTask.waitFor()
Waits for the resource end up in a final state.
|
void |
ResourceTask.waitFor(float timeoutInSeconds)
Waits for the task to end up in a final state.
|
void |
ResourceTask.waitFor(float timeoutInSeconds,
State state)
Waits for the task to end up in specified state.
|
void |
ResourceTask.waitFor(State state)
Waits for the task to end up in specified state.
|
Modifier and Type | Method and Description |
---|---|
void |
RPC.call(Parameter... parameters)
Calls the remote procedure.
|
void |
RPC.close()
Non-blocking close of the RPC handle instance.
|
void |
RPC.close(float timeoutInSeconds)
Closes the RPC handle instance.
|
Modifier and Type | Method and Description |
---|---|
Stream |
StreamServer.connect()
Establishes a connection to the stream server.
|
void |
Stream.connect()
Establishes a connection to the target defined during the construction of
the stream.
|
Stream |
StreamServer.connect(float timeoutInSeconds)
Establishes a connection to the stream server.
|
void |
Stream.connect(float timeoutInSeconds)
Establishes a connection to the target defined during the construction of
the stream.
|
Context |
Stream.getContext()
Returns the remote authorization info.
|
StreamInputStream |
Stream.getInputStream()
Obtains an InputStream from the stream.
|
StreamOutputStream |
Stream.getOutputStream()
Obtains an OutputStream from the stream.
|
URL |
StreamServer.getUrl()
Obtains the URL to be used to connect to this server.
|
URL |
Stream.getUrl()
Obtains the URL that was used to create the stream.
|
int |
Stream.read(Buffer buffer)
Reads a raw buffer from the stream.
|
int |
Stream.read(Buffer buffer,
int len)
Reads a raw buffer from the stream.
|
Stream |
StreamServer.serve()
Waits for incoming client connections (like an accept of a serversocket).
|
Stream |
StreamServer.serve(float timeoutInSeconds)
Waits for incoming client connections (like an accept of a serversocket).
|
int |
Stream.waitFor(int what)
Checks if the stream is ready for I/O, or if it has entered the ERROR
state.
|
int |
Stream.waitFor(int what,
float timeoutInSeconds)
Checks if the stream is ready for I/O, or if it has entered the ERROR
state.
|
int |
Stream.write(Buffer buffer)
Writes a raw buffer to the stream.
|
int |
Stream.write(Buffer buffer,
int len)
Writes a raw buffer to the stream.
|
Modifier and Type | Method and Description |
---|---|
void |
TaskContainer.cancel()
Cancels all the asynchronous operations in the container.
|
void |
Task.cancel()
Cancels the asynchronous operation.
|
void |
TaskContainer.cancel(float timeoutInSeconds)
Cancels all the asynchronous operations in the container.
|
void |
Task.cancel(float timeoutInSeconds)
Cancels the asynchronous operation.
|
E |
Task.getResult()
Obtains the result of the asynchronous method call.
|
void |
Task.rethrow()
Throws any exception a failed task caught.
|
void |
TaskContainer.run()
Starts all asynchronous operations in the container.
|
void |
Task.run()
Starts the asynchronous operation.
|
Task<?,?> |
TaskContainer.waitFor()
Waits for all tasks to end up in a final state.
|
void |
Task.waitFor()
Waits for the task end up in a final state.
|
Task<?,?> |
TaskContainer.waitFor(float timeoutInSeconds)
Waits for all tasks to end up in a final state.
|
boolean |
Task.waitFor(float timeoutInSeconds)
Waits for the task to end up in a final state.
|
Task<?,?> |
TaskContainer.waitFor(float timeoutInSeconds,
WaitMode mode)
Waits for one or more of the tasks to end up in a final state.
|
Task<?,?> |
TaskContainer.waitFor(WaitMode mode)
Waits for one or more of the tasks to end up in a final state.
|
Copyright © 2016 Open Grid Forum. All rights reserved.