How to use shutdownWorker method in Cypress
Best JavaScript code snippet using cypress
queue.spec.js
Source:queue.spec.js 
...155 describe('#shutdownWorker', function() {156 it('should remove worker', function() {157 var q = new th.Queue(th.testRef, _.noop);158 expect(q.getWorkerCount()).to.equal(1);159 q.shutdownWorker();160 expect(q.getWorkerCount()).to.equal(0);161 });162 it('should shutdown worker', function() {163 var q = new th.Queue(th.testRef, _.noop);164 expect(q.getWorkerCount()).to.equal(1);165 var workerShutdownPromise = q.shutdownWorker();166 return workerShutdownPromise;167 });168 it('should reject when no workers remaining', function() {169 var q = new th.Queue(th.testRef, _.noop);170 expect(q.getWorkerCount()).to.equal(1);171 q.shutdownWorker();172 return q.shutdownWorker().catch(function(error) {173 expect(error.message).to.equal('No workers to shutdown');174 });175 });176 });177 describe('#shutdown', function() {178 var q;179 it('should shutdown a queue initialized with the default spec', function() {180 q = new th.Queue(th.testRef, _.noop);181 return q.shutdown().should.eventually.be.fulfilled;182 });183 it('should shutdown a queue initialized with a custom spec before the listener callback', function() {184 q = new th.Queue(th.testRef, { specId: 'test_task' }, _.noop);185 return q.shutdown().should.eventually.be.fulfilled;186 });...
index.js
Source:index.js
...115}116exports.createInitialWorkers = createInitialWorkers;117// try to cleanly shut down worker threads to avoid SIGABRT in Electron118// @see https://github.com/electron/electron/issues/23366119function shutdownWorker(workerInfo) {120 const { thread } = workerInfo;121 return new bluebird_1.default((resolve) => {122 thread.once('exit', resolve);123 thread.once('error', resolve);124 thread.postMessage({ shutdown: true });125 })126 .timeout(100)127 .catch((err) => {128 debug('error cleanly shutting down worker, terminating from parent %o', { err, workerInfo: _debugWorker(workerInfo) });129 return thread.terminate();130 });131}132exports.shutdownWorker = shutdownWorker;133function terminateAllWorkers() {...
main.js
Source:main.js
...178 process.send({ cmd: 'worker_shutdown', pid: process.pid });179 };180 sockDomain.on('error', function(error) {181 helpers.logError(workerName, 'Socket HTTP server error: '+error);182 shutdownWorker();183 });184 httpDomain.on('error', function(error) {185 helpers.logError(workerName, 'HTTP server error: '+error);186 shutdownWorker();187 });...
ClusterManager.js
Source:ClusterManager.js
...92 worker.removeOldWorker = setTimeout(function() {93 if (shutdownArray.length > 0) {94 var workerToShutdown = shutdownArray.pop();95 log('New worker[' + worker.id + '] has been up for ' + timeoutBeforeShutdown + 'ms. Asking worker[' + workerToShutdown.id + '] to shutdown');96 shutdownWorker(workerToShutdown);97 }98 }, timeoutBeforeShutdown);99 });100 process.on('SIGHUP', function SIGHUP() {101 log('Rolling restarting request received');102 if (!fs.existsSync(options.exec)) {103 log('File ' + options.exec + " does not exist. Won't restart.", true);104 if (notify !== null) {105 sendNotification(notify, '[' + hostname + '] File ' + options.exec + ' does not exist. Wont restart.', runningWorkersMsg()); // eslint-disable-line no-use-before-define106 }107 return;108 }109 if (notify !== null) {110 sendNotification(notify, '[' + hostname + '] Rolling restart of instances', runningWorkersMsg()); // eslint-disable-line no-use-before-define111 }112 var currentTotal;113 var currentWorkers = Object.keys(cluster.workers);114 var workerID;115 var worker;116 for (currentTotal = 0; currentTotal < numWorkers; currentTotal++) {117 log('Spawning new process...');118 cluster.fork();119 if (currentWorkers.length > 0) {120 workerID = currentWorkers.pop();121 worker = cluster.workers[workerID];122 shutdownArray.push(worker);123 }124 }125 for (workerID in currentWorkers) {126 worker = cluster.workers[currentWorkers[workerID]];127 log('Removing excess workers: ' + worker.id);128 shutdownWorker(worker);129 }130 });131 process.on('SIGUSR1', function SIGUSR1() {132 log(runningWorkersMsg(), true);133 });134 process.on('SIGUSR2', function SIGUSR2() {135 var currentWorkers = Object.keys(cluster.workers).length;136 log('Workers running: ' + currentWorkers + ' - Max Workers: ' + numWorkers);137 if (currentWorkers < numWorkers) {138 log('Starting ' + (numWorkers - currentWorkers) + ' worker(s)');139 for (var currentTotal = 0; currentTotal < (numWorkers - currentWorkers); currentTotal++) {140 cluster.fork();141 }142 }143 log(runningWorkersMsg());144 });145 process.on('SIGTERM', function SIGTERM() {146 log('Termination request received');147 if (notify !== null) {148 sendNotification(notify, '[' + hostname + '] Shutting down all worker instances', runningWorkersMsg()); // eslint-disable-line no-use-before-define149 }150 var currentWorkers = Object.keys(cluster.workers);151 for (var workerID in currentWorkers) {152 var worker = cluster.workers[currentWorkers[workerID]];153 shutdownWorker(worker);154 }155 });156 cluster.fork = function() {157 if (!fs.existsSync(cluster.settings.exec)) {158 console.error('File ' + cluster.settings.exec + " does not exist. Won't FORK.");159 if (notify !== null) {160 sendNotification(notify, '[' + hostname + '] File ' + cluster.settings.exec + ' does not exist. Wont FORK.', runningWorkersMsg()); // eslint-disable-line no-use-before-define161 }162 return;163 }164 origFork.bind(this)();165 };166 log('Master process PID is ' + process.pid);167 if (pidfile !== null) {...
server.js
Source:server.js
1#!/usr/bin/env node2/**3 * Cluster-based Parsoid web service runner. Implements4 * https://www.mediawiki.org/wiki/Parsoid#The_Parsoid_web_API5 *6 * Local configuration:7 *8 * To configure locally, add localsettings.js to this directory and export a9 * setup function.10 *11 * example:12 * exports.setup = function(parsoidConfig) {13 * parsoidConfig.setMwApi('localhost', { uri: 'http://localhost/wiki' });14 * };15 *16 * (See localsettings.js.example for more options to setMwApi.)17 * Alternatively, specify a --config file explicitly. See --help for other18 * options.19 *20 * See https://www.mediawiki.org/wiki/Parsoid/Setup for more instructions.21 */22'use strict';23require('../lib/core-upgrade.js');24var cluster = require('cluster');25var path = require('path');26var util = require('util');27var fs = require('fs');28// process arguments29var opts = require("yargs")30 .usage("Usage: $0 [-h|-v] [--param[=val]]")31 .default({32 // Start a few more workers than there are cpus visible to the OS,33 // so that we get some degree of parallelism even on single-core34 // systems. A single long-running request would otherwise hold up35 // all concurrent short requests.36 n: require("os").cpus().length + 3,37 c: __dirname + '/localsettings.js',38 v: false,39 h: false,40 })41 .boolean([ "h", "v" ])42 .alias("h", "help")43 .alias("v", "version")44 .alias("c", "config")45 .alias("n", "num-workers");46// Help47var argv = opts.argv;48if (argv.h) {49 opts.showHelp();50 process.exit(0);51}52// Version53var meta = require(path.join(__dirname, "../package.json"));54if (argv.v) {55 console.log(meta.name + " " + meta.version);56 process.exit(0);57}58var ParsoidService = require("./ParsoidService.js").ParsoidService;59var ParsoidConfig = require("../lib/mediawiki.ParsoidConfig").ParsoidConfig;60var Logger = require("../lib/Logger.js").Logger;61var PLogger = require("../lib/ParsoidLogger.js");62var ParsoidLogger = PLogger.ParsoidLogger;63var ParsoidLogData = PLogger.ParsoidLogData;64// The global parsoid configuration object65var lsp = path.resolve(process.cwd(), argv.c);66var localSettings;67try {68 localSettings = require(lsp);69} catch (e) {70 console.error(71 "Cannot load local settings from %s. Please see: %s",72 lsp, path.join(__dirname, "localsettings.js.example")73 );74 process.exit(1);75}76var parsoidConfig = new ParsoidConfig(localSettings, null);77var locationData = {78 process: {79 name: cluster.isMaster ? "master" : "worker",80 pid: process.pid,81 },82 toString: function() {83 return util.format("[%s][%s]", this.process.name, this.process.pid);84 },85};86// Setup process logger87var logger = new Logger();88logger._createLogData = function(logType, logObject) {89 return new ParsoidLogData(logType, logObject, locationData);90};91logger._defaultBackend = ParsoidLogger.prototype._defaultBackend;92ParsoidLogger.prototype.registerLoggingBackends.call(93 logger, [ "fatal", "error", "warning", "info" ], parsoidConfig94);95process.on('uncaughtException', function(err) {96 logger.log('fatal', 'uncaught exception', err);97});98if (cluster.isMaster && argv.n > 0) {99 // Master100 var timeoutHandler;101 var timeouts = new Map();102 var spawn = function() {103 var worker = cluster.fork();104 worker.on('message', timeoutHandler.bind(null, worker));105 };106 // Kill cpu hogs107 timeoutHandler = function(worker, msg) {108 if (msg.type === 'startup') {109 // relay startup messages to parent process110 if (process.send) { process.send(msg); }111 }112 if (msg.type !== "timeout") { return; }113 if (msg.done) {114 clearTimeout(timeouts.get(msg.timeoutId));115 timeouts.delete(msg.timeoutId);116 } else if (msg.timeout) {117 var pid = worker.process.pid;118 timeouts.set(msg.timeoutId, setTimeout(function() {119 timeouts.delete(msg.timeoutId);120 if (worker.id in cluster.workers) {121 logger.log("warning", util.format(122 "Cpu timeout fetching: %s; killing worker %s.",123 msg.location, pid124 ));125 worker.kill("SIGKILL");126 spawn();127 }128 }, msg.timeout));129 }130 };131 // Fork workers132 var worker;133 logger.log("info", util.format("initializing %s workers", argv.n));134 for (var i = 0; i < argv.n; i++) {135 spawn();136 }137 cluster.on('exit', function(worker, code, signal) {138 if (!worker.suicide) {139 var pid = worker.process.pid;140 logger.log("warning", util.format("worker %s died (%s), restarting.", pid, code));141 spawn();142 }143 });144 var shutdownMaster = function() {145 logger.log("info", "shutting down, killing workers");146 cluster.disconnect(function() {147 logger.log("info", "exiting");148 process.exit(0);149 });150 };151 process.on('SIGINT', shutdownMaster);152 process.on('SIGTERM', shutdownMaster);153} else {154 // Worker155 var shutdownWorker = function() {156 logger.log("warning", "shutting down");157 process.exit(0);158 };159 process.on('SIGTERM', shutdownWorker);160 process.on('disconnect', shutdownWorker);161 // Enable heap dumps in /tmp on kill -USR2.162 // See https://github.com/bnoordhuis/node-heapdump/163 // For node 0.6/0.8: npm install heapdump@0.1.0164 // For 0.10: npm install heapdump165 process.on('SIGUSR2', function() {166 var heapdump = require('heapdump');167 logger.log("warning", "SIGUSR2 received! Writing snapshot.");168 process.chdir('/tmp');169 heapdump.writeSnapshot();170 });171 // Send heap usage statistics to Graphite at the requested sample rate172 if (parsoidConfig.performanceTimer && parsoidConfig.heapUsageSampleInterval) {173 setInterval(function() {174 var heapUsage = process.memoryUsage();175 parsoidConfig.performanceTimer.timing('heap.rss', '', heapUsage.rss);176 parsoidConfig.performanceTimer.timing('heap.total', '', heapUsage.heapTotal);177 parsoidConfig.performanceTimer.timing('heap.used', '', heapUsage.heapUsed);178 }, parsoidConfig.heapUsageSampleInterval);179 }180 var app = new ParsoidService(parsoidConfig, logger);...
Worker.js
Source:Worker.js
1var Asimov = require('./Asimov');2module.exports = Asimov.extend({3 'start': function (next) {4 var self = this;5 if (self.running) return;6 self.running = true;7 self._publicInterface.register = function () {8 throw new Error('Cannot register public interface after calling asimov.start()');9 };10 var started = new Date();11 process.on('message', self.onMessage);12 process.on('exit', self.shutdownWorker);13 process.on('SIGHUP', self.shutdownWorker);14 process.on('SIGTERM', self.shutdownWorker);15 process.on('SIGINT', self.shutdownWorker);16 var amount = self.getSequence('preinit').length + self.getSequence('init').length + self.getSequence('postinit').length;17 if (!amount) {18 self.publish('app:started');19 process.send && process.send({20 'event': 'app:started',21 'initializers': amount22 });23 return next && next();24 }25 asimov.config('state', 'starting');26 self.runSequence('preinit').done(function () {27 self.runSequence('init').done(function () {28 self.runSequence('postinit').done(function () {29 asimov.config('state', 'running');30 self.publish('app:started');31 process.send && process.send({32 'event': 'app:started',33 'initializers': amount,34 'started': started.valueOf()35 });36 if (typeof next === 'function') next();37 }).fail(self.error);38 }).fail(self.error);39 }).fail(self.error);40 return self.publicInterface();41 },42 'onMessage': function (data) {43 var self = this;44 // console.log('worker received', data);45 },46 // more or less only here to catch the "exit" event47 'terminateWorker': function () {48 process.exit();49 },50 'shutdownWorker': function () {51 var self = this;52 if (!self._shutdown) {53 asimov.config('state', 'stopping');54 self._shutdown = true;55 process.connected && process.disconnect();56 var killSelf = setTimeout(function () {57 process.exit();58 }, 3 * 1000);59 killSelf.unref();60 self.runSequence('shutdown');61 }62 }...
luna.js
Source:luna.js
...52 setTimeout(function() {53 prevWorker.kill();54 }, 60000);55 workersKilled++;56 shutdownWorker();57 });58 newWorker.on("message", handleMsg);59 }60 shutdownWorker();61 };62} else {63 var backend = require("./backend");...
app.js
Source:app.js
...16 () => () => {}, // Empty graceful shutdown function17 ),18 ]),19 ([ shutdownManager, shutdownWorker ]) => async () => {20 await shutdownWorker()21 await shutdownManager()22 },23 shutdownFunction => setupProcessHandlers(logger, shutdownFunction),...
Using AI Code Generation
1Cypress.on('uncaught:exception', (err, runnable) => {2 if (err.message.includes('ResizeObserver loop limit exceeded')) {3 }4 })5 describe('My First Test', () => {6 it('Does not do much!', () => {7 expect(true).to.equal(true)8 })9 })10 Cypress.on('uncaught:exception', (err, runnable) => {11 if (err.message.includes('ResizeObserver loop limit exceeded')) {12 }13 })14 describe('My First Test', () => {15 it('Does not do much!', () => {16 expect(true).to.equal(true)17 })18 })19 Cypress.on('uncaught:exception', (err, runnable) => {20 if (err.message.includes('ResizeObserver loop limit exceeded')) {21 }22 })23 describe('My First Test', () => {24 it('Does not do much!', () => {25 expect(true).to.equal(true)26 })27 })28 Cypress.on('uncaught:exception', (err, runnable) => {29 if (err.message.includes('ResizeObserver loop limit exceeded')) {30 }31 })32 describe('My First Test', () => {33 it('Does not do much!', () => {34 expect(true).to.equal(true)35 })36 })37 Cypress.on('uncaught:exception', (err, runnable) => {38 if (err.message.includes('ResizeObserver loop limit exceeded')) {39 }40 })41 describe('My First Test', () => {42 it('Does not do much!', () => {43 expect(true).to.equal(true)44 })45 })46 Cypress.on('uncaught:exception', (err, runnable)
Using AI Code Generation
1Cypress.on('uncaught:exception', (err, runnable) => {2 })3 describe('My First Test', function() {4 it('Does not do much!', function() {5 cy.contains('type').click()6 cy.url().should('include', '/commands/actions')7 cy.get('.action-email')8 .type('fake@email')9 .should('have.value', 'fake@email')10 })11 })
Using AI Code Generation
1cy.shutdownWorker()2### `cy.shutdownWorkers()`3cy.shutdownWorkers()4### `cy.shutdownWorkers({ force: true })`5cy.shutdownWorkers({ force: true })6### `cy.shutdownWorkers({ force: false })`7cy.shutdownWorkers({ force: false })8### `cy.getWorker()`9cy.getWorker('worker-1')10### `cy.getAllWorkers()`11cy.getAllWorkers()12### `cy.getWorkerState()`13cy.getWorkerState('worker-1')14### `cy.getAllWorkersState()`15cy.getAllWorkersState()16### `cy.getWorkerMessage()`17cy.getWorkerMessage('worker-1')18### `cy.getAllWorkersMessage()`19cy.getAllWorkersMessage()20### `cy.getWorkerError()`21cy.getWorkerError('worker-1')22### `cy.getAllWorkersError()`23cy.getAllWorkersError()24### `cy.getWorkerOnMessage()`
Using AI Code Generation
1Cypress.shutdownWorker()2Cypress.restartWorker()3Cypress.restartAndClearCache()4Cypress.route('GET', '/users', 'fixture:users')5Cypress.run()6Cypress.server()7Cypress.setCookie('token', '123ABC')8Cypress.task('clear:database')9Cypress.then()10Cypress.uncaught()
Cypress Tutorial
Cypress is a renowned Javascript-based open-source, easy-to-use end-to-end testing framework primarily used for testing web applications. Cypress is a relatively new player in the automation testing space and has been gaining much traction lately, as evidenced by the number of Forks (2.7K) and Stars (42.1K) for the project. LambdaTest’s Cypress Tutorial covers step-by-step guides that will help you learn from the basics till you run automation tests on LambdaTest.
Chapters:
- What is Cypress? -
- Why Cypress? - Learn why Cypress might be a good choice for testing your web applications.
- Features of Cypress Testing - Learn about features that make Cypress a powerful and flexible tool for testing web applications.
- Cypress Drawbacks - Although Cypress has many strengths, it has a few limitations that you should be aware of.
- Cypress Architecture - Learn more about Cypress architecture and how it is designed to be run directly in the browser, i.e., it does not have any additional servers.
- Browsers Supported by Cypress - Cypress is built on top of the Electron browser, supporting all modern web browsers. Learn browsers that support Cypress.
- Selenium vs Cypress: A Detailed Comparison - Compare and explore some key differences in terms of their design and features.
- Cypress Learning: Best Practices - Take a deep dive into some of the best practices you should use to avoid anti-patterns in your automation tests.
- How To Run Cypress Tests on LambdaTest? - Set up a LambdaTest account, and now you are all set to learn how to run Cypress tests.
Certification
You can elevate your expertise with end-to-end testing using the Cypress automation framework and stay one step ahead in your career by earning a Cypress certification. Check out our Cypress 101 Certification.
YouTube
Watch this 3 hours of complete tutorial to learn the basics of Cypress and various Cypress commands with the Cypress testing at LambdaTest.
Run Cypress automation tests on LambdaTest cloud grid
Perform automation testing on 3000+ real desktop and mobile devices online.
Try LambdaTest Now !!
Get 100 minutes of automation test minutes FREE!!
Was this article helpful?
