File tree Expand file tree Collapse file tree 1 file changed +12
-2
lines changed Expand file tree Collapse file tree 1 file changed +12
-2
lines changed Original file line number Diff line number Diff line change @@ -3,6 +3,9 @@ var crypto = require('crypto');
3
3
var EventEmitter = require ( 'events' ) . EventEmitter ;
4
4
var domain = require ( 'domain' ) ;
5
5
var fork = require ( 'child_process' ) . fork ;
6
+ var os = require ( 'os' ) ;
7
+ var fs = require ( 'fs' ) ;
8
+ var wrench = require ( 'wrench' ) ;
6
9
7
10
var SocketCluster = function ( options ) {
8
11
var self = this ;
@@ -110,9 +113,16 @@ SocketCluster.prototype._init = function (options) {
110
113
} ;
111
114
112
115
if ( process . platform == 'win32' ) {
113
- self . _socketDirPath = '\\\\.\\pipe\\sc \\' + self . options . appName + '\\' ;
116
+ self . _socketDirPath = '\\\\.\\pipe\\socketcluster \\' + self . options . appName + '\\' ;
114
117
} else {
115
- self . _socketDirPath = '/sc/' + self . options . appName + '/' ;
118
+ var socketDir = os . tmpdir ( ) + '/socketcluster/' ;
119
+ if ( fs . existsSync ( socketDir ) ) {
120
+ wrench . rmdirSyncRecursive ( socketDir ) ;
121
+ }
122
+ fs . mkdirSync ( socketDir ) ;
123
+ socketDir += self . options . appName + '/' ;
124
+ fs . mkdirSync ( socketDir ) ;
125
+ self . _socketDirPath = socketDir ;
116
126
}
117
127
118
128
if ( self . options . balancerController ) {
You can’t perform that action at this time.
0 commit comments