Robotics Service Bus

Only happens if the Python process is the BusServer!

Now hands upon call to deactivate:

ip-129-70-135-195:~ swrede$ ipython
Python 2.7.1 (r271:86832, Jun 25 2011, 05:09:01) 
Type "copyright", "credits" or "license" for more information.

IPython 0.12 -- An enhanced Interactive Python.
?         -> Introduction and overview of IPython's features.
%quickref -> Quick reference.
help      -> Python's own help system.
object?   -> Details about 'object', use 'object??' for extra details.

In [1]: from rsb import createInformer, Scope

In [2]: i = createInformer(Scope("/example/informer"),dataType=str)

In [3]: i.publishData("sdadsfasdf")
Out[3]: Event[id = EventId(UUID('963ceab4-ef0d-40cf-bcaa-b5168b20ab68'), 0), scope = 'Scope[/example/informer/]', data = 'sdadsfasdf', type = '<type 'str'>', metaData = MetaData[create = 1340902160.96, send = 1340902160.96, receive = None, deliver = None, userTimes = {}, userInfos = {}], causes = []]

In [4]: i.deactivate()
No handlers could be found for logger "rsb.transport.socket.BusServer" 

Create a test for this and build rsb-python also on the mac slave. Then we have a reproducible setup.

Almost... ;) While I now get a pure RSB-Python BusServer activated and deactivated, the C++ client can not connect anymore...

Output in Python is as follows:

In [6]: i = createInformer(Scope("/example/informer"),dataType=str)INFO:rsb.transport.socket.BusServer:Waiting for clients
In [6]: INFO:rsb.transport.socket.BusServer:Waiting for clients
In [6]: logging.basicConfig(level=logging.DEBUG)INFO:rsb.transport.socket.BusServer:Waiting for clients
In [6]: import loggingINFO:rsb.transport.socket.BusServer:Waiting for clients
logging.basicConfig(level=logging.DEBUG)INFO:rsb.transport.socket.BusServer:Waiting for clients
In [6]: i.publishData("sdadsfasdf")INFO:rsb.transport.socket.BusServer:Waiting for clients
INFO:rsb.transport.socket.BusServer:Waiting for clients
INFO:rsb.transport.socket.BusServer:Waiting for clients
INFO:rsb.transport.socket.BusServer:Waiting for clients
INFO:rsb.transport.socket.BusServer:Waiting for clients
INFO:rsb.transport.socket.BusServer:Accepted client ('127.0.0.1', 65500)
INFO:rsb.transport.socket.BusConnection:Receiving notifications
INFO:rsb.transport.socket.BusServer:Waiting for clients
WARNING:rsb.transport.socket.BusConnection:Receive error: [Errno 35] Resource temporarily unavailable
INFO:rsb.transport.socket.BusServer:Removing connection <BusConnection 1 handlers at 0x101600050>

And in C++:

ubi-1-216-55:latex swrede$ rsb_listener 
Listener setup finished. Waiting for messages on scope Scope[/example/informer/]
1340985973439 rsb.transport.socket.BusConnection [WARN]: Receive failure (error asio.misc:2) or incomplete message header (received 0 bytes); closing connection
1340985973439 rsb.transport.socket.BusConnection [ERROR]: Failed to disconnect (in handleReadLength): shutdown: Socket is not connected

Please try this:

Index: __init__.py
===================================================================
--- __init__.py    (revision 3684)
+++ __init__.py    (working copy)
@@ -547,6 +547,8 @@
             self.__logger.info('Waiting for clients')
             try:
                 socket, addr = self.__socket.accept()
+                if sys.platform == 'darwin':
+                    socket.timeout(None)
                 self.__logger.info('Accepted client %s', addr)
                 self.addConnection(BusConnection(socket_ = socket, isServer = True))
             except:

Unfortunate result: C++ BusClient hangs in handshake (I suppose). The sympton is that no output at all is printed from the C++ listener. The output of the Python process is as follows:

In [4]: i = createInformer(Scope("/example/informer"),dataType=str)
DEBUG:rsb.transport.socket.OutConnector:Using specified converter map for wire-type <type 'bytearray'>
DEBUG:rsb.eventprocessing.OutRouteConfigurator:Got new scope Scope[/example/informer/]
INFO:rsb.Informer:Activating informer
INFO:rsb.eventprocessing.OutRouteConfigurator:Activating configurator
INFO:rsb.transport.socket.OutConnector:Activating
INFO:rsb.transport.socket.OutConnector:Requested server role: auto
INFO:rsb.transport.socket.OutConnector:Trying to get bus server localhost:55555 (in server = auto mode)
INFO:rsb.transport.socket.BusServer:Opening listen socket 0.0.0.0:55555
INFO:rsb.transport.socket.BusServer:Starting acceptor thread
INFO:rsb.transport.socket.BusServer:Waiting for clients
INFO:rsb.transport.socket.BusServer:Adding connector <rsb.transport.socket.OutConnector object at 0x102bf3610>
INFO:rsb.transport.socket.OutConnector:Got <BusServer 0 connection(s) 1 connector(s) at 0x102d01ad0>

In [5]: INFO:rsb.transport.socket.BusServer:Waiting for clients
INFO:rsb.transport.socket.BusServer:Waiting for clients
INFO:rsb.transport.socket.BusServer:Waiting for clients
INFO:rsb.transport.socket.BusServer:Waiting for clients
INFO:rsb.transport.socket.BusServer:Waiting for clients
...

OK, I give up.

Noooooo... ;-)