| 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.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.permissions |
The permissions package provides the interface
Permissions
to query and set
permissions on Saga objects, such as files or streams. |
| org.ogf.saga.resource |
This package provides classes to manage resources on remote grid/cloud systems.
|
| org.ogf.saga.resource.manager |
This package provides the Resource Manager class.
|
| 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 |
|---|---|
Task<T,Boolean> |
AsyncAttributes.existsAttribute(TaskMode mode,
String key)
Creates a task that tests for the existence of an attribute.
|
Task<T,String[]> |
AsyncAttributes.findAttributes(TaskMode mode,
String... patterns)
Creates a task that finds matching attributes.
|
Task<T,String> |
AsyncAttributes.getAttribute(TaskMode mode,
String key)
Creates a task that obtains the value of an attribute.
|
Task<T,String[]> |
AsyncAttributes.getVectorAttribute(TaskMode mode,
String key)
Creates a task that obtains the array of values associated with an
attribute.
|
Task<T,Boolean> |
AsyncAttributes.isReadOnlyAttribute(TaskMode mode,
String key)
Creates a task that checks the attribute mode for being read-only.
|
Task<T,Boolean> |
AsyncAttributes.isRemovableAttribute(TaskMode mode,
String key)
Creates a task that checks the attribute mode for being removable.
|
Task<T,Boolean> |
AsyncAttributes.isVectorAttribute(TaskMode mode,
String key)
Creates a task that checks the attribute mode for being a vector.
|
Task<T,Boolean> |
AsyncAttributes.isWritableAttribute(TaskMode mode,
String key)
Creates a task that checks the attribute mode for being writable.
|
Task<T,String[]> |
AsyncAttributes.listAttributes(TaskMode mode)
Creates a task that obtains the list of attribute keys.
|
Task<T,Void> |
AsyncAttributes.removeAttribute(TaskMode mode,
String key)
Creates a task that removes an attribute.
|
Task<T,Void> |
AsyncAttributes.setAttribute(TaskMode mode,
String key,
String value)
Creates a task that sets an attribute to a value.
|
Task<T,Void> |
AsyncAttributes.setVectorAttribute(TaskMode mode,
String key,
String[] values)
Creates a task that sets an attribute to an array of values.
|
| Modifier and Type | Method and Description |
|---|---|
abstract Task<FileInputStream,Integer> |
FileInputStream.available(TaskMode mode)
Creates a task that determines how many bytes are available from this
stream.
|
abstract Task<FileInputStream,Void> |
FileInputStream.close(TaskMode mode)
Creates a task that closes this stream.
|
abstract Task<FileOutputStream,Void> |
FileOutputStream.close(TaskMode mode)
Creates a task that closes this stream.
|
static Task<FileFactory,Directory> |
FileFactory.createDirectory(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name)
Creates a task that creates a Directory for reading.
|
static Task<FileFactory,Directory> |
FileFactory.createDirectory(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a Directory.
|
static Task<FileFactory,Directory> |
FileFactory.createDirectory(String sagaFactoryClassname,
TaskMode mode,
URL name)
Creates a task that creates a Directory for reading, using the default
session.
|
static Task<FileFactory,Directory> |
FileFactory.createDirectory(String sagaFactoryClassname,
TaskMode mode,
URL name,
int flags)
Creates a task that creates a Directory, using the default session.
|
static Task<FileFactory,Directory> |
FileFactory.createDirectory(TaskMode mode,
Session session,
URL name)
Creates a task that creates a Directory for reading.
|
static Task<FileFactory,Directory> |
FileFactory.createDirectory(TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a Directory.
|
static Task<FileFactory,Directory> |
FileFactory.createDirectory(TaskMode mode,
URL name)
Creates a task that creates a Directory for reading, using the default
session.
|
static Task<FileFactory,Directory> |
FileFactory.createDirectory(TaskMode mode,
URL name,
int flags)
Creates a task that creates a Directory, using the default session.
|
static Task<FileFactory,File> |
FileFactory.createFile(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name)
Creates a task that creates a File for reading.
|
static Task<FileFactory,File> |
FileFactory.createFile(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a File.
|
static Task<FileFactory,File> |
FileFactory.createFile(String sagaFactoryClassname,
TaskMode mode,
URL name)
Creates a task that creates a File for reading, using the default
session.
|
static Task<FileFactory,File> |
FileFactory.createFile(String sagaFactoryClassname,
TaskMode mode,
URL name,
int flags)
Creates a task that creates a File, using the default session.
|
static Task<FileFactory,File> |
FileFactory.createFile(TaskMode mode,
Session session,
URL name)
Creates a task that creates a File for reading.
|
static Task<FileFactory,File> |
FileFactory.createFile(TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a File.
|
static Task<FileFactory,File> |
FileFactory.createFile(TaskMode mode,
URL name)
Creates a task that creates a File for reading, using the default
session.
|
static Task<FileFactory,File> |
FileFactory.createFile(TaskMode mode,
URL name,
int flags)
Creates a task that creates a File, using the default session.
|
static Task<FileFactory,FileInputStream> |
FileFactory.createFileInputStream(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name)
Creates a task that creates a FileInputStream.
|
static Task<FileFactory,FileInputStream> |
FileFactory.createFileInputStream(String sagaFactoryClassname,
TaskMode mode,
URL name)
Creates a task that creates a FileInputStream using the default session.
|
static Task<FileFactory,FileInputStream> |
FileFactory.createFileInputStream(TaskMode mode,
Session session,
URL name)
Creates a task that creates a FileInputStream.
|
static Task<FileFactory,FileInputStream> |
FileFactory.createFileInputStream(TaskMode mode,
URL name)
Creates a task that creates a FileInputStream using the default session.
|
static Task<FileFactory,FileOutputStream> |
FileFactory.createFileOutputStream(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name)
Creates a task that creates a FileOutputStream.
|
static Task<FileFactory,FileOutputStream> |
FileFactory.createFileOutputStream(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name,
boolean append)
Creates a task that creates a FileOutputStream.
|
static Task<FileFactory,FileOutputStream> |
FileFactory.createFileOutputStream(String sagaFactoryClassname,
TaskMode mode,
URL name)
Creates a task that creates a FileOutputStream using the default session.
|
static Task<FileFactory,FileOutputStream> |
FileFactory.createFileOutputStream(String sagaFactoryClassname,
TaskMode mode,
URL name,
boolean append)
Creates a task that creates a FileOutputStream.
|
static Task<FileFactory,FileOutputStream> |
FileFactory.createFileOutputStream(TaskMode mode,
Session session,
URL name)
Creates a task that creates a FileOutputStream.
|
static Task<FileFactory,FileOutputStream> |
FileFactory.createFileOutputStream(TaskMode mode,
Session session,
URL name,
boolean append)
Creates a task that creates a FileOutputStream.
|
static Task<FileFactory,FileOutputStream> |
FileFactory.createFileOutputStream(TaskMode mode,
URL name)
Creates a task that creates a FileOutputStream using the default session.
|
static Task<FileFactory,FileOutputStream> |
FileFactory.createFileOutputStream(TaskMode mode,
URL name,
boolean append)
Creates a task that creates a FileOutputStream.
|
protected abstract Task<FileFactory,Directory> |
FileFactory.doCreateDirectory(TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a Directory.
|
protected abstract Task<FileFactory,File> |
FileFactory.doCreateFile(TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a File.
|
protected abstract Task<FileFactory,FileInputStream> |
FileFactory.doCreateFileInputStream(TaskMode mode,
Session session,
URL name)
Creates a task that creates a FileInputStream.
|
protected abstract Task<FileFactory,FileOutputStream> |
FileFactory.doCreateFileOutputStream(TaskMode mode,
Session session,
URL name,
boolean append)
Creates a task that creates a FileOutputStream.
|
abstract Task<FileOutputStream,Void> |
FileOutputStream.flush(TaskMode mode)
Creates a task that flushes this stream.
|
Task<File,Long> |
File.getSize(TaskMode mode)
Creates a task that obtains the number of bytes in the file.
|
Task<Directory,Long> |
Directory.getSize(TaskMode mode,
URL name)
Creates a task that retrieves the number of bytes in the specified file.
|
Task<Directory,Long> |
Directory.getSize(TaskMode mode,
URL name,
int flags)
Creates a task that retrieves the number of bytes in the specified file.
|
Task<Directory,Boolean> |
Directory.isFile(TaskMode mode,
URL name)
Creates a task that tests the name for being a directory entry.
|
abstract Task<FileInputStream,Void> |
FileInputStream.mark(TaskMode mode,
int readlimit)
Creates a task that marks the current position in this stream.
|
abstract Task<FileInputStream,Boolean> |
FileInputStream.markSupported(TaskMode mode)
Creates a task that determines if
InputStream.mark(int)
is supported. |
Task<File,List<String>> |
File.modesE(TaskMode mode)
Creates a task that lists the extended modes available in this
implementation and/or on the server side.
|
Task<Directory,Directory> |
Directory.openDirectory(TaskMode mode,
URL name)
Creates a task that creates a new
Directory instance. |
Task<Directory,Directory> |
Directory.openDirectory(TaskMode mode,
URL name,
int flags)
Creates a task that creates a new
Directory instance. |
Task<Directory,File> |
Directory.openFile(TaskMode mode,
URL name)
Creates a task that creates a new
File instance. |
Task<Directory,File> |
Directory.openFile(TaskMode mode,
URL name,
int flags)
Creates a task that creates a new
File instance. |
Task<Directory,FileInputStream> |
Directory.openFileInputStream(TaskMode mode,
URL name)
Creates a task that creates a new
FileInputStream
instance. |
Task<Directory,FileOutputStream> |
Directory.openFileOutputStream(TaskMode mode,
URL name)
Creates a task that creates a new
FileOutputStream
instance. |
Task<Directory,FileOutputStream> |
Directory.openFileOutputStream(TaskMode mode,
URL name,
boolean append)
Creates a task that creates a new
FileOutputStream
instance. |
abstract Task<FileInputStream,Integer> |
FileInputStream.read(TaskMode mode)
Creates a task that reads a byte from this stream.
|
Task<File,Integer> |
File.read(TaskMode mode,
Buffer buffer)
Creates a task that reads up to the buffer's size bytes from the file
into the buffer.
|
Task<File,Integer> |
File.read(TaskMode mode,
Buffer buffer,
int len)
Creates a task that reads up to
len bytes from the file
into the buffer. |
Task<File,Integer> |
File.read(TaskMode mode,
Buffer buffer,
int offset,
int len)
Creates a task that reads up to
len bytes from the file
into the buffer at the specified buffer offset. |
Task<FileInputStream,Integer> |
FileInputStream.read(TaskMode mode,
byte[] buf)
Creates a task that reads a buffer from this stream.
|
abstract Task<FileInputStream,Integer> |
FileInputStream.read(TaskMode mode,
byte[] buf,
int off,
int len)
Creates task that reads (part of) a buffer from this stream.
|
Task<File,Integer> |
File.readE(TaskMode mode,
String emode,
String spec,
Buffer buffer)
Creates a task for an extended read.
|
Task<File,Integer> |
File.readP(TaskMode mode,
String pattern,
Buffer buffer)
Creates a task that does a pattern-based read.
|
Task<File,Void> |
File.readV(TaskMode mode,
IOVec[] iovecs)
Creates a task that does a gather/scatter read.
|
abstract Task<FileInputStream,Void> |
FileInputStream.reset(TaskMode mode)
Creates a task that resets the position to the position last marked.
|
Task<File,Long> |
File.seek(TaskMode mode,
long offset,
SeekMode whence)
Creates a task that repositions the current file position as requested.
|
Task<File,Integer> |
File.sizeE(TaskMode mode,
String emode,
String spec)
Creates a task that determines the storage size required for an extended
I/O operation.
|
Task<File,Integer> |
File.sizeP(TaskMode mode,
String pattern)
Creates a task that determines the storage size required for a pattern
I/O operation.
|
abstract Task<FileInputStream,Long> |
FileInputStream.skip(TaskMode mode,
long n)
Creates a task that skips the specified number of bytes from this stream.
|
Task<File,Integer> |
File.write(TaskMode mode,
Buffer buffer)
Creates a task that writes up to the buffer's size bytes from the buffer
to the file at the current file position.
|
Task<File,Integer> |
File.write(TaskMode mode,
Buffer buffer,
int len)
Creates a task that writes up to
len bytes from the buffer
to the file at the current file position. |
Task<File,Integer> |
File.write(TaskMode mode,
Buffer buffer,
int offset,
int len)
Creates a task that writes up to
len bytes from the buffer
at the specified buffer offset to the file at the current
file position. |
Task<FileOutputStream,Void> |
FileOutputStream.write(TaskMode mode,
byte[] buf)
Creates a task that writes a buffer to this stream.
|
abstract Task<FileOutputStream,Void> |
FileOutputStream.write(TaskMode mode,
byte[] buf,
int off,
int len)
Creates a task that writes (part of) a buffer to this stream.
|
abstract Task<FileOutputStream,Void> |
FileOutputStream.write(TaskMode mode,
int b)
Creates a task that writes a byte to this stream.
|
Task<File,Integer> |
File.writeE(TaskMode mode,
String emode,
String spec,
Buffer buffer)
Creates a task for an extended write.
|
Task<File,Integer> |
File.writeP(TaskMode mode,
String pattern,
Buffer buffer)
Creates a task that does a pattern-based write.
|
Task<File,Void> |
File.writeV(TaskMode mode,
IOVec[] iovecs)
Creates a task that does a gather/scatter write.
|
| Modifier and Type | Method and Description |
|---|---|
Task<Job,Void> |
Job.checkpoint(TaskMode mode)
Creates a task that asks the resource manager to initiate a checkpoint
operation on a running job.
|
Task<JobService,Job> |
JobService.createJob(TaskMode mode,
JobDescription jd)
Creates a task that creates a job instance as specified by the job
description provided.
|
static Task<JobFactory,JobService> |
JobFactory.createJobService(String sagaFactoryClassname,
TaskMode mode)
Creates a task that creates a job service, using the default session and
default contact string.
|
static Task<JobFactory,JobService> |
JobFactory.createJobService(String sagaFactoryClassname,
TaskMode mode,
Session session)
Creates a task that creates a job service, using a default contact
string.
|
static Task<JobFactory,JobService> |
JobFactory.createJobService(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL rm)
Creates a task that creates a job service.
|
static Task<JobFactory,JobService> |
JobFactory.createJobService(String sagaFactoryClassname,
TaskMode mode,
URL rm)
Creates a task that creates a job service, using the default session.
|
static Task<JobFactory,JobService> |
JobFactory.createJobService(TaskMode mode)
Creates a task that creates a job service, using the default session and
default contact string.
|
static Task<JobFactory,JobService> |
JobFactory.createJobService(TaskMode mode,
Session session)
Creates a task that creates a job service, using a default contact
string.
|
static Task<JobFactory,JobService> |
JobFactory.createJobService(TaskMode mode,
Session session,
URL rm)
Creates a task that creates a job service.
|
static Task<JobFactory,JobService> |
JobFactory.createJobService(TaskMode mode,
URL rm)
Creates a task that creates a job service, using the default session.
|
protected abstract Task<JobFactory,JobService> |
JobFactory.doCreateJobService(TaskMode mode,
Session session,
URL rm)
Creates a task that creates a job service.
|
Task<JobService,Job> |
JobService.getJob(TaskMode mode,
String jobId)
Creates a task that obtains the job instance associated with the
specified job identification.
|
Task<Job,JobDescription> |
Job.getJobDescription(TaskMode mode)
Creates a task that retrieves the job description that was used to submit
this job instance.
|
Task<JobService,JobSelf> |
JobService.getSelf(TaskMode mode)
Creates a task that obtains a job instance representing the calling
application.
|
Task<Job,InputStream> |
Job.getStderr(TaskMode mode)
Creates a task that obtains the error stream of this job (which can be
read).
|
Task<Job,OutputStream> |
Job.getStdin(TaskMode mode)
Creates a task that obtains the input stream of this job (to which can be
written).
|
Task<Job,InputStream> |
Job.getStdout(TaskMode mode)
Creates a task that obtains the output stream of this job (which can be
read).
|
Task<JobService,List<String>> |
JobService.list(TaskMode mode)
Creates a task that obtains the list of jobs that are currently known to
the resource manager.
|
Task<Job,Void> |
Job.migrate(TaskMode mode,
JobDescription jd)
Creates a task that asks the resource manager to migrate a job.
|
Task<Job,Void> |
Job.resume(TaskMode mode)
Creates a task that asks the resource manager to perform a resume
operation on a suspended job.
|
Task<JobService,Job> |
JobService.runJob(TaskMode mode,
String commandLine)
Creates a task that runs the specified command, non-interactively, on a
host chosen by the implementation.
|
Task<JobService,Job> |
JobService.runJob(TaskMode mode,
String commandLine,
boolean interactive)
Creates a task that runs the specified command on a host chosen by the
implementation.
|
Task<JobService,Job> |
JobService.runJob(TaskMode mode,
String commandLine,
String host)
Creates a task that runs the specified command, non-interactively, on the
specified host.
|
Task<JobService,Job> |
JobService.runJob(TaskMode mode,
String commandLine,
String host,
boolean interactive)
Creates a task that runs the specified command on the specified host.
|
Task<Job,Void> |
Job.signal(TaskMode mode,
int signum)
Creates a task that asks the resource manager to deliver an arbitrary
signal to a dispatched job.
|
Task<Job,Void> |
Job.suspend(TaskMode mode)
Creates a task that asks the resource manager to perform a suspend
operation on a running job.
|
| Modifier and Type | Method and Description |
|---|---|
Task<LogicalFile,Void> |
LogicalFile.addLocation(TaskMode mode,
URL name)
Creates a task that adds a replica location to the replica set.
|
static Task<LogicalFileFactory,LogicalDirectory> |
LogicalFileFactory.createLogicalDirectory(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name)
Creates a task that creates a LogicalDirectory using READ open mode.
|
static Task<LogicalFileFactory,LogicalDirectory> |
LogicalFileFactory.createLogicalDirectory(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a LogicalDirectory.
|
static Task<LogicalFileFactory,LogicalDirectory> |
LogicalFileFactory.createLogicalDirectory(String sagaFactoryClassname,
TaskMode mode,
URL name)
Creates a task that creates a LogicalDirectory using READ open mode,
using the default session.
|
static Task<LogicalFileFactory,LogicalDirectory> |
LogicalFileFactory.createLogicalDirectory(String sagaFactoryClassname,
TaskMode mode,
URL name,
int flags)
Creates a task that creates a LogicalDirectory using the default session.
|
static Task<LogicalFileFactory,LogicalDirectory> |
LogicalFileFactory.createLogicalDirectory(TaskMode mode,
Session session,
URL name)
Creates a task that creates a LogicalDirectory using READ open mode.
|
static Task<LogicalFileFactory,LogicalDirectory> |
LogicalFileFactory.createLogicalDirectory(TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a LogicalDirectory.
|
static Task<LogicalFileFactory,LogicalDirectory> |
LogicalFileFactory.createLogicalDirectory(TaskMode mode,
URL name)
Creates a task that creates a LogicalDirectory using READ open mode,
using the default session.
|
static Task<LogicalFileFactory,LogicalDirectory> |
LogicalFileFactory.createLogicalDirectory(TaskMode mode,
URL name,
int flags)
Creates a task that creates a LogicalDirectory using the default session.
|
static Task<LogicalFileFactory,LogicalFile> |
LogicalFileFactory.createLogicalFile(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name)
Creates a task that creates a LogicalFile using READ open mode.
|
static Task<LogicalFileFactory,LogicalFile> |
LogicalFileFactory.createLogicalFile(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a LogicalFile.
|
static Task<LogicalFileFactory,LogicalFile> |
LogicalFileFactory.createLogicalFile(String sagaFactoryClassname,
TaskMode mode,
URL name)
Creates a task that creates a LogicalFile using READ open mode, using the
default session.
|
static Task<LogicalFileFactory,LogicalFile> |
LogicalFileFactory.createLogicalFile(String sagaFactoryClassname,
TaskMode mode,
URL name,
int flags)
Creates a task that creates a LogicalFile using the default session.
|
static Task<LogicalFileFactory,LogicalFile> |
LogicalFileFactory.createLogicalFile(TaskMode mode,
Session session,
URL name)
Creates a task that creates a LogicalFile using READ open mode.
|
static Task<LogicalFileFactory,LogicalFile> |
LogicalFileFactory.createLogicalFile(TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a LogicalFile.
|
static Task<LogicalFileFactory,LogicalFile> |
LogicalFileFactory.createLogicalFile(TaskMode mode,
URL name)
Creates a task that creates a LogicalFile using READ open mode, using the
default session.
|
static Task<LogicalFileFactory,LogicalFile> |
LogicalFileFactory.createLogicalFile(TaskMode mode,
URL name,
int flags)
Creates a task that creates a LogicalFile using the default session.
|
protected abstract Task<LogicalFileFactory,LogicalDirectory> |
LogicalFileFactory.doCreateLogicalDirectory(TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a LogicalDirectory.
|
protected abstract Task<LogicalFileFactory,LogicalFile> |
LogicalFileFactory.doCreateLogicalFile(TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a LogicalFile.
|
Task<LogicalDirectory,List<URL>> |
LogicalDirectory.find(TaskMode mode,
String namePattern,
String[] attrPattern)
Creates a task that finds entries in the current directory and below,
with matching names and matching meta data.
|
Task<LogicalDirectory,List<URL>> |
LogicalDirectory.find(TaskMode mode,
String namePattern,
String[] attrPattern,
int flags)
Creates a task that finds entries in the current directory and below,
with matching names and matching meta data.
|
Task<NSDirectory,Boolean> |
LogicalDirectory.isFile(TaskMode mode,
URL name)
Creates a task that tests the name for being a logical file.
|
Task<LogicalFile,List<URL>> |
LogicalFile.listLocations(TaskMode mode)
Creates a task that lists the locations in this location set.
|
Task<LogicalDirectory,LogicalDirectory> |
LogicalDirectory.openLogicalDir(TaskMode mode,
URL name)
Creates a task that creates a new
LogicalDirectory
instance. |
Task<LogicalDirectory,LogicalDirectory> |
LogicalDirectory.openLogicalDir(TaskMode mode,
URL name,
int flags)
Creates a task that creates a new
LogicalDirectory
instance. |
Task<LogicalDirectory,LogicalFile> |
LogicalDirectory.openLogicalFile(TaskMode mode,
URL name)
Creates a task that creates a new
LogicalFile instance. |
Task<LogicalDirectory,LogicalFile> |
LogicalDirectory.openLogicalFile(TaskMode mode,
URL name,
int flags)
Creates a task that creates a new
LogicalFile instance. |
Task<LogicalFile,Void> |
LogicalFile.removeLocation(TaskMode mode,
URL name)
Creates a task that removes a replica location from the replica set.
|
Task<LogicalFile,Void> |
LogicalFile.replicate(TaskMode mode,
URL name)
Creates a task that replicates a file from any of the known locations to
a new location, with default flags NONE.
|
Task<LogicalFile,Void> |
LogicalFile.replicate(TaskMode mode,
URL name,
int flags)
Creates a task that replicates a file from any of the known locations to
a new location.
|
Task<LogicalFile,Void> |
LogicalFile.updateLocation(TaskMode mode,
URL nameOld,
URL nameNew)
Creates a task that changes a replica location in the replica set.
|
| Modifier and Type | Method and Description |
|---|---|
Task<T,Integer> |
AsyncMonitorable.addCallback(TaskMode mode,
String name,
Callback cb)
Creates a task that adds a callback to the specified metric.
|
Task<T,Boolean> |
AsyncSteerable.addMetric(TaskMode mode,
Metric metric)
Creates a task that adds a metric instance to the application instance.
|
Task<T,Void> |
AsyncSteerable.fireMetric(TaskMode mode,
String name)
Creates a task that pushes a new metric value to the backend.
|
Task<T,Metric> |
AsyncMonitorable.getMetric(TaskMode mode,
String name)
Creates a task that obtains a metric instance, identified by name.
|
Task<T,String[]> |
AsyncMonitorable.listMetrics(TaskMode mode)
Creates a task that lists all metrics associated with the object.
|
Task<T,Void> |
AsyncMonitorable.removeCallback(TaskMode mode,
String name,
int cookie)
Creates a task that removes the specified callback.
|
Task<T,Void> |
AsyncSteerable.removeMetric(TaskMode mode,
String name)
Creates a task that removes a metric instance.
|
| Modifier and Type | Method and Description |
|---|---|
Task<NSDirectory,Void> |
NSDirectory.changeDir(TaskMode mode,
URL dir)
Creates a task that changes the working directory.
|
Task<NSEntry,Void> |
NSEntry.close(TaskMode mode)
Creates a task that closes this entry.
|
Task<NSEntry,Void> |
NSEntry.close(TaskMode mode,
float timeoutInSeconds)
Creates a task that closes this entry.
|
Task<NSDirectory,Void> |
NSDirectory.copy(TaskMode mode,
String source,
URL target)
Creates a task that copies the source entry to another part of the
namespace.
|
Task<NSDirectory,Void> |
NSDirectory.copy(TaskMode mode,
String source,
URL target,
int flags)
Creates a task that copies the source entry to another part of the
namespace.
|
Task<NSEntry,Void> |
NSEntry.copy(TaskMode mode,
URL target)
Creates a task that copies this entry to another part of the namespace.
|
Task<NSEntry,Void> |
NSEntry.copy(TaskMode mode,
URL target,
int flags)
Creates a task that copies this entry to another part of the namespace.
|
Task<NSDirectory,Void> |
NSDirectory.copy(TaskMode mode,
URL source,
URL target)
Creates a task that copies source the entry to another part of the
namespace.
|
Task<NSDirectory,Void> |
NSDirectory.copy(TaskMode mode,
URL source,
URL target,
int flags)
Creates a task that copies source the entry to another part of the
namespace.
|
static Task<NSFactory,NSDirectory> |
NSFactory.createNSDirectory(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name)
Creates a task that creates a namespace directory.
|
static Task<NSFactory,NSDirectory> |
NSFactory.createNSDirectory(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a namespace directory.
|
static Task<NSFactory,NSDirectory> |
NSFactory.createNSDirectory(String sagaFactoryClassname,
TaskMode mode,
URL name)
Creates a task that creates a namespace directory using the default
session.
|
static Task<NSFactory,NSDirectory> |
NSFactory.createNSDirectory(String sagaFactoryClassname,
TaskMode mode,
URL name,
int flags)
Creates a task that creates a namespace directory using the default
session.
|
static Task<NSFactory,NSDirectory> |
NSFactory.createNSDirectory(TaskMode mode,
Session session,
URL name)
Creates a task that creates a namespace directory.
|
static Task<NSFactory,NSDirectory> |
NSFactory.createNSDirectory(TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a namespace directory.
|
static Task<NSFactory,NSDirectory> |
NSFactory.createNSDirectory(TaskMode mode,
URL name)
Creates a task that creates a namespace directory using the default
session.
|
static Task<NSFactory,NSDirectory> |
NSFactory.createNSDirectory(TaskMode mode,
URL name,
int flags)
Creates a task that creates a namespace directory using the default
session.
|
static Task<NSFactory,NSEntry> |
NSFactory.createNSEntry(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name)
Creates a task that creates a namespace entry.
|
static Task<NSFactory,NSEntry> |
NSFactory.createNSEntry(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a namespace entry.
|
static Task<NSFactory,NSEntry> |
NSFactory.createNSEntry(String sagaFactoryClassname,
TaskMode mode,
URL name)
Creates a task that creates a namespace entry using the default session.
|
static Task<NSFactory,NSEntry> |
NSFactory.createNSEntry(String sagaFactoryClassname,
TaskMode mode,
URL name,
int flags)
Creates a task that creates a namespace entry using the default session.
|
static Task<NSFactory,NSEntry> |
NSFactory.createNSEntry(TaskMode mode,
Session session,
URL name)
Creates a task that creates a namespace entry.
|
static Task<NSFactory,NSEntry> |
NSFactory.createNSEntry(TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a namespace entry.
|
static Task<NSFactory,NSEntry> |
NSFactory.createNSEntry(TaskMode mode,
URL name)
Creates a task that creates a namespace entry using the default session.
|
static Task<NSFactory,NSEntry> |
NSFactory.createNSEntry(TaskMode mode,
URL name,
int flags)
Creates a task that creates a namespace entry using the default session.
|
protected abstract Task<NSFactory,NSDirectory> |
NSFactory.doCreateNSDirectory(TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a namespace directory.
|
protected abstract Task<NSFactory,NSEntry> |
NSFactory.doCreateNSEntry(TaskMode mode,
Session session,
URL name,
int flags)
Creates a task that creates a namespace entry.
|
Task<NSDirectory,Boolean> |
NSDirectory.exists(TaskMode mode,
URL name)
Creates a task that queries for the existence of an entry.
|
Task<NSDirectory,List<URL>> |
NSDirectory.find(TaskMode mode,
String pattern)
Creates a task that finds entries in the directory and below that match
the specified pattern.
|
Task<NSDirectory,List<URL>> |
NSDirectory.find(TaskMode mode,
String pattern,
int flags)
Creates a task that finds entries in the directory and below that match
the specified pattern.
|
Task<NSEntry,URL> |
NSEntry.getCWD(TaskMode mode)
Creates a task that obtains a String representing the current working
directory for the entry.
|
Task<NSDirectory,URL> |
NSDirectory.getEntry(TaskMode mode,
int entry)
Creates a task that gives the name of an entry in the directory based
upon the enumeration defined by getNumEntries().
|
Task<NSEntry,Long> |
NSEntry.getMTime(TaskMode mode)
Creates a task that returns the last modification time of this entry.
|
Task<NSDirectory,Long> |
NSDirectory.getMTime(TaskMode mode,
URL name)
Creates a task that determines the last modification time of
the specified name.
|
Task<NSEntry,URL> |
NSEntry.getName(TaskMode mode)
Creates a task that obtains the name part of the URL of this entry.
|
Task<NSDirectory,Integer> |
NSDirectory.getNumEntries(TaskMode mode)
Creates a task that obtains the number of entries in this directory.
|
Task<NSEntry,URL> |
NSEntry.getURL(TaskMode mode)
Creates a task that obtains the complete URL pointing to the entry.
|
Task<NSEntry,Boolean> |
NSEntry.isDir(TaskMode mode)
Creates a task that tests this entry for being a directory.
|
Task<NSDirectory,Boolean> |
NSDirectory.isDir(TaskMode mode,
URL name)
Creates a task that tests the name for being a directory.
|
Task<NSEntry,Boolean> |
NSEntry.isEntry(TaskMode mode)
Creates a task that tests this entry for being a namespace entry.
|
Task<NSDirectory,Boolean> |
NSDirectory.isEntry(TaskMode mode,
URL name)
Creates a task that tests the name for being a namespace entry.
|
Task<NSEntry,Boolean> |
NSEntry.isLink(TaskMode mode)
Creates a task that tests this entry for being a link.
|
Task<NSDirectory,Boolean> |
NSDirectory.isLink(TaskMode mode,
URL name)
Creates a task that tests the name for being a link.
|
Task<NSDirectory,Void> |
NSDirectory.link(TaskMode mode,
String source,
URL target)
Creates a task that creates a symbolic link from the specified target to
the specified source.
|
Task<NSDirectory,Void> |
NSDirectory.link(TaskMode mode,
String source,
URL target,
int flags)
Creates a task that creates a symbolic link from the specified target to
the specified source.
|
Task<NSEntry,Void> |
NSEntry.link(TaskMode mode,
URL target)
Creates a task that creates a symbolic link from the target to this
entry.
|
Task<NSEntry,Void> |
NSEntry.link(TaskMode mode,
URL target,
int flags)
Creates a task that creates a symbolic link from the target to this
entry.
|
Task<NSDirectory,Void> |
NSDirectory.link(TaskMode mode,
URL source,
URL target)
Creates a task that creates a symbolic link from the specified target to
the specified source.
|
Task<NSDirectory,Void> |
NSDirectory.link(TaskMode mode,
URL source,
URL target,
int flags)
Creates a task that creates a symbolic link from the specified target to
the specified source.
|
Task<NSDirectory,List<URL>> |
NSDirectory.list(TaskMode mode)
Creates a task that lists entries in the directory.
|
Task<NSDirectory,List<URL>> |
NSDirectory.list(TaskMode mode,
int flags)
Creates a task that lists entries in the directory.
|
Task<NSDirectory,List<URL>> |
NSDirectory.list(TaskMode mode,
String pattern)
Creates a task that lists entries in the directory that match the
specified pattern.
|
Task<NSDirectory,List<URL>> |
NSDirectory.list(TaskMode mode,
String pattern,
int flags)
Creates a task that lists entries in the directory that match the
specified pattern.
|
Task<NSDirectory,Void> |
NSDirectory.makeDir(TaskMode mode,
URL target)
Creates a task that creates a new directory.
|
Task<NSDirectory,Void> |
NSDirectory.makeDir(TaskMode mode,
URL target,
int flags)
Creates a task that creates a new directory.
|
Task<NSDirectory,Void> |
NSDirectory.move(TaskMode mode,
String source,
URL target)
Creates a task that renames the specified source to the specified target,
or move the specified source to the specified target if the target is a
directory.
|
Task<NSDirectory,Void> |
NSDirectory.move(TaskMode mode,
String source,
URL target,
int flags)
Creates a task that renames the specified source to the specified target,
or move the specified source to the specified target if the target is a
directory.
|
Task<NSEntry,Void> |
NSEntry.move(TaskMode mode,
URL target)
Creates a task that renames this entry to the target, or moves this entry
to the target if it is a directory.
|
Task<NSEntry,Void> |
NSEntry.move(TaskMode mode,
URL target,
int flags)
Creates a task that renames this entry to the target, or moves this entry
to the target if it is a directory.
|
Task<NSDirectory,Void> |
NSDirectory.move(TaskMode mode,
URL source,
URL target)
Creates a task that renames the specified source to the specified target,
or move the specified source to the specified target if the target is a
directory.
|
Task<NSDirectory,Void> |
NSDirectory.move(TaskMode mode,
URL source,
URL target,
int flags)
Creates a task that renames the specified source to the specified target,
or move the specified source to the specified target if the target is a
directory.
|
Task<NSDirectory,NSEntry> |
NSDirectory.open(TaskMode mode,
URL name)
Creates a task that creates a new
NamespaceEntry instance. |
Task<NSDirectory,NSEntry> |
NSDirectory.open(TaskMode mode,
URL name,
int flags)
Creates a task that creates a new
NamespaceEntry instance. |
Task<NSDirectory,NSDirectory> |
NSDirectory.openDir(TaskMode mode,
URL name)
Creates a task that creates a new
NamespaceDirectory
instance. |
Task<NSDirectory,NSDirectory> |
NSDirectory.openDir(TaskMode mode,
URL name,
int flags)
Creates a task that creates a new
NamespaceDirectory
instance. |
Task<NSEntry,Void> |
NSEntry.permissionsAllow(TaskMode mode,
String id,
int permissions,
int flags)
Creates a task that enables the specified permissions for the specified
id.
|
Task<NSDirectory,Void> |
NSDirectory.permissionsAllow(TaskMode mode,
String target,
String id,
int permissions)
Creates a task that enables the specified permissions for the specified
id.
|
Task<NSDirectory,Void> |
NSDirectory.permissionsAllow(TaskMode mode,
String target,
String id,
int permissions,
int flags)
Creates a task that enables the specified permissions for the specified
id.
|
Task<NSDirectory,Void> |
NSDirectory.permissionsAllow(TaskMode mode,
URL target,
String id,
int permissions)
Creates a task that enables the specified permissions for the specified
id.
|
Task<NSDirectory,Void> |
NSDirectory.permissionsAllow(TaskMode mode,
URL target,
String id,
int permissions,
int flags)
Creates a task that enables the specified permissions for the specified
id.
|
Task<NSEntry,Void> |
NSEntry.permissionsDeny(TaskMode mode,
String id,
int permissions,
int flags)
Creates a task that disables the specified permissions for the specified
id.
|
Task<NSDirectory,Void> |
NSDirectory.permissionsDeny(TaskMode mode,
String target,
String id,
int permissions)
Creates a task that disables the specified permissions for the specified
id.
|
Task<NSDirectory,Void> |
NSDirectory.permissionsDeny(TaskMode mode,
String target,
String id,
int permissions,
int flags)
Creates a task that disables the specified permissions for the specified
id.
|
Task<NSDirectory,Void> |
NSDirectory.permissionsDeny(TaskMode mode,
URL target,
String id,
int permissions)
Creates a task that disables the specified permissions for the specified
id.
|
Task<NSDirectory,Void> |
NSDirectory.permissionsDeny(TaskMode mode,
URL target,
String id,
int permissions,
int flags)
Creates a task that disables the specified permissions for the specified
id.
|
Task<NSEntry,URL> |
NSEntry.readLink(TaskMode mode)
Creates a task that returns the URL representing the link target.
|
Task<NSDirectory,URL> |
NSDirectory.readLink(TaskMode mode,
URL name)
Creates a task that returns the URL representing the link target.
|
Task<NSEntry,Void> |
NSEntry.remove(TaskMode mode)
Creates a task that removes this entry and closes it.
|
Task<NSEntry,Void> |
NSEntry.remove(TaskMode mode,
int flags)
Creates a task that removes this entry and closes it.
|
Task<NSDirectory,Void> |
NSDirectory.remove(TaskMode mode,
String target)
Creates a task that removes the specified entry.
|
Task<NSDirectory,Void> |
NSDirectory.remove(TaskMode mode,
String target,
int flags)
Creates a task that removes the specified entry.
|
Task<NSDirectory,Void> |
NSDirectory.remove(TaskMode mode,
URL target)
Creates a task that removes the specified entry.
|
Task<NSDirectory,Void> |
NSDirectory.remove(TaskMode mode,
URL target,
int flags)
Creates a task that removes the specified entry.
|
| Modifier and Type | Method and Description |
|---|---|
Task<T,String> |
Permissions.getGroup(TaskMode mode)
Creates a task that obtains the group id of the entity.
|
Task<T,String> |
Permissions.getOwner(TaskMode mode)
Creates a task that obtains the owner id of the entity.
|
Task<T,Void> |
Permissions.permissionsAllow(TaskMode mode,
String id,
int permissions)
Creates a task that enables the specified permissions for the specified
id.
|
Task<T,Boolean> |
Permissions.permissionsCheck(TaskMode mode,
String id,
int permissions)
Creates a task that determines if the specified permissions are enabled
for the specified id.
|
Task<T,Void> |
Permissions.permissionsDeny(TaskMode mode,
String id,
int permissions)
Creates a task that disables the specified permissions for the specified
id.
|
| Modifier and Type | Method and Description |
|---|---|
static Task<ResourceFactory,ResourceManager> |
ResourceFactory.createResourceManager(String sagaFactoryClassname,
TaskMode mode)
Creates a task that creates a job service, using the default session and
default contact string.
|
static Task<ResourceFactory,ResourceManager> |
ResourceFactory.createResourceManager(String sagaFactoryClassname,
TaskMode mode,
Session session)
Creates a task that creates a resource manager, using a default contact
string.
|
static Task<ResourceFactory,ResourceManager> |
ResourceFactory.createResourceManager(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL rm)
Creates a task that creates a resource manager.
|
static Task<ResourceFactory,ResourceManager> |
ResourceFactory.createResourceManager(String sagaFactoryClassname,
TaskMode mode,
URL rm)
Creates a task that creates a resource manager, using the default session.
|
static Task<ResourceFactory,ResourceManager> |
ResourceFactory.createResourceManager(TaskMode mode)
Creates a task that creates a resource manager, using the default session and
default contact string.
|
static Task<ResourceFactory,ResourceManager> |
ResourceFactory.createResourceManager(TaskMode mode,
Session session)
Creates a task that creates a resource manager, using a default contact
string.
|
static Task<ResourceFactory,ResourceManager> |
ResourceFactory.createResourceManager(TaskMode mode,
Session session,
URL rm)
Creates a task that creates a resource manager.
|
static Task<ResourceFactory,ResourceManager> |
ResourceFactory.createResourceManager(TaskMode mode,
URL rm)
Creates a task that creates a resource manager, using the default session.
|
protected abstract Task<ResourceFactory,ResourceManager> |
ResourceFactory.doCreateResourceManager(TaskMode mode,
Session session,
URL rm)
Creates a task that creates a resource manager.
|
| Modifier and Type | Method and Description |
|---|---|
Task<ResourceManager,Compute> |
ResourceManager.acquireCompute(TaskMode mode,
ComputeDescription description)
Creates a task that acquires compute resource matching from requirements.
|
Task<ResourceManager,Compute> |
ResourceManager.acquireCompute(TaskMode mode,
String id)
Creates a task that returns resource handle for some known compute resource.
|
Task<ResourceManager,Network> |
ResourceManager.acquireNetwork(TaskMode mode,
NetworkDescription description)
Creates a task that acquires network resource matching from requirements.
|
Task<ResourceManager,Network> |
ResourceManager.acquireNetwork(TaskMode mode,
String id)
Creates a task that returns resource handle for some known network resource.
|
Task<ResourceManager,Storage> |
ResourceManager.acquireStorage(TaskMode mode,
StorageDescription description)
Creates a task that acquires storage resource matching from requirements.
|
Task<ResourceManager,Storage> |
ResourceManager.acquireStorage(TaskMode mode,
String id)
Creates a task that returns resource handle for some known storage resource.
|
Task<ResourceManager,ResourceDescription> |
ResourceManager.getTemplate(TaskMode mode,
String id)
Creates a task that returns human readable description of template.
|
Task<ResourceManager,List<String>> |
ResourceManager.listResources(TaskMode mode,
Type type)
Creates a task that obtains the list of pilot/vm/ar (etc.) instances
that are currently known to the resource manager.
|
Task<ResourceManager,List<String>> |
ResourceManager.listTemplates(TaskMode mode,
Type type)
Creates a task that obtains the list of available templates.
|
Task<ResourceManager,Void> |
ResourceManager.releaseCompute(TaskMode mode,
String id)
Creates a task that closes compute resource, even if it is not drained.
|
Task<ResourceManager,Void> |
ResourceManager.releaseCompute(TaskMode mode,
String id,
boolean drain)
Creates a task that closes compute resource.
|
Task<ResourceManager,Void> |
ResourceManager.releaseNetwork(TaskMode mode,
String id)
Creates a task that closes network resource.
|
Task<ResourceManager,Void> |
ResourceManager.releaseStorage(TaskMode mode,
String id)
Creates a task that closes storage resource.
|
| Modifier and Type | Method and Description |
|---|---|
Task<RPC,Void> |
RPC.call(TaskMode mode,
Parameter... parameters)
Creates a task for calling the remote procedure.
|
Task<RPC,Void> |
RPC.close(TaskMode mode)
Creates a task for closing the RPC handle instance.
|
Task<RPC,Void> |
RPC.close(TaskMode mode,
float timeoutInSeconds)
Creates a task for closing the RPC handle instance.
|
static Task<RPCFactory,RPC> |
RPCFactory.createRPC(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL funcname)
Creates a task that creates a RPC handle instance.
|
static Task<RPCFactory,RPC> |
RPCFactory.createRPC(String sagaFactoryClassname,
TaskMode mode,
URL funcname)
Creates a task that creates a RPC handle instance using the default
session.
|
static Task<RPCFactory,RPC> |
RPCFactory.createRPC(TaskMode mode,
Session session,
URL funcname)
Creates a task that creates a RPC handle instance.
|
static Task<RPCFactory,RPC> |
RPCFactory.createRPC(TaskMode mode,
URL funcname)
Creates a task that creates a RPC handle instance using the default
session.
|
protected abstract Task<RPCFactory,RPC> |
RPCFactory.doCreateRPC(TaskMode mode,
Session session,
URL funcname)
Creates a task that creates a RPC handle instance.
|
| Modifier and Type | Method and Description |
|---|---|
abstract Task<StreamInputStream,Integer> |
StreamInputStream.available(TaskMode mode)
Creates a task that determines how many bytes are available from this
stream.
|
Task<StreamServer,Void> |
StreamServer.close(TaskMode mode)
Obtains a task that closes a stream server.
|
abstract Task<StreamOutputStream,Void> |
StreamOutputStream.close(TaskMode mode)
Creates a task that closes this stream.
|
abstract Task<StreamInputStream,Void> |
StreamInputStream.close(TaskMode mode)
Creates a task that closes this stream.
|
Task<Stream,Void> |
Stream.close(TaskMode mode)
Returns a task that closes an active connection.
|
Task<StreamServer,Void> |
StreamServer.close(TaskMode mode,
float timeoutInSeconds)
Obtains a task that closes a stream server.
|
Task<Stream,Void> |
Stream.close(TaskMode mode,
float timeoutInSeconds)
Returns a task that closes an active connection.
|
Task<StreamServer,Stream> |
StreamServer.connect(TaskMode mode)
Returns a task that establishes a connection to the stream server.
|
Task<Stream,Void> |
Stream.connect(TaskMode mode)
Returns a task that establishes a connection to the target defined during
the construction of the stream.
|
Task<StreamServer,Stream> |
StreamServer.connect(TaskMode mode,
float timeoutInSeconds)
Returns a task that establishes a connection to the stream server.
|
Task<Stream,Void> |
Stream.connect(TaskMode mode,
float timeoutInSeconds)
Returns a task that establishes a connection to the target defined during
the construction of the stream.
|
static Task<StreamFactory,Stream> |
StreamFactory.createStream(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name)
Creates a task that creates a Stream.
|
static Task<StreamFactory,Stream> |
StreamFactory.createStream(String sagaFactoryClassname,
TaskMode mode,
URL name)
Creates a task that creates a Stream using the default session.
|
static Task<StreamFactory,Stream> |
StreamFactory.createStream(TaskMode mode,
Session session,
URL name)
Creates a task that creates a Stream.
|
static Task<StreamFactory,Stream> |
StreamFactory.createStream(TaskMode mode,
URL name)
Creates a task that creates a Stream using the default session.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(String sagaFactoryClassname,
TaskMode mode)
Creates a task that creates a StreamServer using the default session.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(String sagaFactoryClassname,
TaskMode mode,
Session session)
Creates a task that creates a StreamServer.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name)
Creates a task that creates a StreamServer.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(String sagaFactoryClassname,
TaskMode mode,
URL name)
Creates a task that creates a StreamServer using the default session.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(TaskMode mode)
Creates a task that creates a StreamServer using the default session.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(TaskMode mode,
Session session)
Creates a task that creates a StreamServer.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(TaskMode mode,
Session session,
URL name)
Creates a task that creates a StreamServer.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(TaskMode mode,
URL name)
Creates a task that creates a StreamServer using the default session.
|
protected abstract Task<StreamFactory,Stream> |
StreamFactory.doCreateStream(TaskMode mode,
Session session,
URL name)
Creates a task that creates a Stream.
|
protected abstract Task<StreamFactory,StreamServer> |
StreamFactory.doCreateStreamServer(TaskMode mode,
Session session,
URL name)
Creates a task that creates a StreamServer.
|
abstract Task<StreamOutputStream,Void> |
StreamOutputStream.flush(TaskMode mode)
Creates a task that flushes this stream.
|
Task<Stream,Context> |
Stream.getContext(TaskMode mode)
Creates a task that obtains the remote authorization info.
|
Task<Stream,StreamInputStream> |
Stream.getInputStream(TaskMode mode)
Creates a task that obtains an OutputStream from the stream.
|
Task<Stream,StreamOutputStream> |
Stream.getOutputStream(TaskMode mode)
Creates a task that obtains an OutputStream from the stream.
|
Task<StreamServer,URL> |
StreamServer.getUrl(TaskMode mode)
Obtains a task to obtain the URL to be used to connect to this server.
|
Task<Stream,URL> |
Stream.getUrl(TaskMode mode)
Creates a task that obtains the URL that was used to create the stream.
|
abstract Task<StreamInputStream,Void> |
StreamInputStream.mark(TaskMode mode,
int readlimit)
Creates a task that marks the current position in this stream.
|
abstract Task<StreamInputStream,Boolean> |
StreamInputStream.markSupported(TaskMode mode)
Creates a task that determines if
InputStream.mark(int)
is supported. |
abstract Task<StreamInputStream,Integer> |
StreamInputStream.read(TaskMode mode)
Creates a task that reads a byte from this stream.
|
Task<Stream,Integer> |
Stream.read(TaskMode mode,
Buffer buffer)
Creates a task that reads a raw buffer from the stream.
|
Task<Stream,Integer> |
Stream.read(TaskMode mode,
Buffer buffer,
int len)
Creates a task that reads a raw buffer from the stream.
|
Task<StreamInputStream,Integer> |
StreamInputStream.read(TaskMode mode,
byte[] buf)
Creates a task that reads a buffer from this stream.
|
abstract Task<StreamInputStream,Integer> |
StreamInputStream.read(TaskMode mode,
byte[] buf,
int off,
int len)
Creates task that reads (part of) a buffer from this stream.
|
abstract Task<StreamInputStream,Void> |
StreamInputStream.reset(TaskMode mode)
Creates a task that resets the position to the position last marked.
|
Task<StreamServer,Stream> |
StreamServer.serve(TaskMode mode)
Obtains a task that waits for incoming client connections (like an accept
of a serversocket).
|
Task<StreamServer,Stream> |
StreamServer.serve(TaskMode mode,
float timeoutInSeconds)
Obtains a task that waits for incoming client connections (like an accept
of a serversocket).
|
abstract Task<StreamInputStream,Long> |
StreamInputStream.skip(TaskMode mode,
long n)
Creates a task that skips the specified number of bytes from this stream.
|
Task<Stream,Integer> |
Stream.waitFor(TaskMode mode,
int what)
Returns a task that checks if the stream is ready for I/O, or if it has
entered the ERROR state.
|
Task<Stream,Integer> |
Stream.waitFor(TaskMode mode,
int what,
float timeoutInSeconds)
Returns a task that checks if the stream is ready for I/O, or if it has
entered the ERROR state.
|
Task<Stream,Integer> |
Stream.write(TaskMode mode,
Buffer buffer)
Creates a task that writes a raw buffer to the stream.
|
Task<Stream,Integer> |
Stream.write(TaskMode mode,
Buffer buffer,
int len)
Creates a task that writes a raw buffer to the stream.
|
Task<StreamOutputStream,Void> |
StreamOutputStream.write(TaskMode mode,
byte[] buf)
Creates a task that writes a buffer to this stream.
|
abstract Task<StreamOutputStream,Void> |
StreamOutputStream.write(TaskMode mode,
byte[] buf,
int off,
int len)
Creates a task that writes (part of) a buffer to this stream.
|
abstract Task<StreamOutputStream,Void> |
StreamOutputStream.write(TaskMode mode,
int b)
Creates a task that writes a byte to this stream.
|
| Modifier and Type | Method and Description |
|---|---|
static TaskMode |
TaskMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static TaskMode[] |
TaskMode.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Copyright © 2016 Open Grid Forum. All rights reserved.