com.sun.sgs.impl.service.channel
Class ChannelImpl.ReassignCoordinatorsTask

java.lang.Object
  com.sun.sgs.impl.service.channel.ChannelImpl.ReassignCoordinatorsTask

All Implemented Interfaces:

Task, Serializable

Enclosing class:

ChannelImpl

static class ChannelImpl.ReassignCoordinatorsTask
extends Object
implements Task, Serializable

A persistent task to reassign channel coordinators on a failed node to another node. In a single task, only one failed coordinator is reassigned. A task for one coordinator schedules a task for the next reassignment, if there are coordinators on the failed node left to be reassigned.

Constructor Summary

ChannelImpl.ReassignCoordinatorsTask(long failedNodeId)
Constructs an instance of this class with the specified failedNodeId.

Method Summary

void	run() Reassigns the next coordinator for the failedNodeId to another node with member sessions (or the local node if there are no member sessions), and then reschedules this task to reassign the next coordinator.

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelImpl.ReassignCoordinatorsTask

ChannelImpl.ReassignCoordinatorsTask(long failedNodeId)

Constructs an instance of this class with the specified failedNodeId.

Method Detail

run

public void run()

Reassigns the next coordinator for the failedNodeId to another node with member sessions (or the local node if there are no member sessions), and then reschedules this task to reassign the next coordinator. If there are no more coordinators for the specified failedNodeId, then no action is taken.

Specified by:

run in interface Task