<s> from google . net . proto import ProtocolBuffer <EOL> import array <EOL> import dummy_thread as thread <EOL> __pychecker__ = """<STR_LIT>""" <EOL> if hasattr ( ProtocolBuffer , '<STR_LIT>' ) : <EOL> _extension_runtime = True <EOL> _ExtendableProtocolMessage = ProtocolBuffer . ExtendableProtocolMessage <EOL> else : <EOL> _extension_runtime = False <EOL> _ExtendableProtocolMessage = ProtocolBuffer . ProtocolMessage <EOL> from google . appengine . datastore . entity_pb import * <EOL> import google . appengine . datastore . entity_pb <EOL> class AggregateRpcStatsProto ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_service_call_name_ = <NUM_LIT:0> <EOL> service_call_name_ = "<STR_LIT>" <EOL> has_total_amount_of_calls_ = <NUM_LIT:0> <EOL> total_amount_of_calls_ = <NUM_LIT:0> <EOL> has_total_cost_of_calls_microdollars_ = <NUM_LIT:0> <EOL> total_cost_of_calls_microdollars_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> self . total_billed_ops_ = [ ] <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def service_call_name ( self ) : return self . service_call_name_ <EOL> def set_service_call_name ( self , x ) : <EOL> self . has_service_call_name_ = <NUM_LIT:1> <EOL> self . service_call_name_ = x <EOL> def clear_service_call_name ( self ) : <EOL> if self . has_service_call_name_ : <EOL> self . has_service_call_name_ = <NUM_LIT:0> <EOL> self . service_call_name_ = "<STR_LIT>" <EOL> def has_service_call_name ( self ) : return self . has_service_call_name_ <EOL> def total_amount_of_calls ( self ) : return self . total_amount_of_calls_ <EOL> def set_total_amount_of_calls ( self , x ) : <EOL> self . has_total_amount_of_calls_ = <NUM_LIT:1> <EOL> self . total_amount_of_calls_ = x <EOL> def clear_total_amount_of_calls ( self ) : <EOL> if self . has_total_amount_of_calls_ : <EOL> self . has_total_amount_of_calls_ = <NUM_LIT:0> <EOL> self . total_amount_of_calls_ = <NUM_LIT:0> <EOL> def has_total_amount_of_calls ( self ) : return self . has_total_amount_of_calls_ <EOL> def total_cost_of_calls_microdollars ( self ) : return self . total_cost_of_calls_microdollars_ <EOL> def set_total_cost_of_calls_microdollars ( self , x ) : <EOL> self . has_total_cost_of_calls_microdollars_ = <NUM_LIT:1> <EOL> self . total_cost_of_calls_microdollars_ = x <EOL> def clear_total_cost_of_calls_microdollars ( self ) : <EOL> if self . has_total_cost_of_calls_microdollars_ : <EOL> self . has_total_cost_of_calls_microdollars_ = <NUM_LIT:0> <EOL> self . total_cost_of_calls_microdollars_ = <NUM_LIT:0> <EOL> def has_total_cost_of_calls_microdollars ( self ) : return self . has_total_cost_of_calls_microdollars_ <EOL> def total_billed_ops_size ( self ) : return len ( self . total_billed_ops_ ) <EOL> def total_billed_ops_list ( self ) : return self . total_billed_ops_ <EOL> def total_billed_ops ( self , i ) : <EOL> return self . total_billed_ops_ [ i ] <EOL> def mutable_total_billed_ops ( self , i ) : <EOL> return self . total_billed_ops_ [ i ] <EOL> def add_total_billed_ops ( self ) : <EOL> x = BilledOpProto ( ) <EOL> self . total_billed_ops_ . append ( x ) <EOL> return x <EOL> def clear_total_billed_ops ( self ) : <EOL> self . total_billed_ops_ = [ ] <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_service_call_name ( ) ) : self . set_service_call_name ( x . service_call_name ( ) ) <EOL> if ( x . has_total_amount_of_calls ( ) ) : self . set_total_amount_of_calls ( x . total_amount_of_calls ( ) ) <EOL> if ( x . has_total_cost_of_calls_microdollars ( ) ) : self . set_total_cost_of_calls_microdollars ( x . total_cost_of_calls_microdollars ( ) ) <EOL> for i in xrange ( x . total_billed_ops_size ( ) ) : self . add_total_billed_ops ( ) . CopyFrom ( x . total_billed_ops ( i ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_service_call_name_ != x . has_service_call_name_ : return <NUM_LIT:0> <EOL> if self . has_service_call_name_ and self . service_call_name_ != x . service_call_name_ : return <NUM_LIT:0> <EOL> if self . has_total_amount_of_calls_ != x . has_total_amount_of_calls_ : return <NUM_LIT:0> <EOL> if self . has_total_amount_of_calls_ and self . total_amount_of_calls_ != x . total_amount_of_calls_ : return <NUM_LIT:0> <EOL> if self . has_total_cost_of_calls_microdollars_ != x . has_total_cost_of_calls_microdollars_ : return <NUM_LIT:0> <EOL> if self . has_total_cost_of_calls_microdollars_ and self . total_cost_of_calls_microdollars_ != x . total_cost_of_calls_microdollars_ : return <NUM_LIT:0> <EOL> if len ( self . total_billed_ops_ ) != len ( x . total_billed_ops_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . total_billed_ops_ , x . total_billed_ops_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> if ( not self . has_service_call_name_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_total_amount_of_calls_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> for p in self . total_billed_ops_ : <EOL> if not p . IsInitialized ( debug_strs ) : initialized = <NUM_LIT:0> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> n += self . lengthString ( len ( self . service_call_name_ ) ) <EOL> n += self . lengthVarInt64 ( self . total_amount_of_calls_ ) <EOL> if ( self . has_total_cost_of_calls_microdollars_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . total_cost_of_calls_microdollars_ ) <EOL> n += <NUM_LIT:1> * len ( self . total_billed_ops_ ) <EOL> for i in xrange ( len ( self . total_billed_ops_ ) ) : n += self . lengthString ( self . total_billed_ops_ [ i ] . ByteSize ( ) ) <EOL> return n + <NUM_LIT:2> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_service_call_name_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . service_call_name_ ) ) <EOL> if ( self . has_total_amount_of_calls_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . total_amount_of_calls_ ) <EOL> if ( self . has_total_cost_of_calls_microdollars_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . total_cost_of_calls_microdollars_ ) <EOL> n += <NUM_LIT:1> * len ( self . total_billed_ops_ ) <EOL> for i in xrange ( len ( self . total_billed_ops_ ) ) : n += self . lengthString ( self . total_billed_ops_ [ i ] . ByteSizePartial ( ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_service_call_name ( ) <EOL> self . clear_total_amount_of_calls ( ) <EOL> self . clear_total_cost_of_calls_microdollars ( ) <EOL> self . clear_total_billed_ops ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . service_call_name_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . total_amount_of_calls_ ) <EOL> if ( self . has_total_cost_of_calls_microdollars_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:32> ) <EOL> out . putVarInt64 ( self . total_cost_of_calls_microdollars_ ) <EOL> for i in xrange ( len ( self . total_billed_ops_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . total_billed_ops_ [ i ] . ByteSize ( ) ) <EOL> self . total_billed_ops_ [ i ] . OutputUnchecked ( out ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_service_call_name_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . service_call_name_ ) <EOL> if ( self . has_total_amount_of_calls_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . total_amount_of_calls_ ) <EOL> if ( self . has_total_cost_of_calls_microdollars_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:32> ) <EOL> out . putVarInt64 ( self . total_cost_of_calls_microdollars_ ) <EOL> for i in xrange ( len ( self . total_billed_ops_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . total_billed_ops_ [ i ] . ByteSizePartial ( ) ) <EOL> self . total_billed_ops_ [ i ] . OutputPartial ( out ) <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <EOL> if tt == <NUM_LIT:10> : <EOL> self . set_service_call_name ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_total_amount_of_calls ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:32> : <EOL> self . set_total_cost_of_calls_microdollars ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> length = d . getVarInt32 ( ) <EOL> tmp = ProtocolBuffer . Decoder ( d . buffer ( ) , d . pos ( ) , d . pos ( ) + length ) <EOL> d . skip ( length ) <EOL> self . add_total_billed_ops ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if ( tt == <NUM_LIT:0> ) : raise ProtocolBuffer . ProtocolBufferDecodeError <EOL> d . skipData ( tt ) <EOL> def __str__ ( self , prefix = "<STR_LIT>" , printElemNumber = <NUM_LIT:0> ) : <EOL> res = "<STR_LIT>" <EOL> if self . has_service_call_name_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . service_call_name_ ) ) <EOL> if self . has_total_amount_of_calls_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . total_amount_of_calls_ ) ) <EOL> if self . has_total_cost_of_calls_microdollars_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . total_cost_of_calls_microdollars_ ) ) <EOL> cnt = <NUM_LIT:0> <EOL> for e in self . total_billed_ops_ : <EOL> elm = "<STR_LIT>" <EOL> if printElemNumber : elm = "<STR_LIT>" % cnt <EOL> res += prefix + ( "<STR_LIT>" % elm ) <EOL> res += e . __str__ ( prefix + "<STR_LIT:U+0020>" , printElemNumber ) <EOL> res += prefix + "<STR_LIT>" <EOL> cnt += <NUM_LIT:1> <EOL> return res <EOL> def _BuildTagLookupTable ( sparse , maxtag , default = None ) : <EOL> return tuple ( [ sparse . get ( i , default ) for i in xrange ( <NUM_LIT:0> , <NUM_LIT:1> + maxtag ) ] ) <EOL> kservice_call_name = <NUM_LIT:1> <EOL> ktotal_amount_of_calls = <NUM_LIT:3> <EOL> ktotal_cost_of_calls_microdollars = <NUM_LIT:4> <EOL> ktotal_billed_ops = <NUM_LIT:5> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:3> : "<STR_LIT>" , <EOL> <NUM_LIT:4> : "<STR_LIT>" , <EOL> <NUM_LIT:5> : "<STR_LIT>" , <EOL> } , <NUM_LIT:5> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:1> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:3> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:4> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:5> : ProtocolBuffer . Encoder . STRING , <EOL> } , <NUM_LIT:5> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class KeyValProto ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_key_ = <NUM_LIT:0> <EOL> key_ = "<STR_LIT>" <EOL> has_value_ = <NUM_LIT:0> <EOL> value_ = "<STR_LIT>" <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def key ( self ) : return self . key_ <EOL> def set_key ( self , x ) : <EOL> self . has_key_ = <NUM_LIT:1> <EOL> self . key_ = x <EOL> def clear_key ( self ) : <EOL> if self . has_key_ : <EOL> self . has_key_ = <NUM_LIT:0> <EOL> self . key_ = "<STR_LIT>" <EOL> def has_key ( self ) : return self . has_key_ <EOL> def value ( self ) : return self . value_ <EOL> def set_value ( self , x ) : <EOL> self . has_value_ = <NUM_LIT:1> <EOL> self . value_ = x <EOL> def clear_value ( self ) : <EOL> if self . has_value_ : <EOL> self . has_value_ = <NUM_LIT:0> <EOL> self . value_ = "<STR_LIT>" <EOL> def has_value ( self ) : return self . has_value_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_key ( ) ) : self . set_key ( x . key ( ) ) <EOL> if ( x . has_value ( ) ) : self . set_value ( x . value ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_key_ != x . has_key_ : return <NUM_LIT:0> <EOL> if self . has_key_ and self . key_ != x . key_ : return <NUM_LIT:0> <EOL> if self . has_value_ != x . has_value_ : return <NUM_LIT:0> <EOL> if self . has_value_ and self . value_ != x . value_ : return <NUM_LIT:0> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> if ( not self . has_key_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_value_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> n += self . lengthString ( len ( self . key_ ) ) <EOL> n += self . lengthString ( len ( self . value_ ) ) <EOL> return n + <NUM_LIT:2> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_key_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . key_ ) ) <EOL> if ( self . has_value_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . value_ ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_key ( ) <EOL> self . clear_value ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . key_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . value_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_key_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . key_ ) <EOL> if ( self . has_value_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . value_ ) <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <EOL> if tt == <NUM_LIT:10> : <EOL> self . set_key ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_value ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if ( tt == <NUM_LIT:0> ) : raise ProtocolBuffer . ProtocolBufferDecodeError <EOL> d . skipData ( tt ) <EOL> def __str__ ( self , prefix = "<STR_LIT>" , printElemNumber = <NUM_LIT:0> ) : <EOL> res = "<STR_LIT>" <EOL> if self . has_key_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . key_ ) ) <EOL> if self . has_value_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . value_ ) ) <EOL> return res <EOL> def _BuildTagLookupTable ( sparse , maxtag , default = None ) : <EOL> return tuple ( [ sparse . get ( i , default ) for i in xrange ( <NUM_LIT:0> , <NUM_LIT:1> + maxtag ) ] ) <EOL> kkey = <NUM_LIT:1> <EOL> kvalue = <NUM_LIT:2> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:key>" , <EOL> <NUM_LIT:2> : "<STR_LIT:value>" , <EOL> } , <NUM_LIT:2> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:1> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:2> : ProtocolBuffer . Encoder . STRING , <EOL> } , <NUM_LIT:2> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class StackFrameProto ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_class_or_file_name_ = <NUM_LIT:0> <EOL> class_or_file_name_ = "<STR_LIT>" <EOL> has_line_number_ = <NUM_LIT:0> <EOL> line_number_ = <NUM_LIT:0> <EOL> has_function_name_ = <NUM_LIT:0> <EOL> function_name_ = "<STR_LIT>" <EOL> def __init__ ( self , contents = None ) : <EOL> self . variables_ = [ ] <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def class_or_file_name ( self ) : return self . class_or_file_name_ <EOL> def set_class_or_file_name ( self , x ) : <EOL> self . has_class_or_file_name_ = <NUM_LIT:1> <EOL> self . class_or_file_name_ = x <EOL> def clear_class_or_file_name ( self ) : <EOL> if self . has_class_or_file_name_ : <EOL> self . has_class_or_file_name_ = <NUM_LIT:0> <EOL> self . class_or_file_name_ = "<STR_LIT>" <EOL> def has_class_or_file_name ( self ) : return self . has_class_or_file_name_ <EOL> def line_number ( self ) : return self . line_number_ <EOL> def set_line_number ( self , x ) : <EOL> self . has_line_number_ = <NUM_LIT:1> <EOL> self . line_number_ = x <EOL> def clear_line_number ( self ) : <EOL> if self . has_line_number_ : <EOL> self . has_line_number_ = <NUM_LIT:0> <EOL> self . line_number_ = <NUM_LIT:0> <EOL> def has_line_number ( self ) : return self . has_line_number_ <EOL> def function_name ( self ) : return self . function_name_ <EOL> def set_function_name ( self , x ) : <EOL> self . has_function_name_ = <NUM_LIT:1> <EOL> self . function_name_ = x <EOL> def clear_function_name ( self ) : <EOL> if self . has_function_name_ : <EOL> self . has_function_name_ = <NUM_LIT:0> <EOL> self . function_name_ = "<STR_LIT>" <EOL> def has_function_name ( self ) : return self . has_function_name_ <EOL> def variables_size ( self ) : return len ( self . variables_ ) <EOL> def variables_list ( self ) : return self . variables_ <EOL> def variables ( self , i ) : <EOL> return self . variables_ [ i ] <EOL> def mutable_variables ( self , i ) : <EOL> return self . variables_ [ i ] <EOL> def add_variables ( self ) : <EOL> x = KeyValProto ( ) <EOL> self . variables_ . append ( x ) <EOL> return x <EOL> def clear_variables ( self ) : <EOL> self . variables_ = [ ] <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_class_or_file_name ( ) ) : self . set_class_or_file_name ( x . class_or_file_name ( ) ) <EOL> if ( x . has_line_number ( ) ) : self . set_line_number ( x . line_number ( ) ) <EOL> if ( x . has_function_name ( ) ) : self . set_function_name ( x . function_name ( ) ) <EOL> for i in xrange ( x . variables_size ( ) ) : self . add_variables ( ) . CopyFrom ( x . variables ( i ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_class_or_file_name_ != x . has_class_or_file_name_ : return <NUM_LIT:0> <EOL> if self . has_class_or_file_name_ and self . class_or_file_name_ != x . class_or_file_name_ : return <NUM_LIT:0> <EOL> if self . has_line_number_ != x . has_line_number_ : return <NUM_LIT:0> <EOL> if self . has_line_number_ and self . line_number_ != x . line_number_ : return <NUM_LIT:0> <EOL> if self . has_function_name_ != x . has_function_name_ : return <NUM_LIT:0> <EOL> if self . has_function_name_ and self . function_name_ != x . function_name_ : return <NUM_LIT:0> <EOL> if len ( self . variables_ ) != len ( x . variables_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . variables_ , x . variables_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> if ( not self . has_class_or_file_name_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_function_name_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> for p in self . variables_ : <EOL> if not p . IsInitialized ( debug_strs ) : initialized = <NUM_LIT:0> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> n += self . lengthString ( len ( self . class_or_file_name_ ) ) <EOL> if ( self . has_line_number_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . line_number_ ) <EOL> n += self . lengthString ( len ( self . function_name_ ) ) <EOL> n += <NUM_LIT:1> * len ( self . variables_ ) <EOL> for i in xrange ( len ( self . variables_ ) ) : n += self . lengthString ( self . variables_ [ i ] . ByteSize ( ) ) <EOL> return n + <NUM_LIT:2> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_class_or_file_name_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . class_or_file_name_ ) ) <EOL> if ( self . has_line_number_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . line_number_ ) <EOL> if ( self . has_function_name_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . function_name_ ) ) <EOL> n += <NUM_LIT:1> * len ( self . variables_ ) <EOL> for i in xrange ( len ( self . variables_ ) ) : n += self . lengthString ( self . variables_ [ i ] . ByteSizePartial ( ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_class_or_file_name ( ) <EOL> self . clear_line_number ( ) <EOL> self . clear_function_name ( ) <EOL> self . clear_variables ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . class_or_file_name_ ) <EOL> if ( self . has_line_number_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putVarInt32 ( self . line_number_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . function_name_ ) <EOL> for i in xrange ( len ( self . variables_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . variables_ [ i ] . ByteSize ( ) ) <EOL> self . variables_ [ i ] . OutputUnchecked ( out ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_class_or_file_name_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . class_or_file_name_ ) <EOL> if ( self . has_line_number_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putVarInt32 ( self . line_number_ ) <EOL> if ( self . has_function_name_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . function_name_ ) <EOL> for i in xrange ( len ( self . variables_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . variables_ [ i ] . ByteSizePartial ( ) ) <EOL> self . variables_ [ i ] . OutputPartial ( out ) <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <EOL> if tt == <NUM_LIT:10> : <EOL> self . set_class_or_file_name ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:16> : <EOL> self . set_line_number ( d . getVarInt32 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_function_name ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> length = d . getVarInt32 ( ) <EOL> tmp = ProtocolBuffer . Decoder ( d . buffer ( ) , d . pos ( ) , d . pos ( ) + length ) <EOL> d . skip ( length ) <EOL> self . add_variables ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if ( tt == <NUM_LIT:0> ) : raise ProtocolBuffer . ProtocolBufferDecodeError <EOL> d . skipData ( tt ) <EOL> def __str__ ( self , prefix = "<STR_LIT>" , printElemNumber = <NUM_LIT:0> ) : <EOL> res = "<STR_LIT>" <EOL> if self . has_class_or_file_name_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . class_or_file_name_ ) ) <EOL> if self . has_line_number_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt32 ( self . line_number_ ) ) <EOL> if self . has_function_name_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . function_name_ ) ) <EOL> cnt = <NUM_LIT:0> <EOL> for e in self . variables_ : <EOL> elm = "<STR_LIT>" <EOL> if printElemNumber : elm = "<STR_LIT>" % cnt <EOL> res += prefix + ( "<STR_LIT>" % elm ) <EOL> res += e . __str__ ( prefix + "<STR_LIT:U+0020>" , printElemNumber ) <EOL> res += prefix + "<STR_LIT>" <EOL> cnt += <NUM_LIT:1> <EOL> return res <EOL> def _BuildTagLookupTable ( sparse , maxtag , default = None ) : <EOL> return tuple ( [ sparse . get ( i , default ) for i in xrange ( <NUM_LIT:0> , <NUM_LIT:1> + maxtag ) ] ) <EOL> kclass_or_file_name = <NUM_LIT:1> <EOL> kline_number = <NUM_LIT:2> <EOL> kfunction_name = <NUM_LIT:3> <EOL> kvariables = <NUM_LIT:4> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:2> : "<STR_LIT>" , <EOL> <NUM_LIT:3> : "<STR_LIT>" , <EOL> <NUM_LIT:4> : "<STR_LIT>" , <EOL> } , <NUM_LIT:4> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:1> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:2> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:3> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:4> : ProtocolBuffer . Encoder . STRING , <EOL> } , <NUM_LIT:4> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class BilledOpProto ( ProtocolBuffer . ProtocolMessage ) : <EOL> DATASTORE_READ = <NUM_LIT:0> <EOL> DATASTORE_WRITE = <NUM_LIT:1> <EOL> DATASTORE_SMALL = <NUM_LIT:2> <EOL> MAIL_RECIPIENT = <NUM_LIT:3> <EOL> CHANNEL_OPEN = <NUM_LIT:4> <EOL> XMPP_STANZA = <NUM_LIT:5> <EOL> CHANNEL_PRESENCE = <NUM_LIT:6> <EOL> _BilledOp_NAMES = { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:2> : "<STR_LIT>" , <EOL> <NUM_LIT:3> : "<STR_LIT>" , <EOL> <NUM_LIT:4> : "<STR_LIT>" , <EOL> <NUM_LIT:5> : "<STR_LIT>" , <EOL> <NUM_LIT:6> : "<STR_LIT>" , <EOL> } <EOL> def BilledOp_Name ( cls , x ) : return cls . _BilledOp_NAMES . get ( x , "<STR_LIT>" ) <EOL> BilledOp_Name = classmethod ( BilledOp_Name ) <EOL> has_op_ = <NUM_LIT:0> <EOL> op_ = <NUM_LIT:0> <EOL> has_num_ops_ = <NUM_LIT:0> <EOL> num_ops_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def op ( self ) : return self . op_ <EOL> def set_op ( self , x ) : <EOL> self . has_op_ = <NUM_LIT:1> <EOL> self . op_ = x <EOL> def clear_op ( self ) : <EOL> if self . has_op_ : <EOL> self . has_op_ = <NUM_LIT:0> <EOL> self . op_ = <NUM_LIT:0> <EOL> def has_op ( self ) : return self . has_op_ <EOL> def num_ops ( self ) : return self . num_ops_ <EOL> def set_num_ops ( self , x ) : <EOL> self . has_num_ops_ = <NUM_LIT:1> <EOL> self . num_ops_ = x <EOL> def clear_num_ops ( self ) : <EOL> if self . has_num_ops_ : <EOL> self . has_num_ops_ = <NUM_LIT:0> <EOL> self . num_ops_ = <NUM_LIT:0> <EOL> def has_num_ops ( self ) : return self . has_num_ops_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_op ( ) ) : self . set_op ( x . op ( ) ) <EOL> if ( x . has_num_ops ( ) ) : self . set_num_ops ( x . num_ops ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_op_ != x . has_op_ : return <NUM_LIT:0> <EOL> if self . has_op_ and self . op_ != x . op_ : return <NUM_LIT:0> <EOL> if self . has_num_ops_ != x . has_num_ops_ : return <NUM_LIT:0> <EOL> if self . has_num_ops_ and self . num_ops_ != x . num_ops_ : return <NUM_LIT:0> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> if ( not self . has_op_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_num_ops_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> n += self . lengthVarInt64 ( self . op_ ) <EOL> n += self . lengthVarInt64 ( self . num_ops_ ) <EOL> return n + <NUM_LIT:2> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_op_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . op_ ) <EOL> if ( self . has_num_ops_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . num_ops_ ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_op ( ) <EOL> self . clear_num_ops ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:8> ) <EOL> out . putVarInt32 ( self . op_ ) <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putVarInt32 ( self . num_ops_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_op_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:8> ) <EOL> out . putVarInt32 ( self . op_ ) <EOL> if ( self . has_num_ops_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putVarInt32 ( self . num_ops_ ) <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <EOL> if tt == <NUM_LIT:8> : <EOL> self . set_op ( d . getVarInt32 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:16> : <EOL> self . set_num_ops ( d . getVarInt32 ( ) ) <EOL> continue <EOL> if ( tt == <NUM_LIT:0> ) : raise ProtocolBuffer . ProtocolBufferDecodeError <EOL> d . skipData ( tt ) <EOL> def __str__ ( self , prefix = "<STR_LIT>" , printElemNumber = <NUM_LIT:0> ) : <EOL> res = "<STR_LIT>" <EOL> if self . has_op_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt32 ( self . op_ ) ) <EOL> if self . has_num_ops_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt32 ( self . num_ops_ ) ) <EOL> return res <EOL> def _BuildTagLookupTable ( sparse , maxtag , default = None ) : <EOL> return tuple ( [ sparse . get ( i , default ) for i in xrange ( <NUM_LIT:0> , <NUM_LIT:1> + maxtag ) ] ) <EOL> kop = <NUM_LIT:1> <EOL> knum_ops = <NUM_LIT:2> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:2> : "<STR_LIT>" , <EOL> } , <NUM_LIT:2> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:1> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:2> : ProtocolBuffer . Encoder . NUMERIC , <EOL> } , <NUM_LIT:2> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class DatastoreCallDetailsProto ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_query_kind_ = <NUM_LIT:0> <EOL> query_kind_ = "<STR_LIT>" <EOL> has_query_ancestor_ = <NUM_LIT:0> <EOL> query_ancestor_ = None <EOL> has_query_thiscursor_ = <NUM_LIT:0> <EOL> query_thiscursor_ = <NUM_LIT:0> <EOL> has_query_nextcursor_ = <NUM_LIT:0> <EOL> query_nextcursor_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> self . get_successful_fetch_ = [ ] <EOL> self . keys_read_ = [ ] <EOL> self . keys_written_ = [ ] <EOL> self . lazy_init_lock_ = thread . allocate_lock ( ) <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def query_kind ( self ) : return self . query_kind_ <EOL> def set_query_kind ( self , x ) : <EOL> self . has_query_kind_ = <NUM_LIT:1> <EOL> self . query_kind_ = x <EOL> def clear_query_kind ( self ) : <EOL> if self . has_query_kind_ : <EOL> self . has_query_kind_ = <NUM_LIT:0> <EOL> self . query_kind_ = "<STR_LIT>" <EOL> def has_query_kind ( self ) : return self . has_query_kind_ <EOL> def query_ancestor ( self ) : <EOL> if self . query_ancestor_ is None : <EOL> self . lazy_init_lock_ . acquire ( ) <EOL> try : <EOL> if self . query_ancestor_ is None : self . query_ancestor_ = Reference ( ) <EOL> finally : <EOL> self . lazy_init_lock_ . release ( ) <EOL> return self . query_ancestor_ <EOL> def mutable_query_ancestor ( self ) : self . has_query_ancestor_ = <NUM_LIT:1> ; return self . query_ancestor ( ) <EOL> def clear_query_ancestor ( self ) : <EOL> if self . has_query_ancestor_ : <EOL> self . has_query_ancestor_ = <NUM_LIT:0> ; <EOL> if self . query_ancestor_ is not None : self . query_ancestor_ . Clear ( ) <EOL> def has_query_ancestor ( self ) : return self . has_query_ancestor_ <EOL> def query_thiscursor ( self ) : return self . query_thiscursor_ <EOL> def set_query_thiscursor ( self , x ) : <EOL> self . has_query_thiscursor_ = <NUM_LIT:1> <EOL> self . query_thiscursor_ = x <EOL> def clear_query_thiscursor ( self ) : <EOL> if self . has_query_thiscursor_ : <EOL> self . has_query_thiscursor_ = <NUM_LIT:0> <EOL> self . query_thiscursor_ = <NUM_LIT:0> <EOL> def has_query_thiscursor ( self ) : return self . has_query_thiscursor_ <EOL> def query_nextcursor ( self ) : return self . query_nextcursor_ <EOL> def set_query_nextcursor ( self , x ) : <EOL> self . has_query_nextcursor_ = <NUM_LIT:1> <EOL> self . query_nextcursor_ = x <EOL> def clear_query_nextcursor ( self ) : <EOL> if self . has_query_nextcursor_ : <EOL> self . has_query_nextcursor_ = <NUM_LIT:0> <EOL> self . query_nextcursor_ = <NUM_LIT:0> <EOL> def has_query_nextcursor ( self ) : return self . has_query_nextcursor_ <EOL> def get_successful_fetch_size ( self ) : return len ( self . get_successful_fetch_ ) <EOL> def get_successful_fetch_list ( self ) : return self . get_successful_fetch_ <EOL> def get_successful_fetch ( self , i ) : <EOL> return self . get_successful_fetch_ [ i ] <EOL> def set_get_successful_fetch ( self , i , x ) : <EOL> self . get_successful_fetch_ [ i ] = x <EOL> def add_get_successful_fetch ( self , x ) : <EOL> self . get_successful_fetch_ . append ( x ) <EOL> def clear_get_successful_fetch ( self ) : <EOL> self . get_successful_fetch_ = [ ] <EOL> def keys_read_size ( self ) : return len ( self . keys_read_ ) <EOL> def keys_read_list ( self ) : return self . keys_read_ <EOL> def keys_read ( self , i ) : <EOL> return self . keys_read_ [ i ] <EOL> def mutable_keys_read ( self , i ) : <EOL> return self . keys_read_ [ i ] <EOL> def add_keys_read ( self ) : <EOL> x = Reference ( ) <EOL> self . keys_read_ . append ( x ) <EOL> return x <EOL> def clear_keys_read ( self ) : <EOL> self . keys_read_ = [ ] <EOL> def keys_written_size ( self ) : return len ( self . keys_written_ ) <EOL> def keys_written_list ( self ) : return self . keys_written_ <EOL> def keys_written ( self , i ) : <EOL> return self . keys_written_ [ i ] <EOL> def mutable_keys_written ( self , i ) : <EOL> return self . keys_written_ [ i ] <EOL> def add_keys_written ( self ) : <EOL> x = Reference ( ) <EOL> self . keys_written_ . append ( x ) <EOL> return x <EOL> def clear_keys_written ( self ) : <EOL> self . keys_written_ = [ ] <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_query_kind ( ) ) : self . set_query_kind ( x . query_kind ( ) ) <EOL> if ( x . has_query_ancestor ( ) ) : self . mutable_query_ancestor ( ) . MergeFrom ( x . query_ancestor ( ) ) <EOL> if ( x . has_query_thiscursor ( ) ) : self . set_query_thiscursor ( x . query_thiscursor ( ) ) <EOL> if ( x . has_query_nextcursor ( ) ) : self . set_query_nextcursor ( x . query_nextcursor ( ) ) <EOL> for i in xrange ( x . get_successful_fetch_size ( ) ) : self . add_get_successful_fetch ( x . get_successful_fetch ( i ) ) <EOL> for i in xrange ( x . keys_read_size ( ) ) : self . add_keys_read ( ) . CopyFrom ( x . keys_read ( i ) ) <EOL> for i in xrange ( x . keys_written_size ( ) ) : self . add_keys_written ( ) . CopyFrom ( x . keys_written ( i ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_query_kind_ != x . has_query_kind_ : return <NUM_LIT:0> <EOL> if self . has_query_kind_ and self . query_kind_ != x . query_kind_ : return <NUM_LIT:0> <EOL> if self . has_query_ancestor_ != x . has_query_ancestor_ : return <NUM_LIT:0> <EOL> if self . has_query_ancestor_ and self . query_ancestor_ != x . query_ancestor_ : return <NUM_LIT:0> <EOL> if self . has_query_thiscursor_ != x . has_query_thiscursor_ : return <NUM_LIT:0> <EOL> if self . has_query_thiscursor_ and self . query_thiscursor_ != x . query_thiscursor_ : return <NUM_LIT:0> <EOL> if self . has_query_nextcursor_ != x . has_query_nextcursor_ : return <NUM_LIT:0> <EOL> if self . has_query_nextcursor_ and self . query_nextcursor_ != x . query_nextcursor_ : return <NUM_LIT:0> <EOL> if len ( self . get_successful_fetch_ ) != len ( x . get_successful_fetch_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . get_successful_fetch_ , x . get_successful_fetch_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> if len ( self . keys_read_ ) != len ( x . keys_read_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . keys_read_ , x . keys_read_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> if len ( self . keys_written_ ) != len ( x . keys_written_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . keys_written_ , x . keys_written_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> if ( self . has_query_ancestor_ and not self . query_ancestor_ . IsInitialized ( debug_strs ) ) : initialized = <NUM_LIT:0> <EOL> for p in self . keys_read_ : <EOL> if not p . IsInitialized ( debug_strs ) : initialized = <NUM_LIT:0> <EOL> for p in self . keys_written_ : <EOL> if not p . IsInitialized ( debug_strs ) : initialized = <NUM_LIT:0> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_query_kind_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . query_kind_ ) ) <EOL> if ( self . has_query_ancestor_ ) : n += <NUM_LIT:1> + self . lengthString ( self . query_ancestor_ . ByteSize ( ) ) <EOL> if ( self . has_query_thiscursor_ ) : n += <NUM_LIT:9> <EOL> if ( self . has_query_nextcursor_ ) : n += <NUM_LIT:9> <EOL> n += <NUM_LIT:2> * len ( self . get_successful_fetch_ ) <EOL> n += <NUM_LIT:1> * len ( self . keys_read_ ) <EOL> for i in xrange ( len ( self . keys_read_ ) ) : n += self . lengthString ( self . keys_read_ [ i ] . ByteSize ( ) ) <EOL> n += <NUM_LIT:1> * len ( self . keys_written_ ) <EOL> for i in xrange ( len ( self . keys_written_ ) ) : n += self . lengthString ( self . keys_written_ [ i ] . ByteSize ( ) ) <EOL> return n <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_query_kind_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . query_kind_ ) ) <EOL> if ( self . has_query_ancestor_ ) : n += <NUM_LIT:1> + self . lengthString ( self . query_ancestor_ . ByteSizePartial ( ) ) <EOL> if ( self . has_query_thiscursor_ ) : n += <NUM_LIT:9> <EOL> if ( self . has_query_nextcursor_ ) : n += <NUM_LIT:9> <EOL> n += <NUM_LIT:2> * len ( self . get_successful_fetch_ ) <EOL> n += <NUM_LIT:1> * len ( self . keys_read_ ) <EOL> for i in xrange ( len ( self . keys_read_ ) ) : n += self . lengthString ( self . keys_read_ [ i ] . ByteSizePartial ( ) ) <EOL> n += <NUM_LIT:1> * len ( self . keys_written_ ) <EOL> for i in xrange ( len ( self . keys_written_ ) ) : n += self . lengthString ( self . keys_written_ [ i ] . ByteSizePartial ( ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_query_kind ( ) <EOL> self . clear_query_ancestor ( ) <EOL> self . clear_query_thiscursor ( ) <EOL> self . clear_query_nextcursor ( ) <EOL> self . clear_get_successful_fetch ( ) <EOL> self . clear_keys_read ( ) <EOL> self . clear_keys_written ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> if ( self . has_query_kind_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . query_kind_ ) <EOL> if ( self . has_query_ancestor_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . query_ancestor_ . ByteSize ( ) ) <EOL> self . query_ancestor_ . OutputUnchecked ( out ) <EOL> if ( self . has_query_thiscursor_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . put64 ( self . query_thiscursor_ ) <EOL> if ( self . has_query_nextcursor_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . put64 ( self . query_nextcursor_ ) <EOL> for i in xrange ( len ( self . get_successful_fetch_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putBoolean ( self . get_successful_fetch_ [ i ] ) <EOL> for i in xrange ( len ( self . keys_read_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT:50> ) <EOL> out . putVarInt32 ( self . keys_read_ [ i ] . ByteSize ( ) ) <EOL> self . keys_read_ [ i ] . OutputUnchecked ( out ) <EOL> for i in xrange ( len ( self . keys_written_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . keys_written_ [ i ] . ByteSize ( ) ) <EOL> self . keys_written_ [ i ] . OutputUnchecked ( out ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_query_kind_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . query_kind_ ) <EOL> if ( self . has_query_ancestor_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . query_ancestor_ . ByteSizePartial ( ) ) <EOL> self . query_ancestor_ . OutputPartial ( out ) <EOL> if ( self . has_query_thiscursor_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . put64 ( self . query_thiscursor_ ) <EOL> if ( self . has_query_nextcursor_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . put64 ( self . query_nextcursor_ ) <EOL> for i in xrange ( len ( self . get_successful_fetch_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putBoolean ( self . get_successful_fetch_ [ i ] ) <EOL> for i in xrange ( len ( self . keys_read_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT:50> ) <EOL> out . putVarInt32 ( self . keys_read_ [ i ] . ByteSizePartial ( ) ) <EOL> self . keys_read_ [ i ] . OutputPartial ( out ) <EOL> for i in xrange ( len ( self . keys_written_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . keys_written_ [ i ] . ByteSizePartial ( ) ) <EOL> self . keys_written_ [ i ] . OutputPartial ( out ) <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <EOL> if tt == <NUM_LIT:10> : <EOL> self . set_query_kind ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> length = d . getVarInt32 ( ) <EOL> tmp = ProtocolBuffer . Decoder ( d . buffer ( ) , d . pos ( ) , d . pos ( ) + length ) <EOL> d . skip ( length ) <EOL> self . mutable_query_ancestor ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_query_thiscursor ( d . get64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_query_nextcursor ( d . get64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . add_get_successful_fetch ( d . getBoolean ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:50> : <EOL> length = d . getVarInt32 ( ) <EOL> tmp = ProtocolBuffer . Decoder ( d . buffer ( ) , d . pos ( ) , d . pos ( ) + length ) <EOL> d . skip ( length ) <EOL> self . add_keys_read ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> length = d . getVarInt32 ( ) <EOL> tmp = ProtocolBuffer . Decoder ( d . buffer ( ) , d . pos ( ) , d . pos ( ) + length ) <EOL> d . skip ( length ) <EOL> self . add_keys_written ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if ( tt == <NUM_LIT:0> ) : raise ProtocolBuffer . ProtocolBufferDecodeError <EOL> d . skipData ( tt ) <EOL> def __str__ ( self , prefix = "<STR_LIT>" , printElemNumber = <NUM_LIT:0> ) : <EOL> res = "<STR_LIT>" <EOL> if self . has_query_kind_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . query_kind_ ) ) <EOL> if self . has_query_ancestor_ : <EOL> res += prefix + "<STR_LIT>" <EOL> res += self . query_ancestor_ . __str__ ( prefix + "<STR_LIT:U+0020>" , printElemNumber ) <EOL> res += prefix + "<STR_LIT>" <EOL> if self . has_query_thiscursor_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatFixed64 ( self . query_thiscursor_ ) ) <EOL> if self . has_query_nextcursor_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatFixed64 ( self . query_nextcursor_ ) ) <EOL> cnt = <NUM_LIT:0> <EOL> for e in self . get_successful_fetch_ : <EOL> elm = "<STR_LIT>" <EOL> if printElemNumber : elm = "<STR_LIT>" % cnt <EOL> res += prefix + ( "<STR_LIT>" % ( elm , self . DebugFormatBool ( e ) ) ) <EOL> cnt += <NUM_LIT:1> <EOL> cnt = <NUM_LIT:0> <EOL> for e in self . keys_read_ : <EOL> elm = "<STR_LIT>" <EOL> if printElemNumber : elm = "<STR_LIT>" % cnt <EOL> res += prefix + ( "<STR_LIT>" % elm ) <EOL> res += e . __str__ ( prefix + "<STR_LIT:U+0020>" , printElemNumber ) <EOL> res += prefix + "<STR_LIT>" <EOL> cnt += <NUM_LIT:1> <EOL> cnt = <NUM_LIT:0> <EOL> for e in self . keys_written_ : <EOL> elm = "<STR_LIT>" <EOL> if printElemNumber : elm = "<STR_LIT>" % cnt <EOL> res += prefix + ( "<STR_LIT>" % elm ) <EOL> res += e . __str__ ( prefix + "<STR_LIT:U+0020>" , printElemNumber ) <EOL> res += prefix + "<STR_LIT>" <EOL> cnt += <NUM_LIT:1> <EOL> return res <EOL> def _BuildTagLookupTable ( sparse , maxtag , default = None ) : <EOL> return tuple ( [ sparse . get ( i , default ) for i in xrange ( <NUM_LIT:0> , <NUM_LIT:1> + maxtag ) ] ) <EOL> kquery_kind = <NUM_LIT:1> <EOL> kquery_ancestor = <NUM_LIT:2> <EOL> kquery_thiscursor = <NUM_LIT:3> <EOL> kquery_nextcursor = <NUM_LIT:4> <EOL> kget_successful_fetch = <NUM_LIT:5> <EOL> kkeys_read = <NUM_LIT:6> <EOL> kkeys_written = <NUM_LIT:7> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:2> : "<STR_LIT>" , <EOL> <NUM_LIT:3> : "<STR_LIT>" , <EOL> <NUM_LIT:4> : "<STR_LIT>" , <EOL> <NUM_LIT:5> : "<STR_LIT>" , <EOL> <NUM_LIT:6> : "<STR_LIT>" , <EOL> <NUM_LIT:7> : "<STR_LIT>" , <EOL> } , <NUM_LIT:7> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:1> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:2> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:3> : ProtocolBuffer . Encoder . DOUBLE , <EOL> <NUM_LIT:4> : ProtocolBuffer . Encoder . DOUBLE , <EOL> <NUM_LIT:5> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:6> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:7> : ProtocolBuffer . Encoder . STRING , <EOL> } , <NUM_LIT:7> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class IndividualRpcStatsProto ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_service_call_name_ = <NUM_LIT:0> <EOL> service_call_name_ = "<STR_LIT>" <EOL> has_request_data_summary_ = <NUM_LIT:0> <EOL> request_data_summary_ = "<STR_LIT>" <EOL> has_response_data_summary_ = <NUM_LIT:0> <EOL> response_data_summary_ = "<STR_LIT>" <EOL> has_api_mcycles_ = <NUM_LIT:0> <EOL> api_mcycles_ = <NUM_LIT:0> <EOL> has_api_milliseconds_ = <NUM_LIT:0> <EOL> api_milliseconds_ = <NUM_LIT:0> <EOL> has_start_offset_milliseconds_ = <NUM_LIT:0> <EOL> start_offset_milliseconds_ = <NUM_LIT:0> <EOL> has_duration_milliseconds_ = <NUM_LIT:0> <EOL> duration_milliseconds_ = <NUM_LIT:0> <EOL> has_namespace_ = <NUM_LIT:0> <EOL> namespace_ = "<STR_LIT>" <EOL> has_was_successful_ = <NUM_LIT:0> <EOL> was_successful_ = <NUM_LIT:1> <EOL> has_datastore_details_ = <NUM_LIT:0> <EOL> datastore_details_ = None <EOL> has_call_cost_microdollars_ = <NUM_LIT:0> <EOL> call_cost_microdollars_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> self . call_stack_ = [ ] <EOL> self . billed_ops_ = [ ] <EOL> self . lazy_init_lock_ = thread . allocate_lock ( ) <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def service_call_name ( self ) : return self . service_call_name_ <EOL> def set_service_call_name ( self , x ) : <EOL> self . has_service_call_name_ = <NUM_LIT:1> <EOL> self . service_call_name_ = x <EOL> def clear_service_call_name ( self ) : <EOL> if self . has_service_call_name_ : <EOL> self . has_service_call_name_ = <NUM_LIT:0> <EOL> self . service_call_name_ = "<STR_LIT>" <EOL> def has_service_call_name ( self ) : return self . has_service_call_name_ <EOL> def request_data_summary ( self ) : return self . request_data_summary_ <EOL> def set_request_data_summary ( self , x ) : <EOL> self . has_request_data_summary_ = <NUM_LIT:1> <EOL> self . request_data_summary_ = x <EOL> def clear_request_data_summary ( self ) : <EOL> if self . has_request_data_summary_ : <EOL> self . has_request_data_summary_ = <NUM_LIT:0> <EOL> self . request_data_summary_ = "<STR_LIT>" <EOL> def has_request_data_summary ( self ) : return self . has_request_data_summary_ <EOL> def response_data_summary ( self ) : return self . response_data_summary_ <EOL> def set_response_data_summary ( self , x ) : <EOL> self . has_response_data_summary_ = <NUM_LIT:1> <EOL> self . response_data_summary_ = x <EOL> def clear_response_data_summary ( self ) : <EOL> if self . has_response_data_summary_ : <EOL> self . has_response_data_summary_ = <NUM_LIT:0> <EOL> self . response_data_summary_ = "<STR_LIT>" <EOL> def has_response_data_summary ( self ) : return self . has_response_data_summary_ <EOL> def api_mcycles ( self ) : return self . api_mcycles_ <EOL> def set_api_mcycles ( self , x ) : <EOL> self . has_api_mcycles_ = <NUM_LIT:1> <EOL> self . api_mcycles_ = x <EOL> def clear_api_mcycles ( self ) : <EOL> if self . has_api_mcycles_ : <EOL> self . has_api_mcycles_ = <NUM_LIT:0> <EOL> self . api_mcycles_ = <NUM_LIT:0> <EOL> def has_api_mcycles ( self ) : return self . has_api_mcycles_ <EOL> def api_milliseconds ( self ) : return self . api_milliseconds_ <EOL> def set_api_milliseconds ( self , x ) : <EOL> self . has_api_milliseconds_ = <NUM_LIT:1> <EOL> self . api_milliseconds_ = x <EOL> def clear_api_milliseconds ( self ) : <EOL> if self . has_api_milliseconds_ : <EOL> self . has_api_milliseconds_ = <NUM_LIT:0> <EOL> self . api_milliseconds_ = <NUM_LIT:0> <EOL> def has_api_milliseconds ( self ) : return self . has_api_milliseconds_ <EOL> def start_offset_milliseconds ( self ) : return self . start_offset_milliseconds_ <EOL> def set_start_offset_milliseconds ( self , x ) : <EOL> self . has_start_offset_milliseconds_ = <NUM_LIT:1> <EOL> self . start_offset_milliseconds_ = x <EOL> def clear_start_offset_milliseconds ( self ) : <EOL> if self . has_start_offset_milliseconds_ : <EOL> self . has_start_offset_milliseconds_ = <NUM_LIT:0> <EOL> self . start_offset_milliseconds_ = <NUM_LIT:0> <EOL> def has_start_offset_milliseconds ( self ) : return self . has_start_offset_milliseconds_ <EOL> def duration_milliseconds ( self ) : return self . duration_milliseconds_ <EOL> def set_duration_milliseconds ( self , x ) : <EOL> self . has_duration_milliseconds_ = <NUM_LIT:1> <EOL> self . duration_milliseconds_ = x <EOL> def clear_duration_milliseconds ( self ) : <EOL> if self . has_duration_milliseconds_ : <EOL> self . has_duration_milliseconds_ = <NUM_LIT:0> <EOL> self . duration_milliseconds_ = <NUM_LIT:0> <EOL> def has_duration_milliseconds ( self ) : return self . has_duration_milliseconds_ <EOL> def namespace ( self ) : return self . namespace_ <EOL> def set_namespace ( self , x ) : <EOL> self . has_namespace_ = <NUM_LIT:1> <EOL> self . namespace_ = x <EOL> def clear_namespace ( self ) : <EOL> if self . has_namespace_ : <EOL> self . has_namespace_ = <NUM_LIT:0> <EOL> self . namespace_ = "<STR_LIT>" <EOL> def has_namespace ( self ) : return self . has_namespace_ <EOL> def was_successful ( self ) : return self . was_successful_ <EOL> def set_was_successful ( self , x ) : <EOL> self . has_was_successful_ = <NUM_LIT:1> <EOL> self . was_successful_ = x <EOL> def clear_was_successful ( self ) : <EOL> if self . has_was_successful_ : <EOL> self . has_was_successful_ = <NUM_LIT:0> <EOL> self . was_successful_ = <NUM_LIT:1> <EOL> def has_was_successful ( self ) : return self . has_was_successful_ <EOL> def call_stack_size ( self ) : return len ( self . call_stack_ ) <EOL> def call_stack_list ( self ) : return self . call_stack_ <EOL> def call_stack ( self , i ) : <EOL> return self . call_stack_ [ i ] <EOL> def mutable_call_stack ( self , i ) : <EOL> return self . call_stack_ [ i ] <EOL> def add_call_stack ( self ) : <EOL> x = StackFrameProto ( ) <EOL> self . call_stack_ . append ( x ) <EOL> return x <EOL> def clear_call_stack ( self ) : <EOL> self . call_stack_ = [ ] <EOL> def datastore_details ( self ) : <EOL> if self . datastore_details_ is None : <EOL> self . lazy_init_lock_ . acquire ( ) <EOL> try : <EOL> if self . datastore_details_ is None : self . datastore_details_ = DatastoreCallDetailsProto ( ) <EOL> finally : <EOL> self . lazy_init_lock_ . release ( ) <EOL> return self . datastore_details_ <EOL> def mutable_datastore_details ( self ) : self . has_datastore_details_ = <NUM_LIT:1> ; return self . datastore_details ( ) <EOL> def clear_datastore_details ( self ) : <EOL> if self . has_datastore_details_ : <EOL> self . has_datastore_details_ = <NUM_LIT:0> ; <EOL> if self . datastore_details_ is not None : self . datastore_details_ . Clear ( ) <EOL> def has_datastore_details ( self ) : return self . has_datastore_details_ <EOL> def call_cost_microdollars ( self ) : return self . call_cost_microdollars_ <EOL> def set_call_cost_microdollars ( self , x ) : <EOL> self . has_call_cost_microdollars_ = <NUM_LIT:1> <EOL> self . call_cost_microdollars_ = x <EOL> def clear_call_cost_microdollars ( self ) : <EOL> if self . has_call_cost_microdollars_ : <EOL> self . has_call_cost_microdollars_ = <NUM_LIT:0> <EOL> self . call_cost_microdollars_ = <NUM_LIT:0> <EOL> def has_call_cost_microdollars ( self ) : return self . has_call_cost_microdollars_ <EOL> def billed_ops_size ( self ) : return len ( self . billed_ops_ ) <EOL> def billed_ops_list ( self ) : return self . billed_ops_ <EOL> def billed_ops ( self , i ) : <EOL> return self . billed_ops_ [ i ] <EOL> def mutable_billed_ops ( self , i ) : <EOL> return self . billed_ops_ [ i ] <EOL> def add_billed_ops ( self ) : <EOL> x = BilledOpProto ( ) <EOL> self . billed_ops_ . append ( x ) <EOL> return x <EOL> def clear_billed_ops ( self ) : <EOL> self . billed_ops_ = [ ] <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_service_call_name ( ) ) : self . set_service_call_name ( x . service_call_name ( ) ) <EOL> if ( x . has_request_data_summary ( ) ) : self . set_request_data_summary ( x . request_data_summary ( ) ) <EOL> if ( x . has_response_data_summary ( ) ) : self . set_response_data_summary ( x . response_data_summary ( ) ) <EOL> if ( x . has_api_mcycles ( ) ) : self . set_api_mcycles ( x . api_mcycles ( ) ) <EOL> if ( x . has_api_milliseconds ( ) ) : self . set_api_milliseconds ( x . api_milliseconds ( ) ) <EOL> if ( x . has_start_offset_milliseconds ( ) ) : self . set_start_offset_milliseconds ( x . start_offset_milliseconds ( ) ) <EOL> if ( x . has_duration_milliseconds ( ) ) : self . set_duration_milliseconds ( x . duration_milliseconds ( ) ) <EOL> if ( x . has_namespace ( ) ) : self . set_namespace ( x . namespace ( ) ) <EOL> if ( x . has_was_successful ( ) ) : self . set_was_successful ( x . was_successful ( ) ) <EOL> for i in xrange ( x . call_stack_size ( ) ) : self . add_call_stack ( ) . CopyFrom ( x . call_stack ( i ) ) <EOL> if ( x . has_datastore_details ( ) ) : self . mutable_datastore_details ( ) . MergeFrom ( x . datastore_details ( ) ) <EOL> if ( x . has_call_cost_microdollars ( ) ) : self . set_call_cost_microdollars ( x . call_cost_microdollars ( ) ) <EOL> for i in xrange ( x . billed_ops_size ( ) ) : self . add_billed_ops ( ) . CopyFrom ( x . billed_ops ( i ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_service_call_name_ != x . has_service_call_name_ : return <NUM_LIT:0> <EOL> if self . has_service_call_name_ and self . service_call_name_ != x . service_call_name_ : return <NUM_LIT:0> <EOL> if self . has_request_data_summary_ != x . has_request_data_summary_ : return <NUM_LIT:0> <EOL> if self . has_request_data_summary_ and self . request_data_summary_ != x . request_data_summary_ : return <NUM_LIT:0> <EOL> if self . has_response_data_summary_ != x . has_response_data_summary_ : return <NUM_LIT:0> <EOL> if self . has_response_data_summary_ and self . response_data_summary_ != x . response_data_summary_ : return <NUM_LIT:0> <EOL> if self . has_api_mcycles_ != x . has_api_mcycles_ : return <NUM_LIT:0> <EOL> if self . has_api_mcycles_ and self . api_mcycles_ != x . api_mcycles_ : return <NUM_LIT:0> <EOL> if self . has_api_milliseconds_ != x . has_api_milliseconds_ : return <NUM_LIT:0> <EOL> if self . has_api_milliseconds_ and self . api_milliseconds_ != x . api_milliseconds_ : return <NUM_LIT:0> <EOL> if self . has_start_offset_milliseconds_ != x . has_start_offset_milliseconds_ : return <NUM_LIT:0> <EOL> if self . has_start_offset_milliseconds_ and self . start_offset_milliseconds_ != x . start_offset_milliseconds_ : return <NUM_LIT:0> <EOL> if self . has_duration_milliseconds_ != x . has_duration_milliseconds_ : return <NUM_LIT:0> <EOL> if self . has_duration_milliseconds_ and self . duration_milliseconds_ != x . duration_milliseconds_ : return <NUM_LIT:0> <EOL> if self . has_namespace_ != x . has_namespace_ : return <NUM_LIT:0> <EOL> if self . has_namespace_ and self . namespace_ != x . namespace_ : return <NUM_LIT:0> <EOL> if self . has_was_successful_ != x . has_was_successful_ : return <NUM_LIT:0> <EOL> if self . has_was_successful_ and self . was_successful_ != x . was_successful_ : return <NUM_LIT:0> <EOL> if len ( self . call_stack_ ) != len ( x . call_stack_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . call_stack_ , x . call_stack_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> if self . has_datastore_details_ != x . has_datastore_details_ : return <NUM_LIT:0> <EOL> if self . has_datastore_details_ and self . datastore_details_ != x . datastore_details_ : return <NUM_LIT:0> <EOL> if self . has_call_cost_microdollars_ != x . has_call_cost_microdollars_ : return <NUM_LIT:0> <EOL> if self . has_call_cost_microdollars_ and self . call_cost_microdollars_ != x . call_cost_microdollars_ : return <NUM_LIT:0> <EOL> if len ( self . billed_ops_ ) != len ( x . billed_ops_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . billed_ops_ , x . billed_ops_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> if ( not self . has_service_call_name_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_start_offset_milliseconds_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> for p in self . call_stack_ : <EOL> if not p . IsInitialized ( debug_strs ) : initialized = <NUM_LIT:0> <EOL> if ( self . has_datastore_details_ and not self . datastore_details_ . IsInitialized ( debug_strs ) ) : initialized = <NUM_LIT:0> <EOL> for p in self . billed_ops_ : <EOL> if not p . IsInitialized ( debug_strs ) : initialized = <NUM_LIT:0> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> n += self . lengthString ( len ( self . service_call_name_ ) ) <EOL> if ( self . has_request_data_summary_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . request_data_summary_ ) ) <EOL> if ( self . has_response_data_summary_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . response_data_summary_ ) ) <EOL> if ( self . has_api_mcycles_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . api_mcycles_ ) <EOL> if ( self . has_api_milliseconds_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . api_milliseconds_ ) <EOL> n += self . lengthVarInt64 ( self . start_offset_milliseconds_ ) <EOL> if ( self . has_duration_milliseconds_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . duration_milliseconds_ ) <EOL> if ( self . has_namespace_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . namespace_ ) ) <EOL> if ( self . has_was_successful_ ) : n += <NUM_LIT:2> <EOL> n += <NUM_LIT:1> * len ( self . call_stack_ ) <EOL> for i in xrange ( len ( self . call_stack_ ) ) : n += self . lengthString ( self . call_stack_ [ i ] . ByteSize ( ) ) <EOL> if ( self . has_datastore_details_ ) : n += <NUM_LIT:1> + self . lengthString ( self . datastore_details_ . ByteSize ( ) ) <EOL> if ( self . has_call_cost_microdollars_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . call_cost_microdollars_ ) <EOL> n += <NUM_LIT:1> * len ( self . billed_ops_ ) <EOL> for i in xrange ( len ( self . billed_ops_ ) ) : n += self . lengthString ( self . billed_ops_ [ i ] . ByteSize ( ) ) <EOL> return n + <NUM_LIT:2> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_service_call_name_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . service_call_name_ ) ) <EOL> if ( self . has_request_data_summary_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . request_data_summary_ ) ) <EOL> if ( self . has_response_data_summary_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . response_data_summary_ ) ) <EOL> if ( self . has_api_mcycles_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . api_mcycles_ ) <EOL> if ( self . has_api_milliseconds_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . api_milliseconds_ ) <EOL> if ( self . has_start_offset_milliseconds_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . start_offset_milliseconds_ ) <EOL> if ( self . has_duration_milliseconds_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . duration_milliseconds_ ) <EOL> if ( self . has_namespace_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . namespace_ ) ) <EOL> if ( self . has_was_successful_ ) : n += <NUM_LIT:2> <EOL> n += <NUM_LIT:1> * len ( self . call_stack_ ) <EOL> for i in xrange ( len ( self . call_stack_ ) ) : n += self . lengthString ( self . call_stack_ [ i ] . ByteSizePartial ( ) ) <EOL> if ( self . has_datastore_details_ ) : n += <NUM_LIT:1> + self . lengthString ( self . datastore_details_ . ByteSizePartial ( ) ) <EOL> if ( self . has_call_cost_microdollars_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . call_cost_microdollars_ ) <EOL> n += <NUM_LIT:1> * len ( self . billed_ops_ ) <EOL> for i in xrange ( len ( self . billed_ops_ ) ) : n += self . lengthString ( self . billed_ops_ [ i ] . ByteSizePartial ( ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_service_call_name ( ) <EOL> self . clear_request_data_summary ( ) <EOL> self . clear_response_data_summary ( ) <EOL> self . clear_api_mcycles ( ) <EOL> self . clear_api_milliseconds ( ) <EOL> self . clear_start_offset_milliseconds ( ) <EOL> self . clear_duration_milliseconds ( ) <EOL> self . clear_namespace ( ) <EOL> self . clear_was_successful ( ) <EOL> self . clear_call_stack ( ) <EOL> self . clear_datastore_details ( ) <EOL> self . clear_call_cost_microdollars ( ) <EOL> self . clear_billed_ops ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . service_call_name_ ) <EOL> if ( self . has_request_data_summary_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . request_data_summary_ ) <EOL> if ( self . has_response_data_summary_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . response_data_summary_ ) <EOL> if ( self . has_api_mcycles_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . api_mcycles_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . start_offset_milliseconds_ ) <EOL> if ( self . has_duration_milliseconds_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . duration_milliseconds_ ) <EOL> if ( self . has_namespace_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . namespace_ ) <EOL> if ( self . has_was_successful_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putBoolean ( self . was_successful_ ) <EOL> for i in xrange ( len ( self . call_stack_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . call_stack_ [ i ] . ByteSize ( ) ) <EOL> self . call_stack_ [ i ] . OutputUnchecked ( out ) <EOL> if ( self . has_api_milliseconds_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . api_milliseconds_ ) <EOL> if ( self . has_datastore_details_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . datastore_details_ . ByteSize ( ) ) <EOL> self . datastore_details_ . OutputUnchecked ( out ) <EOL> if ( self . has_call_cost_microdollars_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . call_cost_microdollars_ ) <EOL> for i in xrange ( len ( self . billed_ops_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . billed_ops_ [ i ] . ByteSize ( ) ) <EOL> self . billed_ops_ [ i ] . OutputUnchecked ( out ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_service_call_name_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . service_call_name_ ) <EOL> if ( self . has_request_data_summary_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . request_data_summary_ ) <EOL> if ( self . has_response_data_summary_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . response_data_summary_ ) <EOL> if ( self . has_api_mcycles_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . api_mcycles_ ) <EOL> if ( self . has_start_offset_milliseconds_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . start_offset_milliseconds_ ) <EOL> if ( self . has_duration_milliseconds_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . duration_milliseconds_ ) <EOL> if ( self . has_namespace_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . namespace_ ) <EOL> if ( self . has_was_successful_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putBoolean ( self . was_successful_ ) <EOL> for i in xrange ( len ( self . call_stack_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . call_stack_ [ i ] . ByteSizePartial ( ) ) <EOL> self . call_stack_ [ i ] . OutputPartial ( out ) <EOL> if ( self . has_api_milliseconds_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . api_milliseconds_ ) <EOL> if ( self . has_datastore_details_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . datastore_details_ . ByteSizePartial ( ) ) <EOL> self . datastore_details_ . OutputPartial ( out ) <EOL> if ( self . has_call_cost_microdollars_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . call_cost_microdollars_ ) <EOL> for i in xrange ( len ( self . billed_ops_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . billed_ops_ [ i ] . ByteSizePartial ( ) ) <EOL> self . billed_ops_ [ i ] . OutputPartial ( out ) <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <EOL> if tt == <NUM_LIT:10> : <EOL> self . set_service_call_name ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_request_data_summary ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_response_data_summary ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_api_mcycles ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_start_offset_milliseconds ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_duration_milliseconds ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_namespace ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_was_successful ( d . getBoolean ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> length = d . getVarInt32 ( ) <EOL> tmp = ProtocolBuffer . Decoder ( d . buffer ( ) , d . pos ( ) , d . pos ( ) + length ) <EOL> d . skip ( length ) <EOL> self . add_call_stack ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_api_milliseconds ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> length = d . getVarInt32 ( ) <EOL> tmp = ProtocolBuffer . Decoder ( d . buffer ( ) , d . pos ( ) , d . pos ( ) + length ) <EOL> d . skip ( length ) <EOL> self . mutable_datastore_details ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_call_cost_microdollars ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> length = d . getVarInt32 ( ) <EOL> tmp = ProtocolBuffer . Decoder ( d . buffer ( ) , d . pos ( ) , d . pos ( ) + length ) <EOL> d . skip ( length ) <EOL> self . add_billed_ops ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if ( tt == <NUM_LIT:0> ) : raise ProtocolBuffer . ProtocolBufferDecodeError <EOL> d . skipData ( tt ) <EOL> def __str__ ( self , prefix = "<STR_LIT>" , printElemNumber = <NUM_LIT:0> ) : <EOL> res = "<STR_LIT>" <EOL> if self . has_service_call_name_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . service_call_name_ ) ) <EOL> if self . has_request_data_summary_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . request_data_summary_ ) ) <EOL> if self . has_response_data_summary_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . response_data_summary_ ) ) <EOL> if self . has_api_mcycles_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . api_mcycles_ ) ) <EOL> if self . has_api_milliseconds_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . api_milliseconds_ ) ) <EOL> if self . has_start_offset_milliseconds_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . start_offset_milliseconds_ ) ) <EOL> if self . has_duration_milliseconds_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . duration_milliseconds_ ) ) <EOL> if self . has_namespace_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . namespace_ ) ) <EOL> if self . has_was_successful_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatBool ( self . was_successful_ ) ) <EOL> cnt = <NUM_LIT:0> <EOL> for e in self . call_stack_ : <EOL> elm = "<STR_LIT>" <EOL> if printElemNumber : elm = "<STR_LIT>" % cnt <EOL> res += prefix + ( "<STR_LIT>" % elm ) <EOL> res += e . __str__ ( prefix + "<STR_LIT:U+0020>" , printElemNumber ) <EOL> res += prefix + "<STR_LIT>" <EOL> cnt += <NUM_LIT:1> <EOL> if self . has_datastore_details_ : <EOL> res += prefix + "<STR_LIT>" <EOL> res += self . datastore_details_ . __str__ ( prefix + "<STR_LIT:U+0020>" , printElemNumber ) <EOL> res += prefix + "<STR_LIT>" <EOL> if self . has_call_cost_microdollars_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . call_cost_microdollars_ ) ) <EOL> cnt = <NUM_LIT:0> <EOL> for e in self . billed_ops_ : <EOL> elm = "<STR_LIT>" <EOL> if printElemNumber : elm = "<STR_LIT>" % cnt <EOL> res += prefix + ( "<STR_LIT>" % elm ) <EOL> res += e . __str__ ( prefix + "<STR_LIT:U+0020>" , printElemNumber ) <EOL> res += prefix + "<STR_LIT>" <EOL> cnt += <NUM_LIT:1> <EOL> return res <EOL> def _BuildTagLookupTable ( sparse , maxtag , default = None ) : <EOL> return tuple ( [ sparse . get ( i , default ) for i in xrange ( <NUM_LIT:0> , <NUM_LIT:1> + maxtag ) ] ) <EOL> kservice_call_name = <NUM_LIT:1> <EOL> krequest_data_summary = <NUM_LIT:3> <EOL> kresponse_data_summary = <NUM_LIT:4> <EOL> kapi_mcycles = <NUM_LIT:5> <EOL> kapi_milliseconds = <NUM_LIT:11> <EOL> kstart_offset_milliseconds = <NUM_LIT:6> <EOL> kduration_milliseconds = <NUM_LIT:7> <EOL> knamespace = <NUM_LIT:8> <EOL> kwas_successful = <NUM_LIT:9> <EOL> kcall_stack = <NUM_LIT:10> <EOL> kdatastore_details = <NUM_LIT:12> <EOL> kcall_cost_microdollars = <NUM_LIT> <EOL> kbilled_ops = <NUM_LIT> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:3> : "<STR_LIT>" , <EOL> <NUM_LIT:4> : "<STR_LIT>" , <EOL> <NUM_LIT:5> : "<STR_LIT>" , <EOL> <NUM_LIT:6> : "<STR_LIT>" , <EOL> <NUM_LIT:7> : "<STR_LIT>" , <EOL> <NUM_LIT:8> : "<STR_LIT>" , <EOL> <NUM_LIT:9> : "<STR_LIT>" , <EOL> <NUM_LIT:10> : "<STR_LIT>" , <EOL> <NUM_LIT:11> : "<STR_LIT>" , <EOL> <NUM_LIT:12> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> } , <NUM_LIT> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:1> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:3> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:4> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:5> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:6> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:7> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:8> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:9> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:10> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:11> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:12> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT> : ProtocolBuffer . Encoder . STRING , <EOL> } , <NUM_LIT> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class RequestStatProto ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_start_timestamp_milliseconds_ = <NUM_LIT:0> <EOL> start_timestamp_milliseconds_ = <NUM_LIT:0> <EOL> has_http_method_ = <NUM_LIT:0> <EOL> http_method_ = "<STR_LIT:GET>" <EOL> has_http_path_ = <NUM_LIT:0> <EOL> http_path_ = "<STR_LIT:/>" <EOL> has_http_query_ = <NUM_LIT:0> <EOL> http_query_ = "<STR_LIT>" <EOL> has_http_status_ = <NUM_LIT:0> <EOL> http_status_ = <NUM_LIT:200> <EOL> has_duration_milliseconds_ = <NUM_LIT:0> <EOL> duration_milliseconds_ = <NUM_LIT:0> <EOL> has_api_mcycles_ = <NUM_LIT:0> <EOL> api_mcycles_ = <NUM_LIT:0> <EOL> has_processor_mcycles_ = <NUM_LIT:0> <EOL> processor_mcycles_ = <NUM_LIT:0> <EOL> has_overhead_walltime_milliseconds_ = <NUM_LIT:0> <EOL> overhead_walltime_milliseconds_ = <NUM_LIT:0> <EOL> has_user_email_ = <NUM_LIT:0> <EOL> user_email_ = "<STR_LIT>" <EOL> has_is_admin_ = <NUM_LIT:0> <EOL> is_admin_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> self . rpc_stats_ = [ ] <EOL> self . cgi_env_ = [ ] <EOL> self . individual_stats_ = [ ] <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def start_timestamp_milliseconds ( self ) : return self . start_timestamp_milliseconds_ <EOL> def set_start_timestamp_milliseconds ( self , x ) : <EOL> self . has_start_timestamp_milliseconds_ = <NUM_LIT:1> <EOL> self . start_timestamp_milliseconds_ = x <EOL> def clear_start_timestamp_milliseconds ( self ) : <EOL> if self . has_start_timestamp_milliseconds_ : <EOL> self . has_start_timestamp_milliseconds_ = <NUM_LIT:0> <EOL> self . start_timestamp_milliseconds_ = <NUM_LIT:0> <EOL> def has_start_timestamp_milliseconds ( self ) : return self . has_start_timestamp_milliseconds_ <EOL> def http_method ( self ) : return self . http_method_ <EOL> def set_http_method ( self , x ) : <EOL> self . has_http_method_ = <NUM_LIT:1> <EOL> self . http_method_ = x <EOL> def clear_http_method ( self ) : <EOL> if self . has_http_method_ : <EOL> self . has_http_method_ = <NUM_LIT:0> <EOL> self . http_method_ = "<STR_LIT:GET>" <EOL> def has_http_method ( self ) : return self . has_http_method_ <EOL> def http_path ( self ) : return self . http_path_ <EOL> def set_http_path ( self , x ) : <EOL> self . has_http_path_ = <NUM_LIT:1> <EOL> self . http_path_ = x <EOL> def clear_http_path ( self ) : <EOL> if self . has_http_path_ : <EOL> self . has_http_path_ = <NUM_LIT:0> <EOL> self . http_path_ = "<STR_LIT:/>" <EOL> def has_http_path ( self ) : return self . has_http_path_ <EOL> def http_query ( self ) : return self . http_query_ <EOL> def set_http_query ( self , x ) : <EOL> self . has_http_query_ = <NUM_LIT:1> <EOL> self . http_query_ = x <EOL> def clear_http_query ( self ) : <EOL> if self . has_http_query_ : <EOL> self . has_http_query_ = <NUM_LIT:0> <EOL> self . http_query_ = "<STR_LIT>" <EOL> def has_http_query ( self ) : return self . has_http_query_ <EOL> def http_status ( self ) : return self . http_status_ <EOL> def set_http_status ( self , x ) : <EOL> self . has_http_status_ = <NUM_LIT:1> <EOL> self . http_status_ = x <EOL> def clear_http_status ( self ) : <EOL> if self . has_http_status_ : <EOL> self . has_http_status_ = <NUM_LIT:0> <EOL> self . http_status_ = <NUM_LIT:200> <EOL> def has_http_status ( self ) : return self . has_http_status_ <EOL> def duration_milliseconds ( self ) : return self . duration_milliseconds_ <EOL> def set_duration_milliseconds ( self , x ) : <EOL> self . has_duration_milliseconds_ = <NUM_LIT:1> <EOL> self . duration_milliseconds_ = x <EOL> def clear_duration_milliseconds ( self ) : <EOL> if self . has_duration_milliseconds_ : <EOL> self . has_duration_milliseconds_ = <NUM_LIT:0> <EOL> self . duration_milliseconds_ = <NUM_LIT:0> <EOL> def has_duration_milliseconds ( self ) : return self . has_duration_milliseconds_ <EOL> def api_mcycles ( self ) : return self . api_mcycles_ <EOL> def set_api_mcycles ( self , x ) : <EOL> self . has_api_mcycles_ = <NUM_LIT:1> <EOL> self . api_mcycles_ = x <EOL> def clear_api_mcycles ( self ) : <EOL> if self . has_api_mcycles_ : <EOL> self . has_api_mcycles_ = <NUM_LIT:0> <EOL> self . api_mcycles_ = <NUM_LIT:0> <EOL> def has_api_mcycles ( self ) : return self . has_api_mcycles_ <EOL> def processor_mcycles ( self ) : return self . processor_mcycles_ <EOL> def set_processor_mcycles ( self , x ) : <EOL> self . has_processor_mcycles_ = <NUM_LIT:1> <EOL> self . processor_mcycles_ = x <EOL> def clear_processor_mcycles ( self ) : <EOL> if self . has_processor_mcycles_ : <EOL> self . has_processor_mcycles_ = <NUM_LIT:0> <EOL> self . processor_mcycles_ = <NUM_LIT:0> <EOL> def has_processor_mcycles ( self ) : return self . has_processor_mcycles_ <EOL> def rpc_stats_size ( self ) : return len ( self . rpc_stats_ ) <EOL> def rpc_stats_list ( self ) : return self . rpc_stats_ <EOL> def rpc_stats ( self , i ) : <EOL> return self . rpc_stats_ [ i ] <EOL> def mutable_rpc_stats ( self , i ) : <EOL> return self . rpc_stats_ [ i ] <EOL> def add_rpc_stats ( self ) : <EOL> x = AggregateRpcStatsProto ( ) <EOL> self . rpc_stats_ . append ( x ) <EOL> return x <EOL> def clear_rpc_stats ( self ) : <EOL> self . rpc_stats_ = [ ] <EOL> def cgi_env_size ( self ) : return len ( self . cgi_env_ ) <EOL> def cgi_env_list ( self ) : return self . cgi_env_ <EOL> def cgi_env ( self , i ) : <EOL> return self . cgi_env_ [ i ] <EOL> def mutable_cgi_env ( self , i ) : <EOL> return self . cgi_env_ [ i ] <EOL> def add_cgi_env ( self ) : <EOL> x = KeyValProto ( ) <EOL> self . cgi_env_ . append ( x ) <EOL> return x <EOL> def clear_cgi_env ( self ) : <EOL> self . cgi_env_ = [ ] <EOL> def overhead_walltime_milliseconds ( self ) : return self . overhead_walltime_milliseconds_ <EOL> def set_overhead_walltime_milliseconds ( self , x ) : <EOL> self . has_overhead_walltime_milliseconds_ = <NUM_LIT:1> <EOL> self . overhead_walltime_milliseconds_ = x <EOL> def clear_overhead_walltime_milliseconds ( self ) : <EOL> if self . has_overhead_walltime_milliseconds_ : <EOL> self . has_overhead_walltime_milliseconds_ = <NUM_LIT:0> <EOL> self . overhead_walltime_milliseconds_ = <NUM_LIT:0> <EOL> def has_overhead_walltime_milliseconds ( self ) : return self . has_overhead_walltime_milliseconds_ <EOL> def user_email ( self ) : return self . user_email_ <EOL> def set_user_email ( self , x ) : <EOL> self . has_user_email_ = <NUM_LIT:1> <EOL> self . user_email_ = x <EOL> def clear_user_email ( self ) : <EOL> if self . has_user_email_ : <EOL> self . has_user_email_ = <NUM_LIT:0> <EOL> self . user_email_ = "<STR_LIT>" <EOL> def has_user_email ( self ) : return self . has_user_email_ <EOL> def is_admin ( self ) : return self . is_admin_ <EOL> def set_is_admin ( self , x ) : <EOL> self . has_is_admin_ = <NUM_LIT:1> <EOL> self . is_admin_ = x <EOL> def clear_is_admin ( self ) : <EOL> if self . has_is_admin_ : <EOL> self . has_is_admin_ = <NUM_LIT:0> <EOL> self . is_admin_ = <NUM_LIT:0> <EOL> def has_is_admin ( self ) : return self . has_is_admin_ <EOL> def individual_stats_size ( self ) : return len ( self . individual_stats_ ) <EOL> def individual_stats_list ( self ) : return self . individual_stats_ <EOL> def individual_stats ( self , i ) : <EOL> return self . individual_stats_ [ i ] <EOL> def mutable_individual_stats ( self , i ) : <EOL> return self . individual_stats_ [ i ] <EOL> def add_individual_stats ( self ) : <EOL> x = IndividualRpcStatsProto ( ) <EOL> self . individual_stats_ . append ( x ) <EOL> return x <EOL> def clear_individual_stats ( self ) : <EOL> self . individual_stats_ = [ ] <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_start_timestamp_milliseconds ( ) ) : self . set_start_timestamp_milliseconds ( x . start_timestamp_milliseconds ( ) ) <EOL> if ( x . has_http_method ( ) ) : self . set_http_method ( x . http_method ( ) ) <EOL> if ( x . has_http_path ( ) ) : self . set_http_path ( x . http_path ( ) ) <EOL> if ( x . has_http_query ( ) ) : self . set_http_query ( x . http_query ( ) ) <EOL> if ( x . has_http_status ( ) ) : self . set_http_status ( x . http_status ( ) ) <EOL> if ( x . has_duration_milliseconds ( ) ) : self . set_duration_milliseconds ( x . duration_milliseconds ( ) ) <EOL> if ( x . has_api_mcycles ( ) ) : self . set_api_mcycles ( x . api_mcycles ( ) ) <EOL> if ( x . has_processor_mcycles ( ) ) : self . set_processor_mcycles ( x . processor_mcycles ( ) ) <EOL> for i in xrange ( x . rpc_stats_size ( ) ) : self . add_rpc_stats ( ) . CopyFrom ( x . rpc_stats ( i ) ) <EOL> for i in xrange ( x . cgi_env_size ( ) ) : self . add_cgi_env ( ) . CopyFrom ( x . cgi_env ( i ) ) <EOL> if ( x . has_overhead_walltime_milliseconds ( ) ) : self . set_overhead_walltime_milliseconds ( x . overhead_walltime_milliseconds ( ) ) <EOL> if ( x . has_user_email ( ) ) : self . set_user_email ( x . user_email ( ) ) <EOL> if ( x . has_is_admin ( ) ) : self . set_is_admin ( x . is_admin ( ) ) <EOL> for i in xrange ( x . individual_stats_size ( ) ) : self . add_individual_stats ( ) . CopyFrom ( x . individual_stats ( i ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_start_timestamp_milliseconds_ != x . has_start_timestamp_milliseconds_ : return <NUM_LIT:0> <EOL> if self . has_start_timestamp_milliseconds_ and self . start_timestamp_milliseconds_ != x . start_timestamp_milliseconds_ : return <NUM_LIT:0> <EOL> if self . has_http_method_ != x . has_http_method_ : return <NUM_LIT:0> <EOL> if self . has_http_method_ and self . http_method_ != x . http_method_ : return <NUM_LIT:0> <EOL> if self . has_http_path_ != x . has_http_path_ : return <NUM_LIT:0> <EOL> if self . has_http_path_ and self . http_path_ != x . http_path_ : return <NUM_LIT:0> <EOL> if self . has_http_query_ != x . has_http_query_ : return <NUM_LIT:0> <EOL> if self . has_http_query_ and self . http_query_ != x . http_query_ : return <NUM_LIT:0> <EOL> if self . has_http_status_ != x . has_http_status_ : return <NUM_LIT:0> <EOL> if self . has_http_status_ and self . http_status_ != x . http_status_ : return <NUM_LIT:0> <EOL> if self . has_duration_milliseconds_ != x . has_duration_milliseconds_ : return <NUM_LIT:0> <EOL> if self . has_duration_milliseconds_ and self . duration_milliseconds_ != x . duration_milliseconds_ : return <NUM_LIT:0> <EOL> if self . has_api_mcycles_ != x . has_api_mcycles_ : return <NUM_LIT:0> <EOL> if self . has_api_mcycles_ and self . api_mcycles_ != x . api_mcycles_ : return <NUM_LIT:0> <EOL> if self . has_processor_mcycles_ != x . has_processor_mcycles_ : return <NUM_LIT:0> <EOL> if self . has_processor_mcycles_ and self . processor_mcycles_ != x . processor_mcycles_ : return <NUM_LIT:0> <EOL> if len ( self . rpc_stats_ ) != len ( x . rpc_stats_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . rpc_stats_ , x . rpc_stats_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> if len ( self . cgi_env_ ) != len ( x . cgi_env_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . cgi_env_ , x . cgi_env_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> if self . has_overhead_walltime_milliseconds_ != x . has_overhead_walltime_milliseconds_ : return <NUM_LIT:0> <EOL> if self . has_overhead_walltime_milliseconds_ and self . overhead_walltime_milliseconds_ != x . overhead_walltime_milliseconds_ : return <NUM_LIT:0> <EOL> if self . has_user_email_ != x . has_user_email_ : return <NUM_LIT:0> <EOL> if self . has_user_email_ and self . user_email_ != x . user_email_ : return <NUM_LIT:0> <EOL> if self . has_is_admin_ != x . has_is_admin_ : return <NUM_LIT:0> <EOL> if self . has_is_admin_ and self . is_admin_ != x . is_admin_ : return <NUM_LIT:0> <EOL> if len ( self . individual_stats_ ) != len ( x . individual_stats_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . individual_stats_ , x . individual_stats_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> if ( not self . has_start_timestamp_milliseconds_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_duration_milliseconds_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> for p in self . rpc_stats_ : <EOL> if not p . IsInitialized ( debug_strs ) : initialized = <NUM_LIT:0> <EOL> for p in self . cgi_env_ : <EOL> if not p . IsInitialized ( debug_strs ) : initialized = <NUM_LIT:0> <EOL> for p in self . individual_stats_ : <EOL> if not p . IsInitialized ( debug_strs ) : initialized = <NUM_LIT:0> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> n += self . lengthVarInt64 ( self . start_timestamp_milliseconds_ ) <EOL> if ( self . has_http_method_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . http_method_ ) ) <EOL> if ( self . has_http_path_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . http_path_ ) ) <EOL> if ( self . has_http_query_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . http_query_ ) ) <EOL> if ( self . has_http_status_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . http_status_ ) <EOL> n += self . lengthVarInt64 ( self . duration_milliseconds_ ) <EOL> if ( self . has_api_mcycles_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . api_mcycles_ ) <EOL> if ( self . has_processor_mcycles_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . processor_mcycles_ ) <EOL> n += <NUM_LIT:1> * len ( self . rpc_stats_ ) <EOL> for i in xrange ( len ( self . rpc_stats_ ) ) : n += self . lengthString ( self . rpc_stats_ [ i ] . ByteSize ( ) ) <EOL> n += <NUM_LIT:2> * len ( self . cgi_env_ ) <EOL> for i in xrange ( len ( self . cgi_env_ ) ) : n += self . lengthString ( self . cgi_env_ [ i ] . ByteSize ( ) ) <EOL> if ( self . has_overhead_walltime_milliseconds_ ) : n += <NUM_LIT:2> + self . lengthVarInt64 ( self . overhead_walltime_milliseconds_ ) <EOL> if ( self . has_user_email_ ) : n += <NUM_LIT:2> + self . lengthString ( len ( self . user_email_ ) ) <EOL> if ( self . has_is_admin_ ) : n += <NUM_LIT:3> <EOL> n += <NUM_LIT:2> * len ( self . individual_stats_ ) <EOL> for i in xrange ( len ( self . individual_stats_ ) ) : n += self . lengthString ( self . individual_stats_ [ i ] . ByteSize ( ) ) <EOL> return n + <NUM_LIT:2> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_start_timestamp_milliseconds_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . start_timestamp_milliseconds_ ) <EOL> if ( self . has_http_method_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . http_method_ ) ) <EOL> if ( self . has_http_path_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . http_path_ ) ) <EOL> if ( self . has_http_query_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . http_query_ ) ) <EOL> if ( self . has_http_status_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . http_status_ ) <EOL> if ( self . has_duration_milliseconds_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . duration_milliseconds_ ) <EOL> if ( self . has_api_mcycles_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . api_mcycles_ ) <EOL> if ( self . has_processor_mcycles_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . processor_mcycles_ ) <EOL> n += <NUM_LIT:1> * len ( self . rpc_stats_ ) <EOL> for i in xrange ( len ( self . rpc_stats_ ) ) : n += self . lengthString ( self . rpc_stats_ [ i ] . ByteSizePartial ( ) ) <EOL> n += <NUM_LIT:2> * len ( self . cgi_env_ ) <EOL> for i in xrange ( len ( self . cgi_env_ ) ) : n += self . lengthString ( self . cgi_env_ [ i ] . ByteSizePartial ( ) ) <EOL> if ( self . has_overhead_walltime_milliseconds_ ) : n += <NUM_LIT:2> + self . lengthVarInt64 ( self . overhead_walltime_milliseconds_ ) <EOL> if ( self . has_user_email_ ) : n += <NUM_LIT:2> + self . lengthString ( len ( self . user_email_ ) ) <EOL> if ( self . has_is_admin_ ) : n += <NUM_LIT:3> <EOL> n += <NUM_LIT:2> * len ( self . individual_stats_ ) <EOL> for i in xrange ( len ( self . individual_stats_ ) ) : n += self . lengthString ( self . individual_stats_ [ i ] . ByteSizePartial ( ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_start_timestamp_milliseconds ( ) <EOL> self . clear_http_method ( ) <EOL> self . clear_http_path ( ) <EOL> self . clear_http_query ( ) <EOL> self . clear_http_status ( ) <EOL> self . clear_duration_milliseconds ( ) <EOL> self . clear_api_mcycles ( ) <EOL> self . clear_processor_mcycles ( ) <EOL> self . clear_rpc_stats ( ) <EOL> self . clear_cgi_env ( ) <EOL> self . clear_overhead_walltime_milliseconds ( ) <EOL> self . clear_user_email ( ) <EOL> self . clear_is_admin ( ) <EOL> self . clear_individual_stats ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:8> ) <EOL> out . putVarInt64 ( self . start_timestamp_milliseconds_ ) <EOL> if ( self . has_http_method_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . http_method_ ) <EOL> if ( self . has_http_path_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . http_path_ ) <EOL> if ( self . has_http_query_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . http_query_ ) <EOL> if ( self . has_http_status_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . http_status_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . duration_milliseconds_ ) <EOL> if ( self . has_api_mcycles_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . api_mcycles_ ) <EOL> if ( self . has_processor_mcycles_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:64> ) <EOL> out . putVarInt64 ( self . processor_mcycles_ ) <EOL> for i in xrange ( len ( self . rpc_stats_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . rpc_stats_ [ i ] . ByteSize ( ) ) <EOL> self . rpc_stats_ [ i ] . OutputUnchecked ( out ) <EOL> for i in xrange ( len ( self . cgi_env_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . cgi_env_ [ i ] . ByteSize ( ) ) <EOL> self . cgi_env_ [ i ] . OutputUnchecked ( out ) <EOL> if ( self . has_overhead_walltime_milliseconds_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . overhead_walltime_milliseconds_ ) <EOL> if ( self . has_user_email_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . user_email_ ) <EOL> if ( self . has_is_admin_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putBoolean ( self . is_admin_ ) <EOL> for i in xrange ( len ( self . individual_stats_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . individual_stats_ [ i ] . ByteSize ( ) ) <EOL> self . individual_stats_ [ i ] . OutputUnchecked ( out ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_start_timestamp_milliseconds_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:8> ) <EOL> out . putVarInt64 ( self . start_timestamp_milliseconds_ ) <EOL> if ( self . has_http_method_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . http_method_ ) <EOL> if ( self . has_http_path_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . http_path_ ) <EOL> if ( self . has_http_query_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . http_query_ ) <EOL> if ( self . has_http_status_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . http_status_ ) <EOL> if ( self . has_duration_milliseconds_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . duration_milliseconds_ ) <EOL> if ( self . has_api_mcycles_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . api_mcycles_ ) <EOL> if ( self . has_processor_mcycles_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:64> ) <EOL> out . putVarInt64 ( self . processor_mcycles_ ) <EOL> for i in xrange ( len ( self . rpc_stats_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . rpc_stats_ [ i ] . ByteSizePartial ( ) ) <EOL> self . rpc_stats_ [ i ] . OutputPartial ( out ) <EOL> for i in xrange ( len ( self . cgi_env_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . cgi_env_ [ i ] . ByteSizePartial ( ) ) <EOL> self . cgi_env_ [ i ] . OutputPartial ( out ) <EOL> if ( self . has_overhead_walltime_milliseconds_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . overhead_walltime_milliseconds_ ) <EOL> if ( self . has_user_email_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . user_email_ ) <EOL> if ( self . has_is_admin_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putBoolean ( self . is_admin_ ) <EOL> for i in xrange ( len ( self . individual_stats_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . individual_stats_ [ i ] . ByteSizePartial ( ) ) <EOL> self . individual_stats_ [ i ] . OutputPartial ( out ) <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <EOL> if tt == <NUM_LIT:8> : <EOL> self . set_start_timestamp_milliseconds ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_http_method ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_http_path ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_http_query ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_http_status ( d . getVarInt32 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_duration_milliseconds ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_api_mcycles ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:64> : <EOL> self . set_processor_mcycles ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> length = d . getVarInt32 ( ) <EOL> tmp = ProtocolBuffer . Decoder ( d . buffer ( ) , d . pos ( ) , d . pos ( ) + length ) <EOL> d . skip ( length ) <EOL> self . add_rpc_stats ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> length = d . getVarInt32 ( ) <EOL> tmp = ProtocolBuffer . Decoder ( d . buffer ( ) , d . pos ( ) , d . pos ( ) + length ) <EOL> d . skip ( length ) <EOL> self . add_cgi_env ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_overhead_walltime_milliseconds ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_user_email ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_is_admin ( d . getBoolean ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> length = d . getVarInt32 ( ) <EOL> tmp = ProtocolBuffer . Decoder ( d . buffer ( ) , d . pos ( ) , d . pos ( ) + length ) <EOL> d . skip ( length ) <EOL> self . add_individual_stats ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if ( tt == <NUM_LIT:0> ) : raise ProtocolBuffer . ProtocolBufferDecodeError <EOL> d . skipData ( tt ) <EOL> def __str__ ( self , prefix = "<STR_LIT>" , printElemNumber = <NUM_LIT:0> ) : <EOL> res = "<STR_LIT>" <EOL> if self . has_start_timestamp_milliseconds_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . start_timestamp_milliseconds_ ) ) <EOL> if self . has_http_method_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . http_method_ ) ) <EOL> if self . has_http_path_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . http_path_ ) ) <EOL> if self . has_http_query_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . http_query_ ) ) <EOL> if self . has_http_status_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt32 ( self . http_status_ ) ) <EOL> if self . has_duration_milliseconds_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . duration_milliseconds_ ) ) <EOL> if self . has_api_mcycles_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . api_mcycles_ ) ) <EOL> if self . has_processor_mcycles_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . processor_mcycles_ ) ) <EOL> cnt = <NUM_LIT:0> <EOL> for e in self . rpc_stats_ : <EOL> elm = "<STR_LIT>" <EOL> if printElemNumber : elm = "<STR_LIT>" % cnt <EOL> res += prefix + ( "<STR_LIT>" % elm ) <EOL> res += e . __str__ ( prefix + "<STR_LIT:U+0020>" , printElemNumber ) <EOL> res += prefix + "<STR_LIT>" <EOL> cnt += <NUM_LIT:1> <EOL> cnt = <NUM_LIT:0> <EOL> for e in self . cgi_env_ : <EOL> elm = "<STR_LIT>" <EOL> if printElemNumber : elm = "<STR_LIT>" % cnt <EOL> res += prefix + ( "<STR_LIT>" % elm ) <EOL> res += e . __str__ ( prefix + "<STR_LIT:U+0020>" , printElemNumber ) <EOL> res += prefix + "<STR_LIT>" <EOL> cnt += <NUM_LIT:1> <EOL> if self . has_overhead_walltime_milliseconds_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . overhead_walltime_milliseconds_ ) ) <EOL> if self . has_user_email_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . user_email_ ) ) <EOL> if self . has_is_admin_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatBool ( self . is_admin_ ) ) <EOL> cnt = <NUM_LIT:0> <EOL> for e in self . individual_stats_ : <EOL> elm = "<STR_LIT>" <EOL> if printElemNumber : elm = "<STR_LIT>" % cnt <EOL> res += prefix + ( "<STR_LIT>" % elm ) <EOL> res += e . __str__ ( prefix + "<STR_LIT:U+0020>" , printElemNumber ) <EOL> res += prefix + "<STR_LIT>" <EOL> cnt += <NUM_LIT:1> <EOL> return res <EOL> def _BuildTagLookupTable ( sparse , maxtag , default = None ) : <EOL> return tuple ( [ sparse . get ( i , default ) for i in xrange ( <NUM_LIT:0> , <NUM_LIT:1> + maxtag ) ] ) <EOL> kstart_timestamp_milliseconds = <NUM_LIT:1> <EOL> khttp_method = <NUM_LIT:2> <EOL> khttp_path = <NUM_LIT:3> <EOL> khttp_query = <NUM_LIT:4> <EOL> khttp_status = <NUM_LIT:5> <EOL> kduration_milliseconds = <NUM_LIT:6> <EOL> kapi_mcycles = <NUM_LIT:7> <EOL> kprocessor_mcycles = <NUM_LIT:8> <EOL> krpc_stats = <NUM_LIT:9> <EOL> kcgi_env = <NUM_LIT> <EOL> koverhead_walltime_milliseconds = <NUM_LIT> <EOL> kuser_email = <NUM_LIT> <EOL> kis_admin = <NUM_LIT> <EOL> kindividual_stats = <NUM_LIT> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:2> : "<STR_LIT>" , <EOL> <NUM_LIT:3> : "<STR_LIT>" , <EOL> <NUM_LIT:4> : "<STR_LIT>" , <EOL> <NUM_LIT:5> : "<STR_LIT>" , <EOL> <NUM_LIT:6> : "<STR_LIT>" , <EOL> <NUM_LIT:7> : "<STR_LIT>" , <EOL> <NUM_LIT:8> : "<STR_LIT>" , <EOL> <NUM_LIT:9> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> } , <NUM_LIT> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:1> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:2> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:3> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:4> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:5> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:6> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:7> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:8> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:9> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT> : ProtocolBuffer . Encoder . STRING , <EOL> } , <NUM_LIT> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> if _extension_runtime : <EOL> pass <EOL> __all__ = [ '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' ] </s>
