"""
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
"""
from thbase.util.handlers import ExceptionHandler, MessageType
from thbase.hbase.ttypes import TException

import logging
import time

logger = logging.getLogger(__name__)


class Executor(object):
    def __init__(self, retry_times, retry_timeout, master):
        self._retry_times = retry_times
        self._retry_timeout = retry_timeout
        self._master = master
        self.handler = ExceptionHandler(self._master)

    def call(self, func):
        """
        Execute a specific function with given parameters.
        If the system meets an exception the exception handler will try to handle it.
        If the exception is critical and can not be handled, it will be raised and interrupt the system.
        If the exception is acceptable, the system will retry the operation for several times (set in config).
        After retrying, if the system still cannot get a valid value,
        the function will be marked as failed and return a False.
        Args:
            func: A callable function.

        Returns:
            For Put, Delete operations: True if success, False otherwise.
            For Get, Scan operations: A list of results, False otherwise.
        """
        if not callable(func):
            raise ValueError("A callable function needed here but got {}.".format(type(func)))
        for i in range(self._retry_times + 1):
            try:
                result = func()
                # if result is None, the func is Put, or Delete,
                # so should return a bool to represent if the operation successes.
                if result is None:
                    return True
                # when result is not None, it contains a list of TResult objects with Get and Scan operation.
                # so here return the list directly.
                return result
            except TException as e:
                if not self.handler.handle(MessageType.ERROR, value=e):
                    logger.error("There occurs an error that can not be handled. {}. "
                                 "System is shutdown.".format(e.message))
                    raise e
                else:
                    logger.warn("An error occurs, {}. Redo the operation after {} seconds.".
                                format(e.message, self._retry_timeout))
            time.sleep(self._retry_timeout)
        # this False means the operation failed after retry N times.
        return False

"""
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
"""
from thbase.util.handlers import ExceptionHandler, MessageType
from thbase.hbase.ttypes import TException

import logging
import time

logger = logging.getLogger(__name__)


class Executor(object):
    def __init__(self, retry_times, retry_timeout, master):
        self._retry_times = retry_times
        self._retry_timeout = retry_timeout
        self._master = master
        self.handler = ExceptionHandler(self._master)

    def call(self, func):
        """
        Execute a specific function with given parameters.
        If the system meets an exception the exception handler will try to handle it.
        If the exception is critical and can not be handled, it will be raised and interrupt the system.
        If the exception is acceptable, the system will retry the operation for several times (set in config).
        After retrying, if the system still cannot get a valid value,
        the function will be marked as failed and return a False.
        Args:
            func: A callable function.

        Returns:
            For Put, Delete operations: True if success, False otherwise.
            For Get, Scan operations: A list of results, False otherwise.
        """
        if not callable(func):
            raise ValueError("A callable function needed here but got {}.".format(type(func)))
        for i in range(self._retry_times + 1):
            try:
                result = func()
                # if result is None, the func is Put, or Delete,
                # so should return a bool to represent if the operation successes.
                if result is None:
                    return True
                # when result is not None, it contains a list of TResult objects with Get and Scan operation.
                # so here return the list directly.
                return result
            except TException as e:
                if not self.handler.handle(MessageType.ERROR, value=e):
                    logger.error("There occurs an error that can not be handled. {}. "
                                 "System is shutdown.".format(e.message))
                    raise e
                else:
                    logger.warn("An error occurs, {}. Redo the operation after {} seconds.".
                                format(e.message, self._retry_timeout))
            time.sleep(self._retry_timeout)
        # this False means the operation failed after retry N times.
        return False

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at      http://www.apache.org/licenses/LICENSE-2.0  Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Execute a specific function with given parameters.         If the system meets an exception the exception handler will try to handle it.         If the exception is critical and can not be handled, it will be raised and interrupt the system.         If the exception is acceptable, the system will retry the operation for several times (set in config).         After retrying, if the system still cannot get a valid value,         the function will be marked as failed and return a False.         Args:             func: A callable function.          Returns:             For Put, Delete operations: True if success, False otherwise.             For Get, Scan operations: A list of results, False otherwise. # if result is None, the func is Put, or Delete, # so should return a bool to represent if the operation successes. # when result is not None, it contains a list of TResult objects with Get and Scan operation. # so here return the list directly. # this False means the operation failed after retry N times.