jp.ac.tokushima_u.db.rmi

Class RMGrid<RM extends RemoteMachine>

java.lang.Object

jp.ac.tokushima_u.db.rmi.RMGrid<RM>

Direct Known Subclasses:

UTLFGrid

public class RMGrid<RM extends RemoteMachine>
extends Object

Remote Machine Grid Schedular. $Id: RMGrid.java,v 1.38 2025/03/14 11:01:57 alex Exp $

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	RMGrid.RMC Context of RemoteMachine
static class	RMGrid.RMInitializer
(package private) static class	RMGrid.RMTask1<R,U>
static interface	RMGrid.RMTask1Spi<R,U>
(package private) static class	RMGrid.RMTask2<R,U,V>
static interface	RMGrid.RMTask2Spi<R,U,V>
(package private) static class	RMGrid.RMTask3<R,U,V,W>
static interface	RMGrid.RMTask3Spi<R,U,V,W>

Field Summary

Fields

Modifier and Type	Field and Description
static String	DefaultGridListURL

Constructor Summary

Constructors

Constructor and Description
RMGrid(boolean sh)
RMGrid(Collection<String> servers, boolean ssl, String name, RMGrid.RMInitializer init)

Method Summary

Modifier and Type	Method and Description
void	addMachine(String server, boolean ssl, RMI.RemoteMachineSpec spec, double weight, double bias, RMGrid.RMInitializer init)
void	addMachine(String server, boolean ssl, String name, String implClass, String implCodebase, String[] args, double weight, double bias, RMGrid.RMInitializer init)
void	addMachines(Collection<String> servers, boolean ssl, RMI.RemoteMachineSpec spec, RMGrid.RMInitializer init)
void	addMachines(Collection<String> servers, boolean ssl, String name, String implClass, String implCodebase, String[] args, RMGrid.RMInitializer init)
void	connectMachine(String server, boolean ssl, String name, double weight, double bias, RMGrid.RMInitializer init)
void	connectMachines(Collection<String> servers, boolean ssl, String name, RMGrid.RMInitializer init)
static RMGrid<RemoteMachine>	createRMGrid(Collection<String> servers, boolean ssl, String name, String implClass, String implCodebase, String[] args, RMGrid.RMInitializer init) Create RMGrid for RemoteMachine interface.
static RMGrid<RemoteMachine>	createRMGrid(Collection<String> servers, String name, String implClass, String implCodebase, String[] args, RMGrid.RMInitializer init) Create RMGrid for RemoteMachine interface.
static RMGrid<RemoteMachine>	createSharableRMGrid(Collection<String> servers, boolean ssl, String name, String implClass, String implCodebase, String[] args, RMGrid.RMInitializer init) Create RMGrid for RemoteMachine interface.
static RMGrid<RemoteMachine>	createSharableRMGrid(Collection<String> servers, String name, String implClass, String implCodebase, String[] args, RMGrid.RMInitializer init) Create RMGrid for RemoteMachine interface.
void	disconnect() Disconnect remoteMachines.
<R,U> RMResult<R>	executeTask(RMGrid.RMTask1Spi<R,U> spi, U arg1) Execute RMTask (1 argument).
<R,U,V> RMResult<R>	executeTask(RMGrid.RMTask2Spi<R,U,V> spi, U arg1, V arg2) Execute RMTask (2 arguments).
<R,U,V,W> RMResult<R>	executeTask(RMGrid.RMTask3Spi<R,U,V,W> spi, U arg1, V arg2, W arg3) Execute RMTask (3 arguments).
<T> RMResult<T>	executeTask(RMTask<T> task) Execute RMTask.
boolean	executeTaskAll(RMTask<Boolean> task) Execute RMTask on all remote machines.
protected RMGrid.RMC	getRemoteMachineContext()
boolean	isEmpty()
int	preferredRetries()
void	purge() Purge sharable remoteMachines from registry.
void	showStatistics(PrintStream out) Show statistics of each remoteMachine registered in this grid.
void	shuffle()
int	size()
void	standby() Standby sharable remoteMachines.
void	terminate() Terminate all remoteMachines registered in this grid.
void	vacuum() Clean up distributed objects.
void	waitForReady()

