Changeset 102

Timestamp:

04/15/02 12:19:52 (6 years ago)

Author:

sholloway

Message:

*** empty log message ***

Files:

• trunk/RBFoundation/RBFoundation/SmartSelect.py (modified) (4 diffs)
• trunk/RBJabber/RBJabber/Client.py (modified) (1 diff)
• trunk/RBJabber/RBJabber/JabberConnection.py (modified) (2 diffs)
• trunk/RBSkinning/support/scripts/.cvsignore (added)

trunk/RBFoundation/RBFoundation/SmartSelect.py

@@ -43 +43 @@
-
-class ClientBase(object):
+    """An abstract base class for creating "Smart Sockets" or other select.select able objects"""
+    #def fileno(self): return 0 ## override this, returning something that works with select.select, like socket.fileno
-    def _NeedsRead(self): return 0
-    #def _ProcessRead(self): pass  ## If there is no definition, then these will raise if not "overridden"
@@ -52 +54 @@
-#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
-
-
-
-
-
+
+
+
-    def Process(self, timeout=None):
+        """Uses select.select to wait on several file (proxy) handles in an object-oriented way."""
-        lstSelected = select.select(self.ReadList, self.WriteList, self.ErrorList, timeout)
-
@@ -65 +67 @@
-        return (lstSelected[0] or lstSelected[1] or lstSelected[2]) and 1 or 0
-
+    def ProcessPending(self, timeout=0.0):
+        """Calls Process until a timeout occurs."""
+        while self.Process(timeout):
+            pass
+        return 0
+
+#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+
+class SmartSelectClientBase(ClientBase, SmartSelectBase):
+    """Allows base classes of a smart select to be able to run "by themselves" as if they were their own SmartSelectors"""
+    def _getReadList(self): return self._NeedsRead() and [self] or []
+    ReadList = property(_getReadList)
+
+    def _getWriteList(self): return self._NeedsWrite() and [self] or []
+    WriteList = property(_getWriteList)
+
+    def _getErrorList(self): return self._NeedsError() and [self] or []
+    ErrorList = property(_getErrorList)
+    
-#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
-
-class SmartSelectList(SmartSelectBase, list):
+    """A list collection of Smart Sockets to aid in pseudo "non-blocking" socket programming.  
+    Note, this is very simalr to asyncore.dispatcher."""
+
+    def __call__(self, *args, **kw):
+        return apply(self.Process, args, kw)
+        
-    def _getReadList(self): return [x for x in self if x._NeedsRead()]
-    ReadList = property(_getReadList)
@@ -81 +108 @@
-
-class SmartSelectDict(SmartSelectBase, dict):
+    """A dictionary collection of Smart Sockets to aid in pseudo "non-blocking" socket programming.  
+    Note, this is very simalr to asyncore.dispatcher."""
+
+    def __call__(self, *args, **kw):
+        return apply(self.Process, args, kw)
+        
-    def _getReadList(self): return [x for x in self.itervalues() if x._NeedsRead()]
-    ReadList = property(_getReadList)

trunk/RBJabber/RBJabber/Client.py

@@ -155 +155 @@
-        return query
-
+    def SetData(self, namespace, xml):
+        self.SenddXML('''<iq id='%s' type='set'><query xmlns='%s'>%s</query></iq> ''' % (self._GetNextID(), namespace, xmlData))
+ 
+    def GetData(self, namespace, callback=None, xml=''):
+        return self.Query(namespace, '', callback, xml)
+
+    def Query(self, namespace, toJID='', callback=None, xml=''):
+        import iqQuery
+        query = iqQuery.iqQuery(self, callback)
+        query.SendQuery(namespace, toJID) 
+        return query
+
-    def Message(self, toJID, body, subject='', type='message', xml=''):
-        idMessage = self._GetNextID()

trunk/RBJabber/RBJabber/JabberConnection.py

@@ -54 +54 @@
-#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
-
-
+SmartSelect
-    #~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
-    #~ Constants / Variables / Etc. 
@@ -116 +116 @@
-        self._fileOut = fileOut
-
-    def Process(self, timeout=None):
-        lstSelected = select.select(self._NeedsRead() and [self] or [], self._NeedsWrite() and [self] or [], self._NeedsError() and [self] or [], timeout)
-
-        if lstSelected[0]: self._ProcessRead()
-        if lstSelected[1]: self._ProcessWrite()
-        if lstSelected[2]: self._ProcessError()
-
-        return (lstSelected[0] or lstSelected[1] or lstSelected[2]) and 1 or 0
-
-    #~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
-    #~ Private Methods