Added serialization and service module for RPC functionality.

setup.py

@@ -3,7 +3,7 @@
 from setuptools import setup
 from setuptools.extension import Extension
 
-modules = ['ropebuffer', 'channel', 'messenger']
+modules = ['ropebuffer', 'channel', 'messenger', 'serialize', 'service']
 
 extensions = [Extension(
         name ='socketless.%s' % module,

socketless/__init__.py

@@ -1,5 +1,7 @@
-__all__ = ['ropebuffer', 'channel', 'messenger', 'channelserver']
+__all__ = ['ropebuffer', 'channel', 'messenger', 'channelserver', 'service', 'serialize']
 
 import ropebuffer
 import messenger
 import channelserver
+import service
+import serialize

socketless/channel.pyx

@@ -9,6 +9,8 @@ from ropebuffer import RopeBuffer
 
 from syncless import coio
 
+import logging
+
 cdef extern from "stdint.h":
 	ctypedef unsigned int uint32_t
 
@@ -94,7 +96,7 @@ cdef class Channel:
 				self.buffer.add(read(self.socket))
 			size = self.unpack(self.header_spec, self.buffer.read(4))[0]
 			if not size:
-				return None
+				return ''
 			while self.buffer.len < size:
 				self.buffer.add(read(self.socket))
 			message = self.buffer.read(size)
@@ -104,8 +106,8 @@ cdef class Channel:
 
 	cpdef close(self):
 		if self.socket:
-			self.send('')
-			self.flush()
+            # self.send('')
+            # self.flush()
 			try:
 				self.socket.close()
 			except socket.error:

socketless/channelserver.py

@@ -33,8 +33,12 @@ def _serve(self):
             coio.stackless.schedule()
 
     def stop(self):
-        self.listening_tasklet.kill()
-        self.listening_tasklet = None
+        if self.listening_tasklet:
+            self.listening_tasklet.kill()
+            self.listening_tasklet = None
+        if self.listening_socket:
+            self.listening_socket.close()
+            self.listening_socket = None
 
     def serve_forever(self):
         self._serve()