org.mmbase.module.core
Class MMBaseMultiCast

java.lang.Object
  extended byorg.mmbase.module.core.MMBaseMultiCast
All Implemented Interfaces:
MMBaseChangeInterface, java.lang.Runnable

public class MMBaseMultiCast
extends java.lang.Object
implements MMBaseChangeInterface, java.lang.Runnable

Builds a MultiCast Thread to receive and send changes from other MMBase Servers.

Version:
$Id: MMBaseMultiCast.java,v 1.16.2.2 2004/07/16 11:23:35 pierre Exp $
Author:
Daniel Ockeloen, Rico Jansen
Warning: No Java Documentation Available.

Field Summary
static int dpsize
           
 int incount
           
static int mport
          Port for sending datapackets send by Multicast
static int mTTL
          Time To Live for datapackets send by Multicast
static java.lang.String multicastaddress
           
 int outcount
           
 int spawncount
           
 
Constructor Summary
MMBaseMultiCast(MMBase parent)
           
 
Method Summary
 boolean changedNode(int nodenr, java.lang.String tableName, java.lang.String type)
           
 void checkWaitingNodes(java.lang.String snumber)
           
 boolean commitXML(java.lang.String machine, java.lang.String vnr, java.lang.String id, java.lang.String tb, java.lang.String ctype, java.lang.String xml)
           
 void doWork()
          admin probe, try's to make a call to all the maintainance calls.
 boolean handleMsg(java.lang.String machine, java.lang.String vnr, java.lang.String id, java.lang.String tb, java.lang.String ctype)
           
 void init()
           
 void run()
          admin probe, try's to make a call to all the maintainance calls.
 void start()
          Starts the admin Thread.
 void stop()
          Stops the admin Thread.
 boolean waitUntilNodeChanged(MMObjectNode node)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

multicastaddress

public static java.lang.String multicastaddress
Warning: No Java Documentation Available.

dpsize

public static int dpsize
Warning: No Java Documentation Available.

mport

public static int mport
Port for sending datapackets send by Multicast


mTTL

public static int mTTL
Time To Live for datapackets send by Multicast


incount

public int incount
Warning: Scope will be changed to:
private
Warning: No Java Documentation Available.

outcount

public int outcount
Warning: Scope will be changed to:
private
Warning: No Java Documentation Available.

spawncount

public int spawncount
Warning: Scope will be changed to:
private
Warning: No Java Documentation Available.
Constructor Detail

MMBaseMultiCast

public MMBaseMultiCast(MMBase parent)
Warning: No Java Documentation Available.
Method Detail

init

public void init()
Warning: No Java Documentation Available.

start

public void start()
Starts the admin Thread.


stop

public void stop()
Stops the admin Thread.


run

public void run()
admin probe, try's to make a call to all the maintainance calls.

Specified by:
run in interface java.lang.Runnable

doWork

public void doWork()
admin probe, try's to make a call to all the maintainance calls.

To Do:
determine what encoding to use on receiving packages

handleMsg

public boolean handleMsg(java.lang.String machine,
                         java.lang.String vnr,
                         java.lang.String id,
                         java.lang.String tb,
                         java.lang.String ctype)
Specified by:
handleMsg in interface MMBaseChangeInterface
Warning: No Java Documentation Available.

changedNode

public boolean changedNode(int nodenr,
                           java.lang.String tableName,
                           java.lang.String type)
Specified by:
changedNode in interface MMBaseChangeInterface
Warning: No Java Documentation Available.

waitUntilNodeChanged

public boolean waitUntilNodeChanged(MMObjectNode node)
Specified by:
waitUntilNodeChanged in interface MMBaseChangeInterface
Warning: No Java Documentation Available.

checkWaitingNodes

public void checkWaitingNodes(java.lang.String snumber)
Specified by:
checkWaitingNodes in interface MMBaseChangeInterface
Warning: No Java Documentation Available.

commitXML

public boolean commitXML(java.lang.String machine,
                         java.lang.String vnr,
                         java.lang.String id,
                         java.lang.String tb,
                         java.lang.String ctype,
                         java.lang.String xml)
Specified by:
commitXML in interface MMBaseChangeInterface
Warning: No Java Documentation Available.


MMBase build 1.7.1.20041002