org.javagroups.ensemble
Class Hot_Ensemble

java.lang.Object
  extended byorg.javagroups.ensemble.Hot_Ensemble
All Implemented Interfaces:
java.lang.Runnable

public class Hot_Ensemble
extends java.lang.Object
implements java.lang.Runnable


Field Summary
 int HOT_ENS_MSG_SEND_CURRENT_VIEW
           
 int HOT_ENS_MSG_SEND_NEXT_VIEW
           
 int HOT_ENS_MSG_SEND_UNSPECIFIED_VIEW
           
 
Constructor Summary
Hot_Ensemble()
          Constructs a Hot_Ensemble object starting the Ensemble Outboard process on a random port between 5000 and 8000
Hot_Ensemble(int port)
          Constructs a Hot_Ensemble object starting the Ensemble Outboard process on the specified port.
 
Method Summary
 Hot_Error cast(Hot_GroupContext gc, Hot_Message orig_msg, int[] send_view)
          Broadcast a Hot_Message to the group specified in the Hot_GroupContext
 Hot_Error changeProperties(Hot_GroupContext gc, java.lang.String properties)
          Change the properties of the group specified by the Hot_GroupContext to the properties specified by the String
 Hot_Error changeProtocol(Hot_GroupContext gc, java.lang.String protocol)
          Change the protocol used by the group specified by the Hot_GroupContext to the protocol specified by the String
 void destroyOutboard()
          Destroys the associated outboard process.
 Hot_Error join(Hot_JoinOps jops, Hot_GroupContext[] gctx)
          Join the Ensemble group specified in the Hot_JoinOps structure
 Hot_Error leave(Hot_GroupContext gc)
          Leave the Ensemble group specified in the Hot_GroupContext
static void panic(java.lang.String s)
          Halts the application with the error specified by the String
 Hot_Error requestNewView(Hot_GroupContext gc)
          Request a new view in the group specified by the Hot_GroupContext
 void run()
          Mainloop of the process
 Hot_Error send(Hot_GroupContext gc, Hot_Endpoint dest, Hot_Message orig_msg, int[] send_view)
          Send a Hot_Message to member specified by the Hot_Endpoint in the group specified by the Hot_GroupContext
 void setDebug(boolean b)
          Set whether or not to display lots of debug information.
 void stopEnsThread()
           
 Hot_Error suspect(Hot_GroupContext gc, Hot_Endpoint[] suspects)
          NOT SUPPORTED CURRENTLY IN THE ML
static void trace(java.lang.String s)
          Prints (or does not print) the specified string to standard error based upon the debug flag
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

HOT_ENS_MSG_SEND_UNSPECIFIED_VIEW

public final int HOT_ENS_MSG_SEND_UNSPECIFIED_VIEW
See Also:
Constant Field Values

HOT_ENS_MSG_SEND_NEXT_VIEW

public final int HOT_ENS_MSG_SEND_NEXT_VIEW
See Also:
Constant Field Values

HOT_ENS_MSG_SEND_CURRENT_VIEW

public final int HOT_ENS_MSG_SEND_CURRENT_VIEW
See Also:
Constant Field Values
Constructor Detail

Hot_Ensemble

public Hot_Ensemble()
Constructs a Hot_Ensemble object starting the Ensemble Outboard process on a random port between 5000 and 8000


Hot_Ensemble

public Hot_Ensemble(int port)
Constructs a Hot_Ensemble object starting the Ensemble Outboard process on the specified port. If you use this version of the constructor, you are expected to make sure the port is not already in use. You can check for successful startup by invoking isOutboardStarted();

Method Detail

destroyOutboard

public void destroyOutboard()
Destroys the associated outboard process. All instances of Hot_Ensemble (in an instance of the VM) use the same outboard process (currently). So, if you destroy the outboard process for one instance, it gets destroyed for all instances. A future version of Ensemble/Java will change this restriction.


stopEnsThread

public void stopEnsThread()

setDebug

public void setDebug(boolean b)
Set whether or not to display lots of debug information. Default: false


join

public Hot_Error join(Hot_JoinOps jops,
                      Hot_GroupContext[] gctx)
Join the Ensemble group specified in the Hot_JoinOps structure


leave

public Hot_Error leave(Hot_GroupContext gc)
Leave the Ensemble group specified in the Hot_GroupContext


cast

public Hot_Error cast(Hot_GroupContext gc,
                      Hot_Message orig_msg,
                      int[] send_view)
Broadcast a Hot_Message to the group specified in the Hot_GroupContext


send

public Hot_Error send(Hot_GroupContext gc,
                      Hot_Endpoint dest,
                      Hot_Message orig_msg,
                      int[] send_view)
Send a Hot_Message to member specified by the Hot_Endpoint in the group specified by the Hot_GroupContext


suspect

public Hot_Error suspect(Hot_GroupContext gc,
                         Hot_Endpoint[] suspects)
NOT SUPPORTED CURRENTLY IN THE ML


changeProtocol

public Hot_Error changeProtocol(Hot_GroupContext gc,
                                java.lang.String protocol)
Change the protocol used by the group specified by the Hot_GroupContext to the protocol specified by the String


changeProperties

public Hot_Error changeProperties(Hot_GroupContext gc,
                                  java.lang.String properties)
Change the properties of the group specified by the Hot_GroupContext to the properties specified by the String


requestNewView

public Hot_Error requestNewView(Hot_GroupContext gc)
Request a new view in the group specified by the Hot_GroupContext


run

public void run()
Mainloop of the process

Specified by:
run in interface java.lang.Runnable

panic

public static void panic(java.lang.String s)
Halts the application with the error specified by the String


trace

public static void trace(java.lang.String s)
Prints (or does not print) the specified string to standard error based upon the debug flag



Copyright © 2001,2002 www.javagroups.com . All Rights Reserved.