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

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

All Implemented Interfaces:

Task, Serializable

Enclosing class:

ChannelImpl

static class ChannelImpl.RemoveFailedNodeFromLocalChannelsTask
extends Object
implements Task, Serializable

A persistent task to remove a failed node, from locally coordinated channels. This task handles a single locally-coordinated channel, and then schedules another task to handle the next one.

Constructor Summary

ChannelImpl.RemoveFailedNodeFromLocalChannelsTask(long localNodeId, long failedNodeId)
Constructs an instance with the specified localNodeId and failedNodeId.

Method Summary

void	run() Gets the next locally-coordinated channel, removes the failed node from that channel, and reschedules this task to handle the next locally-coordinated channel.

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelImpl.RemoveFailedNodeFromLocalChannelsTask

ChannelImpl.RemoveFailedNodeFromLocalChannelsTask(long localNodeId,
                                                  long failedNodeId)

Constructs an instance with the specified localNodeId and failedNodeId.

Method Detail

run

public void run()

Gets the next locally-coordinated channel, removes the failed node from that channel, and reschedules this task to handle the next locally-coordinated channel. If there are no more locally-coordinated channels, then this task takes no action.

Specified by:

run in interface Task