Module Import alias Import alias Import alias Import alias Import alias Import alias Import alias Import alias Import alias identifier Import alias Import alias Import alias identifier Import alias identifier Import alias identifier Import alias identifier Assign NameStore Num Assign NameStore Num ClassDef bases AttributeLoad NameLoad attr body FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults body TryExcept body Expr Call AttributeLoad NameLoad attr Str NameLoad TryFinally body Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad finalbody Expr Call AttributeLoad NameLoad attr NameLoad If CompareEq Call NameLoad NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str If NameLoad body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr NameLoad Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Call NameLoad NameLoad Call AttributeLoad NameLoad attr Call NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr While NameLoad body Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr NameLoad Call AttributeLoad NameLoad attr Str Assign NameStore NameLoad If CompareEq Call NameLoad NameLoad NameLoad body For NameStore NameLoad body If CompareNotEq SubscriptLoad NameLoad Index NameLoad Call AttributeLoad NameLoad attr Call NameLoad NameLoad body Assign NameStore NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Return Expr Call AttributeLoad NameLoad attr Num If CompareGt BinOpSub Call AttributeLoad NameLoad attr NameLoad Num body Expr Call AttributeLoad NameLoad attr BinOpMod Str NameLoad Return Expr Call AttributeLoad NameLoad attr handlers ExceptHandler body Expr Call AttributeLoad NameLoad attr BinOpAdd Str Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body For NameStore Call NameLoad NameLoad body Assign NameStore ListLoad Assign NameStore ListLoad Expr Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore ListLoad Assign NameStore ListLoad Assign NameStore ListLoad Assign NameStore Call AttributeLoad NameLoad attr For NameStore Call NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword TupleLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad Expr Call AttributeLoad SubscriptLoad NameLoad Index Num attr For NameStore NameLoad body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str Assign NameStore ListLoad Expr Call AttributeLoad NameLoad attr Str For NameStore NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad Assert CompareEq Call NameLoad NameLoad NameLoad BinOpMod Str TupleLoad NameLoad Call NameLoad NameLoad NameLoad Call NameLoad NameLoad Assign NameStore ListLoad Assign NameStore ListLoad Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr Str decorator_list FunctionDef arguments args NameParam defaults kwarg body Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad keyword AttributeLoad Call AttributeLoad NameLoad attr attr TryFinally body Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword NameLoad keyword NameLoad finalbody Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad keyword AttributeLoad Call AttributeLoad NameLoad attr attr TryFinally body Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword NameLoad keyword NameLoad finalbody Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad keyword AttributeLoad Call AttributeLoad NameLoad attr attr TryFinally body Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword NameLoad keyword NameLoad finalbody Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad keyword AttributeLoad Call AttributeLoad NameLoad attr attr TryFinally body Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword NameLoad keyword NameLoad finalbody Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad TryFinally body Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Str Num Assign NameStore Call AttributeLoad NameLoad attr NameLoad Num NameLoad NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore ListComp Call AttributeLoad NameLoad attr Call NameLoad NameLoad comprehension NameStore Call NameLoad Num FunctionDef arguments args defaults body With Call AttributeLoad NameLoad attr NameLoad body For NameStore NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad TupleLoad NameLoad Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr Str decorator_list Assign NameStore ListLoad FunctionDef arguments args defaults body While CompareLt Call NameLoad NameLoad Call NameLoad NameLoad body Assign NameStore Call AttributeLoad NameLoad attr For TupleStore NameStore NameStore NameLoad body If CompareEq NameLoad Str body For NameStore NameLoad body Expr Call AttributeLoad NameLoad attr SubscriptLoad NameLoad Index Num decorator_list Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad Call NameLoad NameLoad finalbody Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad TryFinally body Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Str Num Assign NameStore Call AttributeLoad NameLoad attr NameLoad Num NameLoad NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore ListComp Call NameLoad NameLoad comprehension NameStore Call NameLoad Num Assign NameStore BinOpMult BinOpMult Str Num Num With Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr NameLoad With Call AttributeLoad NameLoad attr NameLoad body For NameStore NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad TupleLoad Call AttributeLoad NameLoad attr NameLoad Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr finalbody Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr BinOpMod Str Call AttributeLoad NameLoad attr Assign NameStore Num If CompareGtE NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr BinOpMod Str Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr CompareLt NameLoad NameLoad BinOpMod Str NameLoad Assign TupleStore NameStore NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword Num TryFinally body Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr TupleLoad BinOpAdd NameLoad Num NameLoad For NameStore Call NameLoad Num body Assign NameStore Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr BinOpMod Str NameLoad Num Assign NameStore Call AttributeLoad NameLoad attr NameLoad Num NameLoad NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad TupleLoad Call AttributeLoad NameLoad attr BinOpMod Str NameLoad With Call AttributeLoad NameLoad attr NameLoad body Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr BinOpMod Str NameLoad finalbody Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr TupleLoad NameLoad NameLoad TryExcept body Expr Call AttributeLoad NameLoad attr NameLoad handlers ExceptHandler body Pass decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr TryFinally body Assign NameStore Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Str Num Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr NameLoad Num NameLoad NameLoad NameLoad NameLoad For NameStore Call NameLoad Num body With Call AttributeLoad NameLoad attr NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad TupleLoad Call AttributeLoad NameLoad attr Str Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr Call NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Num Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad With Call AttributeLoad NameLoad attr NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad TupleLoad Call AttributeLoad NameLoad attr Str Assign NameStore BinOpAdd Str AttributeLoad Call AttributeLoad NameLoad attr attr Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Num FunctionDef arguments args defaults body With Call AttributeLoad NameLoad attr NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad TupleLoad Call AttributeLoad NameLoad attr Str Assign NameStore BinOpAdd Str AttributeLoad Call AttributeLoad NameLoad attr attr Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr NameLoad decorator_list Expr Call AttributeLoad NameLoad attr NameLoad NameLoad finalbody Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body TryFinally body Assign NameStore Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Str Num Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad Assign NameStore Call AttributeLoad NameLoad attr FunctionDef arguments args defaults body With Call AttributeLoad NameLoad attr NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad TupleLoad Str Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr Str decorator_list Expr Call AttributeLoad NameLoad attr NameLoad NameLoad finalbody Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr TryFinally body Assign NameStore Dict FunctionDef arguments args NameParam defaults body TryFinally body TryExcept body Assign NameStore ListComp Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr BinOpMod Str NameLoad Num comprehension NameStore Call NameLoad Num Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad Assign NameStore Call AttributeLoad NameLoad attr For NameStore NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Num NameLoad NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad For NameStore Call NameLoad Num body Assign NameStore BinOpMod BinOpAdd NameLoad NameLoad Call NameLoad NameLoad Assign NameStore SubscriptLoad NameLoad Index NameLoad With Call AttributeLoad NameLoad attr NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad TupleLoad Call AttributeLoad NameLoad attr BinOpMod Str NameLoad Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Str Assign NameStore Call AttributeLoad NameLoad attr BinOpMod Str TupleLoad NameLoad NameLoad NameLoad AttributeLoad Call AttributeLoad NameLoad attr attr Assign SubscriptStore NameLoad Index NameLoad NameLoad Assign SubscriptStore NameLoad Index NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad Assign NameStore Call AttributeLoad NameLoad attr For NameStore NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Num NameLoad NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad For TupleStore NameStore NameStore Call AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad SubscriptLoad NameLoad Index NameLoad handlers ExceptHandler body Expr Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Raise finalbody Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr decorator_list For NameStore Call NameLoad Num body Expr Call NameLoad NameLoad finalbody Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Assign NameStore Num Assign NameStore NameLoad While CompareLt NameLoad Num body With Call AttributeLoad NameLoad attr NameLoad body If CompareIsNot SubscriptLoad NameLoad Index NameLoad NameLoad body Assign NameStore Call AttributeLoad SubscriptLoad NameLoad Index NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad NameLoad Return AugAssignAdd NameStore Num Expr Call AttributeLoad NameLoad attr Num Assert NameLoad BinOpMod Str TupleLoad NameLoad NameLoad NameLoad decorator_list decorator_list
N/A N/A logging N/A os N/A time N/A uuid N/A resource N/A tempfile N/A shutil N/A threading N/A ufora.native.Json NativeJson N/A traceback N/A unittest N/A ufora.config.Setup Setup N/A ufora.native.Json JsonNative N/A ufora.distributed.SharedState.SharedState SharedState N/A ufora.distributed.SharedState.tests.SharedStateTestHarness SharedStateTestHarness N/A DEFAULT_PASS_COUNT 5 N/A DEFAULT_THREAD_COUNT 10 TestSharedState N/A N/A unittest TestCase N/A clientThread N/A N/A self harness passIndex threadIndex totalThreadCount successList failureList connectedThreads connectedThreadEvent viewList blockUntilConnected N/A N/A N/A N/A N/A N/A N/A logging info Connecting to SharedState in thread %s threadIndex N/A N/A N/A view N/A N/A harness newView N/A N/A N/A viewList append view N/A N/A N/A N/A connectedThreads append threadIndex N/A N/A N/A len connectedThreads totalThreadCount N/A N/A N/A N/A connectedThreadEvent set N/A N/A N/A logging debug All reconnection test threads have connected. N/A blockUntilConnected N/A N/A N/A N/A connectedThreadEvent wait N/A N/A N/A logging info Have view in thread %s threadIndex N/A N/A N/A logging info Connected to shared state in thread %s threadIndex N/A N/A N/A harness subscribeToKeyspace view N/A N/A NativeJson Json data N/A N/A N/A harness writeToKeyspace view N/A N/A NativeJson Json data N/A N/A NativeJson Json N/A str threadIndex N/A N/A NativeJson Json N/A str passIndex N/A t0 N/A N/A time time N/A True N/A N/A itemDict N/A dict N/A N/A harness getAllItemsFromView view N/A N/A NativeJson Json data N/A allAreCurPass True N/A N/A N/A len itemDict totalThreadCount N/A N/A i itemDict N/A N/A N/A N/A itemDict N/A i N/A N/A NativeJson Json N/A str passIndex N/A N/A allAreCurPass False N/A allAreCurPass N/A N/A N/A N/A successList append threadIndex N/A N/A N/A N/A time sleep 0.01 N/A N/A N/A N/A N/A time time t0 5.0 N/A N/A N/A N/A failureList append N/A Bad dict: %s itemDict N/A N/A N/A N/A view flush N/A N/A N/A N/A N/A N/A failureList append N/A Exception:  N/A N/A traceback format_exc N/A rapidReconnectionTest N/A N/A self harness totalThreadCount passCount blockUntilConnected N/A N/A N/A passIndex N/A range passCount N/A N/A successes N/A N/A failures N/A N/A N/A N/A logging info Starting connect-pass %s passIndex N/A threads N/A N/A connectedThreads N/A N/A viewList N/A N/A allConnectedEvent N/A N/A threading Event N/A threadIndex N/A range totalThreadCount N/A N/A N/A N/A threads append N/A N/A threading Thread target N/A self clientThread args N/A harness passIndex threadIndex totalThreadCount successes failures connectedThreads allConnectedEvent viewList blockUntilConnected N/A N/A N/A N/A threads N/A -1 start N/A t threads N/A N/A N/A N/A t join N/A N/A N/A logging debug All reconnection test threads joined. N/A viewList N/A N/A N/A N/A logging debug All views destroyed. N/A f failures N/A N/A N/A N/A logging warn Failure: %s f N/A N/A N/A len successes totalThreadCount N/A Failed on pass %s. %s instead of %s. %s marked failures N/A passIndex N/A len successes totalThreadCount N/A len failures N/A successes N/A N/A failures N/A N/A N/A N/A time sleep 0.25 N/A N/A N/A logging info DONE SLEEPING




 N/A getHarness N/A N/A self N/A kwds N/A N/A N/A N/A SharedStateTestHarness SharedStateTestHarness kwds N/A test_rapid_connections_InMemory_BlockUntilConnected N/A N/A self N/A N/A N/A harness N/A N/A self getHarness inMemory True port N/A N/A N/A Setup config sharedStatePort N/A N/A N/A N/A N/A self rapidReconnectionTest harness totalThreadCount DEFAULT_THREAD_COUNT passCount DEFAULT_PASS_COUNT blockUntilConnected True N/A N/A N/A N/A time sleep 0.01 N/A N/A N/A harness teardown N/A test_rapid_connections_UsingSockets_BlockUntilConnected N/A N/A self N/A N/A N/A harness N/A N/A self getHarness inMemory False port N/A N/A N/A Setup config sharedStatePort N/A N/A N/A N/A N/A self rapidReconnectionTest harness totalThreadCount DEFAULT_THREAD_COUNT passCount DEFAULT_PASS_COUNT blockUntilConnected True N/A N/A N/A N/A harness teardown N/A test_rapid_connections_InMemory N/A N/A self N/A N/A N/A harness N/A N/A self getHarness inMemory True port N/A N/A N/A Setup config sharedStatePort N/A N/A N/A N/A N/A self rapidReconnectionTest harness totalThreadCount DEFAULT_THREAD_COUNT passCount DEFAULT_PASS_COUNT blockUntilConnected False N/A N/A N/A N/A time sleep 0.01 N/A N/A N/A harness teardown N/A test_rapid_connections_UsingSockets N/A N/A self N/A N/A N/A harness N/A N/A self getHarness inMemory False port N/A N/A N/A Setup config sharedStatePort N/A N/A N/A N/A N/A self rapidReconnectionTest harness totalThreadCount DEFAULT_THREAD_COUNT passCount DEFAULT_PASS_COUNT blockUntilConnected False N/A N/A N/A N/A harness teardown N/A test_listener N/A N/A self N/A N/A N/A harness N/A N/A self getHarness inMemory True N/A N/A N/A v1 N/A N/A harness newView N/A v2 N/A N/A harness newView N/A l N/A N/A SharedState Listener v2 N/A space N/A N/A SharedState Keyspace ComparisonKeyType N/A N/A NativeJson Json TestSpace 1 N/A rng N/A N/A SharedState KeyRange space 0 None None True False N/A N/A N/A v1 subscribe rng N/A N/A N/A v2 subscribe rng N/A keysToWrite N/A N/A N/A JsonNative Json N/A str x N/A x N/A range 40 writer N/A N/A N/A N/A N/A N/A N/A SharedState Transaction v1 N/A N/A keyName keysToWrite N/A N/A key N/A N/A SharedState Key space N/A keyName N/A N/A v1 N/A key N/A N/A JsonNative Json value N/A N/A changedKeys N/A reader N/A N/A N/A N/A N/A N/A N/A len changedKeys N/A len keysToWrite N/A N/A updates N/A N/A l get N/A N/A updateType update updates N/A N/A N/A updateType KeyUpdates N/A N/A key update N/A N/A N/A N/A changedKeys append N/A key N/A 0 N/A N/A writerThread N/A N/A threading Thread target writer N/A readerThread N/A N/A threading Thread target reader N/A N/A N/A writerThread start N/A N/A N/A readerThread start N/A N/A N/A writerThread join N/A N/A N/A readerThread join N/A N/A N/A self assertEqual N/A set keysToWrite N/A set changedKeys N/A N/A N/A N/A time sleep 0.01 N/A N/A N/A harness teardown N/A test_flush N/A N/A self N/A N/A N/A harness N/A N/A self getHarness inMemory True N/A N/A N/A v1 N/A N/A harness newView N/A space N/A N/A SharedState Keyspace ComparisonKeyType N/A N/A NativeJson Json TestSpace 1 N/A rng N/A N/A SharedState KeyRange space 0 None None True False N/A N/A N/A v1 subscribe rng N/A keysToWrite N/A N/A str x N/A x N/A range 40 N/A value N/A N/A value 100 1024 N/A N/A N/A SharedState Transaction v1 N/A N/A N/A N/A self assertRaises UserWarning N/A v1 flush True N/A N/A N/A SharedState Transaction v1 N/A N/A keyName keysToWrite N/A N/A key N/A N/A SharedState Key space N/A N/A N/A NativeJson Json keyName N/A N/A v1 N/A key N/A N/A NativeJson Json value N/A N/A N/A v1 flush N/A N/A N/A N/A time sleep 0.01 N/A N/A N/A harness teardown N/A test_file_management N/A N/A self N/A N/A N/A tempDir N/A N/A tempfile mkdtemp N/A curOpenFiles N/A len N/A N/A os listdir N/A /proc/%s/fd N/A N/A os getpid N/A OPEN_FILE_LIMIT 200 N/A N/A curOpenFiles OPEN_FILE_LIMIT N/A N/A N/A N/A os system N/A ls -alh /proc/%s/fd N/A N/A os getpid N/A N/A N/A self assertTrue N/A curOpenFiles OPEN_FILE_LIMIT N/A Too many open files: %s curOpenFiles N/A N/A soft hard N/A N/A resource getrlimit N/A resource RLIMIT_OFILE N/A harness N/A N/A self getHarness inMemory True cachePathOverride tempDir maxOpenFiles 15 N/A N/A N/A v1 N/A N/A harness newView N/A N/A N/A resource setrlimit N/A resource RLIMIT_OFILE N/A N/A curOpenFiles 30 hard N/A ix N/A range 128 N/A N/A space N/A N/A SharedState Keyspace TakeHighestIdKeyType N/A N/A NativeJson Json N/A TestSpace%s ix 1 N/A rng N/A N/A SharedState KeyRange space 0 None None True False N/A N/A N/A v1 subscribe rng N/A key N/A N/A SharedState Key space N/A N/A N/A NativeJson Json N/A key%s ix N/A N/A N/A SharedState Transaction v1 N/A N/A N/A v1 N/A key N/A N/A NativeJson Json N/A value %s ix N/A N/A N/A N/A time sleep 0.01 N/A N/A N/A harness teardown N/A N/A N/A resource setrlimit N/A resource RLIMIT_OFILE N/A soft hard N/A N/A N/A N/A N/A shutil rmtree tempDir N/A N/A N/A N/A N/A test_require_subscription_manager N/A N/A self N/A N/A N/A tempDir N/A N/A tempfile mkdtemp N/A N/A N/A testKeyspace N/A N/A SharedState Keyspace TakeHighestIdKeyType N/A N/A NativeJson Json TestSpace 1 N/A harness N/A N/A self getHarness inMemory True cachePathOverride tempDir N/A v1 N/A N/A harness newView N/A N/A N/A v1 subscribe N/A N/A SharedState KeyRange testKeyspace 0 None None True False N/A ix N/A range 1000 N/A N/A N/A N/A SharedState Transaction v1 N/A N/A key N/A N/A SharedState Key testKeyspace N/A N/A N/A NativeJson Json key N/A N/A v1 N/A key N/A N/A NativeJson Json N/A str ix N/A N/A N/A time sleep 2 N/A v2 N/A N/A harness newView N/A N/A N/A v2 setMustSubscribe False N/A N/A N/A SharedState Transaction v2 N/A N/A key N/A N/A SharedState Key testKeyspace N/A N/A N/A NativeJson Json key N/A value N/A value is N/A N/A N/A uuid uuid4 hex N/A N/A v2 N/A key N/A N/A NativeJson Json value N/A N/A N/A time sleep 2 toTry N/A N/A N/A N/A N/A N/A N/A SharedState Transaction v2 N/A N/A key N/A N/A SharedState Key testKeyspace N/A N/A N/A NativeJson Json key N/A value N/A value is N/A N/A N/A uuid uuid4 hex N/A N/A v2 N/A key N/A N/A NativeJson Json value N/A N/A N/A N/A self assertRaises UserWarning toTry N/A N/A N/A N/A time sleep 0.01 N/A N/A N/A harness teardown N/A N/A N/A shutil rmtree tempDir N/A test_require_subscription_view N/A N/A self N/A N/A N/A N/A N/A testKeyspace N/A N/A SharedState Keyspace TakeHighestIdKeyType N/A N/A NativeJson Json TestSpace 1 N/A harness N/A N/A self getHarness inMemory True N/A v1 N/A N/A harness newView toTry N/A N/A N/A N/A N/A N/A N/A SharedState Transaction v1 N/A N/A key N/A N/A SharedState Key testKeyspace N/A key N/A N/A v1 N/A key N/A N/A NativeJson Json this is a test value N/A N/A N/A N/A self assertRaises UserWarning toTry N/A N/A N/A N/A time sleep 0.01 N/A N/A N/A harness teardown N/A test_persistence N/A N/A self N/A N/A N/A tempDir N/A N/A tempfile mkdtemp N/A N/A N/A testValues N/A testWrite N/A N/A passIx N/A N/A N/A N/A N/A N/A N/A testKeyspaces N/A N/A N/A SharedState Keyspace TakeHighestIdKeyType N/A N/A NativeJson Json N/A TestSpace%s ix 3 N/A ix N/A range 3 N/A harness N/A N/A self getHarness inMemory True cachePathOverride tempDir N/A v1 N/A N/A harness newView N/A space testKeyspaces N/A N/A rng N/A N/A SharedState KeyRange space 0 None None True False N/A N/A N/A v1 subscribe rng N/A ix N/A range 9 N/A N/A keyspaceIx N/A N/A ix passIx N/A len testKeyspaces N/A space N/A testKeyspaces N/A keyspaceIx N/A N/A N/A SharedState Transaction v1 N/A N/A key N/A N/A SharedState Key space N/A N/A N/A NativeJson Json N/A key %s ix N/A N/A NativeJson Json N/A N/A NativeJson Json N/A value N/A N/A JsonNative Json N/A <value is %s in space %s on pass %s: %s> N/A ix keyspaceIx passIx N/A N/A N/A uuid uuid4 hex N/A N/A v1 N/A key value N/A N/A testValues N/A key value N/A N/A N/A v1 flush N/A N/A N/A time sleep 0.01 N/A N/A N/A harness teardown N/A harness N/A N/A self getHarness inMemory True cachePathOverride tempDir N/A v1 N/A N/A harness newView N/A space testKeyspaces N/A N/A rng N/A N/A SharedState KeyRange space 0 None None True False N/A N/A N/A v1 subscribe rng N/A N/A key value N/A N/A testValues iteritems N/A N/A N/A N/A self assertSharedStateKeyResolvesToValue key v1 N/A testValues N/A key N/A N/A N/A N/A N/A N/A logging warn Exception: %s N/A N/A traceback format_exc N/A N/A N/A N/A N/A time sleep 0.01 N/A N/A N/A harness teardown N/A N/A ix N/A range 2 N/A N/A N/A testWrite ix N/A N/A N/A N/A shutil rmtree tempDir N/A assertSharedStateKeyResolvesToValue N/A N/A self key view value N/A N/A N/A passes 0 N/A lastVal None N/A N/A passes 100 N/A N/A N/A N/A SharedState Transaction view N/A N/A N/A N/A view N/A key None N/A N/A lastVal N/A N/A N/A view N/A key value N/A N/A N/A self assertEqual value lastVal N/A N/A passes 1 N/A N/A N/A time sleep 0.1 N/A False N/A key %s never resolved to value %s. stayed as %s N/A key value lastVal N/A N/A