searx.plugins.calculator Namespace Reference

Classes
class	SXNGPlugin

Functions
	_eval_expr (expr)
	_eval (node)
	handler (multiprocessing.Queue q, func, args, **kwargs)
	timeout_func (timeout, func, *args, **kwargs)

Variables
	mp_fork = multiprocessing.get_context("fork")

Detailed Description

Calculate mathematical expressions using :py:obj:`ast.parse` (mode="eval").

Function Documentation

_eval()

searx.plugins.calculator._eval ( node )

protected

Definition at line 122 of file calculator.py.

def _eval(node):
    if isinstance(node, ast.Constant) and isinstance(node.value, (int, float)):
        return node.value
 
    if isinstance(node, ast.BinOp):
        return operators[type(node.op)](_eval(node.left), _eval(node.right))
 
    if isinstance(node, ast.UnaryOp):
        return operators[type(node.op)](_eval(node.operand))
 
    raise TypeError(node)
 
 

References _eval().

Referenced by _eval(), and _eval_expr().

Here is the call graph for this function:

Here is the caller graph for this function:

_eval_expr()

searx.plugins.calculator._eval_expr ( expr )

protected

>>> _eval_expr('2^6')
64
>>> _eval_expr('2**6')
64
>>> _eval_expr('1 + 2*3**(4^5) / (6 + -7)')
-5.0

Definition at line 106 of file calculator.py.

def _eval_expr(expr):
    """
    >>> _eval_expr('2^6')
    64
    >>> _eval_expr('2**6')
    64
    >>> _eval_expr('1 + 2*3**(4^5) / (6 + -7)')
    -5.0
    """
    try:
        return _eval(ast.parse(expr, mode='eval').body)
    except ZeroDivisionError:
        # This is undefined
        return ""
 
 

References _eval().

Here is the call graph for this function:

handler()

searx.plugins.calculator.handler	(	multiprocessing.Queue	q,
			func,
			args,
		**	kwargs )

Definition at line 135 of file calculator.py.

def handler(q: multiprocessing.Queue, func, args, **kwargs):  # pylint:disable=invalid-name
    try:
        q.put(func(*args, **kwargs))
    except:
        q.put(None)
        raise
 
 

timeout_func()

searx.plugins.calculator.timeout_func	(		timeout,
			func,
		*	args,
		**	kwargs )

Definition at line 143 of file calculator.py.

def timeout_func(timeout, func, *args, **kwargs):
 
    que = mp_fork.Queue()
    p = mp_fork.Process(target=handler, args=(que, func, args), kwargs=kwargs)
    p.start()
    p.join(timeout=timeout)
    ret_val = None
    # pylint: disable=used-before-assignment,undefined-variable
    if not p.is_alive():
        ret_val = que.get()
    else:
        logger.debug("terminate function after timeout is exceeded")  # type: ignore
        p.terminate()
    p.join()
    p.close()
    return ret_val

Referenced by searx.plugins.calculator.SXNGPlugin.post_search().

Here is the caller graph for this function:

Variable Documentation

mp_fork

searx.plugins.calculator.mp_fork = multiprocessing.get_context("fork")

Definition at line 103 of file calculator.py.