org.eurogrid.broker.client
Class BrokerRequestManager

java.lang.Object
  |
  +--org.eurogrid.broker.client.BrokerRequestManager

All Implemented Interfaces:

com.pallas.unicore.threadpool.IObserver

public class BrokerRequestManager

extends Object

implements com.pallas.unicore.threadpool.IObserver

A thread manager for BrokerRequest threads.

Version:

$Revision: 1.9 $, $Date: 2004/02/17 11:32:40 $

Author:

Jon MacLaren

Constructor Summary

BrokerRequestManager(BrokerPlugin plugin, OfferTableModel model, TaskResourceDAG resourceDAG)
Simple constructor

Method Summary

void	addRequest(Vsite vsite, com.pallas.unicore.extensions.Usite usite, User user, boolean qosRequest, String jobAjoIdName) Add another request to another vsite
void	observableUpdate(Object theObserved, Object changeCode) Take note of estimates coming from BrokerRequest threads, add to the list.
void	setTable(org.eurogrid.broker.client.OfferTableDialog table) Set the handle to the table for updating the running count
void	terminate() Stop now - force the threads to terminate

Methods inherited from class java.lang.Object

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

Constructor Detail

BrokerRequestManager

public BrokerRequestManager(BrokerPlugin plugin,
                            OfferTableModel model,
                            TaskResourceDAG resourceDAG)

Simple constructor

Parameters:

plugin - The broker plugin containing the manager

model - The TableModel where the offers are sent

resourceDAG - The resource DAG for the Job Group being brokered

Method Detail

addRequest

public void addRequest(Vsite vsite,
                       com.pallas.unicore.extensions.Usite usite,
                       User user,
                       boolean qosRequest,
                       String jobAjoIdName)

Add another request to another vsite

Parameters:

vsite - The Vsite to make the request to

usite - The Vsite's Usite

user - The user making the request

qosRequest - True for QoSCheck, False for ResourceCheck

jobAjoIdName -

observableUpdate

public void observableUpdate(Object theObserved,
                             Object changeCode)

Take note of estimates coming from BrokerRequest threads, add to the list.

Specified by:

observableUpdate in interface com.pallas.unicore.threadpool.IObserver

Parameters:

theObserved - The BrokerRequest thread

changeCode - Either the final AbstractJob_Outcome if the thread is done, or a CheckQoS_Outcome or a CheckResources_Outcome, or even an OutcomeWrapper.

setTable

public void setTable(org.eurogrid.broker.client.OfferTableDialog table)

Set the handle to the table for updating the running count

Parameters:

table - The table dialog object

terminate

public void terminate()

Stop now - force the threads to terminate