uka.karmi.rmi.server
Class ReplicatedServerRef.CollectiveOperation

java.lang.Object
  uka.karmi.rmi.server.ReplicatedServerRef.CollectiveOperation

Direct Known Subclasses:

ReplicatedServerRef.CollectiveUpdate

Enclosing class:

ReplicatedServerRef

public abstract static class ReplicatedServerRef.CollectiveOperation

extends java.lang.Object

Constructor Summary

ReplicatedServerRef.CollectiveOperation()

Method Summary

protected abstract void	closeReceiveFrom(PatchReader reader, int rank)
protected abstract void	closeSendToAll()
protected abstract PatchReader	openReceiveFrom(int rank, Connection c)
protected abstract void	openSendToAll(Connection[] c)
void	receiveFrom(int rank, Connection c)
void	sendToAll(Connection[] c)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicatedServerRef.CollectiveOperation

public ReplicatedServerRef.CollectiveOperation()

Method Detail

receiveFrom

public void receiveFrom(int rank,
                        Connection c)
                 throws java.io.IOException,
                        java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

sendToAll

public void sendToAll(Connection[] c)
               throws java.io.IOException,
                      java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

openReceiveFrom

protected abstract PatchReader openReceiveFrom(int rank,
                                               Connection c)
                                        throws java.io.IOException,
                                               java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

closeReceiveFrom

protected abstract void closeReceiveFrom(PatchReader reader,
                                         int rank)
                                  throws java.io.IOException,
                                         java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

openSendToAll

protected abstract void openSendToAll(Connection[] c)
                               throws java.io.IOException,
                                      java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

closeSendToAll

protected abstract void closeSendToAll()
                                throws java.io.IOException,
                                       java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException