|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectcgl.narada.node.ClientNode
public class ClientNode
This is the client node for our class. This class is responsible for
| Field Summary |
|---|
| Fields inherited from interface cgl.narada.node.NodeDebugFlags |
|---|
BrokerNode_Debug, BrokerPropertiesReader_Debug, ClientNode_Debug, ServerNode_Debug |
| Constructor Summary | |
|---|---|
ClientNode()
|
|
| Method Summary | |
|---|---|
void |
connectTo(String hostName,
int portNum,
byte transport)
Initiates a connection with the server that posseses the information contained within the request |
void |
eventPropagationRequest(String server,
String event,
int minSize)
This method is responsible for publishing an event to the system. |
void |
gatherStats(int _pubRate,
int _matchRate,
int _messageSize)
|
int[] |
getMatchRates()
|
int[] |
getMessageSizes()
|
int[] |
getPublishRates()
|
void |
initializeLatencyArray(int size)
|
void |
initializeReportFile(String fileName)
|
void |
loopThroughMessageSizes(String reportFileName)
|
static void |
main(String[] args)
|
void |
nodeAddressRequest(String server)
This method is reponsible for issuing a node address request to the server in question. |
void |
persistentEventPropagationRequest(String server,
String event,
int minSize)
This method is responsible for publishing a PERSISTENT event to the system. |
void |
profilePropagationRequest(String server,
String subscription)
Propagates the interest in a subscription to the server in question. |
float |
readPublishRate()
|
void |
setMatchRate(int matchRate)
|
void |
setPublishRate(int pRate)
|
void |
setRates(int pubRate,
int numOfMessages,
int messagesAtTime)
This method sets the publish rate ... |
void |
setUpNode(int portNum,
byte transportType)
This method serves as an intermediary between the transport layer and protocol layer and is responsible for setting up the server node. |
void |
setUpNodeNew(Properties props,
String transportType)
This method serves as an intermediary between the transport layer and protocol layer and is responsible for setting up the server node. |
void |
startTestingProcess(String serverName,
int portNum)
|
void |
writeLatenciesToFile(long[] acceptedLatencies)
|
void |
writePublishRate(float publishRate)
|
void |
writeToReportFile(String reportLine)
|
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public ClientNode()
| Method Detail |
|---|
public void setRates(int pubRate,
int numOfMessages,
int messagesAtTime)
pubRate - The publish ratepublic void setPublishRate(int pRate)
public void setMatchRate(int matchRate)
public int[] getMessageSizes()
public int[] getPublishRates()
public int[] getMatchRates()
public void setUpNode(int portNum,
byte transportType)
public void setUpNodeNew(Properties props, String transportType)
public void connectTo(String hostName, int portNum, byte transport)
public void nodeAddressRequest(String server)
server - The server to which this request is being issued.public void profilePropagationRequest(String server, String subscription)
server - The server to which this client is attached.subscription - The subscription predicate for the clientpublic void eventPropagationRequest(String server, String event, int minSize)
server - The server to which this request is being issued.event - The event that is being publishedminSize - Minimum Size of the event being published.public void persistentEventPropagationRequest(String server, String event, int minSize)
server - The server to which this request is being issued.event - The event that is being publishedminSize - Minimum Size of the event being published.
public void gatherStats(int _pubRate,
int _matchRate,
int _messageSize)
public void initializeLatencyArray(int size)
public void loopThroughMessageSizes(String reportFileName)
public void startTestingProcess(String serverName, int portNum)
public void initializeReportFile(String fileName)
public void writeToReportFile(String reportLine)
public void writeLatenciesToFile(long[] acceptedLatencies)
public void writePublishRate(float publishRate)
public float readPublishRate()
public static void main(String[] args)
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||