module flaskJSONRPCServer.execBackend.parallelWithSocket

Description 

This module contains dispatcher-execution backend for flaskJSONRPCServer.

class execBackend(self, poolSize=1, importGlobalsFromParent=True, parentGlobals=None, sleepTime_resultCheck=0.1, sleepTime_emptyQueue=0.1, sleepTime_waitLock=0.75, sleepTime_lazyRequest=120000, sleepTime_checkPoolStopping=0.3, allowThreads=True, id="execBackend_parallelWithSocket", socketPath=None, saveResult=True, persistent_queueGet=True, persistent_waitLock=True, useCPickle=False, disableGeventInChild=False)

Parametrs
poolSize int
importGlobalsFromParent bool
parentGlobals scope
sleepTime_resultCheck float
sleepTime_emptyQueue float
sleepTime_waitLock float
sleepTime_lazyRequest int
sleepTime_checkPoolStopping float
allowThreads bool
id str
socketPath str
saveResult bool
persistent_queueGet bool
useCPickle bool
disableGeventInChild bool
Return
instance Instance of class execBackend

method_public childRemoteVar(self, name, default=None, clear=False)

Description 
Инициирует обертку virtVar() для переменной, связывая ее с переменной в родительском процессе

method_public sendRequestEx(self, data, async=False, cb=None, returnAllData=False)

Description 
Если <async> равен True и не задан <cb>, запрос будет отправлен как notify-request в текущем потоке. Если же <cb> задан, обычный запрос выполнится в новом потоке и вызовет <cb> по окончании.

method_special __init__(self, poolSize=1, importGlobalsFromParent=True, parentGlobals=None, sleepTime_resultCheck=0.1, sleepTime_emptyQueue=0.1, sleepTime_waitLock=0.75, sleepTime_lazyRequest=120000, sleepTime_checkPoolStopping=0.3, allowThreads=True, id="execBackend_parallelWithSocket", socketPath=None, saveResult=True, persistent_queueGet=True, persistent_waitLock=True, useCPickle=False, disableGeventInChild=False)

method_undoc add(self, uniqueId, path, dataIn, request, isJSONP=False)

method_undoc api_parentEval(self, code, scope=None, isExec=False, mergeGlobals=False, _connection=None)

method_undoc api_parentLock(self, dispatcherId=None, _connection=None)

method_undoc api_parentSpeedStatsAdd(self, name, val, _connection=None)

method_undoc api_parentStats(self, inMS, _connection=None)

method_undoc api_parentUnlock(self, dispatcherId=None, exclusive=False, _connection=None)

method_undoc api_parentVarCheck(self, nameHash, returnIfNotMatch=True, _connection=None)

method_undoc api_parentWait(self, dispatcherId=None, ignorePersistent=False, _connection=None)

method_undoc api_queueGet(self, _connection=None)

method_undoc api_queueResult(self, uniqueId, status, params, result, _connection=None)

method_undoc check(self, uniqueId, _)

method_undoc childCallDispatcher(self, p)

method_undoc childCicle(self, parentServer, id=0)

method_undoc childCopyGlobal(self, name, actual=True, cb=None, magicVarForDispatcher=None)

method_undoc childDisableNotImplemented(self)

method_undoc childEval(self, code, scope=None, wait=True, cb=None, isExec=False, mergeGlobals=False, magicVarForDispatcher=None)

method_undoc childLogger(self, level, *args)

method_undoc childMagicVarOverload(self, magicVarForDispatcher)

method_undoc childReplaceToPatched(self)

method_undoc childSendLazyRequest(self)

method_undoc childSpeedStatsAdd(self, name, val)

method_undoc childWait(self, dispatcher=None, sleepMethod=None, returnStatus=False)

method_undoc sendRequest(self, path, method, params=None, notif=False)

method_undoc start(self, server)

method_undoc stats(self, inMS=False)

method_undoc stop(self, server, timeout=20, processingDispatcherCountMax=0)

method_undoc var2hash(self, var, name, returnSerialized=False)