diff --git a/src/vs/base/parts/ipc/node/ipc.net.ts b/src/vs/base/parts/ipc/node/ipc.net.ts index cd6474e039c..c802f0bd42d 100644 --- a/src/vs/base/parts/ipc/node/ipc.net.ts +++ b/src/vs/base/parts/ipc/node/ipc.net.ts @@ -6,7 +6,6 @@ 'use strict'; import { Socket, Server as NetServer, createConnection, createServer } from 'net'; -import { TPromise } from 'vs/base/common/winjs.base'; import { Event, Emitter, once, mapEvent, fromNodeEventEmitter } from 'vs/base/common/event'; import { IMessagePassingProtocol, ClientConnectionEvent, IPCServer, IPCClient } from 'vs/base/parts/ipc/node/ipc'; import { join } from 'path'; @@ -247,10 +246,10 @@ export class Client extends IPCClient { } } -export function serve(port: number): TPromise; -export function serve(namedPipe: string): TPromise; -export function serve(hook: any): TPromise { - return new TPromise((c, e) => { +export function serve(port: number): Thenable; +export function serve(namedPipe: string): Thenable; +export function serve(hook: any): Thenable { + return new Promise((c, e) => { const server = createServer(); server.on('error', e); @@ -261,11 +260,11 @@ export function serve(hook: any): TPromise { }); } -export function connect(options: { host: string, port: number }, clientId: string): TPromise; -export function connect(port: number, clientId: string): TPromise; -export function connect(namedPipe: string, clientId: string): TPromise; -export function connect(hook: any, clientId: string): TPromise { - return new TPromise((c, e) => { +export function connect(options: { host: string, port: number }, clientId: string): Thenable; +export function connect(port: number, clientId: string): Thenable; +export function connect(namedPipe: string, clientId: string): Thenable; +export function connect(hook: any, clientId: string): Thenable { + return new Promise((c, e) => { const socket = createConnection(hook, () => { socket.removeListener('error', e); c(Client.fromSocket(socket, clientId)); diff --git a/src/vs/code/electron-browser/sharedProcess/sharedProcessMain.ts b/src/vs/code/electron-browser/sharedProcess/sharedProcessMain.ts index 8d33d957398..ff48ec7cb67 100644 --- a/src/vs/code/electron-browser/sharedProcess/sharedProcessMain.ts +++ b/src/vs/code/electron-browser/sharedProcess/sharedProcessMain.ts @@ -145,11 +145,11 @@ function main(server: Server, initData: ISharedProcessInitData, configuration: I }); } -function setupIPC(hook: string): TPromise { - function setup(retry: boolean): TPromise { +function setupIPC(hook: string): Thenable { + function setup(retry: boolean): Thenable { return serve(hook).then(null, err => { if (!retry || platform.isWindows || err.code !== 'EADDRINUSE') { - return TPromise.wrapError(err); + return Promise.reject(err); } // should retry, not windows and eaddrinuse @@ -158,7 +158,7 @@ function setupIPC(hook: string): TPromise { client => { // we could connect to a running instance. this is not good, abort client.dispose(); - return TPromise.wrapError(new Error('There is an instance already running.')); + return Promise.reject(new Error('There is an instance already running.')); }, err => { // it happens on Linux and OS X that the pipe is left behind @@ -167,7 +167,7 @@ function setupIPC(hook: string): TPromise { try { fs.unlinkSync(hook); } catch (e) { - return TPromise.wrapError(new Error('Error deleting the shared ipc hook.')); + return Promise.reject(new Error('Error deleting the shared ipc hook.')); } return setup(false); diff --git a/src/vs/code/electron-main/main.ts b/src/vs/code/electron-main/main.ts index 8ca74864a3f..46007f71cf3 100644 --- a/src/vs/code/electron-main/main.ts +++ b/src/vs/code/electron-main/main.ts @@ -111,7 +111,7 @@ class ExpectedError extends Error { public readonly isExpected = true; } -function setupIPC(accessor: ServicesAccessor): TPromise { +function setupIPC(accessor: ServicesAccessor): Thenable { const logService = accessor.get(ILogService); const environmentService = accessor.get(IEnvironmentService); const requestService = accessor.get(IRequestService); @@ -136,7 +136,7 @@ function setupIPC(accessor: ServicesAccessor): TPromise { return promise; } - function setup(retry: boolean): TPromise { + function setup(retry: boolean): Thenable { return serve(environmentService.mainIPCHandle).then(server => { // Print --status usage info @@ -163,7 +163,7 @@ function setupIPC(accessor: ServicesAccessor): TPromise { return server; }, err => { if (err.code !== 'EADDRINUSE') { - return TPromise.wrapError(err); + return Promise.reject(err); } // Since we are the second instance, we do not want to show the dock @@ -181,7 +181,7 @@ function setupIPC(accessor: ServicesAccessor): TPromise { logService.error(msg); client.dispose(); - return TPromise.wrapError(new Error(msg)); + return Promise.reject(new Error(msg)); } // Show a warning dialog after some timeout if it takes long to talk to the other instance @@ -203,14 +203,14 @@ function setupIPC(accessor: ServicesAccessor): TPromise { // Process Info if (environmentService.args.status) { return service.getMainProcessInfo().then(info => { - return diagnosticsService.printDiagnostics(info).then(() => TPromise.wrapError(new ExpectedError())); + return diagnosticsService.printDiagnostics(info).then(() => Promise.reject(new ExpectedError())); }); } // Log uploader if (typeof environmentService.args['upload-logs'] !== 'undefined') { return uploadLogs(channel, requestService, environmentService) - .then(() => TPromise.wrapError(new ExpectedError())); + .then(() => Promise.reject(new ExpectedError())); } logService.trace('Sending env to running instance...'); @@ -225,7 +225,7 @@ function setupIPC(accessor: ServicesAccessor): TPromise { clearTimeout(startupWarningDialogHandle); } - return TPromise.wrapError(new ExpectedError('Sent env to running instance. Terminating...')); + return Promise.reject(new ExpectedError('Sent env to running instance. Terminating...')); }); }, err => { @@ -237,7 +237,7 @@ function setupIPC(accessor: ServicesAccessor): TPromise { ); } - return TPromise.wrapError(err); + return Promise.reject(err); } // it happens on Linux and OS X that the pipe is left behind @@ -247,7 +247,7 @@ function setupIPC(accessor: ServicesAccessor): TPromise { fs.unlinkSync(environmentService.mainIPCHandle); } catch (e) { logService.warn('Could not delete obsolete instance handle', e); - return TPromise.wrapError(e); + return Promise.reject(e); } return setup(false);