kmip/services/server/server.py
def stop(self):
        """
        Stop the server.

        Halt server client connections and clean up any existing connection
        threads.

        Raises:
            NetworkingError: Raised if a failure occurs while sutting down
                or closing the TLS server socket.
        """
        self._logger.info("Cleaning up remaining connection threads.")

        for thread in threading.enumerate():
            if thread is not threading.current_thread():
                try:
                    thread.join(10.0)
                except Exception as e:
                    self._logger.info(
                        "Error occurred while attempting to cleanup thread: "
                        "{0}".format(thread.name)
                    )
                    self._logger.exception(e)
                else:
                    if thread.is_alive():
                        self._logger.warning(
                            "Cleanup failed for thread: {0}. Thread is "
                            "still alive".format(thread.name)
                        )
                    else:
                        self._logger.info(
                            "Cleanup succeeded for thread: {0}".format(
                                thread.name
                            )
                        )

        self._logger.info("Shutting down server socket handler.")
        try:
            self._socket.shutdown(socket.SHUT_RDWR)
            self._socket.close()
        except Exception as e:
            self._logger.exception(e)
            raise exceptions.NetworkingError(
                "Server failed to shutdown socket handler."
            )

        if hasattr(self, "policy_monitor"):
            try:
                self.policy_monitor.stop()
                self.policy_monitor.join()
            except Exception as e:
                self._logger.exception(e)
                raise exceptions.ShutdownError(
                    "Server failed to clean up the policy monitor."
                )
def stop(self):
        self._logger.info("Cleaning up remaining connection threads.")

        for thread in threading.enumerate():
            if thread is not threading.current_thread():
                try:
                    thread.join(10.0)
                except Exception as e:
                    self._logger.info(
                        "Error occurred while attempting to cleanup thread: "
                        "{0}".format(thread.name)
                    )
                    self._logger.exception(e)
                else:
                    if thread.is_alive():
                        self._logger.warning(
                            "Cleanup failed for thread: {0}. Thread is "
                            "still alive".format(thread.name)
                        )
                    else:
                        self._logger.info(
                            "Cleanup succeeded for thread: {0}".format(
                                thread.name
                            )
                        )

        self._logger.info("Shutting down server socket handler.")
        try:
            self._socket.shutdown(socket.SHUT_RDWR)
            self._socket.close()
        except Exception as e:
            self._logger.exception(e)
            raise exceptions.NetworkingError(
                "Server failed to shutdown socket handler."
            )

        if hasattr(self, "policy_monitor"):
            try:
                self.policy_monitor.stop()
                self.policy_monitor.join()
            except Exception as e:
                self._logger.exception(e)
                raise exceptions.ShutdownError(
                    "Server failed to clean up the policy monitor."
                )
def stop ( self ) : self . _logger . info ( "Cleaning up remaining connection threads." ) for thread in threading . enumerate ( ) : if thread is not threading . current_thread ( ) : try : thread . join ( 10.0 ) except Exception as e : self . _logger . info ( "Error occurred while attempting to cleanup thread: " "{0}" . format ( thread . name ) ) self . _logger . exception ( e ) else : if thread . is_alive ( ) : self . _logger . warning ( "Cleanup failed for thread: {0}. Thread is " "still alive" . format ( thread . name ) ) else : self . _logger . info ( "Cleanup succeeded for thread: {0}" . format ( thread . name ) ) self . _logger . info ( "Shutting down server socket handler." ) try : self . _socket . shutdown ( socket . SHUT_RDWR ) self . _socket . close ( ) except Exception as e : self . _logger . exception ( e ) raise exceptions . NetworkingError ( "Server failed to shutdown socket handler." ) if hasattr ( self , "policy_monitor" ) : try : self . policy_monitor . stop ( ) self . policy_monitor . join ( ) except Exception as e : self . _logger . exception ( e ) raise exceptions . ShutdownError ( "Server failed to clean up the policy monitor." )
Stop the server.

        Halt server client connections and clean up any existing connection
        threads.

        Raises:
            NetworkingError: Raised if a failure occurs while sutting down
                or closing the TLS server socket.
Stop the server .