ostore.network
Class Network
java.lang.Object
|
+--ostore.network.Network
- All Implemented Interfaces:
- EventHandlerIF, ProfilableIF
- public class Network
- extends Object
- implements EventHandlerIF, ProfilableIF
A stage to tie the OceanStore dispatch model to Sandstorms asyncronous
networking functionality. To send a message on the network, inherit it
from NetworkMessage, set inbound = false, and dispatch it. This stage
will catch the event, open a connection (if one is not open already),
and send it. To receive messages, just listen for the correct type
conditioned on inbound == true.
- Version:
- $Id: Network.java,v 1.38 2002/04/03 02:50:13 srhea Exp $
- Author:
- Sean C. Rhea
Field Summary |
static boolean |
DEBUG
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DEBUG
public static final boolean DEBUG
Network
public Network()
handle_sink_flushed_event
public void handle_sink_flushed_event(SinkFlushedEvent flush)
handleEvent
public void handleEvent(QueueElementIF item)
throws EventHandlerException
- Specified by:
handleEvent
in interface EventHandlerIF
handleEvents
public void handleEvents(QueueElementIF[] items)
throws EventHandlerException
- Specified by:
handleEvents
in interface EventHandlerIF
init
public void init(ConfigDataIF config)
throws Exception
- Specified by:
init
in interface EventHandlerIF
destroy
public void destroy()
throws Exception
- Specified by:
destroy
in interface EventHandlerIF
profileSize
public int profileSize()
- Specified by:
profileSize
in interface ProfilableIF
process_identity_message
protected NodeId process_identity_message(IdentityMessage ident)