galileo.dht

Class StorageNode

java.lang.Object

galileo.dht.StorageNode

public class StorageNode
extends java.lang.Object

Primary communication component in the Galileo DHT. StorageNodes service client requests and communication from other StorageNodes to disseminate state information throughout the DHT.

Author:

malensek

Constructor Summary

Constructors

Constructor and Description
StorageNode()

Method Summary

Modifier and Type	Method and Description
void	handleQuery(QueryEvent query, galileo.event.EventContext context) Handles an internal Query request (from another StorageNode)
void	handleQueryRequest(QueryRequest request, galileo.event.EventContext context) Handles a query request from a client.
void	handleQueryResponse(QueryResponse response, galileo.event.EventContext context)
void	handleStorage(StorageEvent store, galileo.event.EventContext context)
void	handleStorageRequest(StorageRequest request, galileo.event.EventContext context) Handles a storage request from a client.
static void	main(java.lang.String[] args) Executable entrypoint for a Galileo DHT Storage Node
void	start() Begins Server execution.

Methods inherited from class java.lang.Object

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

Constructor Detail

StorageNode

public StorageNode()

Method Detail

start

public void start()
           throws java.lang.Exception

Begins Server execution. This method attempts to fail fast to provide immediate feedback to wrapper scripts or other user interface tools. Only once all the prerequisite components are initialized and in a sane state will the StorageNode begin accepting connections.

Throws:

java.lang.Exception

handleStorageRequest

public void handleStorageRequest(StorageRequest request,
                                 galileo.event.EventContext context)
                          throws HashException,
                                 java.io.IOException,
                                 PartitionException

Handles a storage request from a client. This involves determining where the data belongs via a Partitioner implementation and then forwarding the data on to its destination.

Throws:

HashException

java.io.IOException

PartitionException

handleStorage

public void handleStorage(StorageEvent store,
                          galileo.event.EventContext context)
                   throws FileSystemException,
                          java.io.IOException

Throws:

FileSystemException

java.io.IOException

handleQueryRequest

public void handleQueryRequest(QueryRequest request,
                               galileo.event.EventContext context)
                        throws java.io.IOException

Handles a query request from a client. Query requests result in a number of subqueries being performed across the Galileo network.

Throws:

java.io.IOException

handleQuery

public void handleQuery(QueryEvent query,
                        galileo.event.EventContext context)
                 throws java.io.IOException

Handles an internal Query request (from another StorageNode)

Throws:

java.io.IOException

handleQueryResponse

public void handleQueryResponse(QueryResponse response,
                                galileo.event.EventContext context)
                         throws java.io.IOException

Throws:

java.io.IOException

main

public static void main(java.lang.String[] args)

Executable entrypoint for a Galileo DHT Storage Node