94 _WampConnection = RegisterWampClient() |
94 _WampConnection = RegisterWampClient() |
95 AddToDoBeforeQuit(reactor.stop) |
95 AddToDoBeforeQuit(reactor.stop) |
96 reactor.run(installSignalHandlers=False) |
96 reactor.run(installSignalHandlers=False) |
97 |
97 |
98 def WampSessionProcMapper(funcname): |
98 def WampSessionProcMapper(funcname): |
|
99 wampfuncname = '.'.join((ID,funcname)) |
99 def catcher_func(*args,**kwargs): |
100 def catcher_func(*args,**kwargs): |
100 global _WampSession |
101 global _WampSession |
101 if _WampSession is not None : |
102 if _WampSession is not None : |
102 try: |
103 try: |
103 return threads.blockingCallFromThread( |
104 return threads.blockingCallFromThread( |
104 reactor, _WampSession.call, funcname, |
105 reactor, _WampSession.call, wampfuncname, |
105 *args,**kwargs) |
106 *args,**kwargs) |
106 except TransportLost, e: |
107 except TransportLost, e: |
107 confnodesroot.logger.write_error("Connection lost!\n") |
108 confnodesroot.logger.write_error("Connection lost!\n") |
108 confnodesroot._SetConnector(None) |
109 confnodesroot._SetConnector(None) |
109 except Exception,e: |
110 except Exception,e: |