edu.iu.harp.client

Class SyncClient

java.lang.Object

edu.iu.harp.client.SyncClient

All Implemented Interfaces:

java.lang.Runnable

public class SyncClient
extends java.lang.Object
implements java.lang.Runnable

Synchronous client

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	LOG

Constructor Summary

Constructors

Constructor and Description
SyncClient(Workers workers)

Method Summary

Modifier and Type	Method and Description
void	run() Main process by this client Go through each queue, drain the queue and send/broadcast
void	start() Start the client
void	stop() Send StopSign to the execution threads
boolean	submitCollectiveEvent(Event event) Submit a collective event (broadcast)
boolean	submitMessageEvent(Event event) Submit a message event

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Logger LOG

Constructor Detail

SyncClient

public SyncClient(Workers workers)

Method Detail

submitMessageEvent

public boolean submitMessageEvent(Event event)

Submit a message event

Parameters:

event - the event to submit

Returns:

true if succeeded, false otherwise

submitCollectiveEvent

public boolean submitCollectiveEvent(Event event)

Submit a collective event (broadcast)

Parameters:

event -

hasFuture -

Returns:

start

public void start()

Start the client

run

public void run()

Main process by this client Go through each queue, drain the queue and send/broadcast

Specified by:

run in interface java.lang.Runnable

stop

public void stop()

Send StopSign to the execution threads