diff -r 000000000000 -r 6474c204b198 js/src/jit-test/lib/parallelarray-helpers.js --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/js/src/jit-test/lib/parallelarray-helpers.js Wed Dec 31 06:09:35 2014 +0100 @@ -0,0 +1,223 @@ +/* This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ + +// Explanation of minItemsTestingThreshold: +// +// If the volume of input items in a test is small, then all of them +// may be processed during warmup alone, and the parallel-invocation +// will trivially succeed even if we are intentionally trying to +// detect a failure. +// +// The maximum number of items processed by sequential warmups for +// ArrayBuildPar is: +// maxSeqItems = maxBailouts * numSlices * CHUNK_SIZE +// +// For maxBailouts = 3, maxSeqItems == 3 * 8 * 32 == 768 +// For maxBailouts = 5, maxSeqItems == 5 * 8 * 32 == 1280 +// +// Our test code does not have access to the values of these constants +// (maxBailouts, numSlices, CHUNK_SIZE). Therefore, the value of +// minItemsTestingThreshold should be kept in sync with some value +// greater than maxSeqItems as calculated above. +// +// This is still imperfect since it assumes numSlices <= 8, but +// numSlices is machine-dependent. +// (TODO: consider exposing numSlices via builtin/TestingFunctions.cpp) + +var minItemsTestingThreshold = 1024; + +// The standard sequence of modes to test. +// First mode compiles for parallel exec. +// Second mode checks that parallel exec does not bail. +// Final mode tests the sequential fallback path. +var MODE_STRINGS = ["compile", "par", "seq"]; +var MODES = MODE_STRINGS.map(s => ({mode: s})); + +var INVALIDATE_MODE_STRINGS = ["seq", "compile", "par", "seq"]; +var INVALIDATE_MODES = INVALIDATE_MODE_STRINGS.map(s => ({mode: s})); + +function build(n, f) { + var result = []; + for (var i = 0; i < n; i++) + result.push(f(i)); + return result; +} + +function range(n, m) { + // Returns an array with [n..m] (include on n, exclusive on m) + + var result = []; + for (var i = n; i < m; i++) + result.push(i); + return result; +} + +function seq_scan(array, f) { + // Simple sequential version of scan() that operates over an array + + var result = []; + result[0] = array[0]; + for (var i = 1; i < array.length; i++) { + result[i] = f(result[i-1], array[i]); + } + return result; +} + +function assertAlmostEq(v1, v2) { + if (v1 === v2) + return true; + // + and other fp ops can vary somewhat when run in parallel! + assertEq(typeof v1, "number"); + assertEq(typeof v2, "number"); + var diff = Math.abs(v1 - v2); + var percent = diff / v1 * 100.0; + print("v1 = " + v1); + print("v2 = " + v2); + print("% diff = " + percent); + assertEq(percent < 1e-10, true); // off by an less than 1e-10%...good enough. +} + +function assertStructuralEq(e1, e2) { + if (e1 instanceof Array && e2 instanceof Array) { + assertEqArray(e1, e2); + } else if (e1 instanceof Object && e2 instanceof Object) { + assertEq(e1.__proto__, e2.__proto__); + for (prop in e1) { + if (e1.hasOwnProperty(prop)) { + assertEq(e2.hasOwnProperty(prop), true); + assertStructuralEq(e1[prop], e2[prop]); + } + } + } else { + assertEq(e1, e2); + } +} + +function assertEqArray(a, b) { + assertEq(a.length, b.length); + for (var i = 0, l = a.length; i < l; i++) { + try { + assertStructuralEq(a[i], b[i]); + } catch (e) { + print("...in index", i, "of", l); + throw e; + } + } +} + +// Checks that whenever we execute this in parallel mode, +// it bails out. `opFunction` should be a closure that takes a +// mode parameter and performs some parallel array operation. +// This closure will be invoked repeatedly. +// +// Here is an example of the expected usage: +// +// assertParallelExecWillBail(function(m) { +// Array.buildPar(..., m) +// }); +// +// where the `Array.buildPar(...)` is a stand-in +// for some parallel array operation. +function assertParallelExecWillBail(opFunction) { + opFunction({mode:"compile"}); // get the script compiled + opFunction({mode:"bailout"}); // check that it bails when executed +} + +// Checks that when we execute this in parallel mode, +// some bailouts will occur but we will recover and +// return to parallel execution mode. `opFunction` is a closure +// that expects a mode, just as in `assertParallelExecWillBail`. +function assertParallelExecWillRecover(opFunction) { + opFunction({mode:"compile"}); // get the script compiled + opFunction({mode:"recover"}); // check that it bails when executed +} + +// Checks that we will (eventually) be able to compile and exection +// `opFunction` in parallel mode. Invokes `cmpFunction` with the +// result. For some tests, it takes many compile rounds to reach a TI +// fixed point. So this function will repeatedly attempt to invoke +// `opFunction` with `compile` and then `par` mode until getting a +// successful `par` run. After enough tries, of course, we give up +// and declare a test failure. +function assertParallelExecSucceeds(opFunction, cmpFunction) { + var failures = 0; + while (true) { + print("Attempting compile #", failures); + var result = opFunction({mode:"compile"}); + cmpFunction(result); + + try { + print("Attempting parallel run #", failures); + var result = opFunction({mode:"par"}); + cmpFunction(result); + break; + } catch (e) { + failures++; + if (failures > 5) { + throw e; // doesn't seem to be reaching a fixed point! + } else { + print(e); + } + } + } + + print("Attempting sequential run"); + var result = opFunction({mode:"seq"}); + cmpFunction(result); +} + +// Compares an Array constructed in parallel against one constructed +// sequentially. `func` should be the closure to provide as argument. For +// example: +// +// assertArraySeqParResultsEq([1, 2, 3], "map", i => i + 1) +// +// would check that `[1, 2, 3].map(i => i+1)` and `[1, 2, 3].mapPar(i => i+1)` +// yield the same result. +// +// Based on `assertParallelExecSucceeds` +function assertArraySeqParResultsEq(arr, op, func, cmpFunc) { + if (!cmpFunc) + cmpFunc = assertStructuralEq; + var expected = arr[op].apply(arr, [func]); + assertParallelExecSucceeds( + function (m) { return arr[op + "Par"].apply(arr, [func, m]); }, + function (r) { cmpFunc(expected, r); }); +} + +// Similar to `compareAgainstArray`, but for the `scan` method which +// does not appear on array. +function testArrayScanPar(jsarray, func, cmpFunction) { + if (!cmpFunction) + cmpFunction = assertStructuralEq; + var expected = seq_scan(jsarray, func); + + // Unfortunately, it sometimes happens that running 'par' twice in a + // row causes bailouts and other unfortunate things! + + assertParallelExecSucceeds( + function(m) { + print(m.mode + " " + m.expect); + var p = jsarray.scanPar(func, m); + return p; + }, + function(r) { + cmpFunction(expected, r); + }); +} + +// Checks that `opFunction`, when run with each of the modes +// in `modes`, returns the same value each time. +function assertParallelModesCommute(modes, opFunction) { + var expected = undefined; + var acc = opFunction(modes[0]); + assertParallelExecSucceeds( + opFunction, + function(r) { + if (expected === undefined) + expected = r; + else + assertStructuralEq(expected, r); + }); +}