Commit f991cee5 authored by Anael Beutot's avatar Anael Beutot
Browse files

Tag request done is the same thread as pyev loop.

parent 88a21dac

ccnode/node.py

+3 −2
Original line number Diff line number Diff line
@@ -7,7 +7,7 @@ from functools import partial 


import pyev

from sjrpc.core import RpcConnection

from sjrpc.utils import ConnectionProxy, RpcHandler

from sjrpc.utils import ConnectionProxy, RpcHandler, threadless



from ccnode import __version__

from ccnode.config import NodeConfigParser
@@ -168,7 +168,7 @@ class MainLoop(object): 
        )

        # handlers

        self.rpc_handler = dict(

            get_tags=partial(get_tags, self.tag_db['__main__']),

            get_tags=partial(threadless(get_tags), self.tag_db['__main__']),

            sub_tags=self.sub_tags,

        )
@@ -176,6 +176,7 @@ class MainLoop(object): 
        self.registered_plugins = set()



    # RPC handlers definitions

    @threadless

    def sub_tags(self, sub_id, tags=None, noresolve_tags=None):

        if sub_id == '__main__':

            # FIXME should we raise ?