ucr.app
Class QueryNodeReceiver

java.lang.Object
  ucr.core.MessageReceiverAdapter
      ucr.app.QueryNodeReceiver

All Implemented Interfaces:

MessageReceiver

public class QueryNodeReceiver

extends MessageReceiverAdapter

Test class for receiving search responses

Field Summary

long	endTime
int	hits
int	hosthits
java.lang.String	keyword
private static java.util.Hashtable	PEERS_ALIVE
(package private) ServerSession	serverSession
long	startTime

Constructor Summary

QueryNodeReceiver(java.lang.String keyword)

Method Summary

static void	add2PeersAlive(java.lang.String peer_name) Keeps a log of which peers have responded to any query so far
long	get_endTime()
int	get_hits()
java.lang.String	get_keyword()
long	get_startTime()
void	receiveSearchReply(SearchReplyMessage searchReply, java.lang.String host, int port) Implement to receive a qstreply
void	receiveTraceReply(TraceReplyMessage traceReply) Implement to receive a message reply.
void	set_endTime(long endTime)
void	set_startTime(long startTime)
(package private) void	setServerSession(ServerSession serverSession)

Methods inherited from class ucr.core.MessageReceiverAdapter

receiveSearch, receiveSearchReply, receiveTrace

Methods inherited from class java.lang.Object

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

Field Detail

serverSession

ServerSession serverSession

PEERS_ALIVE

private static java.util.Hashtable PEERS_ALIVE

keyword

public java.lang.String keyword

hits

public int hits

hosthits

public int hosthits

startTime

public long startTime

endTime

public long endTime

Constructor Detail

QueryNodeReceiver

public QueryNodeReceiver(java.lang.String keyword)

Method Detail

get_startTime

public long get_startTime()

Specified by:

get_startTime in interface MessageReceiver

Overrides:

get_startTime in class MessageReceiverAdapter

get_endTime

public long get_endTime()

Specified by:

get_endTime in interface MessageReceiver

Overrides:

get_endTime in class MessageReceiverAdapter

set_startTime

public void set_startTime(long startTime)

Specified by:

set_startTime in interface MessageReceiver

Overrides:

set_startTime in class MessageReceiverAdapter

set_endTime

public void set_endTime(long endTime)

Specified by:

set_endTime in interface MessageReceiver

Overrides:

set_endTime in class MessageReceiverAdapter

get_hits

public int get_hits()

Specified by:

get_hits in interface MessageReceiver

Overrides:

get_hits in class MessageReceiverAdapter

get_keyword

public java.lang.String get_keyword()

Specified by:

get_keyword in interface MessageReceiver

Overrides:

get_keyword in class MessageReceiverAdapter

add2PeersAlive

public static void add2PeersAlive(java.lang.String peer_name)

Keeps a log of which peers have responded to any query so far

receiveTraceReply

public void receiveTraceReply(TraceReplyMessage traceReply)

Description copied from class: MessageReceiverAdapter

Implement to receive a message reply.

Specified by:

receiveTraceReply in interface MessageReceiver

Overrides:

receiveTraceReply in class MessageReceiverAdapter

Parameters:

traceReply - trace reply message

receiveSearchReply

public void receiveSearchReply(SearchReplyMessage searchReply,
                               java.lang.String host,
                               int port)

Description copied from interface: MessageReceiver

Implement to receive a qstreply

setServerSession

void setServerSession(ServerSession serverSession)