Function RunWorkerPingTest

deps/v8/test/mjsunit/worker-ping-test.js:33–138

(config)

}

function RunWorkerPingTest(config) {
  let workers = [];
  let beforeSend = (typeof config.BeforeSend == "function") ?
      config.BeforeSend :
      function BeforeSend(msg) { };
  let beforeReceive = (typeof config.BeforeReceive == "function") ?
      config.BeforeReceive :
      function BeforeReceive(msg) { };

  // Each worker has a circular buffer of size {config.numThings}, recording
  // received things into the buffer and responding with a previous thing.
  // Every {config.allocInterval}, a worker creates a new thing by
  // {config.AllocThing}.

  function workerCode(config, AllocThing, BeforeReceive) {
    eval(AllocThing);
    eval(BeforeReceive);
    const kNumThings = config.numThings;
    const kAllocInterval = config.allocInterval;
    let index = 0;
    let total = 0;
    let id = 0;
    let things = new Array(kNumThings);
    for (let i = 0; i < kNumThings; i++) {
      things[i] = TryAllocThing();
    }

    function TryAllocThing() {
      try {
        let thing = AllocThing(id++);
        if (config.traceAlloc) {
          print("alloc success");
        }
       return thing;
     } catch(e) {
       if (config.abortOnFail) {
         postMessage({error: e.toString()}); throw e;
       }
       if (config.traceAlloc) {
         print("alloc fail: " + e);
       }
     }
    }

    onmessage = function({data:msg}) {
      BeforeReceive(msg);
      if (msg.thing !== undefined) {
        let reply = things[index];
        if ((total % kAllocInterval) == 0) {
          reply = TryAllocThing();
        }
        things[index] = msg.thing;
        postMessage({thing : reply});
        index = (index + 1) % kNumThings;
        total++;
      }
    }
  }