From 7b6a6cb94c8c2abc449351a1238227f9b10b0872 Mon Sep 17 00:00:00 2001
From: RaNaN <Mast3rRaNaN@hotmail.de>
Date: Mon, 8 Jun 2009 12:23:28 +0200
Subject: core able to push data to gui, proxy support: closed #1

---
 module/remote/SocketServer.py | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

(limited to 'module/remote/SocketServer.py')

diff --git a/module/remote/SocketServer.py b/module/remote/SocketServer.py
index c519d8a3b..e5932bb6e 100644
--- a/module/remote/SocketServer.py
+++ b/module/remote/SocketServer.py
@@ -24,6 +24,20 @@ class ServerThread(threading.Thread):
         asyncore.loop()
         print "loop closed"
 
+    def sockets(self):
+        """returns all connected sockets in a list"""
+        sockets = []
+        for value in asyncore.socket_map.values():
+            if SecondaryServerSocket == value.__class__:
+                sockets.append(value)
+
+        return sockets
+
+    def push_all(self, obj):
+        """push obj to all sockets"""
+        for socket in self.sockets():
+            socket.push_obj(obj)
+
 
 class MainServerSocket(asyncore.dispatcher):
     def __init__(self, port, pycore):
@@ -61,3 +75,6 @@ class SecondaryServerSocket(asynchat.async_chat):
     def handle_close(self):
         print "Disconnected from", self.getpeername()
         self.close()
+    def push_obj(self, obj):
+        obj = self.handler.encrypt(obj)
+        self.push(obj)
-- 
cgit v1.2.3