394         # the client part has to be in a thread due to sqlite limitations

   394         # the client part has to be in a thread due to sqlite limitations

   395         t = threading.Thread(target=self._zmq_client, args=(done,))

   395         t = threading.Thread(target=self._zmq_client, args=(done,))

   396         t.start()

   396         t.start()

   397 

   397 

   398         zmq_server = ZMQRepositoryServer(self.repo)

   398         zmq_server = ZMQRepositoryServer(self.repo)

   400 

   400 

   401         t2 = threading.Thread(target=self._zmq_quit, args=(done, zmq_server,))

   401         t2 = threading.Thread(target=self._zmq_quit, args=(done, zmq_server,))

   402         t2.start()

   402         t2.start()

   403 

   403 

   404         zmq_server.run()

   404         zmq_server.run()

   414             time.sleep(0.1)

   414             time.sleep(0.1)

   415         srv.quit()

   415         srv.quit()

   416 

   416 

   417     def _zmq_client(self, done):

   417     def _zmq_client(self, done):

   418         try:

   418         try:

   420                           initlog=False) # don't reset logging configuration

   420                           initlog=False) # don't reset logging configuration

   421             try:

   421             try:

   422                 cnx.load_appobjects(subpath=('entities',))

   422                 cnx.load_appobjects(subpath=('entities',))

   423                 # check we can get the schema

   423                 # check we can get the schema

   424                 schema = cnx.get_schema()

   424                 schema = cnx.get_schema()