YUKI Hiroshi
null+****@clear*****
Fri Oct 18 15:22:03 JST 2013
YUKI Hiroshi 2013-10-18 15:22:03 +0900 (Fri, 18 Oct 2013) New Revision: e216cb93a5bde46ba75f9df1e65a3cb4d6097515 https://github.com/droonga/express-droonga/commit/e216cb93a5bde46ba75f9df1e65a3cb4d6097515 Message: Mark dirty sections with "WORKAROUND" notation comments Modified files: lib/adapter/socket.io.js Modified: lib/adapter/socket.io.js (+8 -0) =================================================================== --- lib/adapter/socket.io.js 2013-10-18 15:16:39 +0900 (c6e91ce) +++ lib/adapter/socket.io.js 2013-10-18 15:22:03 +0900 (c88f581) @@ -130,6 +130,7 @@ exports.register = function(application, server, params) { definition: definition }); }); +// =========================WORKAROUND========================== // "watch" command defined in api/socket.io.js var watchSubscribers = {}; var watchNotificationHandler = function(envelope) { @@ -143,6 +144,7 @@ exports.register = function(application, server, params) { }); }; connection.on('watch.notification', watchNotificationHandler); +// /========================/WORKAROUND========================== var io = socketIo.listen(server); io.sockets.on('connection', function(socket) { @@ -167,8 +169,10 @@ exports.register = function(application, server, params) { socket, { onResponse: function() { +// =========================WORKAROUND========================== if (!watchSubscribers[watchSubscriber]) watchSubscribers[watchSubscriber] = socket; +// ========================/WORKAROUND========================== } } ) @@ -182,8 +186,10 @@ exports.register = function(application, server, params) { socket, { onResponse: function() { +// =========================WORKAROUND========================== if (watchSubscribers[watchSubscriber]) delete watchSubscribers[watchSubscriber]; +// ========================/WORKAROUND========================== } } ) @@ -200,7 +206,9 @@ exports.register = function(application, server, params) { connection.on('error', errorHandler); socket.on('disconnect', function() { +// =========================WORKAROUND========================== delete watchSubscribers[watchSubscriber]; +// ========================/WORKAROUND========================== connection.removeListener('error', errorHandler); socket.removeAllListeners(); }); -------------- next part -------------- HTML����������������������������...Download