diff --git a/lib/rpc-server/acceptors/tcp-acceptor.js b/lib/rpc-server/acceptors/tcp-acceptor.js index ad08eb0..dc9e236 100644 --- a/lib/rpc-server/acceptors/tcp-acceptor.js +++ b/lib/rpc-server/acceptors/tcp-acceptor.js @@ -16,6 +16,7 @@ var Acceptor = function(opts, cb) { this.sockets = {}; this.msgQueues = {}; this.cb = cb; + this.socketId = 1; }; util.inherits(Acceptor, EventEmitter); @@ -40,7 +41,9 @@ pro.listen = function(port) { }); this.server.on('connection', function(socket) { + socket.id = self.socketId; self.sockets[socket.id] = socket; + self.socketId++; socket.composer = new Composer({ maxLength: self.pkgSize }); @@ -173,7 +176,3 @@ var flush = function(acceptor) { module.exports.create = function(opts, cb) { return new Acceptor(opts || {}, cb); }; - -process.on('SIGINT', function() { - process.exit(); -}); \ No newline at end of file