Methods inherited from class java.lang.Object

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

Field Detail

DefaultGridListURL

public static final String DefaultGridListURL

See Also:

Constant Field Values

Constructor Detail

RMGrid

public RMGrid(boolean sh)

RMGrid

public RMGrid(Collection<String> servers,
              boolean ssl,
              String name,
              RMGrid.RMInitializer init)

Method Detail

addMachine

public void addMachine(String server,
                       boolean ssl,
                       RMI.RemoteMachineSpec spec,
                       double weight,
                       double bias,
                       RMGrid.RMInitializer init)

addMachine

public void addMachine(String server,
                       boolean ssl,
                       String name,
                       String implClass,
                       String implCodebase,
                       String[] args,
                       double weight,
                       double bias,
                       RMGrid.RMInitializer init)

addMachines

public void addMachines(Collection<String> servers,
                        boolean ssl,
                        RMI.RemoteMachineSpec spec,
                        RMGrid.RMInitializer init)

addMachines

public void addMachines(Collection<String> servers,
                        boolean ssl,
                        String name,
                        String implClass,
                        String implCodebase,
                        String[] args,
                        RMGrid.RMInitializer init)

connectMachine

public void connectMachine(String server,
                           boolean ssl,
                           String name,
                           double weight,
                           double bias,
                           RMGrid.RMInitializer init)

connectMachines

public void connectMachines(Collection<String> servers,
                            boolean ssl,
                            String name,
                            RMGrid.RMInitializer init)

waitForReady

public void waitForReady()

size

public int size()

isEmpty

public boolean isEmpty()

shuffle

public void shuffle()

getRemoteMachineContext

protected RMGrid.RMC getRemoteMachineContext()

preferredRetries

public int preferredRetries()

executeTask

public <T> RMResult<T> executeTask(RMTask<T> task)
                            throws RemoteException

Execute RMTask.

Type Parameters:

T - class of result

Parameters:

task - Task

Returns:

result

Throws:

RemoteException - Remote Exception

executeTask

public <R,U> RMResult<R> executeTask(RMGrid.RMTask1Spi<R,U> spi,
                                     U arg1)
                              throws RemoteException

Execute RMTask (1 argument).

Type Parameters:

R - class of result

U - class of 1st argument

Parameters:

spi - Task

arg1 - 1st argument

Returns:

result

Throws:

RemoteException - Remote Exception

executeTask

public <R,U,V> RMResult<R> executeTask(RMGrid.RMTask2Spi<R,U,V> spi,
                                       U arg1,
                                       V arg2)
                                throws RemoteException

Execute RMTask (2 arguments).

Type Parameters:

R - class of result

U - class of 1st argument

V - class of 2nd argument

Parameters:

spi - Task

arg1 - 1st argument

arg2 - 2nd argument

Returns:

result

Throws:

RemoteException - Remote Exception

executeTask

public <R,U,V,W> RMResult<R> executeTask(RMGrid.RMTask3Spi<R,U,V,W> spi,
                                         U arg1,
                                         V arg2,
                                         W arg3)
                                  throws RemoteException

Execute RMTask (3 arguments).

Type Parameters:

R - class of result

U - class of 1st argument

V - class of 2nd argument

W - class of 3rd argument

Parameters:

spi - Task

arg1 - 1st argument

arg2 - 2nd argument

arg3 - 3rd argument

Returns:

result

Throws:

RemoteException - Remote Exception

executeTaskAll

public boolean executeTaskAll(RMTask<Boolean> task)
                       throws RemoteException

Execute RMTask on all remote machines.

Parameters:

task - Task

