Module Expr Str ImportFrom alias ImportFrom alias Import alias Import alias ImportFrom alias ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Str decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad BinOpMult Num Num NameLoad NameLoad body Assign AttributeStore NameLoad attr Call NameLoad NameLoad Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr Call NameLoad decorator_list FunctionDef arguments args NameParam defaults vararg kwarg body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Call NameLoad AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return Call NameLoad AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return BinOpSub AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return Call NameLoad AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Assign TupleStore NameStore NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AugAssignAdd AttributeStore NameLoad attr NameLoad If CompareGtE Call NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr body If AttributeLoad NameLoad attr body Expr Call NameLoad BinOpMod Str Call NameLoad AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Str Return Assign NameStore Call NameLoad AttributeLoad NameLoad attr For NameStore Call NameLoad Num Call NameLoad AttributeLoad NameLoad attr body TryExcept body Assign NameStore Call AttributeLoad SubscriptLoad NameLoad Slice NameLoad attr Assign TupleStore NameStore NameStore Call AttributeLoad NameLoad attr NameLoad keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad body Continue ExceptHandler type NameLoad name NameStore body If AttributeLoad NameLoad attr body Expr Call NameLoad BinOpMod Str TupleLoad NameLoad NameLoad Call AttributeLoad NameLoad attr NameLoad Call NameLoad AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Continue Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad AugAssignAdd AttributeStore NameLoad attr Num Expr Call AttributeLoad AttributeLoad NameLoad attr attr TupleLoad NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr SubscriptLoad AttributeLoad NameLoad attr Slice BinOpAdd NameLoad NameLoad Break decorator_list decorator_list
N/A N/A  A StreamHandler that extracts messages from streams  __future__ print_function collections defaultdict N/A sys N/A traceback thrift_message ThriftMessage StreamContext N/A object N/A __init__ N/A N/A self N/A N/A N/A N/A self bytes N/A N/A StreamHandler N/A object N/A __init__ N/A N/A self outqueue protocol finagle_thrift max_message_size read_values debug N/A None False N/A 1024 1000 False False N/A N/A N/A self _contexts_by_streams N/A defaultdict StreamContext N/A N/A self _pop_size 1024 N/A N/A self _outqueue outqueue N/A N/A self _protocol protocol N/A N/A self _finagle_thrift finagle_thrift N/A N/A self _max_message_size max_message_size N/A N/A self _debug debug N/A N/A self _read_values read_values N/A N/A self _seen_messages 0 N/A N/A self _recognized_streams N/A set N/A __call__ N/A N/A self N/A args kwargs N/A N/A N/A N/A self handler args kwargs N/A seen_streams N/A N/A self N/A N/A N/A N/A len N/A self _contexts_by_streams N/A property recognized_streams N/A N/A self N/A N/A N/A N/A len N/A self _recognized_streams N/A property unrecognized_streams N/A N/A self N/A N/A N/A N/A N/A self seen_streams N/A self recognized_streams N/A property pending_thrift_msgs N/A N/A self N/A N/A N/A N/A len N/A self _outqueue N/A property seen_thrift_msgs N/A N/A self N/A N/A N/A N/A self _seen_messages N/A property handler N/A N/A self stream N/A N/A N/A context N/A N/A self _contexts_by_streams N/A stream N/A N/A bytes timestamp N/A N/A stream pop_data N/A self _pop_size N/A N/A context bytes bytes N/A N/A N/A len N/A context bytes N/A self _max_message_size N/A N/A N/A self _debug N/A N/A N/A print N/A Dropping bytes, dropped size: %d N/A len N/A context bytes N/A N/A context bytes N/A N/A view N/A memoryview N/A context bytes N/A idx N/A range 0 N/A len N/A context bytes N/A N/A N/A N/A data_slice N/A N/A N/A view N/A idx tobytes N/A N/A msg msglen N/A N/A ThriftMessage read data_slice protocol N/A self _protocol finagle_thrift N/A self _finagle_thrift read_values N/A self _read_values N/A N/A N/A EOFError N/A N/A N/A N/A Exception N/A ex N/A N/A N/A self _debug N/A N/A N/A print N/A Bad message for stream %s: %s: %s
(idx=%d) (context size=%d) N/A stream ex N/A N/A traceback format_exc idx N/A len N/A context bytes file N/A sys stderr N/A N/A N/A N/A N/A self _recognized_streams add stream N/A N/A self _seen_messages 1 N/A N/A N/A N/A self _outqueue append N/A timestamp N/A stream src N/A stream dst msg N/A N/A context bytes N/A N/A context bytes N/A N/A idx msglen N/A N/A N/A