One Hat Cyber Team

Your IP : 18.218.36.215

Server IP : 192.145.235.60

Server : Linux ngx365.inmotionhosting.com 5.14.0-427.33.1.el9_4.x86_64 #1 SMP PREEMPT_DYNAMIC Fri Aug 30 09:45:56 EDT 2024 x86_64

Server Software : Apache

PHP Version : 8.2.28

Buat File | Buat Folder

Dir : ~/opt/saltstack/salt/extras-3.10/pyroute2/ndb/

View File Name : events.py

import threading
import time


class SyncStart(Exception):
    pass


class SchemaFlush(Exception):
    pass


class SchemaReadLock(Exception):
    pass


class SchemaReadUnlock(Exception):
    pass


class SchemaGenericRequest(object):
    def __init__(self, response, *argv, **kwarg):
        self.response = response
        self.argv = argv
        self.kwarg = kwarg


class MarkFailed(Exception):
    pass


class DBMExitException(Exception):
    pass


class ShutdownException(Exception):
    pass


class RescheduleException(Exception):
    pass


class InvalidateHandlerException(Exception):
    pass


class State(object):
    events = None

    def __init__(self, prime=None, log=None, wait_list=None):
        wait_list = wait_list or []
        self.events = []
        self.log = log
        self.wait_list = {x: threading.Event() for x in wait_list}
        if prime is not None:
            self.load(prime)

    def wait(self, state, *argv, **kwarg):
        return self.wait_list[state].wait(*argv, **kwarg)

    def load(self, prime):
        self.events = []
        for state in prime.events:
            self.events.append(state)

    def transition(self):
        if len(self.events) < 2:
            return None
        return (self.events[-2][1], self.events[-1][1])

    def get(self):
        if not self.events:
            return None
        return self.events[-1][1]

    def set(self, state):
        for key in self.wait_list:
            if key == state:
                self.wait_list[key].set()
            else:
                self.wait_list[key].clear()
        if self.log is not None:
            self.log.debug(state)
        if self.events and self.events[-1][1] == state:
            self.events.pop()
        self.events.append((time.time(), state))
        return state

    def __eq__(self, other):
        if not self.events:
            return False
        return self.events[-1][1] == other

    def __ne__(self, other):
        if not self.events:
            return True
        return self.events[-1][1] != other