Mercurial > hg > blitz_condensed
view src/org/dancres/blitz/notify/SendTask.java @ 34:6f68e94c1fb8 default tip
Add CondensedStats monitoring utility, equivalent to vmstat
author | Dominic Cleal <dominic-cleal@cdo2.com> |
---|---|
date | Thu, 05 Aug 2010 11:07:25 +0100 |
parents | 3dc0c5604566 |
children |
line wrap: on
line source
package org.dancres.blitz.notify; import java.io.IOException; import java.util.logging.*; import net.jini.space.JavaSpace; import org.dancres.blitz.task.Task; import org.dancres.blitz.disk.DiskTxn; import org.dancres.blitz.mangler.MangledEntry; /** <p> RemoteEvent dispatch occurs here. The generator is locked during generation of the RemoteEvent and any logging that may be required. </p> <p> If we fail to deliver the event to the client we take some special action. First we "taint" the generator to prevent further events being processed/dispatched, then we schedule a cleanup task to remove the registration associated with the generator. </p> */ class SendTask implements Task { private EventGenerator theGenerator; private JavaSpace theSource; private DispatchTask theTask; SendTask(JavaSpace aSource, DispatchTask aTask, EventGenerator aGenerator) { theSource = aSource; theGenerator = aGenerator; theTask = aTask; } public void run() { theGenerator.ping(theTask.getEvent(), theSource); theTask.dispatched(); } }