15c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// Copyright 2006-2008 the V8 project authors. All rights reserved. 25c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// Redistribution and use in source and binary forms, with or without 35c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// modification, are permitted provided that the following conditions are 45c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// met: 55c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// 65c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// * Redistributions of source code must retain the above copyright 75c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// notice, this list of conditions and the following disclaimer. 85c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// * Redistributions in binary form must reproduce the above 95c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// copyright notice, this list of conditions and the following 105c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// disclaimer in the documentation and/or other materials provided 115c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// with the distribution. 125c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// * Neither the name of Google Inc. nor the names of its 135c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// contributors may be used to endorse or promote products derived 145c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// from this software without specific prior written permission. 155c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// 165c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 175c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 185c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR 195c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT 205c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 215c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT 225c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, 235c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY 245c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 255c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 265c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 275c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 285c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 295c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// This is a JavaScript implementation of the Richards 305c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// benchmark from: 315c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// 325c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// http://www.cl.cam.ac.uk/~mr10/Bench.html 335c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// 345c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// The benchmark was originally implemented in BCPL by 355c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)// Martin Richards. 365c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 375c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 385c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 395c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * The Richards benchmark simulates the task dispatcher of an 405c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * operating system. 415c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) **/ 425c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)function runRichards() { 435c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) var scheduler = new Scheduler(); 445c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) scheduler.addIdleTask(ID_IDLE, 0, null, COUNT); 455c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 465c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) var queue = new Packet(null, ID_WORKER, KIND_WORK); 475c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) queue = new Packet(queue, ID_WORKER, KIND_WORK); 485c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) scheduler.addWorkerTask(ID_WORKER, 1000, queue); 495c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 505c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE); 515c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE); 525c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE); 535c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue); 545c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 555c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) queue = new Packet(null, ID_DEVICE_B, KIND_DEVICE); 565c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE); 575c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE); 585c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) scheduler.addHandlerTask(ID_HANDLER_B, 3000, queue); 595c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 605c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) scheduler.addDeviceTask(ID_DEVICE_A, 4000, null); 615c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 625c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) scheduler.addDeviceTask(ID_DEVICE_B, 5000, null); 635c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 645c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) scheduler.schedule(); 655c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 665c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (scheduler.queueCount != EXPECTED_QUEUE_COUNT || 675c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) scheduler.holdCount != EXPECTED_HOLD_COUNT) { 685c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) var msg = 695c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) "Error during execution: queueCount = " + scheduler.queueCount + 705c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) ", holdCount = " + scheduler.holdCount + "."; 715c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) throw new Error(msg); 725c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 735c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)} 745c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 755c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var COUNT = 1000; 765c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 775c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 785c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * These two constants specify how many times a packet is queued and 795c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * how many times a task is put on hold in a correct run of richards. 805c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * They don't have any meaning a such but are characteristic of a 815c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * correct run so if the actual queue or hold count is different from 825c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * the expected there must be a bug in the implementation. 835c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) **/ 845c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var EXPECTED_QUEUE_COUNT = 2322; 855c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var EXPECTED_HOLD_COUNT = 928; 865c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 875c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 885c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 895c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * A scheduler can be used to schedule a set of tasks based on their relative 905c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * priorities. Scheduling is done by maintaining a list of task control blocks 915c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * which holds tasks and the data queue they are processing. 925c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @constructor 935c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 945c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)function Scheduler() { 955c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.queueCount = 0; 965c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.holdCount = 0; 975c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.blocks = new Array(NUMBER_OF_IDS); 985c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.list = null; 995c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.currentTcb = null; 1005c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.currentId = null; 1015c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)} 1025c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 1035c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var ID_IDLE = 0; 1045c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var ID_WORKER = 1; 1055c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var ID_HANDLER_A = 2; 1065c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var ID_HANDLER_B = 3; 1075c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var ID_DEVICE_A = 4; 1085c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var ID_DEVICE_B = 5; 1095c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var NUMBER_OF_IDS = 6; 1105c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 1115c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var KIND_DEVICE = 0; 1125c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var KIND_WORK = 1; 1135c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 1145c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 1155c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Add an idle task to this scheduler. 1165c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} id the identity of the task 1175c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} priority the task's priority 1185c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Packet} queue the queue of work to be processed by the task 1195c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} count the number of times to schedule the task 1205c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 1215c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)Scheduler.prototype.addIdleTask = function (id, priority, queue, count) { 1225c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.addRunningTask(id, priority, queue, new IdleTask(this, 1, count)); 1235c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 1245c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 1255c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 1265c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Add a work task to this scheduler. 1275c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} id the identity of the task 1285c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} priority the task's priority 1295c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Packet} queue the queue of work to be processed by the task 1305c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 1315c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)Scheduler.prototype.addWorkerTask = function (id, priority, queue) { 1325c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.addTask(id, priority, queue, new WorkerTask(this, ID_HANDLER_A, 0)); 1335c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 1345c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 1355c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 1365c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Add a handler task to this scheduler. 1375c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} id the identity of the task 1385c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} priority the task's priority 1395c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Packet} queue the queue of work to be processed by the task 1405c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 1415c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)Scheduler.prototype.addHandlerTask = function (id, priority, queue) { 1425c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.addTask(id, priority, queue, new HandlerTask(this)); 1435c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 1445c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 1455c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 1465c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Add a handler task to this scheduler. 1475c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} id the identity of the task 1485c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} priority the task's priority 1495c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Packet} queue the queue of work to be processed by the task 1505c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 1515c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)Scheduler.prototype.addDeviceTask = function (id, priority, queue) { 1525c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.addTask(id, priority, queue, new DeviceTask(this)) 1535c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 1545c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 1555c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 1565c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Add the specified task and mark it as running. 1575c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} id the identity of the task 1585c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} priority the task's priority 1595c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Packet} queue the queue of work to be processed by the task 1605c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Task} task the task to add 1615c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 1625c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)Scheduler.prototype.addRunningTask = function (id, priority, queue, task) { 1635c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.addTask(id, priority, queue, task); 1645c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.currentTcb.setRunning(); 1655c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 1665c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 1675c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 1685c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Add the specified task to this scheduler. 1695c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} id the identity of the task 1705c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} priority the task's priority 1715c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Packet} queue the queue of work to be processed by the task 1725c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Task} task the task to add 1735c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 1745c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)Scheduler.prototype.addTask = function (id, priority, queue, task) { 1755c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.currentTcb = new TaskControlBlock(this.list, id, priority, queue, task); 1765c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.list = this.currentTcb; 1775c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.blocks[id] = this.currentTcb; 1785c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 1795c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 1805c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 1815c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Execute the tasks managed by this scheduler. 1825c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 1835c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)Scheduler.prototype.schedule = function () { 1845c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.currentTcb = this.list; 1855c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) while (this.currentTcb != null) { 1865c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (this.currentTcb.isHeldOrSuspended()) { 1875c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.currentTcb = this.currentTcb.link; 1885c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } else { 1895c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.currentId = this.currentTcb.id; 1905c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.currentTcb = this.currentTcb.run(); 1915c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 1925c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 1935c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 1945c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 1955c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 1965c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Release a task that is currently blocked and return the next block to run. 1975c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} id the id of the task to suspend 1985c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 1995c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)Scheduler.prototype.release = function (id) { 2005c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) var tcb = this.blocks[id]; 2015c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (tcb == null) return tcb; 2025c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) tcb.markAsNotHeld(); 2035c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (tcb.priority > this.currentTcb.priority) { 2045c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return tcb; 2055c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } else { 2065c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return this.currentTcb; 2075c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 2085c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 2095c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 2105c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 2115c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Block the currently executing task and return the next task control block 2125c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * to run. The blocked task will not be made runnable until it is explicitly 2135c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * released, even if new work is added to it. 2145c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 2155c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)Scheduler.prototype.holdCurrent = function () { 2165c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.holdCount++; 2175c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.currentTcb.markAsHeld(); 2185c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return this.currentTcb.link; 2195c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 2205c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 2215c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 2225c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Suspend the currently executing task and return the next task control block 2235c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * to run. If new work is added to the suspended task it will be made runnable. 2245c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 2255c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)Scheduler.prototype.suspendCurrent = function () { 2265c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.currentTcb.markAsSuspended(); 2275c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return this.currentTcb; 2285c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 2295c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 2305c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 2315c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Add the specified packet to the end of the worklist used by the task 2325c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * associated with the packet and make the task runnable if it is currently 2335c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * suspended. 2345c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Packet} packet the packet to add 2355c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 2365c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)Scheduler.prototype.queue = function (packet) { 2375c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) var t = this.blocks[packet.id]; 2385c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (t == null) return t; 2395c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.queueCount++; 2405c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) packet.link = null; 2415c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) packet.id = this.currentId; 2425c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return t.checkPriorityAdd(this.currentTcb, packet); 2435c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 2445c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 2455c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 2465c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * A task control block manages a task and the queue of work packages associated 2475c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * with it. 2485c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {TaskControlBlock} link the preceding block in the linked block list 2495c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} id the id of this block 2505c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} priority the priority of this block 2515c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Packet} queue the queue of packages to be processed by the task 2525c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Task} task the task 2535c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @constructor 2545c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 2555c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)function TaskControlBlock(link, id, priority, queue, task) { 2565c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.link = link; 2575c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.id = id; 2585c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.priority = priority; 2595c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.queue = queue; 2605c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.task = task; 2615c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (queue == null) { 2625c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.state = STATE_SUSPENDED; 2635c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } else { 2645c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.state = STATE_SUSPENDED_RUNNABLE; 2655c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 2665c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)} 2675c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 2685c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 2695c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * The task is running and is currently scheduled. 2705c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 2715c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var STATE_RUNNING = 0; 2725c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 2735c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 2745c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * The task has packets left to process. 2755c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 2765c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var STATE_RUNNABLE = 1; 2775c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 2785c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 2795c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * The task is not currently running. The task is not blocked as such and may 2805c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)* be started by the scheduler. 2815c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 2825c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var STATE_SUSPENDED = 2; 2835c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 2845c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 2855c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * The task is blocked and cannot be run until it is explicitly released. 2865c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 2875c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var STATE_HELD = 4; 2885c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 2895c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var STATE_SUSPENDED_RUNNABLE = STATE_SUSPENDED | STATE_RUNNABLE; 2905c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var STATE_NOT_HELD = ~STATE_HELD; 2915c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 2925c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)TaskControlBlock.prototype.setRunning = function () { 2935c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.state = STATE_RUNNING; 2945c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 2955c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 2965c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)TaskControlBlock.prototype.markAsNotHeld = function () { 2975c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.state = this.state & STATE_NOT_HELD; 2985c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 2995c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 3005c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)TaskControlBlock.prototype.markAsHeld = function () { 3015c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.state = this.state | STATE_HELD; 3025c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 3035c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 3045c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)TaskControlBlock.prototype.isHeldOrSuspended = function () { 3055c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return (this.state & STATE_HELD) != 0 || (this.state == STATE_SUSPENDED); 3065c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 3075c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 3085c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)TaskControlBlock.prototype.markAsSuspended = function () { 3095c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.state = this.state | STATE_SUSPENDED; 3105c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 3115c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 3125c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)TaskControlBlock.prototype.markAsRunnable = function () { 3135c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.state = this.state | STATE_RUNNABLE; 3145c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 3155c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 3165c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 3175c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Runs this task, if it is ready to be run, and returns the next task to run. 3185c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 3195c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)TaskControlBlock.prototype.run = function () { 3205c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) var packet; 3215c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (this.state == STATE_SUSPENDED_RUNNABLE) { 3225c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) packet = this.queue; 3235c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.queue = packet.link; 3245c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (this.queue == null) { 3255c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.state = STATE_RUNNING; 3265c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } else { 3275c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.state = STATE_RUNNABLE; 3285c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 3295c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } else { 3305c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) packet = null; 3315c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 3325c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return this.task.run(packet); 3335c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 3345c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 3355c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 3365c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Adds a packet to the worklist of this block's task, marks this as runnable if 3375c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * necessary, and returns the next runnable object to run (the one 3385c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * with the highest priority). 3395c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 3405c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)TaskControlBlock.prototype.checkPriorityAdd = function (task, packet) { 3415c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (this.queue == null) { 3425c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.queue = packet; 3435c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.markAsRunnable(); 3445c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (this.priority > task.priority) return this; 3455c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } else { 3465c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.queue = packet.addTo(this.queue); 3475c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 3485c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return task; 3495c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 3505c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 3515c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)TaskControlBlock.prototype.toString = function () { 3525c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return "tcb { " + this.task + "@" + this.state + " }"; 3535c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 3545c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 3555c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 3565c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * An idle task doesn't do any work itself but cycles control between the two 3575c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * device tasks. 3585c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Scheduler} scheduler the scheduler that manages this task 3595c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} v1 a seed value that controls how the device tasks are scheduled 3605c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} count the number of times this task should be scheduled 3615c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @constructor 3625c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 3635c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)function IdleTask(scheduler, v1, count) { 3645c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.scheduler = scheduler; 3655c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v1 = v1; 3665c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.count = count; 3675c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)} 3685c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 3695c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)IdleTask.prototype.run = function (packet) { 3705c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.count--; 3715c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (this.count == 0) return this.scheduler.holdCurrent(); 3725c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if ((this.v1 & 1) == 0) { 3735c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v1 = this.v1 >> 1; 3745c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return this.scheduler.release(ID_DEVICE_A); 3755c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } else { 3765c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v1 = (this.v1 >> 1) ^ 0xD008; 3775c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return this.scheduler.release(ID_DEVICE_B); 3785c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 3795c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 3805c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 3815c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)IdleTask.prototype.toString = function () { 3825c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return "IdleTask" 3835c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 3845c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 3855c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 3865c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * A task that suspends itself after each time it has been run to simulate 3875c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * waiting for data from an external device. 3885c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Scheduler} scheduler the scheduler that manages this task 3895c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @constructor 3905c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 3915c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)function DeviceTask(scheduler) { 3925c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.scheduler = scheduler; 3935c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v1 = null; 3945c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)} 3955c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 3965c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)DeviceTask.prototype.run = function (packet) { 3975c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (packet == null) { 3985c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (this.v1 == null) return this.scheduler.suspendCurrent(); 3995c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) var v = this.v1; 4005c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v1 = null; 4015c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return this.scheduler.queue(v); 4025c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } else { 4035c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v1 = packet; 4045c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return this.scheduler.holdCurrent(); 4055c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 4065c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 4075c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 4085c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)DeviceTask.prototype.toString = function () { 4095c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return "DeviceTask"; 4105c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 4115c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 4125c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 4135c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * A task that manipulates work packets. 4145c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Scheduler} scheduler the scheduler that manages this task 4155c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} v1 a seed used to specify how work packets are manipulated 4165c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} v2 another seed used to specify how work packets are manipulated 4175c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @constructor 4185c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 4195c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)function WorkerTask(scheduler, v1, v2) { 4205c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.scheduler = scheduler; 4215c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v1 = v1; 4225c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v2 = v2; 4235c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)} 4245c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 4255c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)WorkerTask.prototype.run = function (packet) { 4265c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (packet == null) { 4275c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return this.scheduler.suspendCurrent(); 4285c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } else { 4295c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (this.v1 == ID_HANDLER_A) { 4305c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v1 = ID_HANDLER_B; 4315c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } else { 4325c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v1 = ID_HANDLER_A; 4335c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 4345c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) packet.id = this.v1; 4355c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) packet.a1 = 0; 4365c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) for (var i = 0; i < DATA_SIZE; i++) { 4375c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v2++; 4385c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (this.v2 > 26) this.v2 = 1; 4395c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) packet.a2[i] = this.v2; 4405c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 4415c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return this.scheduler.queue(packet); 4425c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 4435c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 4445c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 4455c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)WorkerTask.prototype.toString = function () { 4465c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return "WorkerTask"; 4475c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 4485c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 4495c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 4505c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * A task that manipulates work packets and then suspends itself. 4515c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Scheduler} scheduler the scheduler that manages this task 4525c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @constructor 4535c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 4545c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)function HandlerTask(scheduler) { 4555c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.scheduler = scheduler; 4565c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v1 = null; 4575c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v2 = null; 4585c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)} 4595c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 4605c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)HandlerTask.prototype.run = function (packet) { 4615c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (packet != null) { 4625c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (packet.kind == KIND_WORK) { 4635c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v1 = packet.addTo(this.v1); 4645c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } else { 4655c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v2 = packet.addTo(this.v2); 4665c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 4675c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 4685c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (this.v1 != null) { 4695c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) var count = this.v1.a1; 4705c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) var v; 4715c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (count < DATA_SIZE) { 4725c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (this.v2 != null) { 4735c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) v = this.v2; 4745c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v2 = this.v2.link; 4755c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) v.a1 = this.v1.a2[count]; 4765c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v1.a1 = count + 1; 4775c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return this.scheduler.queue(v); 4785c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 4795c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } else { 4805c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) v = this.v1; 4815c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.v1 = this.v1.link; 4825c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return this.scheduler.queue(v); 4835c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 4845c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) } 4855c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return this.scheduler.suspendCurrent(); 4865c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 4875c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 4885c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)HandlerTask.prototype.toString = function () { 4895c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return "HandlerTask"; 4905c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 4915c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 4925c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/* --- * 4935c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * P a c k e t 4945c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * --- */ 4955c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 4965c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)var DATA_SIZE = 4; 4975c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 4985c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 4995c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * A simple package of data that is manipulated by the tasks. The exact layout 5005c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * of the payload data carried by a packet is not importaint, and neither is the 5015c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * nature of the work performed on packets by the tasks. 5025c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * 5035c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Besides carrying data, packets form linked lists and are hence used both as 5045c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * data and worklists. 5055c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Packet} link the tail of the linked list of packets 5065c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} id an ID for this packet 5075c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {int} kind the type of this packet 5085c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @constructor 5095c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 5105c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)function Packet(link, id, kind) { 5115c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.link = link; 5125c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.id = id; 5135c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.kind = kind; 5145c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.a1 = 0; 5155c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.a2 = new Array(DATA_SIZE); 5165c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)} 5175c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 5185c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)/** 5195c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * Add this packet to the end of a worklist, and return the worklist. 5205c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) * @param {Packet} queue the worklist to add this packet to 5215c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) */ 5225c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)Packet.prototype.addTo = function (queue) { 5235c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) this.link = null; 5245c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) if (queue == null) return this; 5255c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) var peek, next = queue; 5265c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) while ((peek = next.link) != null) 5275c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) next = peek; 5285c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) next.link = this; 5295c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return queue; 5305c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 5315c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 5325c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)Packet.prototype.toString = function () { 5335c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) return "Packet"; 5345c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)}; 5355c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) 5365c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles)for (var i = 0; i < 350; ++i) 5375c87bf8b86a7c82ef50fb7a89697d8e02e2553beTorne (Richard Coles) runRichards(); 538