lbg.peer.service
Class SimulatedWithCloningPeerService
java.lang.Object
lbg.peer.service.SimulatedPeerService
lbg.peer.service.SimulatedWithCloningPeerService
- All Implemented Interfaces:
- AbstractExternalPeerHandle, AbstractInternalPeerHandle, AbstractUserPeerHandle, PeerService
public class SimulatedWithCloningPeerService
- extends SimulatedPeerService
A partial reimplementation of SimulatedPeerService where incoming Tasks
are cloned before being passed to the overridden method.
- Author:
- Cyril Briquet
Methods inherited from class lbg.peer.service.SimulatedPeerService |
addResource, cancelJob, createHandle, grantConsumption, hostname, id, isAlive, peerPort, queryJobStatus, removeResource, requestSupplying, resourcePort, submitJob, userPort |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
SimulatedWithCloningPeerService
public SimulatedWithCloningPeerService(Peer owner_peer)
throws GridException
- Throws:
GridException
toString
public java.lang.String toString()
- Overrides:
toString
in class SimulatedPeerService
computeSupplyingTask
public ConsumptionTaskID computeSupplyingTask(java.lang.String consumer_id,
Task t)
throws GridException
- Specified by:
computeSupplyingTask
in interface AbstractExternalPeerHandle
- Overrides:
computeSupplyingTask
in class SimulatedPeerService
- Throws:
GridException
cancelSupplyingTaskOnLocalResource
public void cancelSupplyingTaskOnLocalResource(java.lang.String consumer_id,
Task t)
throws GridException
- Specified by:
cancelSupplyingTaskOnLocalResource
in interface AbstractExternalPeerHandle
- Overrides:
cancelSupplyingTaskOnLocalResource
in class SimulatedPeerService
- Throws:
GridException
cancelLocalTaskOnSupplyingResource
public void cancelLocalTaskOnSupplyingResource(java.lang.String supplier_id,
Task t)
throws GridException
- Specified by:
cancelLocalTaskOnSupplyingResource
in interface AbstractExternalPeerHandle
- Overrides:
cancelLocalTaskOnSupplyingResource
in class SimulatedPeerService
- Throws:
GridException
uploadBySupplyingCompletedTask
public void uploadBySupplyingCompletedTask(java.lang.String supplier_id,
Task t)
throws GridException
- Specified by:
uploadBySupplyingCompletedTask
in interface AbstractExternalPeerHandle
- Overrides:
uploadBySupplyingCompletedTask
in class SimulatedPeerService
- Throws:
GridException
preemptLocalTaskOnLocalResource
public void preemptLocalTaskOnLocalResource(Task t,
byte[] logs)
throws GridException
- Specified by:
preemptLocalTaskOnLocalResource
in interface AbstractInternalPeerHandle
- Overrides:
preemptLocalTaskOnLocalResource
in class SimulatedPeerService
- Throws:
GridException
preemptSupplyingTaskOnLocalResource
public void preemptSupplyingTaskOnLocalResource(java.lang.String consumer_id,
Task t,
byte[] logs)
throws GridException
- Specified by:
preemptSupplyingTaskOnLocalResource
in interface AbstractInternalPeerHandle
- Overrides:
preemptSupplyingTaskOnLocalResource
in class SimulatedPeerService
- Throws:
GridException
uploadLocallyCompletedTask
public void uploadLocallyCompletedTask(Task t)
throws GridException
- Specified by:
uploadLocallyCompletedTask
in interface AbstractInternalPeerHandle
- Overrides:
uploadLocallyCompletedTask
in class SimulatedPeerService
- Throws:
GridException
Copyright (c) 2005-2008, Cyril Briquet, parts Xavier Dalem.