close.js (1460B)
1 /** 2 * @license Apache-2.0 3 * 4 * Copyright (c) 2018 The Stdlib Authors. 5 * 6 * Licensed under the Apache License, Version 2.0 (the "License"); 7 * you may not use this file except in compliance with the License. 8 * You may obtain a copy of the License at 9 * 10 * http://www.apache.org/licenses/LICENSE-2.0 11 * 12 * Unless required by applicable law or agreed to in writing, software 13 * distributed under the License is distributed on an "AS IS" BASIS, 14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 15 * See the License for the specific language governing permissions and 16 * limitations under the License. 17 */ 18 19 'use strict'; 20 21 // MODULES // 22 23 var logger = require( 'debug' ); 24 var objectKeys = require( './../../../../keys' ); 25 var proc = require( './process.js' ); 26 var db = require( './children.js' ); 27 28 29 // VARIABLES // 30 31 var debug = logger( 'parallel:worker:close' ); 32 33 34 // MAIN // 35 36 /** 37 * Closes all child processes. 38 * 39 * @private 40 */ 41 function close() { // eslint-disable-line stdlib/no-redeclare 42 var keys; 43 var pid; 44 var i; 45 46 debug( 'Killing all child processes...' ); 47 keys = objectKeys( db ); 48 for ( i = 0; i < keys.length; i++ ) { 49 pid = keys[ i ]; 50 debug( 'Killing child process (pid: %d)...', pid ); 51 db[ pid ].kill(); 52 delete db[ pid ]; 53 } 54 // Disconnect this process from the parent to allow this process to gracefully close: 55 debug( 'Disconnecting worker from parent process...' ); 56 proc.disconnect(); 57 } 58 59 60 // EXPORTS // 61 62 module.exports = close;