| Server IP : 88.222.222.225 / Your IP : 216.73.216.122 Web Server : LiteSpeed System : Linux id-dci-web1986.main-hosting.eu 5.14.0-611.26.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Jan 29 05:24:47 EST 2026 x86_64 User : u686484674 ( 686484674) PHP Version : 8.0.30 Disable Function : system, exec, shell_exec, passthru, mysql_list_dbs, ini_alter, dl, symlink, link, chgrp, leak, popen, apache_child_terminate, virtual, mb_send_mail MySQL : OFF | cURL : ON | WGET : ON | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /proc/self/root/opt/./alt/python311/lib/python3.11/site-packages/pyroute2/ndb/ |
Upload File : |
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