From fdafb72c343ab983125cfc73e0265af9e692c23f Mon Sep 17 00:00:00 2001
From: barisusakli <barisusakli@gmail.com>
Date: Wed, 3 Sep 2014 17:22:29 -0400
Subject: [PATCH] removed getUserSockets for chat

emit to users rooms directly
---
 loader.js                |  2 +-
 src/socket.io/modules.js | 24 +++++++++---------------
 2 files changed, 10 insertions(+), 16 deletions(-)

diff --git a/loader.js b/loader.js
index e38a3984c1..f5399bd899 100644
--- a/loader.js
+++ b/loader.js
@@ -106,7 +106,7 @@ Loader.init = function() {
 		silent: true
 	});
 
-	for(var x=0;x<numCPUs;x++) {
+	for(var x=0;x<4;x++) {
 		// Only the first worker sets up templates/sounds/jobs/etc
 		cluster.fork({ cluster_setup: x === 0 });
 	}
diff --git a/src/socket.io/modules.js b/src/socket.io/modules.js
index 0be1b64a5b..de9936db6e 100644
--- a/src/socket.io/modules.js
+++ b/src/socket.io/modules.js
@@ -204,22 +204,18 @@ SocketModules.chats.send = function(socket, data, callback) {
 
 		// Recipient
 		SocketModules.chats.pushUnreadCount(touid);
-		server.getUserSockets(touid).forEach(function(s) {
-			s.emit('event:chats.receive', {
-				withUid: socket.uid,
-				message: message,
-				self: 0
-			});
+		server.in('uid_' + touid).emit('event:chats.receive', {
+			withUid: socket.uid,
+			message: message,
+			self: 0
 		});
 
 		// Sender
 		SocketModules.chats.pushUnreadCount(socket.uid);
-		server.getUserSockets(socket.uid).forEach(function(s) {
-			s.emit('event:chats.receive', {
-				withUid: touid,
-				message: message,
-				self: 1
-			});
+		server.in('uid_' + socket.uid).emit('event:chats.receive', {
+			withUid: touid,
+			message: message,
+			self: 1
 		});
 	});
 };
@@ -246,9 +242,7 @@ SocketModules.chats.pushUnreadCount = function(uid) {
 		if (err) {
 			return;
 		}
-		server.getUserSockets(uid).forEach(function(s) {
-			s.emit('event:unread.updateChatCount', null, unreadCount);
-		});
+		server.in('uid_' + uid).emit('event:unread.updateChatCount', null, unreadCount);
 	});
 };