oreolek/nmig
1
0
Fork 0
Code Releases Activity

migrating to typescript

Browse source
This commit is contained in:
Anatoly 2018-08-18 01:33:34 +03:00
parent 4c1f33d138
commit 6dd3d011b7
2 changed files with 3 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/DataPipeManager.ts
View file

@ -18,8 +18,7 @@
*
* @author Anatoly Khaytovich <anatolyuss@gmail.com>
*/
import { ChildProcess } from 'child_process';
import * as childProcess from 'child_process';
import { ChildProcess, fork } from 'child_process';
import * as path from 'path';
import log from './Logger';
import Conversion from './Conversion';
@ -116,7 +115,7 @@ async function pipeData(conversion: Conversion, dataLoaderPath: string, options:
return processConstraints(conversion);
}
const loaderProcess: ChildProcess = childProcess.fork(dataLoaderPath, options);
const loaderProcess: ChildProcess = fork(dataLoaderPath, options);
const bandwidth: number[] = fillBandwidth(conversion);
const chunksToLoad: any[] = bandwidth.map((index: number) => conversion._dataPool[index]);

3
src/Main.ts
View file

@ -29,7 +29,6 @@ import boot from './BootProcessor';
import { createStateLogsTable } from './MigrationStateManager';
import { createDataPoolTable, readDataPool } from './DataPoolManager';
import log from './Logger';
import { Stats } from 'fs';
export class Main {
/**
@ -90,7 +89,7 @@ export class Main {
public createLogsDirectory(self: Conversion): Promise<Conversion> {
return new Promise(resolve => {
console.log('\t--[DirectoriesManager.createLogsDirectory] Creating logs directory...');
fs.stat(self._logsDirPath, (directoryDoesNotExist: Error, stat: Stats) => {
fs.stat(self._logsDirPath, (directoryDoesNotExist: Error, stat: fs.Stats) => {
if (directoryDoesNotExist) {
fs.mkdir(self._logsDirPath, self._0777, e => {
if (e) {