|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||||
| Packages that use BundleWrapper | |
|---|---|
| org.jppf.server | Classes supporting the core functionality of the JPPF asynchronous comunication model. |
| org.jppf.server.job | Support for job management in the server. |
| org.jppf.server.nio.nodeserver | Classes supporting the server node-side of the JPPF asynchronous comunication model. |
| org.jppf.server.protocol | Classes supporting the data transported between components of the communication model. |
| org.jppf.server.queue | Classes supporting the tasks queuing mechanism. |
| Uses of BundleWrapper in org.jppf.server |
|---|
| Methods in org.jppf.server that return types with arguments of type BundleWrapper | |
|---|---|
protected List<BundleWrapper> |
AbstractResultSender.getResultList()
Get the list of task bundles whose execution has been completed. |
| Methods in org.jppf.server with parameters of type BundleWrapper | |
|---|---|
abstract void |
AbstractResultSender.sendPartialResults(BundleWrapper bundle)
Send the results of the tasks in a bundle back to the client who submitted the request. |
void |
AbstractResultSender.taskCompleted(BundleWrapper result)
Callback method invoked when the execution of a task has completed. |
| Method parameters in org.jppf.server with type arguments of type BundleWrapper | |
|---|---|
protected void |
AbstractResultSender.setResultList(List<BundleWrapper> resultList)
Set the list of task bundles whose execution has been completed. |
| Uses of BundleWrapper in org.jppf.server.job |
|---|
| Methods in org.jppf.server.job that return BundleWrapper | |
|---|---|
BundleWrapper |
JPPFJobManager.getBundleForJob(String jobUuid)
Get the queued bundle wrapper for the specified job. |
| Methods in org.jppf.server.job with parameters of type BundleWrapper | |
|---|---|
void |
JPPFJobManager.jobDispatched(BundleWrapper bundleWrapper,
ChannelWrapper channel)
Called when all or part of a job is dispatched to a node. |
void |
JPPFJobManager.jobEnded(BundleWrapper bundleWrapper)
Called when a job is complete and returned to the client. |
void |
JPPFJobManager.jobQueued(BundleWrapper bundleWrapper)
Called when a job is added to the server queue. |
void |
JPPFJobManager.jobReturned(BundleWrapper bundleWrapper,
ChannelWrapper channel)
Called when all or part of a job has returned from a node. |
void |
JPPFJobManager.jobUpdated(BundleWrapper bundleWrapper)
Called when a job is added to the server queue. |
| Constructors in org.jppf.server.job with parameters of type BundleWrapper | |
|---|---|
ChannelBundlePair(ChannelWrapper<?> first,
BundleWrapper second)
Initialize this object with the specified parameters. |
|
| Uses of BundleWrapper in org.jppf.server.nio.nodeserver |
|---|
| Fields in org.jppf.server.nio.nodeserver declared as BundleWrapper | |
|---|---|
protected BundleWrapper |
AbstractNodeContext.bundle
The task bundle to send or receive. |
| Methods in org.jppf.server.nio.nodeserver that return BundleWrapper | |
|---|---|
BundleWrapper |
AbstractNodeContext.deserializeBundle()
Deserialize a task bundle from the message read into this buffer. |
BundleWrapper |
AbstractNodeContext.getBundle()
Get the task bundle to send or receive. |
| Methods in org.jppf.server.nio.nodeserver with parameters of type BundleWrapper | |
|---|---|
void |
AbstractNodeContext.resubmitBundle(BundleWrapper bundle)
Resubmit a task bundle at the head of the queue. |
void |
AbstractNodeContext.setBundle(BundleWrapper bundle)
Set the task bundle to send or receive. |
| Uses of BundleWrapper in org.jppf.server.protocol |
|---|
| Methods in org.jppf.server.protocol that return BundleWrapper | |
|---|---|
BundleWrapper |
BundleWrapper.copy()
Make a copy of this bundle wrapper. |
BundleWrapper |
BundleWrapper.copy(int nbTasks)
Make a copy of this bundle wrapper containing only the first nbTasks tasks it contains. |
| Methods in org.jppf.server.protocol with parameters of type BundleWrapper | |
|---|---|
void |
BundleWrapper.merge(BundleWrapper other,
boolean after)
Merge this bundle wrapper with another. |
void |
TaskCompletionListener.taskCompleted(BundleWrapper result)
Callback method invoked when the execution of a task has completed. |
| Uses of BundleWrapper in org.jppf.server.queue |
|---|
| Fields in org.jppf.server.queue with type parameters of type BundleWrapper | |
|---|---|
protected TreeMap<Integer,List<BundleWrapper>> |
AbstractJPPFQueue.sizeMap
An ordered map of bundle sizes, mapping to a list of bundles of this size. |
| Methods in org.jppf.server.queue that return BundleWrapper | |
|---|---|
BundleWrapper |
QueueEvent.getBundleWrapper()
Get the task bundle that is the cause of the event. |
BundleWrapper |
JPPFQueue.nextBundle(BundleWrapper bundleWrapper,
int nbTasks)
Get the next object in the queue. |
BundleWrapper |
JPPFPriorityQueue.nextBundle(BundleWrapper bundleWrapper,
int nbTasks)
Get the next object in the queue. |
BundleWrapper |
JPPFQueue.nextBundle(int nbTasks)
Get the next object in the queue. |
BundleWrapper |
JPPFPriorityQueue.nextBundle(int nbTasks)
Get the next object in the queue. |
BundleWrapper |
JPPFQueue.removeBundle(BundleWrapper bundleWrapper)
Remove the specified bundle from the queue. |
BundleWrapper |
JPPFPriorityQueue.removeBundle(BundleWrapper bundleWrapper)
Remove the specified bundle from the queue. |
| Methods in org.jppf.server.queue that return types with arguments of type BundleWrapper | |
|---|---|
Iterator<BundleWrapper> |
JPPFPriorityQueue.iterator()
Get an iterator on the task bundles in this queue. |
| Methods in org.jppf.server.queue with parameters of type BundleWrapper | |
|---|---|
void |
JPPFQueue.addBundle(BundleWrapper bundleWrapper)
Add an object to the queue, and notify all listeners about it. |
void |
JPPFPriorityQueue.addBundle(BundleWrapper bundleWrapper)
Add an object to the queue, and notify all listeners about it. |
protected int |
AbstractJPPFQueue.getSize(BundleWrapper bundleWrapper)
Get the bundle size to use for bundle size tuning. |
BundleWrapper |
JPPFQueue.nextBundle(BundleWrapper bundleWrapper,
int nbTasks)
Get the next object in the queue. |
BundleWrapper |
JPPFPriorityQueue.nextBundle(BundleWrapper bundleWrapper,
int nbTasks)
Get the next object in the queue. |
BundleWrapper |
JPPFQueue.removeBundle(BundleWrapper bundleWrapper)
Remove the specified bundle from the queue. |
BundleWrapper |
JPPFPriorityQueue.removeBundle(BundleWrapper bundleWrapper)
Remove the specified bundle from the queue. |
void |
BroadcastJobCompletionListener.taskCompleted(BundleWrapper result)
Callback method invoked when the execution of a task has completed. |
| Constructors in org.jppf.server.queue with parameters of type BundleWrapper | |
|---|---|
BroadcastJobCompletionListener(BundleWrapper bundleWrapper,
Set<String> nodeUuids)
Initialize this completion listener with the specified bradcast job and set of node uuids. |
|
QueueEvent(JPPFQueue queue,
BundleWrapper bundleWrapper)
Initialize this event with the specified queue and bundle. |
|
QueueEvent(JPPFQueue queue,
BundleWrapper bundleWrapper,
boolean requeue)
Initialize this event with the specified queue and bundle. |
|
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||||