From a5a8cdc9dda15fc8866bc4624170303372edd383 Mon Sep 17 00:00:00 2001 From: flamefox Date: Mon, 27 Mar 2017 13:25:20 +0800 Subject: [PATCH] fix acceptor error --- lib/rpc-server/acceptors/tcp-acceptor.js | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) 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