All Packages Class Hierarchy This Package Previous Next Index
Class JavaGroups.JavaStack.Protocols.RpcGMS
java.lang.Object
|
+----JavaGroups.JavaStack.Protocol
|
+----JavaGroups.JavaStack.MessageProtocol
|
+----JavaGroups.JavaStack.RpcProtocol
|
+----JavaGroups.JavaStack.Protocols.RpcGMS
- public class RpcGMS
- extends RpcProtocol
- implements Runnable
-
group_addr
-
-
impl_mutex
-
-
initial_mbrs_timeout
-
-
join_retry_timeout
-
-
join_timeout
-
-
leave_timeout
-
-
local_addr
-
-
ltime
-
-
members
-
-
props
-
-
trace
-
-
view_id
-
-
view_mutex
-
-
RpcGMS()
-
-
CastView(View)
-
-
CastViewChange(View)
- Run view update protocol to install a new view in all members (this involves casting the new
view to all members).
-
GetName()
-
-
GetNextView(Vector, Vector)
- Computes the next view.
-
HandleDownEvent(Event)
- Callback.
-
HandleJoin(Address)
-
-
HandleLeave(Address)
-
-
HandleMerge(Vector, Vector, long)
-
-
HandleSuspect(Address)
-
-
HandleUpEvent(Event)
- Callback.
-
HandleViewChange(ViewId, Vector)
-
-
InstallView(ViewId, Vector)
- Assigns the new ltime.
-
Join(Address)
-
-
Leave(Address)
-
-
MakeView(Vector)
-
-
MakeView(Vector, ViewId)
-
-
Merge(Vector)
-
-
run()
-
-
Send(Message)
- Add header and pass down.
-
SetImpl(RpcGmsImpl)
-
-
SetProperties(Properties)
- Setup the Protocol instance acording to the configuration string
-
Suspect(Address)
-
props
public Properties props
local_addr
public Address local_addr
group_addr
public String group_addr
members
public Membership members
view_id
public ViewId view_id
ltime
public long ltime
initial_mbrs_timeout
public long initial_mbrs_timeout
join_timeout
public long join_timeout
join_retry_timeout
public long join_retry_timeout
leave_timeout
public long leave_timeout
trace
public boolean trace
impl_mutex
public Integer impl_mutex
view_mutex
public Integer view_mutex
RpcGMS
public RpcGMS()
GetName
public String GetName()
- Overrides:
- GetName in class RpcProtocol
SetImpl
public void SetImpl(RpcGmsImpl new_impl)
Send
public void Send(Message msg) throws Exception
- Add header and pass down.
- Overrides:
- Send in class MessageProtocol
GetNextView
public View GetNextView(Vector new_mbrs,
Vector suspected_mbrs)
- Computes the next view. Returns a copy that has
suspected_mbrs
removed
and new_mbrs
added.
CastViewChange
public synchronized void CastViewChange(View v)
- Run view update protocol to install a new view in all members (this involves casting the new
view to all members).
InstallView
public void InstallView(ViewId new_view,
Vector mbrs)
- Assigns the new ltime. Installs view and view_id. Changes role to coordinator if necessary.
Sends VIEW_CHANGE event up and down the stack.
MakeView
public View MakeView(Vector mbrs)
MakeView
public View MakeView(Vector mbrs,
ViewId vid)
Join
public void Join(Address mbr)
Leave
public void Leave(Address mbr)
Suspect
public void Suspect(Address mbr)
Merge
public void Merge(Vector new_mbrs)
HandleJoin
public JoinRsp HandleJoin(Address mbr)
HandleLeave
public boolean HandleLeave(Address mbr)
HandleViewChange
public void HandleViewChange(ViewId new_view,
Vector mbrs)
HandleMerge
public void HandleMerge(Vector new_mbrs,
Vector suspects,
long other_ltime)
HandleSuspect
public void HandleSuspect(Address mbr)
CastView
public void CastView(View v)
HandleUpEvent
public boolean HandleUpEvent(Event evt)
- Callback. Called by superclass when event may be handled.
Do not use PassUp
in this method as the event is passed up
by default by the superclass after this method returns !
- Returns:
- boolean Defaults to true. If false, event will not be passed up the stack.
- Overrides:
- HandleUpEvent in class RpcProtocol
HandleDownEvent
public boolean HandleDownEvent(Event evt)
- Callback. Called by superclass when event may be handled.
Do not use PassDown
in this method as the event is passed down
by default by the superclass after this method returns !
- Returns:
- boolean Defaults to true. If false, event will not be passed down the stack.
- Overrides:
- HandleDownEvent in class RpcProtocol
SetProperties
public boolean SetProperties(Properties props)
- Setup the Protocol instance acording to the configuration string
- Overrides:
- SetProperties in class Protocol
run
public void run()
All Packages Class Hierarchy This Package Previous Next Index