(self)
Stops the migration engine
Stops the migration engine
Stops the migration engine
def stop(self):
      """ Stops the migration engine """
      self.serverThread.shutdown()
      self.clientThread.shutdown()
      server_timeout = self.serverThread.timeout
      client_timeout = self.clientThread.timeout

      self.serverThread.join(server_timeout + 3)
      self.clientThread.join(client_timeout + 3)

      if self.serverThread.isAlive():
         logging.warning("warning: server thread not joined !")

      if self.clientThread.isAlive():
         logging.warning("warning: client thread not joined !")
def stop ( self ) : self . serverThread . shutdown ( ) self . clientThread . shutdown ( ) server_timeout = self . serverThread . timeout client_timeout = self . clientThread . timeout self . serverThread . join ( server_timeout + 3 ) self . clientThread . join ( client_timeout + 3 ) if self . serverThread . isAlive ( ) : logging . warning ( "warning: server thread not joined !" ) if self . clientThread . isAlive ( ) : logging . warning ( "warning: client thread not joined !" )