Module ImportFrom alias Import alias ImportFrom alias alias alias ImportFrom alias alias ImportFrom alias alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body TryFinally body TryExcept body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr If UnaryOpNot AttributeLoad NameLoad attr body Return Assign AttributeStore NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad body Expr Call NameLoad AttributeLoad NameLoad attr ExceptHandler type NameLoad body Pass finalbody Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr If CompareIn AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Raise Call NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults Num NameLoad body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr SubscriptLoad AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Index Str Assign NameStore Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr If CompareIsNot NameLoad NameLoad body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad Str attr AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore NameLoad Assign NameStore NameLoad TryFinally body TryExcept body Expr Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Call NameLoad AttributeLoad NameLoad attr If CompareLt AttributeLoad AttributeLoad NameLoad attr attr BinOpMult AttributeLoad NameLoad attr Num body Expr Call AttributeLoad NameLoad attr NameLoad orelse If Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str body Expr Call AttributeLoad NameLoad attr NameLoad orelse Expr Call AttributeLoad NameLoad attr NameLoad handlers ExceptHandler type NameLoad body Pass orelse Assign NameStore NameLoad finalbody If NameLoad body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body If AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr orelse Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr TupleLoad NameLoad Call AttributeLoad Call NameLoad AttributeLoad NameLoad attr attr Assign NameStore Call AttributeLoad NameLoad attr If CompareEq SubscriptLoad NameLoad Index Num NameLoad body Raise Call NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr If Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr SubscriptLoad NameLoad Index Num orelse Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr Num SubscriptLoad NameLoad Index Num decorator_list FunctionDef arguments args NameParam NameParam defaults body While CompareLt AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr body If Call AttributeLoad AttributeLoad NameLoad attr attr body Raise Call NameLoad Expr Call AttributeLoad NameLoad attr TupleLoad NameLoad Call AttributeLoad Call NameLoad AttributeLoad NameLoad attr attr Call AttributeLoad Call NameLoad AttributeLoad NameLoad attr attr Call AttributeLoad Call NameLoad AttributeLoad NameLoad attr attr Assign NameStore Call AttributeLoad NameLoad attr If BoolOpOr CompareLt Call NameLoad NameLoad Num CompareEq SubscriptLoad NameLoad Index Num NameLoad body Raise Call NameLoad Assign NameStore SubscriptLoad NameLoad Index Num If BoolOpOr UnaryOpNot NameLoad CompareEq Call NameLoad NameLoad Num body Raise Call NameLoad Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad AugAssignAdd AttributeStore NameLoad attr Call NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body If Call AttributeLoad AttributeLoad NameLoad attr attr body Assign NameStore NameLoad If NameLoad body TryExcept body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad body Assign NameStore NameLoad If UnaryOpNot NameLoad body TryExcept body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad body Pass If NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr orelse Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr TryExcept body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad body Pass Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Assign NameStore AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str TryExcept body If BoolOpAnd NameLoad AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr orelse Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore Call NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call NameLoad handlers ExceptHandler type NameLoad body Pass Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr NameLoad decorator_list decorator_list Assign NameStore Dict NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad
N/A threading Event N/A zmq onitu.referee UP DEL MOV onitu.utils get_brocker_uri log_traceback onitu.brocker.commands GET_CHUNK GET_FILE onitu.brocker.responses ERROR onitu.escalator.client EscalatorClosed metadata Metadata exceptions AbortOperation Worker N/A object N/A __init__ N/A N/A self dealer fid N/A N/A N/A N/A N/A N/A super Worker self __init__ N/A N/A self dealer dealer N/A N/A self fid fid N/A N/A self logger N/A dealer logger N/A N/A self call N/A N/A dealer plug call N/A N/A self session N/A N/A dealer plug session N/A N/A self _stop N/A Event N/A N/A self context N/A N/A zmq Context N/A N/A self escalator N/A N/A N/A N/A self dealer escalator clone context N/A self context N/A __call__ N/A N/A self N/A N/A N/A N/A N/A N/A N/A N/A self metadata N/A N/A Metadata get_by_id N/A N/A self dealer plug N/A self fid N/A N/A N/A self metadata N/A N/A N/A N/A self filename N/A N/A self metadata filename N/A N/A N/A self do N/A N/A N/A Exception N/A N/A N/A log_traceback N/A self logger N/A N/A EscalatorClosed N/A N/A N/A N/A N/A N/A N/A self escalator close N/A N/A N/A N/A self context destroy N/A N/A N/A self fid N/A N/A self dealer in_progress N/A N/A N/A N/A N/A N/A self dealer in_progress pop N/A self fid N/A do N/A N/A self N/A N/A N/A N/A NotImplementedError N/A stop N/A N/A self N/A N/A N/A N/A N/A N/A self _stop set N/A N/A TransferWorker N/A Worker N/A __init__ N/A N/A self dealer fid offset restart N/A 0 False N/A N/A N/A N/A N/A super TransferWorker self __init__ dealer fid N/A N/A self offset offset N/A N/A self restart restart N/A N/A self chunk_size N/A N/A N/A N/A self dealer plug options N/A chunk_size N/A driver_chunk_size N/A N/A self call set_chunk_size N/A self chunk_size N/A N/A driver_chunk_size None N/A N/A N/A self chunk_size driver_chunk_size N/A N/A self transfer_key N/A N/A service:{}:transfer:{} format N/A N/A self dealer name N/A self fid N/A do N/A N/A self N/A N/A N/A success False N/A dealer None N/A N/A N/A N/A N/A N/A N/A self start_transfer N/A dealer N/A N/A N/A self context socket N/A zmq DEALER N/A N/A N/A dealer connect N/A get_brocker_uri N/A self session N/A N/A N/A N/A self metadata size N/A N/A self chunk_size 2 N/A N/A N/A N/A self get_file_oneshot dealer N/A N/A N/A N/A N/A N/A self dealer plug has_handler upload_chunk N/A N/A N/A N/A self get_file_multipart dealer N/A N/A N/A N/A self get_file_oneshot dealer N/A N/A N/A AbortOperation N/A N/A N/A N/A success True N/A N/A dealer N/A N/A N/A N/A dealer close N/A N/A N/A self end_transfer success N/A start_transfer N/A N/A self N/A N/A N/A N/A self restart N/A N/A N/A N/A self call restart_upload N/A self metadata N/A self offset N/A N/A N/A N/A self logger info Restarting transfer of '{}' N/A self filename N/A N/A N/A N/A N/A self escalator put N/A self transfer_key N/A self offset N/A N/A N/A self call start_upload N/A self metadata N/A N/A N/A N/A self logger info Starting to get '{}' N/A self filename N/A get_file_oneshot N/A N/A self dealer N/A N/A N/A N/A N/A N/A self logger debug Getting the content of '{}' N/A self filename N/A N/A N/A dealer send_multipart N/A GET_FILE N/A N/A N/A str N/A self fid encode N/A resp N/A N/A dealer recv_multipart N/A N/A N/A resp N/A 0 ERROR N/A N/A N/A AbortOperation N/A N/A N/A N/A self logger debug Received content of file '{}' N/A self filename N/A N/A N/A N/A N/A self dealer plug has_handler upload_file N/A N/A N/A N/A self call upload_file N/A self metadata N/A resp N/A 1 N/A N/A N/A N/A self call upload_chunk N/A self metadata 0 N/A resp N/A 1 N/A get_file_multipart N/A N/A self dealer N/A N/A N/A N/A N/A self offset N/A N/A self metadata size N/A N/A N/A N/A N/A self _stop is_set N/A N/A N/A AbortOperation N/A N/A N/A dealer send_multipart N/A GET_CHUNK N/A N/A N/A str N/A self fid encode N/A N/A N/A str N/A self offset encode N/A N/A N/A str N/A self chunk_size encode N/A resp N/A N/A dealer recv_multipart N/A N/A N/A N/A len resp 2 N/A N/A resp N/A 0 ERROR N/A N/A N/A AbortOperation N/A chunk N/A resp N/A 1 N/A N/A N/A chunk N/A N/A len chunk 0 N/A N/A N/A AbortOperation N/A N/A N/A self call upload_chunk N/A self metadata N/A self offset chunk N/A N/A self offset N/A len chunk N/A N/A N/A N/A self escalator put N/A self transfer_key N/A self offset N/A end_transfer N/A N/A self success N/A N/A N/A N/A N/A N/A self _stop is_set N/A N/A success False N/A success N/A N/A N/A N/A N/A N/A self call end_upload N/A self metadata N/A N/A N/A AbortOperation N/A N/A success False N/A N/A success N/A N/A N/A N/A N/A N/A self call abort_upload N/A self metadata N/A N/A N/A AbortOperation N/A N/A N/A success N/A N/A N/A N/A N/A self escalator delete N/A self transfer_key N/A N/A N/A N/A self metadata set_uptodate N/A N/A N/A N/A self metadata write N/A N/A N/A N/A self logger info Transfer of '{}' successful N/A self filename N/A N/A N/A N/A N/A self logger info Transfer of '{}' aborted N/A self filename N/A N/A DeletionWorker N/A Worker N/A __init__ N/A N/A self dealer fid N/A N/A N/A N/A N/A N/A super DeletionWorker self __init__ dealer fid N/A do N/A N/A self N/A N/A N/A N/A N/A N/A self logger debug Deleting '{}' N/A self filename N/A N/A N/A N/A N/A self call delete_file N/A self metadata N/A N/A N/A AbortOperation N/A N/A N/A N/A N/A N/A self metadata delete N/A N/A N/A N/A self logger info '{}' deleted N/A self filename N/A N/A MoveWorker N/A Worker N/A __init__ N/A N/A self dealer fid new_fid N/A N/A N/A N/A N/A N/A super MoveWorker self __init__ dealer fid N/A N/A self new_fid new_fid N/A do N/A N/A self N/A N/A N/A new_metadata N/A N/A Metadata get_by_id N/A N/A self dealer plug N/A self new_fid N/A new_filename N/A new_metadata filename N/A N/A N/A N/A self logger debug Moving '{}' to '{}' N/A self filename new_filename N/A has_move_file N/A N/A N/A N/A self dealer plug has_handler move_file N/A N/A N/A N/A has_move_file N/A N/A self metadata is_uptodate N/A N/A N/A N/A self call move_file N/A self metadata new_metadata N/A N/A N/A N/A self metadata delete N/A N/A N/A new_metadata set_uptodate N/A N/A N/A N/A self call delete_file N/A self metadata N/A N/A N/A N/A self metadata delete N/A transfer N/A TransferWorker N/A self dealer N/A self new_fid N/A N/A transfer N/A N/A N/A AbortOperation N/A N/A N/A N/A N/A N/A self logger info '{}' moved to '{}' N/A self filename new_filename N/A N/A N/A WORKERS N/A UP DEL MOV TransferWorker DeletionWorker MoveWorker