Returns:

result

Throws:

RemoteException - Remote Exception

disconnect

public void disconnect()
                throws RemoteException,
                       NotBoundException

Disconnect remoteMachines. RemoteMachines will not be unbind and terminated.

Throws:

RemoteException - Remote Exception

NotBoundException - Not Bound Exception

purge

public void purge()
           throws RemoteException,
                  NotBoundException

Purge sharable remoteMachines from registry. Unbind remoteMachines from registry, and these will not able to be used. RemoteMachines will not terminate at this time.

Throws:

RemoteException - Remote Exception

NotBoundException - Not Bound Exception

standby

public void standby()
             throws RemoteException,
                    NotBoundException

Standby sharable remoteMachines.

Throws:

RemoteException - Remote Exception

NotBoundException - Not Bound Exception

vacuum

public void vacuum()

Clean up distributed objects.

showStatistics

public void showStatistics(PrintStream out)
                    throws RemoteException,
                           NotBoundException

Show statistics of each remoteMachine registered in this grid. Show statistics of remoteMachine usage.

Parameters:

out - output.

Throws:

RemoteException - Remote Exception

NotBoundException - Not Bound Exception

terminate

public void terminate()
               throws RemoteException,
                      NotBoundException

Terminate all remoteMachines registered in this grid. Terminate all remoteMachines even if these remoteMachines being used by other client.

Throws:

RemoteException - Remote Exception

NotBoundException - Not Bound Exception

createRMGrid

public static RMGrid<RemoteMachine> createRMGrid(Collection<String> servers,
                                                 boolean ssl,
                                                 String name,
                                                 String implClass,
                                                 String implCodebase,
                                                 String[] args,
                                                 RMGrid.RMInitializer init)
                                          throws RemoteException,
                                                 NotBoundException

Create RMGrid for RemoteMachine interface.

Parameters:

servers - server list

ssl - SSL

name - machine name

implClass - class name

implCodebase - code base

args - arguments

init - initializer

Returns:

grid

Throws:

RemoteException - Remote Exception

NotBoundException - Not Bound Exception

createRMGrid

public static RMGrid<RemoteMachine> createRMGrid(Collection<String> servers,
                                                 String name,
                                                 String implClass,
                                                 String implCodebase,
                                                 String[] args,
                                                 RMGrid.RMInitializer init)
                                          throws RemoteException,
                                                 NotBoundException

Create RMGrid for RemoteMachine interface.

Parameters:

servers - server list

name - machine name

implClass - class name

implCodebase - code base

args - arguments

init - initializer

Returns:

grid

Throws:

RemoteException - Remote Exception

NotBoundException - Not Bound Exception

createSharableRMGrid

public static RMGrid<RemoteMachine> createSharableRMGrid(Collection<String> servers,
                                                         boolean ssl,
                                                         String name,
                                                         String implClass,
                                                         String implCodebase,
                                                         String[] args,
                                                         RMGrid.RMInitializer init)
                                                  throws RemoteException,
                                                         NotBoundException

Create RMGrid for RemoteMachine interface.

Parameters:

servers - server list

ssl - SSL

name - machine name

implClass - class name

implCodebase - code base

args - arguments

init - initializer

Returns:

grid

Throws:

RemoteException - Remote Exception

NotBoundException - Not Bound Exception

createSharableRMGrid

public static RMGrid<RemoteMachine> createSharableRMGrid(Collection<String> servers,
                                                         String name,
                                                         String implClass,
                                                         String implCodebase,
                                                         String[] args,
                                                         RMGrid.RMInitializer init)
                                                  throws RemoteException,
                                                         NotBoundException

Create RMGrid for RemoteMachine interface.

Parameters:

servers - server list

name - machine name

implClass - class name

implCodebase - code base

args - arguments

init - initializer

Returns:

grid

Throws:

RemoteException - Remote Exception

NotBoundException - Not Bound Exception