<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 . api . api_base_pb import * <EOL> import google . appengine . api . api_base_pb <EOL> class FileServiceErrors ( ProtocolBuffer . ProtocolMessage ) : <EOL> OK = <NUM_LIT:0> <EOL> API_TEMPORARILY_UNAVAILABLE = <NUM_LIT:1> <EOL> REQUEST_TOO_LARGE = <NUM_LIT:3> <EOL> RESPONSE_TOO_LARGE = <NUM_LIT:4> <EOL> INVALID_FILE_NAME = <NUM_LIT:5> <EOL> OPERATION_NOT_SUPPORTED = <NUM_LIT:6> <EOL> IO_ERROR = <NUM_LIT:7> <EOL> PERMISSION_DENIED = <NUM_LIT:8> <EOL> WRONG_CONTENT_TYPE = <NUM_LIT:9> <EOL> FILE_NOT_OPENED = <NUM_LIT:10> <EOL> WRONG_OPEN_MODE = <NUM_LIT:11> <EOL> EXCLUSIVE_LOCK_REQUIRED = <NUM_LIT:12> <EOL> FILE_TEMPORARILY_UNAVAILABLE = <NUM_LIT> <EOL> EXISTENCE_ERROR = <NUM_LIT:100> <EOL> FINALIZATION_ERROR = <NUM_LIT> <EOL> UNSUPPORTED_CONTENT_TYPE = <NUM_LIT> <EOL> READ_ONLY = <NUM_LIT> <EOL> EXCLUSIVE_LOCK_FAILED = <NUM_LIT> <EOL> EXISTENCE_ERROR_METADATA_NOT_FOUND = <NUM_LIT> <EOL> EXISTENCE_ERROR_METADATA_FOUND = <NUM_LIT> <EOL> EXISTENCE_ERROR_SHARDING_MISMATCH = <NUM_LIT> <EOL> SEQUENCE_KEY_OUT_OF_ORDER = <NUM_LIT> <EOL> OUT_OF_BOUNDS = <NUM_LIT> <EOL> GLOBS_NOT_SUPPORTED = <NUM_LIT> <EOL> FILE_NAME_NOT_SPECIFIED = <NUM_LIT> <EOL> FILE_NAME_SPECIFIED = <NUM_LIT> <EOL> FILE_ALREADY_EXISTS = <NUM_LIT> <EOL> UNSUPPORTED_FILE_SYSTEM = <NUM_LIT> <EOL> INVALID_PARAMETER = <NUM_LIT> <EOL> SHUFFLER_INTERNAL_ERROR = <NUM_LIT> <EOL> SHUFFLE_REQUEST_TOO_LARGE = <NUM_LIT> <EOL> DUPLICATE_SHUFFLE_NAME = <NUM_LIT> <EOL> SHUFFLE_NOT_AVAILABLE = <NUM_LIT> <EOL> SHUFFLER_TEMPORARILY_UNAVAILABLE = <NUM_LIT> <EOL> MAX_ERROR_CODE = <NUM_LIT> <EOL> _ErrorCode_NAMES = { <EOL> <NUM_LIT:0> : "<STR_LIT:OK>" , <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:100> : "<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> : "<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> : "<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> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> } <EOL> def ErrorCode_Name ( cls , x ) : return cls . _ErrorCode_NAMES . get ( x , "<STR_LIT>" ) <EOL> ErrorCode_Name = classmethod ( ErrorCode_Name ) <EOL> def __init__ ( self , contents = None ) : <EOL> pass <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def Clear ( self ) : <EOL> pass <EOL> def OutputUnchecked ( self , out ) : <EOL> pass <EOL> def OutputPartial ( self , out ) : <EOL> pass <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <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> 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> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> } , <NUM_LIT:0> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> } , <NUM_LIT:0> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class KeyValue ( 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 KeyValues ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_key_ = <NUM_LIT:0> <EOL> key_ = "<STR_LIT>" <EOL> def __init__ ( self , contents = None ) : <EOL> self . value_ = [ ] <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_size ( self ) : return len ( self . value_ ) <EOL> def value_list ( self ) : return self . value_ <EOL> def value ( self , i ) : <EOL> return self . value_ [ i ] <EOL> def set_value ( self , i , x ) : <EOL> self . value_ [ i ] = x <EOL> def add_value ( self , x ) : <EOL> self . value_ . append ( x ) <EOL> def clear_value ( self ) : <EOL> self . value_ = [ ] <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_key ( ) ) : self . set_key ( x . key ( ) ) <EOL> for i in xrange ( x . value_size ( ) ) : self . add_value ( x . value ( i ) ) <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 len ( self . value_ ) != len ( x . value_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . value_ , x . value_ ) : <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_key_ ) : <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 += <NUM_LIT:1> * len ( self . value_ ) <EOL> for i in xrange ( len ( self . value_ ) ) : n += self . lengthString ( len ( self . value_ [ i ] ) ) <EOL> return n + <NUM_LIT:1> <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> n += <NUM_LIT:1> * len ( self . value_ ) <EOL> for i in xrange ( len ( self . value_ ) ) : n += self . lengthString ( len ( self . value_ [ i ] ) ) <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> for i in xrange ( len ( self . value_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . value_ [ i ] ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_key_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . key_ ) <EOL> for i in xrange ( len ( self . value_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . value_ [ i ] ) <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 . add_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> cnt = <NUM_LIT:0> <EOL> for e in self . value_ : <EOL> elm = "<STR_LIT>" <EOL> if printElemNumber : elm = "<STR_LIT>" % cnt <EOL> res += prefix + ( "<STR_LIT>" % ( elm , self . DebugFormatString ( e ) ) ) <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> 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 FileContentType ( ProtocolBuffer . ProtocolMessage ) : <EOL> RAW = <NUM_LIT:0> <EOL> DEPRECATED_1 = <NUM_LIT:2> <EOL> INVALID_TYPE = <NUM_LIT> <EOL> _ContentType_NAMES = { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:2> : "<STR_LIT>" , <EOL> <NUM_LIT> : "<STR_LIT>" , <EOL> } <EOL> def ContentType_Name ( cls , x ) : return cls . _ContentType_NAMES . get ( x , "<STR_LIT>" ) <EOL> ContentType_Name = classmethod ( ContentType_Name ) <EOL> def __init__ ( self , contents = None ) : <EOL> pass <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def Clear ( self ) : <EOL> pass <EOL> def OutputUnchecked ( self , out ) : <EOL> pass <EOL> def OutputPartial ( self , out ) : <EOL> pass <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <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> 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> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> } , <NUM_LIT:0> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> } , <NUM_LIT:0> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class CreateRequest_Parameter ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_name_ = <NUM_LIT:0> <EOL> name_ = "<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 name ( self ) : return self . name_ <EOL> def set_name ( self , x ) : <EOL> self . has_name_ = <NUM_LIT:1> <EOL> self . name_ = x <EOL> def clear_name ( self ) : <EOL> if self . has_name_ : <EOL> self . has_name_ = <NUM_LIT:0> <EOL> self . name_ = "<STR_LIT>" <EOL> def has_name ( self ) : return self . has_name_ <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_name ( ) ) : self . set_name ( x . name ( ) ) <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_name_ != x . has_name_ : return <NUM_LIT:0> <EOL> if self . has_name_ and self . name_ != x . name_ : 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_name_ ) : <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 . name_ ) ) <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_name_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . name_ ) ) <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_name ( ) <EOL> self . clear_value ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . name_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . value_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_name_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . name_ ) <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_name ( 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_name_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . name_ ) ) <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> kname = <NUM_LIT:1> <EOL> kvalue = <NUM_LIT:2> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:name>" , <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 CreateRequest ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_filesystem_ = <NUM_LIT:0> <EOL> filesystem_ = "<STR_LIT>" <EOL> has_content_type_ = <NUM_LIT:0> <EOL> content_type_ = <NUM_LIT:0> <EOL> has_filename_ = <NUM_LIT:0> <EOL> filename_ = "<STR_LIT>" <EOL> has_expiration_time_seconds_ = <NUM_LIT:0> <EOL> expiration_time_seconds_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> self . parameters_ = [ ] <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def filesystem ( self ) : return self . filesystem_ <EOL> def set_filesystem ( self , x ) : <EOL> self . has_filesystem_ = <NUM_LIT:1> <EOL> self . filesystem_ = x <EOL> def clear_filesystem ( self ) : <EOL> if self . has_filesystem_ : <EOL> self . has_filesystem_ = <NUM_LIT:0> <EOL> self . filesystem_ = "<STR_LIT>" <EOL> def has_filesystem ( self ) : return self . has_filesystem_ <EOL> def content_type ( self ) : return self . content_type_ <EOL> def set_content_type ( self , x ) : <EOL> self . has_content_type_ = <NUM_LIT:1> <EOL> self . content_type_ = x <EOL> def clear_content_type ( self ) : <EOL> if self . has_content_type_ : <EOL> self . has_content_type_ = <NUM_LIT:0> <EOL> self . content_type_ = <NUM_LIT:0> <EOL> def has_content_type ( self ) : return self . has_content_type_ <EOL> def filename ( self ) : return self . filename_ <EOL> def set_filename ( self , x ) : <EOL> self . has_filename_ = <NUM_LIT:1> <EOL> self . filename_ = x <EOL> def clear_filename ( self ) : <EOL> if self . has_filename_ : <EOL> self . has_filename_ = <NUM_LIT:0> <EOL> self . filename_ = "<STR_LIT>" <EOL> def has_filename ( self ) : return self . has_filename_ <EOL> def parameters_size ( self ) : return len ( self . parameters_ ) <EOL> def parameters_list ( self ) : return self . parameters_ <EOL> def parameters ( self , i ) : <EOL> return self . parameters_ [ i ] <EOL> def mutable_parameters ( self , i ) : <EOL> return self . parameters_ [ i ] <EOL> def add_parameters ( self ) : <EOL> x = CreateRequest_Parameter ( ) <EOL> self . parameters_ . append ( x ) <EOL> return x <EOL> def clear_parameters ( self ) : <EOL> self . parameters_ = [ ] <EOL> def expiration_time_seconds ( self ) : return self . expiration_time_seconds_ <EOL> def set_expiration_time_seconds ( self , x ) : <EOL> self . has_expiration_time_seconds_ = <NUM_LIT:1> <EOL> self . expiration_time_seconds_ = x <EOL> def clear_expiration_time_seconds ( self ) : <EOL> if self . has_expiration_time_seconds_ : <EOL> self . has_expiration_time_seconds_ = <NUM_LIT:0> <EOL> self . expiration_time_seconds_ = <NUM_LIT:0> <EOL> def has_expiration_time_seconds ( self ) : return self . has_expiration_time_seconds_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_filesystem ( ) ) : self . set_filesystem ( x . filesystem ( ) ) <EOL> if ( x . has_content_type ( ) ) : self . set_content_type ( x . content_type ( ) ) <EOL> if ( x . has_filename ( ) ) : self . set_filename ( x . filename ( ) ) <EOL> for i in xrange ( x . parameters_size ( ) ) : self . add_parameters ( ) . CopyFrom ( x . parameters ( i ) ) <EOL> if ( x . has_expiration_time_seconds ( ) ) : self . set_expiration_time_seconds ( x . expiration_time_seconds ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_filesystem_ != x . has_filesystem_ : return <NUM_LIT:0> <EOL> if self . has_filesystem_ and self . filesystem_ != x . filesystem_ : return <NUM_LIT:0> <EOL> if self . has_content_type_ != x . has_content_type_ : return <NUM_LIT:0> <EOL> if self . has_content_type_ and self . content_type_ != x . content_type_ : return <NUM_LIT:0> <EOL> if self . has_filename_ != x . has_filename_ : return <NUM_LIT:0> <EOL> if self . has_filename_ and self . filename_ != x . filename_ : return <NUM_LIT:0> <EOL> if len ( self . parameters_ ) != len ( x . parameters_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . parameters_ , x . parameters_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> if self . has_expiration_time_seconds_ != x . has_expiration_time_seconds_ : return <NUM_LIT:0> <EOL> if self . has_expiration_time_seconds_ and self . expiration_time_seconds_ != x . expiration_time_seconds_ : 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_filesystem_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_content_type_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> for p in self . parameters_ : <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 . filesystem_ ) ) <EOL> n += self . lengthVarInt64 ( self . content_type_ ) <EOL> if ( self . has_filename_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . filename_ ) ) <EOL> n += <NUM_LIT:1> * len ( self . parameters_ ) <EOL> for i in xrange ( len ( self . parameters_ ) ) : n += self . lengthString ( self . parameters_ [ i ] . ByteSize ( ) ) <EOL> if ( self . has_expiration_time_seconds_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . expiration_time_seconds_ ) <EOL> return n + <NUM_LIT:2> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_filesystem_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . filesystem_ ) ) <EOL> if ( self . has_content_type_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . content_type_ ) <EOL> if ( self . has_filename_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . filename_ ) ) <EOL> n += <NUM_LIT:1> * len ( self . parameters_ ) <EOL> for i in xrange ( len ( self . parameters_ ) ) : n += self . lengthString ( self . parameters_ [ i ] . ByteSizePartial ( ) ) <EOL> if ( self . has_expiration_time_seconds_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . expiration_time_seconds_ ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_filesystem ( ) <EOL> self . clear_content_type ( ) <EOL> self . clear_filename ( ) <EOL> self . clear_parameters ( ) <EOL> self . clear_expiration_time_seconds ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filesystem_ ) <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putVarInt32 ( self . content_type_ ) <EOL> if ( self . has_filename_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> for i in xrange ( len ( self . parameters_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . parameters_ [ i ] . ByteSize ( ) ) <EOL> self . parameters_ [ i ] . OutputUnchecked ( out ) <EOL> if ( self . has_expiration_time_seconds_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . expiration_time_seconds_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_filesystem_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filesystem_ ) <EOL> if ( self . has_content_type_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putVarInt32 ( self . content_type_ ) <EOL> if ( self . has_filename_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> for i in xrange ( len ( self . parameters_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . parameters_ [ i ] . ByteSizePartial ( ) ) <EOL> self . parameters_ [ i ] . OutputPartial ( out ) <EOL> if ( self . has_expiration_time_seconds_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . expiration_time_seconds_ ) <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_filesystem ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:16> : <EOL> self . set_content_type ( d . getVarInt32 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_filename ( 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_parameters ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_expiration_time_seconds ( d . getVarInt64 ( ) ) <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_filesystem_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . filesystem_ ) ) <EOL> if self . has_content_type_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt32 ( self . content_type_ ) ) <EOL> if self . has_filename_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . filename_ ) ) <EOL> cnt = <NUM_LIT:0> <EOL> for e in self . parameters_ : <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_expiration_time_seconds_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . expiration_time_seconds_ ) ) <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> kfilesystem = <NUM_LIT:1> <EOL> kcontent_type = <NUM_LIT:2> <EOL> kfilename = <NUM_LIT:3> <EOL> kparameters = <NUM_LIT:4> <EOL> kexpiration_time_seconds = <NUM_LIT:5> <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:filename>" , <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:2> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:3> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:4> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:5> : ProtocolBuffer . Encoder . NUMERIC , <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 CreateResponse ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_filename_ = <NUM_LIT:0> <EOL> filename_ = "<STR_LIT>" <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def filename ( self ) : return self . filename_ <EOL> def set_filename ( self , x ) : <EOL> self . has_filename_ = <NUM_LIT:1> <EOL> self . filename_ = x <EOL> def clear_filename ( self ) : <EOL> if self . has_filename_ : <EOL> self . has_filename_ = <NUM_LIT:0> <EOL> self . filename_ = "<STR_LIT>" <EOL> def has_filename ( self ) : return self . has_filename_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_filename ( ) ) : self . set_filename ( x . filename ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_filename_ != x . has_filename_ : return <NUM_LIT:0> <EOL> if self . has_filename_ and self . filename_ != x . filename_ : 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_filename_ ) : <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 . filename_ ) ) <EOL> return n + <NUM_LIT:1> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_filename_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . filename_ ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_filename ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_filename_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <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_filename ( 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_filename_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . filename_ ) ) <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> kfilename = <NUM_LIT:1> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:filename>" , <EOL> } , <NUM_LIT:1> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:1> : ProtocolBuffer . Encoder . STRING , <EOL> } , <NUM_LIT:1> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class OpenRequest ( ProtocolBuffer . ProtocolMessage ) : <EOL> APPEND = <NUM_LIT:1> <EOL> READ = <NUM_LIT:2> <EOL> _OpenMode_NAMES = { <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:2> : "<STR_LIT>" , <EOL> } <EOL> def OpenMode_Name ( cls , x ) : return cls . _OpenMode_NAMES . get ( x , "<STR_LIT>" ) <EOL> OpenMode_Name = classmethod ( OpenMode_Name ) <EOL> has_filename_ = <NUM_LIT:0> <EOL> filename_ = "<STR_LIT>" <EOL> has_content_type_ = <NUM_LIT:0> <EOL> content_type_ = <NUM_LIT:0> <EOL> has_open_mode_ = <NUM_LIT:0> <EOL> open_mode_ = <NUM_LIT:0> <EOL> has_exclusive_lock_ = <NUM_LIT:0> <EOL> exclusive_lock_ = <NUM_LIT:0> <EOL> has_buffered_output_ = <NUM_LIT:0> <EOL> buffered_output_ = <NUM_LIT:0> <EOL> has_open_lease_time_seconds_ = <NUM_LIT:0> <EOL> open_lease_time_seconds_ = <NUM_LIT:30> <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def filename ( self ) : return self . filename_ <EOL> def set_filename ( self , x ) : <EOL> self . has_filename_ = <NUM_LIT:1> <EOL> self . filename_ = x <EOL> def clear_filename ( self ) : <EOL> if self . has_filename_ : <EOL> self . has_filename_ = <NUM_LIT:0> <EOL> self . filename_ = "<STR_LIT>" <EOL> def has_filename ( self ) : return self . has_filename_ <EOL> def content_type ( self ) : return self . content_type_ <EOL> def set_content_type ( self , x ) : <EOL> self . has_content_type_ = <NUM_LIT:1> <EOL> self . content_type_ = x <EOL> def clear_content_type ( self ) : <EOL> if self . has_content_type_ : <EOL> self . has_content_type_ = <NUM_LIT:0> <EOL> self . content_type_ = <NUM_LIT:0> <EOL> def has_content_type ( self ) : return self . has_content_type_ <EOL> def open_mode ( self ) : return self . open_mode_ <EOL> def set_open_mode ( self , x ) : <EOL> self . has_open_mode_ = <NUM_LIT:1> <EOL> self . open_mode_ = x <EOL> def clear_open_mode ( self ) : <EOL> if self . has_open_mode_ : <EOL> self . has_open_mode_ = <NUM_LIT:0> <EOL> self . open_mode_ = <NUM_LIT:0> <EOL> def has_open_mode ( self ) : return self . has_open_mode_ <EOL> def exclusive_lock ( self ) : return self . exclusive_lock_ <EOL> def set_exclusive_lock ( self , x ) : <EOL> self . has_exclusive_lock_ = <NUM_LIT:1> <EOL> self . exclusive_lock_ = x <EOL> def clear_exclusive_lock ( self ) : <EOL> if self . has_exclusive_lock_ : <EOL> self . has_exclusive_lock_ = <NUM_LIT:0> <EOL> self . exclusive_lock_ = <NUM_LIT:0> <EOL> def has_exclusive_lock ( self ) : return self . has_exclusive_lock_ <EOL> def buffered_output ( self ) : return self . buffered_output_ <EOL> def set_buffered_output ( self , x ) : <EOL> self . has_buffered_output_ = <NUM_LIT:1> <EOL> self . buffered_output_ = x <EOL> def clear_buffered_output ( self ) : <EOL> if self . has_buffered_output_ : <EOL> self . has_buffered_output_ = <NUM_LIT:0> <EOL> self . buffered_output_ = <NUM_LIT:0> <EOL> def has_buffered_output ( self ) : return self . has_buffered_output_ <EOL> def open_lease_time_seconds ( self ) : return self . open_lease_time_seconds_ <EOL> def set_open_lease_time_seconds ( self , x ) : <EOL> self . has_open_lease_time_seconds_ = <NUM_LIT:1> <EOL> self . open_lease_time_seconds_ = x <EOL> def clear_open_lease_time_seconds ( self ) : <EOL> if self . has_open_lease_time_seconds_ : <EOL> self . has_open_lease_time_seconds_ = <NUM_LIT:0> <EOL> self . open_lease_time_seconds_ = <NUM_LIT:30> <EOL> def has_open_lease_time_seconds ( self ) : return self . has_open_lease_time_seconds_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_filename ( ) ) : self . set_filename ( x . filename ( ) ) <EOL> if ( x . has_content_type ( ) ) : self . set_content_type ( x . content_type ( ) ) <EOL> if ( x . has_open_mode ( ) ) : self . set_open_mode ( x . open_mode ( ) ) <EOL> if ( x . has_exclusive_lock ( ) ) : self . set_exclusive_lock ( x . exclusive_lock ( ) ) <EOL> if ( x . has_buffered_output ( ) ) : self . set_buffered_output ( x . buffered_output ( ) ) <EOL> if ( x . has_open_lease_time_seconds ( ) ) : self . set_open_lease_time_seconds ( x . open_lease_time_seconds ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_filename_ != x . has_filename_ : return <NUM_LIT:0> <EOL> if self . has_filename_ and self . filename_ != x . filename_ : return <NUM_LIT:0> <EOL> if self . has_content_type_ != x . has_content_type_ : return <NUM_LIT:0> <EOL> if self . has_content_type_ and self . content_type_ != x . content_type_ : return <NUM_LIT:0> <EOL> if self . has_open_mode_ != x . has_open_mode_ : return <NUM_LIT:0> <EOL> if self . has_open_mode_ and self . open_mode_ != x . open_mode_ : return <NUM_LIT:0> <EOL> if self . has_exclusive_lock_ != x . has_exclusive_lock_ : return <NUM_LIT:0> <EOL> if self . has_exclusive_lock_ and self . exclusive_lock_ != x . exclusive_lock_ : return <NUM_LIT:0> <EOL> if self . has_buffered_output_ != x . has_buffered_output_ : return <NUM_LIT:0> <EOL> if self . has_buffered_output_ and self . buffered_output_ != x . buffered_output_ : return <NUM_LIT:0> <EOL> if self . has_open_lease_time_seconds_ != x . has_open_lease_time_seconds_ : return <NUM_LIT:0> <EOL> if self . has_open_lease_time_seconds_ and self . open_lease_time_seconds_ != x . open_lease_time_seconds_ : 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_filename_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_content_type_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_open_mode_ ) : <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 . filename_ ) ) <EOL> n += self . lengthVarInt64 ( self . content_type_ ) <EOL> n += self . lengthVarInt64 ( self . open_mode_ ) <EOL> if ( self . has_exclusive_lock_ ) : n += <NUM_LIT:2> <EOL> if ( self . has_buffered_output_ ) : n += <NUM_LIT:2> <EOL> if ( self . has_open_lease_time_seconds_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . open_lease_time_seconds_ ) <EOL> return n + <NUM_LIT:3> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_filename_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . filename_ ) ) <EOL> if ( self . has_content_type_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . content_type_ ) <EOL> if ( self . has_open_mode_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . open_mode_ ) <EOL> if ( self . has_exclusive_lock_ ) : n += <NUM_LIT:2> <EOL> if ( self . has_buffered_output_ ) : n += <NUM_LIT:2> <EOL> if ( self . has_open_lease_time_seconds_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . open_lease_time_seconds_ ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_filename ( ) <EOL> self . clear_content_type ( ) <EOL> self . clear_open_mode ( ) <EOL> self . clear_exclusive_lock ( ) <EOL> self . clear_buffered_output ( ) <EOL> self . clear_open_lease_time_seconds ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putVarInt32 ( self . content_type_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . open_mode_ ) <EOL> if ( self . has_exclusive_lock_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:32> ) <EOL> out . putBoolean ( self . exclusive_lock_ ) <EOL> if ( self . has_buffered_output_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putBoolean ( self . buffered_output_ ) <EOL> if ( self . has_open_lease_time_seconds_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . open_lease_time_seconds_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_filename_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> if ( self . has_content_type_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putVarInt32 ( self . content_type_ ) <EOL> if ( self . has_open_mode_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . open_mode_ ) <EOL> if ( self . has_exclusive_lock_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:32> ) <EOL> out . putBoolean ( self . exclusive_lock_ ) <EOL> if ( self . has_buffered_output_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putBoolean ( self . buffered_output_ ) <EOL> if ( self . has_open_lease_time_seconds_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . open_lease_time_seconds_ ) <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_filename ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:16> : <EOL> self . set_content_type ( d . getVarInt32 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_open_mode ( d . getVarInt32 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:32> : <EOL> self . set_exclusive_lock ( d . getBoolean ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_buffered_output ( d . getBoolean ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_open_lease_time_seconds ( 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_filename_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . filename_ ) ) <EOL> if self . has_content_type_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt32 ( self . content_type_ ) ) <EOL> if self . has_open_mode_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt32 ( self . open_mode_ ) ) <EOL> if self . has_exclusive_lock_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatBool ( self . exclusive_lock_ ) ) <EOL> if self . has_buffered_output_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatBool ( self . buffered_output_ ) ) <EOL> if self . has_open_lease_time_seconds_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt32 ( self . open_lease_time_seconds_ ) ) <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> kfilename = <NUM_LIT:1> <EOL> kcontent_type = <NUM_LIT:2> <EOL> kopen_mode = <NUM_LIT:3> <EOL> kexclusive_lock = <NUM_LIT:4> <EOL> kbuffered_output = <NUM_LIT:5> <EOL> kopen_lease_time_seconds = <NUM_LIT:6> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:filename>" , <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:6> ) <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 . NUMERIC , <EOL> <NUM_LIT:4> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:5> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:6> : ProtocolBuffer . Encoder . NUMERIC , <EOL> } , <NUM_LIT:6> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class OpenResponse ( ProtocolBuffer . ProtocolMessage ) : <EOL> def __init__ ( self , contents = None ) : <EOL> pass <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def Clear ( self ) : <EOL> pass <EOL> def OutputUnchecked ( self , out ) : <EOL> pass <EOL> def OutputPartial ( self , out ) : <EOL> pass <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <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> 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> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> } , <NUM_LIT:0> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> } , <NUM_LIT:0> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class CloseRequest ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_filename_ = <NUM_LIT:0> <EOL> filename_ = "<STR_LIT>" <EOL> has_finalize_ = <NUM_LIT:0> <EOL> finalize_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def filename ( self ) : return self . filename_ <EOL> def set_filename ( self , x ) : <EOL> self . has_filename_ = <NUM_LIT:1> <EOL> self . filename_ = x <EOL> def clear_filename ( self ) : <EOL> if self . has_filename_ : <EOL> self . has_filename_ = <NUM_LIT:0> <EOL> self . filename_ = "<STR_LIT>" <EOL> def has_filename ( self ) : return self . has_filename_ <EOL> def finalize ( self ) : return self . finalize_ <EOL> def set_finalize ( self , x ) : <EOL> self . has_finalize_ = <NUM_LIT:1> <EOL> self . finalize_ = x <EOL> def clear_finalize ( self ) : <EOL> if self . has_finalize_ : <EOL> self . has_finalize_ = <NUM_LIT:0> <EOL> self . finalize_ = <NUM_LIT:0> <EOL> def has_finalize ( self ) : return self . has_finalize_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_filename ( ) ) : self . set_filename ( x . filename ( ) ) <EOL> if ( x . has_finalize ( ) ) : self . set_finalize ( x . finalize ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_filename_ != x . has_filename_ : return <NUM_LIT:0> <EOL> if self . has_filename_ and self . filename_ != x . filename_ : return <NUM_LIT:0> <EOL> if self . has_finalize_ != x . has_finalize_ : return <NUM_LIT:0> <EOL> if self . has_finalize_ and self . finalize_ != x . finalize_ : 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_filename_ ) : <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 . filename_ ) ) <EOL> if ( self . has_finalize_ ) : n += <NUM_LIT:2> <EOL> return n + <NUM_LIT:1> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_filename_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . filename_ ) ) <EOL> if ( self . has_finalize_ ) : n += <NUM_LIT:2> <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_filename ( ) <EOL> self . clear_finalize ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> if ( self . has_finalize_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putBoolean ( self . finalize_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_filename_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> if ( self . has_finalize_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putBoolean ( self . finalize_ ) <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_filename ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:16> : <EOL> self . set_finalize ( d . getBoolean ( ) ) <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_filename_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . filename_ ) ) <EOL> if self . has_finalize_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatBool ( self . finalize_ ) ) <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> kfilename = <NUM_LIT:1> <EOL> kfinalize = <NUM_LIT:2> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:filename>" , <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 . STRING , <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 CloseResponse ( ProtocolBuffer . ProtocolMessage ) : <EOL> def __init__ ( self , contents = None ) : <EOL> pass <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def Clear ( self ) : <EOL> pass <EOL> def OutputUnchecked ( self , out ) : <EOL> pass <EOL> def OutputPartial ( self , out ) : <EOL> pass <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <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> 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> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> } , <NUM_LIT:0> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> } , <NUM_LIT:0> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class FileStat ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_filename_ = <NUM_LIT:0> <EOL> filename_ = "<STR_LIT>" <EOL> has_content_type_ = <NUM_LIT:0> <EOL> content_type_ = <NUM_LIT:0> <EOL> has_finalized_ = <NUM_LIT:0> <EOL> finalized_ = <NUM_LIT:0> <EOL> has_length_ = <NUM_LIT:0> <EOL> length_ = <NUM_LIT:0> <EOL> has_ctime_ = <NUM_LIT:0> <EOL> ctime_ = <NUM_LIT:0> <EOL> has_mtime_ = <NUM_LIT:0> <EOL> mtime_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def filename ( self ) : return self . filename_ <EOL> def set_filename ( self , x ) : <EOL> self . has_filename_ = <NUM_LIT:1> <EOL> self . filename_ = x <EOL> def clear_filename ( self ) : <EOL> if self . has_filename_ : <EOL> self . has_filename_ = <NUM_LIT:0> <EOL> self . filename_ = "<STR_LIT>" <EOL> def has_filename ( self ) : return self . has_filename_ <EOL> def content_type ( self ) : return self . content_type_ <EOL> def set_content_type ( self , x ) : <EOL> self . has_content_type_ = <NUM_LIT:1> <EOL> self . content_type_ = x <EOL> def clear_content_type ( self ) : <EOL> if self . has_content_type_ : <EOL> self . has_content_type_ = <NUM_LIT:0> <EOL> self . content_type_ = <NUM_LIT:0> <EOL> def has_content_type ( self ) : return self . has_content_type_ <EOL> def finalized ( self ) : return self . finalized_ <EOL> def set_finalized ( self , x ) : <EOL> self . has_finalized_ = <NUM_LIT:1> <EOL> self . finalized_ = x <EOL> def clear_finalized ( self ) : <EOL> if self . has_finalized_ : <EOL> self . has_finalized_ = <NUM_LIT:0> <EOL> self . finalized_ = <NUM_LIT:0> <EOL> def has_finalized ( self ) : return self . has_finalized_ <EOL> def length ( self ) : return self . length_ <EOL> def set_length ( self , x ) : <EOL> self . has_length_ = <NUM_LIT:1> <EOL> self . length_ = x <EOL> def clear_length ( self ) : <EOL> if self . has_length_ : <EOL> self . has_length_ = <NUM_LIT:0> <EOL> self . length_ = <NUM_LIT:0> <EOL> def has_length ( self ) : return self . has_length_ <EOL> def ctime ( self ) : return self . ctime_ <EOL> def set_ctime ( self , x ) : <EOL> self . has_ctime_ = <NUM_LIT:1> <EOL> self . ctime_ = x <EOL> def clear_ctime ( self ) : <EOL> if self . has_ctime_ : <EOL> self . has_ctime_ = <NUM_LIT:0> <EOL> self . ctime_ = <NUM_LIT:0> <EOL> def has_ctime ( self ) : return self . has_ctime_ <EOL> def mtime ( self ) : return self . mtime_ <EOL> def set_mtime ( self , x ) : <EOL> self . has_mtime_ = <NUM_LIT:1> <EOL> self . mtime_ = x <EOL> def clear_mtime ( self ) : <EOL> if self . has_mtime_ : <EOL> self . has_mtime_ = <NUM_LIT:0> <EOL> self . mtime_ = <NUM_LIT:0> <EOL> def has_mtime ( self ) : return self . has_mtime_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_filename ( ) ) : self . set_filename ( x . filename ( ) ) <EOL> if ( x . has_content_type ( ) ) : self . set_content_type ( x . content_type ( ) ) <EOL> if ( x . has_finalized ( ) ) : self . set_finalized ( x . finalized ( ) ) <EOL> if ( x . has_length ( ) ) : self . set_length ( x . length ( ) ) <EOL> if ( x . has_ctime ( ) ) : self . set_ctime ( x . ctime ( ) ) <EOL> if ( x . has_mtime ( ) ) : self . set_mtime ( x . mtime ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_filename_ != x . has_filename_ : return <NUM_LIT:0> <EOL> if self . has_filename_ and self . filename_ != x . filename_ : return <NUM_LIT:0> <EOL> if self . has_content_type_ != x . has_content_type_ : return <NUM_LIT:0> <EOL> if self . has_content_type_ and self . content_type_ != x . content_type_ : return <NUM_LIT:0> <EOL> if self . has_finalized_ != x . has_finalized_ : return <NUM_LIT:0> <EOL> if self . has_finalized_ and self . finalized_ != x . finalized_ : return <NUM_LIT:0> <EOL> if self . has_length_ != x . has_length_ : return <NUM_LIT:0> <EOL> if self . has_length_ and self . length_ != x . length_ : return <NUM_LIT:0> <EOL> if self . has_ctime_ != x . has_ctime_ : return <NUM_LIT:0> <EOL> if self . has_ctime_ and self . ctime_ != x . ctime_ : return <NUM_LIT:0> <EOL> if self . has_mtime_ != x . has_mtime_ : return <NUM_LIT:0> <EOL> if self . has_mtime_ and self . mtime_ != x . mtime_ : 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_filename_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_content_type_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_finalized_ ) : <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 . filename_ ) ) <EOL> n += self . lengthVarInt64 ( self . content_type_ ) <EOL> if ( self . has_length_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . length_ ) <EOL> if ( self . has_ctime_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . ctime_ ) <EOL> if ( self . has_mtime_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . mtime_ ) <EOL> return n + <NUM_LIT:4> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_filename_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . filename_ ) ) <EOL> if ( self . has_content_type_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . content_type_ ) <EOL> if ( self . has_finalized_ ) : <EOL> n += <NUM_LIT:2> <EOL> if ( self . has_length_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . length_ ) <EOL> if ( self . has_ctime_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . ctime_ ) <EOL> if ( self . has_mtime_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . mtime_ ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_filename ( ) <EOL> self . clear_content_type ( ) <EOL> self . clear_finalized ( ) <EOL> self . clear_length ( ) <EOL> self . clear_ctime ( ) <EOL> self . clear_mtime ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putVarInt32 ( self . content_type_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putBoolean ( self . finalized_ ) <EOL> if ( self . has_length_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:32> ) <EOL> out . putVarInt64 ( self . length_ ) <EOL> if ( self . has_ctime_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . ctime_ ) <EOL> if ( self . has_mtime_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . mtime_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_filename_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> if ( self . has_content_type_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putVarInt32 ( self . content_type_ ) <EOL> if ( self . has_finalized_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putBoolean ( self . finalized_ ) <EOL> if ( self . has_length_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:32> ) <EOL> out . putVarInt64 ( self . length_ ) <EOL> if ( self . has_ctime_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . ctime_ ) <EOL> if ( self . has_mtime_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . mtime_ ) <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_filename ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:16> : <EOL> self . set_content_type ( d . getVarInt32 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_finalized ( d . getBoolean ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:32> : <EOL> self . set_length ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_ctime ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_mtime ( d . getVarInt64 ( ) ) <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_filename_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . filename_ ) ) <EOL> if self . has_content_type_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt32 ( self . content_type_ ) ) <EOL> if self . has_finalized_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatBool ( self . finalized_ ) ) <EOL> if self . has_length_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . length_ ) ) <EOL> if self . has_ctime_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . ctime_ ) ) <EOL> if self . has_mtime_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . mtime_ ) ) <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> kfilename = <NUM_LIT:1> <EOL> kcontent_type = <NUM_LIT:2> <EOL> kfinalized = <NUM_LIT:3> <EOL> klength = <NUM_LIT:4> <EOL> kctime = <NUM_LIT:5> <EOL> kmtime = <NUM_LIT:6> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:filename>" , <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:6> ) <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 . NUMERIC , <EOL> <NUM_LIT:4> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:5> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:6> : ProtocolBuffer . Encoder . NUMERIC , <EOL> } , <NUM_LIT:6> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class StatRequest ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_filename_ = <NUM_LIT:0> <EOL> filename_ = "<STR_LIT>" <EOL> has_file_glob_ = <NUM_LIT:0> <EOL> file_glob_ = "<STR_LIT>" <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def filename ( self ) : return self . filename_ <EOL> def set_filename ( self , x ) : <EOL> self . has_filename_ = <NUM_LIT:1> <EOL> self . filename_ = x <EOL> def clear_filename ( self ) : <EOL> if self . has_filename_ : <EOL> self . has_filename_ = <NUM_LIT:0> <EOL> self . filename_ = "<STR_LIT>" <EOL> def has_filename ( self ) : return self . has_filename_ <EOL> def file_glob ( self ) : return self . file_glob_ <EOL> def set_file_glob ( self , x ) : <EOL> self . has_file_glob_ = <NUM_LIT:1> <EOL> self . file_glob_ = x <EOL> def clear_file_glob ( self ) : <EOL> if self . has_file_glob_ : <EOL> self . has_file_glob_ = <NUM_LIT:0> <EOL> self . file_glob_ = "<STR_LIT>" <EOL> def has_file_glob ( self ) : return self . has_file_glob_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_filename ( ) ) : self . set_filename ( x . filename ( ) ) <EOL> if ( x . has_file_glob ( ) ) : self . set_file_glob ( x . file_glob ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_filename_ != x . has_filename_ : return <NUM_LIT:0> <EOL> if self . has_filename_ and self . filename_ != x . filename_ : return <NUM_LIT:0> <EOL> if self . has_file_glob_ != x . has_file_glob_ : return <NUM_LIT:0> <EOL> if self . has_file_glob_ and self . file_glob_ != x . file_glob_ : return <NUM_LIT:0> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_filename_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . filename_ ) ) <EOL> if ( self . has_file_glob_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . file_glob_ ) ) <EOL> return n <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_filename_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . filename_ ) ) <EOL> if ( self . has_file_glob_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . file_glob_ ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_filename ( ) <EOL> self . clear_file_glob ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> if ( self . has_filename_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> if ( self . has_file_glob_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . file_glob_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_filename_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> if ( self . has_file_glob_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . file_glob_ ) <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_filename ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_file_glob ( 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_filename_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . filename_ ) ) <EOL> if self . has_file_glob_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . file_glob_ ) ) <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> kfilename = <NUM_LIT:1> <EOL> kfile_glob = <NUM_LIT:2> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:filename>" , <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 . 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 StatResponse ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_more_files_found_ = <NUM_LIT:0> <EOL> more_files_found_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> self . stat_ = [ ] <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def stat_size ( self ) : return len ( self . stat_ ) <EOL> def stat_list ( self ) : return self . stat_ <EOL> def stat ( self , i ) : <EOL> return self . stat_ [ i ] <EOL> def mutable_stat ( self , i ) : <EOL> return self . stat_ [ i ] <EOL> def add_stat ( self ) : <EOL> x = FileStat ( ) <EOL> self . stat_ . append ( x ) <EOL> return x <EOL> def clear_stat ( self ) : <EOL> self . stat_ = [ ] <EOL> def more_files_found ( self ) : return self . more_files_found_ <EOL> def set_more_files_found ( self , x ) : <EOL> self . has_more_files_found_ = <NUM_LIT:1> <EOL> self . more_files_found_ = x <EOL> def clear_more_files_found ( self ) : <EOL> if self . has_more_files_found_ : <EOL> self . has_more_files_found_ = <NUM_LIT:0> <EOL> self . more_files_found_ = <NUM_LIT:0> <EOL> def has_more_files_found ( self ) : return self . has_more_files_found_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> for i in xrange ( x . stat_size ( ) ) : self . add_stat ( ) . CopyFrom ( x . stat ( i ) ) <EOL> if ( x . has_more_files_found ( ) ) : self . set_more_files_found ( x . more_files_found ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if len ( self . stat_ ) != len ( x . stat_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . stat_ , x . stat_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> if self . has_more_files_found_ != x . has_more_files_found_ : return <NUM_LIT:0> <EOL> if self . has_more_files_found_ and self . more_files_found_ != x . more_files_found_ : return <NUM_LIT:0> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> for p in self . stat_ : <EOL> if not p . IsInitialized ( debug_strs ) : initialized = <NUM_LIT:0> <EOL> if ( not self . has_more_files_found_ ) : <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 += <NUM_LIT:1> * len ( self . stat_ ) <EOL> for i in xrange ( len ( self . stat_ ) ) : n += self . lengthString ( self . stat_ [ i ] . ByteSize ( ) ) <EOL> return n + <NUM_LIT:2> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> n += <NUM_LIT:1> * len ( self . stat_ ) <EOL> for i in xrange ( len ( self . stat_ ) ) : n += self . lengthString ( self . stat_ [ i ] . ByteSizePartial ( ) ) <EOL> if ( self . has_more_files_found_ ) : <EOL> n += <NUM_LIT:2> <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_stat ( ) <EOL> self . clear_more_files_found ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> for i in xrange ( len ( self . stat_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putVarInt32 ( self . stat_ [ i ] . ByteSize ( ) ) <EOL> self . stat_ [ i ] . OutputUnchecked ( out ) <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putBoolean ( self . more_files_found_ ) <EOL> def OutputPartial ( self , out ) : <EOL> for i in xrange ( len ( self . stat_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putVarInt32 ( self . stat_ [ i ] . ByteSizePartial ( ) ) <EOL> self . stat_ [ i ] . OutputPartial ( out ) <EOL> if ( self . has_more_files_found_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putBoolean ( self . more_files_found_ ) <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <EOL> if tt == <NUM_LIT:10> : <EOL> length = d . getVarInt32 ( ) <EOL> tmp = ProtocolBuffer . Decoder ( d . buffer ( ) , d . pos ( ) , d . pos ( ) + length ) <EOL> d . skip ( length ) <EOL> self . add_stat ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if tt == <NUM_LIT:16> : <EOL> self . set_more_files_found ( d . getBoolean ( ) ) <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> cnt = <NUM_LIT:0> <EOL> for e in self . stat_ : <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_more_files_found_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatBool ( self . more_files_found_ ) ) <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> kstat = <NUM_LIT:1> <EOL> kmore_files_found = <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 . STRING , <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 AppendRequest ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_filename_ = <NUM_LIT:0> <EOL> filename_ = "<STR_LIT>" <EOL> has_data_ = <NUM_LIT:0> <EOL> data_ = "<STR_LIT>" <EOL> has_sequence_key_ = <NUM_LIT:0> <EOL> sequence_key_ = "<STR_LIT>" <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def filename ( self ) : return self . filename_ <EOL> def set_filename ( self , x ) : <EOL> self . has_filename_ = <NUM_LIT:1> <EOL> self . filename_ = x <EOL> def clear_filename ( self ) : <EOL> if self . has_filename_ : <EOL> self . has_filename_ = <NUM_LIT:0> <EOL> self . filename_ = "<STR_LIT>" <EOL> def has_filename ( self ) : return self . has_filename_ <EOL> def data ( self ) : return self . data_ <EOL> def set_data ( self , x ) : <EOL> self . has_data_ = <NUM_LIT:1> <EOL> self . data_ = x <EOL> def clear_data ( self ) : <EOL> if self . has_data_ : <EOL> self . has_data_ = <NUM_LIT:0> <EOL> self . data_ = "<STR_LIT>" <EOL> def has_data ( self ) : return self . has_data_ <EOL> def sequence_key ( self ) : return self . sequence_key_ <EOL> def set_sequence_key ( self , x ) : <EOL> self . has_sequence_key_ = <NUM_LIT:1> <EOL> self . sequence_key_ = x <EOL> def clear_sequence_key ( self ) : <EOL> if self . has_sequence_key_ : <EOL> self . has_sequence_key_ = <NUM_LIT:0> <EOL> self . sequence_key_ = "<STR_LIT>" <EOL> def has_sequence_key ( self ) : return self . has_sequence_key_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_filename ( ) ) : self . set_filename ( x . filename ( ) ) <EOL> if ( x . has_data ( ) ) : self . set_data ( x . data ( ) ) <EOL> if ( x . has_sequence_key ( ) ) : self . set_sequence_key ( x . sequence_key ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_filename_ != x . has_filename_ : return <NUM_LIT:0> <EOL> if self . has_filename_ and self . filename_ != x . filename_ : return <NUM_LIT:0> <EOL> if self . has_data_ != x . has_data_ : return <NUM_LIT:0> <EOL> if self . has_data_ and self . data_ != x . data_ : return <NUM_LIT:0> <EOL> if self . has_sequence_key_ != x . has_sequence_key_ : return <NUM_LIT:0> <EOL> if self . has_sequence_key_ and self . sequence_key_ != x . sequence_key_ : 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_filename_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_data_ ) : <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 . filename_ ) ) <EOL> n += self . lengthString ( len ( self . data_ ) ) <EOL> if ( self . has_sequence_key_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . sequence_key_ ) ) <EOL> return n + <NUM_LIT:2> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_filename_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . filename_ ) ) <EOL> if ( self . has_data_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . data_ ) ) <EOL> if ( self . has_sequence_key_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . sequence_key_ ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_filename ( ) <EOL> self . clear_data ( ) <EOL> self . clear_sequence_key ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . data_ ) <EOL> if ( self . has_sequence_key_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . sequence_key_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_filename_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> if ( self . has_data_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . data_ ) <EOL> if ( self . has_sequence_key_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . sequence_key_ ) <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_filename ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_data ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_sequence_key ( 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_filename_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . filename_ ) ) <EOL> if self . has_data_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . data_ ) ) <EOL> if self . has_sequence_key_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . sequence_key_ ) ) <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> kfilename = <NUM_LIT:1> <EOL> kdata = <NUM_LIT:2> <EOL> ksequence_key = <NUM_LIT:3> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:filename>" , <EOL> <NUM_LIT:2> : "<STR_LIT:data>" , <EOL> <NUM_LIT:3> : "<STR_LIT>" , <EOL> } , <NUM_LIT:3> ) <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 . STRING , <EOL> } , <NUM_LIT:3> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class AppendResponse ( ProtocolBuffer . ProtocolMessage ) : <EOL> def __init__ ( self , contents = None ) : <EOL> pass <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def Clear ( self ) : <EOL> pass <EOL> def OutputUnchecked ( self , out ) : <EOL> pass <EOL> def OutputPartial ( self , out ) : <EOL> pass <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <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> 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> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> } , <NUM_LIT:0> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> } , <NUM_LIT:0> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class DeleteRequest ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_filename_ = <NUM_LIT:0> <EOL> filename_ = "<STR_LIT>" <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def filename ( self ) : return self . filename_ <EOL> def set_filename ( self , x ) : <EOL> self . has_filename_ = <NUM_LIT:1> <EOL> self . filename_ = x <EOL> def clear_filename ( self ) : <EOL> if self . has_filename_ : <EOL> self . has_filename_ = <NUM_LIT:0> <EOL> self . filename_ = "<STR_LIT>" <EOL> def has_filename ( self ) : return self . has_filename_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_filename ( ) ) : self . set_filename ( x . filename ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_filename_ != x . has_filename_ : return <NUM_LIT:0> <EOL> if self . has_filename_ and self . filename_ != x . filename_ : 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_filename_ ) : <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 . filename_ ) ) <EOL> return n + <NUM_LIT:1> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_filename_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . filename_ ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_filename ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_filename_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <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_filename ( 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_filename_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . filename_ ) ) <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> kfilename = <NUM_LIT:1> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:filename>" , <EOL> } , <NUM_LIT:1> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:1> : ProtocolBuffer . Encoder . STRING , <EOL> } , <NUM_LIT:1> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class DeleteResponse ( ProtocolBuffer . ProtocolMessage ) : <EOL> def __init__ ( self , contents = None ) : <EOL> pass <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def Clear ( self ) : <EOL> pass <EOL> def OutputUnchecked ( self , out ) : <EOL> pass <EOL> def OutputPartial ( self , out ) : <EOL> pass <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <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> 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> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> } , <NUM_LIT:0> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> } , <NUM_LIT:0> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class ReadRequest ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_filename_ = <NUM_LIT:0> <EOL> filename_ = "<STR_LIT>" <EOL> has_pos_ = <NUM_LIT:0> <EOL> pos_ = <NUM_LIT:0> <EOL> has_max_bytes_ = <NUM_LIT:0> <EOL> max_bytes_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def filename ( self ) : return self . filename_ <EOL> def set_filename ( self , x ) : <EOL> self . has_filename_ = <NUM_LIT:1> <EOL> self . filename_ = x <EOL> def clear_filename ( self ) : <EOL> if self . has_filename_ : <EOL> self . has_filename_ = <NUM_LIT:0> <EOL> self . filename_ = "<STR_LIT>" <EOL> def has_filename ( self ) : return self . has_filename_ <EOL> def pos ( self ) : return self . pos_ <EOL> def set_pos ( self , x ) : <EOL> self . has_pos_ = <NUM_LIT:1> <EOL> self . pos_ = x <EOL> def clear_pos ( self ) : <EOL> if self . has_pos_ : <EOL> self . has_pos_ = <NUM_LIT:0> <EOL> self . pos_ = <NUM_LIT:0> <EOL> def has_pos ( self ) : return self . has_pos_ <EOL> def max_bytes ( self ) : return self . max_bytes_ <EOL> def set_max_bytes ( self , x ) : <EOL> self . has_max_bytes_ = <NUM_LIT:1> <EOL> self . max_bytes_ = x <EOL> def clear_max_bytes ( self ) : <EOL> if self . has_max_bytes_ : <EOL> self . has_max_bytes_ = <NUM_LIT:0> <EOL> self . max_bytes_ = <NUM_LIT:0> <EOL> def has_max_bytes ( self ) : return self . has_max_bytes_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_filename ( ) ) : self . set_filename ( x . filename ( ) ) <EOL> if ( x . has_pos ( ) ) : self . set_pos ( x . pos ( ) ) <EOL> if ( x . has_max_bytes ( ) ) : self . set_max_bytes ( x . max_bytes ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_filename_ != x . has_filename_ : return <NUM_LIT:0> <EOL> if self . has_filename_ and self . filename_ != x . filename_ : return <NUM_LIT:0> <EOL> if self . has_pos_ != x . has_pos_ : return <NUM_LIT:0> <EOL> if self . has_pos_ and self . pos_ != x . pos_ : return <NUM_LIT:0> <EOL> if self . has_max_bytes_ != x . has_max_bytes_ : return <NUM_LIT:0> <EOL> if self . has_max_bytes_ and self . max_bytes_ != x . max_bytes_ : 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_filename_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_pos_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_max_bytes_ ) : <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 . filename_ ) ) <EOL> n += self . lengthVarInt64 ( self . pos_ ) <EOL> n += self . lengthVarInt64 ( self . max_bytes_ ) <EOL> return n + <NUM_LIT:3> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_filename_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . filename_ ) ) <EOL> if ( self . has_pos_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . pos_ ) <EOL> if ( self . has_max_bytes_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . max_bytes_ ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_filename ( ) <EOL> self . clear_pos ( ) <EOL> self . clear_max_bytes ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putVarInt64 ( self . pos_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . max_bytes_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_filename_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> if ( self . has_pos_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putVarInt64 ( self . pos_ ) <EOL> if ( self . has_max_bytes_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . max_bytes_ ) <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_filename ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:16> : <EOL> self . set_pos ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_max_bytes ( d . getVarInt64 ( ) ) <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_filename_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . filename_ ) ) <EOL> if self . has_pos_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . pos_ ) ) <EOL> if self . has_max_bytes_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . max_bytes_ ) ) <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> kfilename = <NUM_LIT:1> <EOL> kpos = <NUM_LIT:2> <EOL> kmax_bytes = <NUM_LIT:3> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:filename>" , <EOL> <NUM_LIT:2> : "<STR_LIT>" , <EOL> <NUM_LIT:3> : "<STR_LIT>" , <EOL> } , <NUM_LIT:3> ) <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 . NUMERIC , <EOL> } , <NUM_LIT:3> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class ReadResponse ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_data_ = <NUM_LIT:0> <EOL> data_ = "<STR_LIT>" <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def data ( self ) : return self . data_ <EOL> def set_data ( self , x ) : <EOL> self . has_data_ = <NUM_LIT:1> <EOL> self . data_ = x <EOL> def clear_data ( self ) : <EOL> if self . has_data_ : <EOL> self . has_data_ = <NUM_LIT:0> <EOL> self . data_ = "<STR_LIT>" <EOL> def has_data ( self ) : return self . has_data_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_data ( ) ) : self . set_data ( x . data ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_data_ != x . has_data_ : return <NUM_LIT:0> <EOL> if self . has_data_ and self . data_ != x . data_ : 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_data_ ) : <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 . data_ ) ) <EOL> return n + <NUM_LIT:1> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_data_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . data_ ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_data ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . data_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_data_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . data_ ) <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_data ( 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_data_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . data_ ) ) <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> kdata = <NUM_LIT:1> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:data>" , <EOL> } , <NUM_LIT:1> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:1> : ProtocolBuffer . Encoder . STRING , <EOL> } , <NUM_LIT:1> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class ReadKeyValueRequest ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_filename_ = <NUM_LIT:0> <EOL> filename_ = "<STR_LIT>" <EOL> has_start_key_ = <NUM_LIT:0> <EOL> start_key_ = "<STR_LIT>" <EOL> has_max_bytes_ = <NUM_LIT:0> <EOL> max_bytes_ = <NUM_LIT:0> <EOL> has_value_pos_ = <NUM_LIT:0> <EOL> value_pos_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def filename ( self ) : return self . filename_ <EOL> def set_filename ( self , x ) : <EOL> self . has_filename_ = <NUM_LIT:1> <EOL> self . filename_ = x <EOL> def clear_filename ( self ) : <EOL> if self . has_filename_ : <EOL> self . has_filename_ = <NUM_LIT:0> <EOL> self . filename_ = "<STR_LIT>" <EOL> def has_filename ( self ) : return self . has_filename_ <EOL> def start_key ( self ) : return self . start_key_ <EOL> def set_start_key ( self , x ) : <EOL> self . has_start_key_ = <NUM_LIT:1> <EOL> self . start_key_ = x <EOL> def clear_start_key ( self ) : <EOL> if self . has_start_key_ : <EOL> self . has_start_key_ = <NUM_LIT:0> <EOL> self . start_key_ = "<STR_LIT>" <EOL> def has_start_key ( self ) : return self . has_start_key_ <EOL> def max_bytes ( self ) : return self . max_bytes_ <EOL> def set_max_bytes ( self , x ) : <EOL> self . has_max_bytes_ = <NUM_LIT:1> <EOL> self . max_bytes_ = x <EOL> def clear_max_bytes ( self ) : <EOL> if self . has_max_bytes_ : <EOL> self . has_max_bytes_ = <NUM_LIT:0> <EOL> self . max_bytes_ = <NUM_LIT:0> <EOL> def has_max_bytes ( self ) : return self . has_max_bytes_ <EOL> def value_pos ( self ) : return self . value_pos_ <EOL> def set_value_pos ( self , x ) : <EOL> self . has_value_pos_ = <NUM_LIT:1> <EOL> self . value_pos_ = x <EOL> def clear_value_pos ( self ) : <EOL> if self . has_value_pos_ : <EOL> self . has_value_pos_ = <NUM_LIT:0> <EOL> self . value_pos_ = <NUM_LIT:0> <EOL> def has_value_pos ( self ) : return self . has_value_pos_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_filename ( ) ) : self . set_filename ( x . filename ( ) ) <EOL> if ( x . has_start_key ( ) ) : self . set_start_key ( x . start_key ( ) ) <EOL> if ( x . has_max_bytes ( ) ) : self . set_max_bytes ( x . max_bytes ( ) ) <EOL> if ( x . has_value_pos ( ) ) : self . set_value_pos ( x . value_pos ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_filename_ != x . has_filename_ : return <NUM_LIT:0> <EOL> if self . has_filename_ and self . filename_ != x . filename_ : return <NUM_LIT:0> <EOL> if self . has_start_key_ != x . has_start_key_ : return <NUM_LIT:0> <EOL> if self . has_start_key_ and self . start_key_ != x . start_key_ : return <NUM_LIT:0> <EOL> if self . has_max_bytes_ != x . has_max_bytes_ : return <NUM_LIT:0> <EOL> if self . has_max_bytes_ and self . max_bytes_ != x . max_bytes_ : return <NUM_LIT:0> <EOL> if self . has_value_pos_ != x . has_value_pos_ : return <NUM_LIT:0> <EOL> if self . has_value_pos_ and self . value_pos_ != x . value_pos_ : 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_filename_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_start_key_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_max_bytes_ ) : <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 . filename_ ) ) <EOL> n += self . lengthString ( len ( self . start_key_ ) ) <EOL> n += self . lengthVarInt64 ( self . max_bytes_ ) <EOL> if ( self . has_value_pos_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . value_pos_ ) <EOL> return n + <NUM_LIT:3> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_filename_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . filename_ ) ) <EOL> if ( self . has_start_key_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . start_key_ ) ) <EOL> if ( self . has_max_bytes_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . max_bytes_ ) <EOL> if ( self . has_value_pos_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . value_pos_ ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_filename ( ) <EOL> self . clear_start_key ( ) <EOL> self . clear_max_bytes ( ) <EOL> self . clear_value_pos ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . start_key_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . max_bytes_ ) <EOL> if ( self . has_value_pos_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:32> ) <EOL> out . putVarInt64 ( self . value_pos_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_filename_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filename_ ) <EOL> if ( self . has_start_key_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . start_key_ ) <EOL> if ( self . has_max_bytes_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt64 ( self . max_bytes_ ) <EOL> if ( self . has_value_pos_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:32> ) <EOL> out . putVarInt64 ( self . value_pos_ ) <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_filename ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_start_key ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_max_bytes ( d . getVarInt64 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:32> : <EOL> self . set_value_pos ( d . getVarInt64 ( ) ) <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_filename_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . filename_ ) ) <EOL> if self . has_start_key_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . start_key_ ) ) <EOL> if self . has_max_bytes_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . max_bytes_ ) ) <EOL> if self . has_value_pos_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . value_pos_ ) ) <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> kfilename = <NUM_LIT:1> <EOL> kstart_key = <NUM_LIT:2> <EOL> kmax_bytes = <NUM_LIT:3> <EOL> kvalue_pos = <NUM_LIT:4> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:filename>" , <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 . STRING , <EOL> <NUM_LIT:3> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:4> : ProtocolBuffer . Encoder . NUMERIC , <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 ReadKeyValueResponse_KeyValue ( 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 ReadKeyValueResponse ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_next_key_ = <NUM_LIT:0> <EOL> next_key_ = "<STR_LIT>" <EOL> has_truncated_value_ = <NUM_LIT:0> <EOL> truncated_value_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> self . data_ = [ ] <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def data_size ( self ) : return len ( self . data_ ) <EOL> def data_list ( self ) : return self . data_ <EOL> def data ( self , i ) : <EOL> return self . data_ [ i ] <EOL> def mutable_data ( self , i ) : <EOL> return self . data_ [ i ] <EOL> def add_data ( self ) : <EOL> x = ReadKeyValueResponse_KeyValue ( ) <EOL> self . data_ . append ( x ) <EOL> return x <EOL> def clear_data ( self ) : <EOL> self . data_ = [ ] <EOL> def next_key ( self ) : return self . next_key_ <EOL> def set_next_key ( self , x ) : <EOL> self . has_next_key_ = <NUM_LIT:1> <EOL> self . next_key_ = x <EOL> def clear_next_key ( self ) : <EOL> if self . has_next_key_ : <EOL> self . has_next_key_ = <NUM_LIT:0> <EOL> self . next_key_ = "<STR_LIT>" <EOL> def has_next_key ( self ) : return self . has_next_key_ <EOL> def truncated_value ( self ) : return self . truncated_value_ <EOL> def set_truncated_value ( self , x ) : <EOL> self . has_truncated_value_ = <NUM_LIT:1> <EOL> self . truncated_value_ = x <EOL> def clear_truncated_value ( self ) : <EOL> if self . has_truncated_value_ : <EOL> self . has_truncated_value_ = <NUM_LIT:0> <EOL> self . truncated_value_ = <NUM_LIT:0> <EOL> def has_truncated_value ( self ) : return self . has_truncated_value_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> for i in xrange ( x . data_size ( ) ) : self . add_data ( ) . CopyFrom ( x . data ( i ) ) <EOL> if ( x . has_next_key ( ) ) : self . set_next_key ( x . next_key ( ) ) <EOL> if ( x . has_truncated_value ( ) ) : self . set_truncated_value ( x . truncated_value ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if len ( self . data_ ) != len ( x . data_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . data_ , x . data_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> if self . has_next_key_ != x . has_next_key_ : return <NUM_LIT:0> <EOL> if self . has_next_key_ and self . next_key_ != x . next_key_ : return <NUM_LIT:0> <EOL> if self . has_truncated_value_ != x . has_truncated_value_ : return <NUM_LIT:0> <EOL> if self . has_truncated_value_ and self . truncated_value_ != x . truncated_value_ : return <NUM_LIT:0> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> for p in self . data_ : <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 += <NUM_LIT:1> * len ( self . data_ ) <EOL> for i in xrange ( len ( self . data_ ) ) : n += self . lengthString ( self . data_ [ i ] . ByteSize ( ) ) <EOL> if ( self . has_next_key_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . next_key_ ) ) <EOL> if ( self . has_truncated_value_ ) : n += <NUM_LIT:2> <EOL> return n <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> n += <NUM_LIT:1> * len ( self . data_ ) <EOL> for i in xrange ( len ( self . data_ ) ) : n += self . lengthString ( self . data_ [ i ] . ByteSizePartial ( ) ) <EOL> if ( self . has_next_key_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . next_key_ ) ) <EOL> if ( self . has_truncated_value_ ) : n += <NUM_LIT:2> <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_data ( ) <EOL> self . clear_next_key ( ) <EOL> self . clear_truncated_value ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> for i in xrange ( len ( self . data_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putVarInt32 ( self . data_ [ i ] . ByteSize ( ) ) <EOL> self . data_ [ i ] . OutputUnchecked ( out ) <EOL> if ( self . has_next_key_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . next_key_ ) <EOL> if ( self . has_truncated_value_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putBoolean ( self . truncated_value_ ) <EOL> def OutputPartial ( self , out ) : <EOL> for i in xrange ( len ( self . data_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putVarInt32 ( self . data_ [ i ] . ByteSizePartial ( ) ) <EOL> self . data_ [ i ] . OutputPartial ( out ) <EOL> if ( self . has_next_key_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . next_key_ ) <EOL> if ( self . has_truncated_value_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putBoolean ( self . truncated_value_ ) <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <EOL> if tt == <NUM_LIT:10> : <EOL> length = d . getVarInt32 ( ) <EOL> tmp = ProtocolBuffer . Decoder ( d . buffer ( ) , d . pos ( ) , d . pos ( ) + length ) <EOL> d . skip ( length ) <EOL> self . add_data ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_next_key ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_truncated_value ( d . getBoolean ( ) ) <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> cnt = <NUM_LIT:0> <EOL> for e in self . data_ : <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_next_key_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . next_key_ ) ) <EOL> if self . has_truncated_value_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatBool ( self . truncated_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> kdata = <NUM_LIT:1> <EOL> knext_key = <NUM_LIT:2> <EOL> ktruncated_value = <NUM_LIT:3> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:data>" , <EOL> <NUM_LIT:2> : "<STR_LIT>" , <EOL> <NUM_LIT:3> : "<STR_LIT>" , <EOL> } , <NUM_LIT:3> ) <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 . NUMERIC , <EOL> } , <NUM_LIT:3> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class ShuffleEnums ( ProtocolBuffer . ProtocolMessage ) : <EOL> CSV_INPUT = <NUM_LIT:0> <EOL> RECORDS_KEY_VALUE_PROTO_INPUT = <NUM_LIT:1> <EOL> _InputFormat_NAMES = { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> } <EOL> def InputFormat_Name ( cls , x ) : return cls . _InputFormat_NAMES . get ( x , "<STR_LIT>" ) <EOL> InputFormat_Name = classmethod ( InputFormat_Name ) <EOL> CSV_OUTPUT = <NUM_LIT:0> <EOL> RECORDS_KEY_MULTI_VALUE_PROTO_OUTPUT = <NUM_LIT:1> <EOL> _OutputFormat_NAMES = { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> } <EOL> def OutputFormat_Name ( cls , x ) : return cls . _OutputFormat_NAMES . get ( x , "<STR_LIT>" ) <EOL> OutputFormat_Name = classmethod ( OutputFormat_Name ) <EOL> UNKNOWN = <NUM_LIT:1> <EOL> RUNNING = <NUM_LIT:2> <EOL> SUCCESS = <NUM_LIT:3> <EOL> FAILURE = <NUM_LIT:4> <EOL> INVALID_INPUT = <NUM_LIT:5> <EOL> OUTPUT_ALREADY_EXISTS = <NUM_LIT:6> <EOL> INCORRECT_SHUFFLE_SIZE_BYTES = <NUM_LIT:7> <EOL> _Status_NAMES = { <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> } <EOL> def Status_Name ( cls , x ) : return cls . _Status_NAMES . get ( x , "<STR_LIT>" ) <EOL> Status_Name = classmethod ( Status_Name ) <EOL> def __init__ ( self , contents = None ) : <EOL> pass <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def Clear ( self ) : <EOL> pass <EOL> def OutputUnchecked ( self , out ) : <EOL> pass <EOL> def OutputPartial ( self , out ) : <EOL> pass <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <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> 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> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> } , <NUM_LIT:0> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> } , <NUM_LIT:0> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class ShuffleInputSpecification ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_format_ = <NUM_LIT:0> <EOL> format_ = <NUM_LIT:0> <EOL> has_path_ = <NUM_LIT:0> <EOL> path_ = "<STR_LIT>" <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def format ( self ) : return self . format_ <EOL> def set_format ( self , x ) : <EOL> self . has_format_ = <NUM_LIT:1> <EOL> self . format_ = x <EOL> def clear_format ( self ) : <EOL> if self . has_format_ : <EOL> self . has_format_ = <NUM_LIT:0> <EOL> self . format_ = <NUM_LIT:0> <EOL> def has_format ( self ) : return self . has_format_ <EOL> def path ( self ) : return self . path_ <EOL> def set_path ( self , x ) : <EOL> self . has_path_ = <NUM_LIT:1> <EOL> self . path_ = x <EOL> def clear_path ( self ) : <EOL> if self . has_path_ : <EOL> self . has_path_ = <NUM_LIT:0> <EOL> self . path_ = "<STR_LIT>" <EOL> def has_path ( self ) : return self . has_path_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_format ( ) ) : self . set_format ( x . format ( ) ) <EOL> if ( x . has_path ( ) ) : self . set_path ( x . path ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_format_ != x . has_format_ : return <NUM_LIT:0> <EOL> if self . has_format_ and self . format_ != x . format_ : return <NUM_LIT:0> <EOL> if self . has_path_ != x . has_path_ : return <NUM_LIT:0> <EOL> if self . has_path_ and self . path_ != x . path_ : 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_path_ ) : <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> if ( self . has_format_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . format_ ) <EOL> n += self . lengthString ( len ( self . path_ ) ) <EOL> return n + <NUM_LIT:1> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_format_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . format_ ) <EOL> if ( self . has_path_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . path_ ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_format ( ) <EOL> self . clear_path ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> if ( self . has_format_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:8> ) <EOL> out . putVarInt32 ( self . format_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . path_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_format_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:8> ) <EOL> out . putVarInt32 ( self . format_ ) <EOL> if ( self . has_path_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . path_ ) <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_format ( d . getVarInt32 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_path ( 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_format_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt32 ( self . format_ ) ) <EOL> if self . has_path_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . path_ ) ) <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> kformat = <NUM_LIT:1> <EOL> kpath = <NUM_LIT:2> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:2> : "<STR_LIT:path>" , <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 . 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 ShuffleOutputSpecification ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_format_ = <NUM_LIT:0> <EOL> format_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> self . path_ = [ ] <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def format ( self ) : return self . format_ <EOL> def set_format ( self , x ) : <EOL> self . has_format_ = <NUM_LIT:1> <EOL> self . format_ = x <EOL> def clear_format ( self ) : <EOL> if self . has_format_ : <EOL> self . has_format_ = <NUM_LIT:0> <EOL> self . format_ = <NUM_LIT:0> <EOL> def has_format ( self ) : return self . has_format_ <EOL> def path_size ( self ) : return len ( self . path_ ) <EOL> def path_list ( self ) : return self . path_ <EOL> def path ( self , i ) : <EOL> return self . path_ [ i ] <EOL> def set_path ( self , i , x ) : <EOL> self . path_ [ i ] = x <EOL> def add_path ( self , x ) : <EOL> self . path_ . append ( x ) <EOL> def clear_path ( self ) : <EOL> self . path_ = [ ] <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_format ( ) ) : self . set_format ( x . format ( ) ) <EOL> for i in xrange ( x . path_size ( ) ) : self . add_path ( x . path ( i ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_format_ != x . has_format_ : return <NUM_LIT:0> <EOL> if self . has_format_ and self . format_ != x . format_ : return <NUM_LIT:0> <EOL> if len ( self . path_ ) != len ( x . path_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . path_ , x . path_ ) : <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> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_format_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . format_ ) <EOL> n += <NUM_LIT:1> * len ( self . path_ ) <EOL> for i in xrange ( len ( self . path_ ) ) : n += self . lengthString ( len ( self . path_ [ i ] ) ) <EOL> return n <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_format_ ) : n += <NUM_LIT:1> + self . lengthVarInt64 ( self . format_ ) <EOL> n += <NUM_LIT:1> * len ( self . path_ ) <EOL> for i in xrange ( len ( self . path_ ) ) : n += self . lengthString ( len ( self . path_ [ i ] ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_format ( ) <EOL> self . clear_path ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> if ( self . has_format_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:8> ) <EOL> out . putVarInt32 ( self . format_ ) <EOL> for i in xrange ( len ( self . path_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . path_ [ i ] ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_format_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:8> ) <EOL> out . putVarInt32 ( self . format_ ) <EOL> for i in xrange ( len ( self . path_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . path_ [ i ] ) <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_format ( d . getVarInt32 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . add_path ( 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_format_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt32 ( self . format_ ) ) <EOL> cnt = <NUM_LIT:0> <EOL> for e in self . path_ : <EOL> elm = "<STR_LIT>" <EOL> if printElemNumber : elm = "<STR_LIT>" % cnt <EOL> res += prefix + ( "<STR_LIT>" % ( elm , self . DebugFormatString ( e ) ) ) <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> kformat = <NUM_LIT:1> <EOL> kpath = <NUM_LIT:2> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:2> : "<STR_LIT:path>" , <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 . 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 ShuffleRequest_Callback ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_url_ = <NUM_LIT:0> <EOL> url_ = "<STR_LIT>" <EOL> has_app_version_id_ = <NUM_LIT:0> <EOL> app_version_id_ = "<STR_LIT>" <EOL> has_method_ = <NUM_LIT:0> <EOL> method_ = "<STR_LIT:POST>" <EOL> has_queue_ = <NUM_LIT:0> <EOL> queue_ = "<STR_LIT:default>" <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def url ( self ) : return self . url_ <EOL> def set_url ( self , x ) : <EOL> self . has_url_ = <NUM_LIT:1> <EOL> self . url_ = x <EOL> def clear_url ( self ) : <EOL> if self . has_url_ : <EOL> self . has_url_ = <NUM_LIT:0> <EOL> self . url_ = "<STR_LIT>" <EOL> def has_url ( self ) : return self . has_url_ <EOL> def app_version_id ( self ) : return self . app_version_id_ <EOL> def set_app_version_id ( self , x ) : <EOL> self . has_app_version_id_ = <NUM_LIT:1> <EOL> self . app_version_id_ = x <EOL> def clear_app_version_id ( self ) : <EOL> if self . has_app_version_id_ : <EOL> self . has_app_version_id_ = <NUM_LIT:0> <EOL> self . app_version_id_ = "<STR_LIT>" <EOL> def has_app_version_id ( self ) : return self . has_app_version_id_ <EOL> def method ( self ) : return self . method_ <EOL> def set_method ( self , x ) : <EOL> self . has_method_ = <NUM_LIT:1> <EOL> self . method_ = x <EOL> def clear_method ( self ) : <EOL> if self . has_method_ : <EOL> self . has_method_ = <NUM_LIT:0> <EOL> self . method_ = "<STR_LIT:POST>" <EOL> def has_method ( self ) : return self . has_method_ <EOL> def queue ( self ) : return self . queue_ <EOL> def set_queue ( self , x ) : <EOL> self . has_queue_ = <NUM_LIT:1> <EOL> self . queue_ = x <EOL> def clear_queue ( self ) : <EOL> if self . has_queue_ : <EOL> self . has_queue_ = <NUM_LIT:0> <EOL> self . queue_ = "<STR_LIT:default>" <EOL> def has_queue ( self ) : return self . has_queue_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_url ( ) ) : self . set_url ( x . url ( ) ) <EOL> if ( x . has_app_version_id ( ) ) : self . set_app_version_id ( x . app_version_id ( ) ) <EOL> if ( x . has_method ( ) ) : self . set_method ( x . method ( ) ) <EOL> if ( x . has_queue ( ) ) : self . set_queue ( x . queue ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_url_ != x . has_url_ : return <NUM_LIT:0> <EOL> if self . has_url_ and self . url_ != x . url_ : return <NUM_LIT:0> <EOL> if self . has_app_version_id_ != x . has_app_version_id_ : return <NUM_LIT:0> <EOL> if self . has_app_version_id_ and self . app_version_id_ != x . app_version_id_ : return <NUM_LIT:0> <EOL> if self . has_method_ != x . has_method_ : return <NUM_LIT:0> <EOL> if self . has_method_ and self . method_ != x . method_ : return <NUM_LIT:0> <EOL> if self . has_queue_ != x . has_queue_ : return <NUM_LIT:0> <EOL> if self . has_queue_ and self . queue_ != x . queue_ : 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_url_ ) : <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 . url_ ) ) <EOL> if ( self . has_app_version_id_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . app_version_id_ ) ) <EOL> if ( self . has_method_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . method_ ) ) <EOL> if ( self . has_queue_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . queue_ ) ) <EOL> return n + <NUM_LIT:1> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_url_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . url_ ) ) <EOL> if ( self . has_app_version_id_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . app_version_id_ ) ) <EOL> if ( self . has_method_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . method_ ) ) <EOL> if ( self . has_queue_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . queue_ ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_url ( ) <EOL> self . clear_app_version_id ( ) <EOL> self . clear_method ( ) <EOL> self . clear_queue ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . url_ ) <EOL> if ( self . has_app_version_id_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . app_version_id_ ) <EOL> if ( self . has_method_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . method_ ) <EOL> if ( self . has_queue_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . queue_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_url_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . url_ ) <EOL> if ( self . has_app_version_id_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . app_version_id_ ) <EOL> if ( self . has_method_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . method_ ) <EOL> if ( self . has_queue_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . queue_ ) <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_url ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_app_version_id ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_method ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_queue ( 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_url_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . url_ ) ) <EOL> if self . has_app_version_id_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . app_version_id_ ) ) <EOL> if self . has_method_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . method_ ) ) <EOL> if self . has_queue_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . queue_ ) ) <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> kurl = <NUM_LIT:1> <EOL> kapp_version_id = <NUM_LIT:2> <EOL> kmethod = <NUM_LIT:3> <EOL> kqueue = <NUM_LIT:4> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:url>" , <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 . STRING , <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 ShuffleRequest ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_shuffle_name_ = <NUM_LIT:0> <EOL> shuffle_name_ = "<STR_LIT>" <EOL> has_output_ = <NUM_LIT:0> <EOL> has_shuffle_size_bytes_ = <NUM_LIT:0> <EOL> shuffle_size_bytes_ = <NUM_LIT:0> <EOL> has_callback_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> self . input_ = [ ] <EOL> self . output_ = ShuffleOutputSpecification ( ) <EOL> self . callback_ = ShuffleRequest_Callback ( ) <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def shuffle_name ( self ) : return self . shuffle_name_ <EOL> def set_shuffle_name ( self , x ) : <EOL> self . has_shuffle_name_ = <NUM_LIT:1> <EOL> self . shuffle_name_ = x <EOL> def clear_shuffle_name ( self ) : <EOL> if self . has_shuffle_name_ : <EOL> self . has_shuffle_name_ = <NUM_LIT:0> <EOL> self . shuffle_name_ = "<STR_LIT>" <EOL> def has_shuffle_name ( self ) : return self . has_shuffle_name_ <EOL> def input_size ( self ) : return len ( self . input_ ) <EOL> def input_list ( self ) : return self . input_ <EOL> def input ( self , i ) : <EOL> return self . input_ [ i ] <EOL> def mutable_input ( self , i ) : <EOL> return self . input_ [ i ] <EOL> def add_input ( self ) : <EOL> x = ShuffleInputSpecification ( ) <EOL> self . input_ . append ( x ) <EOL> return x <EOL> def clear_input ( self ) : <EOL> self . input_ = [ ] <EOL> def output ( self ) : return self . output_ <EOL> def mutable_output ( self ) : self . has_output_ = <NUM_LIT:1> ; return self . output_ <EOL> def clear_output ( self ) : self . has_output_ = <NUM_LIT:0> ; self . output_ . Clear ( ) <EOL> def has_output ( self ) : return self . has_output_ <EOL> def shuffle_size_bytes ( self ) : return self . shuffle_size_bytes_ <EOL> def set_shuffle_size_bytes ( self , x ) : <EOL> self . has_shuffle_size_bytes_ = <NUM_LIT:1> <EOL> self . shuffle_size_bytes_ = x <EOL> def clear_shuffle_size_bytes ( self ) : <EOL> if self . has_shuffle_size_bytes_ : <EOL> self . has_shuffle_size_bytes_ = <NUM_LIT:0> <EOL> self . shuffle_size_bytes_ = <NUM_LIT:0> <EOL> def has_shuffle_size_bytes ( self ) : return self . has_shuffle_size_bytes_ <EOL> def callback ( self ) : return self . callback_ <EOL> def mutable_callback ( self ) : self . has_callback_ = <NUM_LIT:1> ; return self . callback_ <EOL> def clear_callback ( self ) : self . has_callback_ = <NUM_LIT:0> ; self . callback_ . Clear ( ) <EOL> def has_callback ( self ) : return self . has_callback_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_shuffle_name ( ) ) : self . set_shuffle_name ( x . shuffle_name ( ) ) <EOL> for i in xrange ( x . input_size ( ) ) : self . add_input ( ) . CopyFrom ( x . input ( i ) ) <EOL> if ( x . has_output ( ) ) : self . mutable_output ( ) . MergeFrom ( x . output ( ) ) <EOL> if ( x . has_shuffle_size_bytes ( ) ) : self . set_shuffle_size_bytes ( x . shuffle_size_bytes ( ) ) <EOL> if ( x . has_callback ( ) ) : self . mutable_callback ( ) . MergeFrom ( x . callback ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_shuffle_name_ != x . has_shuffle_name_ : return <NUM_LIT:0> <EOL> if self . has_shuffle_name_ and self . shuffle_name_ != x . shuffle_name_ : return <NUM_LIT:0> <EOL> if len ( self . input_ ) != len ( x . input_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . input_ , x . input_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> if self . has_output_ != x . has_output_ : return <NUM_LIT:0> <EOL> if self . has_output_ and self . output_ != x . output_ : return <NUM_LIT:0> <EOL> if self . has_shuffle_size_bytes_ != x . has_shuffle_size_bytes_ : return <NUM_LIT:0> <EOL> if self . has_shuffle_size_bytes_ and self . shuffle_size_bytes_ != x . shuffle_size_bytes_ : return <NUM_LIT:0> <EOL> if self . has_callback_ != x . has_callback_ : return <NUM_LIT:0> <EOL> if self . has_callback_ and self . callback_ != x . callback_ : 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_shuffle_name_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> for p in self . input_ : <EOL> if not p . IsInitialized ( debug_strs ) : initialized = <NUM_LIT:0> <EOL> if ( not self . has_output_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> elif not self . output_ . IsInitialized ( debug_strs ) : initialized = <NUM_LIT:0> <EOL> if ( not self . has_shuffle_size_bytes_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> if ( not self . has_callback_ ) : <EOL> initialized = <NUM_LIT:0> <EOL> if debug_strs is not None : <EOL> debug_strs . append ( '<STR_LIT>' ) <EOL> elif not self . callback_ . 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 . shuffle_name_ ) ) <EOL> n += <NUM_LIT:1> * len ( self . input_ ) <EOL> for i in xrange ( len ( self . input_ ) ) : n += self . lengthString ( self . input_ [ i ] . ByteSize ( ) ) <EOL> n += self . lengthString ( self . output_ . ByteSize ( ) ) <EOL> n += self . lengthVarInt64 ( self . shuffle_size_bytes_ ) <EOL> n += self . lengthString ( self . callback_ . ByteSize ( ) ) <EOL> return n + <NUM_LIT:4> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_shuffle_name_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . shuffle_name_ ) ) <EOL> n += <NUM_LIT:1> * len ( self . input_ ) <EOL> for i in xrange ( len ( self . input_ ) ) : n += self . lengthString ( self . input_ [ i ] . ByteSizePartial ( ) ) <EOL> if ( self . has_output_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( self . output_ . ByteSizePartial ( ) ) <EOL> if ( self . has_shuffle_size_bytes_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . shuffle_size_bytes_ ) <EOL> if ( self . has_callback_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( self . callback_ . ByteSizePartial ( ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_shuffle_name ( ) <EOL> self . clear_input ( ) <EOL> self . clear_output ( ) <EOL> self . clear_shuffle_size_bytes ( ) <EOL> self . clear_callback ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . shuffle_name_ ) <EOL> for i in xrange ( len ( self . input_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . input_ [ i ] . ByteSize ( ) ) <EOL> self . input_ [ i ] . OutputUnchecked ( out ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . output_ . ByteSize ( ) ) <EOL> self . output_ . OutputUnchecked ( out ) <EOL> out . putVarInt32 ( <NUM_LIT:32> ) <EOL> out . putVarInt64 ( self . shuffle_size_bytes_ ) <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . callback_ . ByteSize ( ) ) <EOL> self . callback_ . OutputUnchecked ( out ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_shuffle_name_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . shuffle_name_ ) <EOL> for i in xrange ( len ( self . input_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . input_ [ i ] . ByteSizePartial ( ) ) <EOL> self . input_ [ i ] . OutputPartial ( out ) <EOL> if ( self . has_output_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . output_ . ByteSizePartial ( ) ) <EOL> self . output_ . OutputPartial ( out ) <EOL> if ( self . has_shuffle_size_bytes_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:32> ) <EOL> out . putVarInt64 ( self . shuffle_size_bytes_ ) <EOL> if ( self . has_callback_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putVarInt32 ( self . callback_ . ByteSizePartial ( ) ) <EOL> self . callback_ . 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_shuffle_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_input ( ) . 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 . mutable_output ( ) . TryMerge ( tmp ) <EOL> continue <EOL> if tt == <NUM_LIT:32> : <EOL> self . set_shuffle_size_bytes ( 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_callback ( ) . 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_shuffle_name_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . shuffle_name_ ) ) <EOL> cnt = <NUM_LIT:0> <EOL> for e in self . input_ : <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_output_ : <EOL> res += prefix + "<STR_LIT>" <EOL> res += self . output_ . __str__ ( prefix + "<STR_LIT:U+0020>" , printElemNumber ) <EOL> res += prefix + "<STR_LIT>" <EOL> if self . has_shuffle_size_bytes_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt64 ( self . shuffle_size_bytes_ ) ) <EOL> if self . has_callback_ : <EOL> res += prefix + "<STR_LIT>" <EOL> res += self . callback_ . __str__ ( prefix + "<STR_LIT:U+0020>" , printElemNumber ) <EOL> res += prefix + "<STR_LIT>" <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> kshuffle_name = <NUM_LIT:1> <EOL> kinput = <NUM_LIT:2> <EOL> koutput = <NUM_LIT:3> <EOL> kshuffle_size_bytes = <NUM_LIT:4> <EOL> kcallback = <NUM_LIT:5> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> <NUM_LIT:2> : "<STR_LIT:input>" , <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:2> : ProtocolBuffer . Encoder . STRING , <EOL> <NUM_LIT:3> : ProtocolBuffer . Encoder . STRING , <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 ShuffleResponse ( ProtocolBuffer . ProtocolMessage ) : <EOL> def __init__ ( self , contents = None ) : <EOL> pass <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def Clear ( self ) : <EOL> pass <EOL> def OutputUnchecked ( self , out ) : <EOL> pass <EOL> def OutputPartial ( self , out ) : <EOL> pass <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <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> 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> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> } , <NUM_LIT:0> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> } , <NUM_LIT:0> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class GetShuffleStatusRequest ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_shuffle_name_ = <NUM_LIT:0> <EOL> shuffle_name_ = "<STR_LIT>" <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def shuffle_name ( self ) : return self . shuffle_name_ <EOL> def set_shuffle_name ( self , x ) : <EOL> self . has_shuffle_name_ = <NUM_LIT:1> <EOL> self . shuffle_name_ = x <EOL> def clear_shuffle_name ( self ) : <EOL> if self . has_shuffle_name_ : <EOL> self . has_shuffle_name_ = <NUM_LIT:0> <EOL> self . shuffle_name_ = "<STR_LIT>" <EOL> def has_shuffle_name ( self ) : return self . has_shuffle_name_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_shuffle_name ( ) ) : self . set_shuffle_name ( x . shuffle_name ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_shuffle_name_ != x . has_shuffle_name_ : return <NUM_LIT:0> <EOL> if self . has_shuffle_name_ and self . shuffle_name_ != x . shuffle_name_ : 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_shuffle_name_ ) : <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 . shuffle_name_ ) ) <EOL> return n + <NUM_LIT:1> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_shuffle_name_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthString ( len ( self . shuffle_name_ ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_shuffle_name ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . shuffle_name_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_shuffle_name_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . shuffle_name_ ) <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_shuffle_name ( 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_shuffle_name_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . shuffle_name_ ) ) <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> kshuffle_name = <NUM_LIT:1> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT>" , <EOL> } , <NUM_LIT:1> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> <NUM_LIT:1> : ProtocolBuffer . Encoder . STRING , <EOL> } , <NUM_LIT:1> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class GetShuffleStatusResponse ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_status_ = <NUM_LIT:0> <EOL> status_ = <NUM_LIT:0> <EOL> has_description_ = <NUM_LIT:0> <EOL> description_ = "<STR_LIT>" <EOL> def __init__ ( self , contents = None ) : <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def status ( self ) : return self . status_ <EOL> def set_status ( self , x ) : <EOL> self . has_status_ = <NUM_LIT:1> <EOL> self . status_ = x <EOL> def clear_status ( self ) : <EOL> if self . has_status_ : <EOL> self . has_status_ = <NUM_LIT:0> <EOL> self . status_ = <NUM_LIT:0> <EOL> def has_status ( self ) : return self . has_status_ <EOL> def description ( self ) : return self . description_ <EOL> def set_description ( self , x ) : <EOL> self . has_description_ = <NUM_LIT:1> <EOL> self . description_ = x <EOL> def clear_description ( self ) : <EOL> if self . has_description_ : <EOL> self . has_description_ = <NUM_LIT:0> <EOL> self . description_ = "<STR_LIT>" <EOL> def has_description ( self ) : return self . has_description_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> if ( x . has_status ( ) ) : self . set_status ( x . status ( ) ) <EOL> if ( x . has_description ( ) ) : self . set_description ( x . description ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if self . has_status_ != x . has_status_ : return <NUM_LIT:0> <EOL> if self . has_status_ and self . status_ != x . status_ : return <NUM_LIT:0> <EOL> if self . has_description_ != x . has_description_ : return <NUM_LIT:0> <EOL> if self . has_description_ and self . description_ != x . description_ : 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_status_ ) : <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 . status_ ) <EOL> if ( self . has_description_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . description_ ) ) <EOL> return n + <NUM_LIT:1> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> if ( self . has_status_ ) : <EOL> n += <NUM_LIT:1> <EOL> n += self . lengthVarInt64 ( self . status_ ) <EOL> if ( self . has_description_ ) : n += <NUM_LIT:1> + self . lengthString ( len ( self . description_ ) ) <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_status ( ) <EOL> self . clear_description ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> out . putVarInt32 ( <NUM_LIT:8> ) <EOL> out . putVarInt32 ( self . status_ ) <EOL> if ( self . has_description_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . description_ ) <EOL> def OutputPartial ( self , out ) : <EOL> if ( self . has_status_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:8> ) <EOL> out . putVarInt32 ( self . status_ ) <EOL> if ( self . has_description_ ) : <EOL> out . putVarInt32 ( <NUM_LIT> ) <EOL> out . putPrefixedString ( self . description_ ) <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_status ( d . getVarInt32 ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT> : <EOL> self . set_description ( 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_status_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatInt32 ( self . status_ ) ) <EOL> if self . has_description_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatString ( self . description_ ) ) <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> kstatus = <NUM_LIT:1> <EOL> kdescription = <NUM_LIT:2> <EOL> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> <NUM_LIT:1> : "<STR_LIT:status>" , <EOL> <NUM_LIT:2> : "<STR_LIT:description>" , <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 . 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 GetCapabilitiesRequest ( ProtocolBuffer . ProtocolMessage ) : <EOL> def __init__ ( self , contents = None ) : <EOL> pass <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> return <NUM_LIT:1> <EOL> def IsInitialized ( self , debug_strs = None ) : <EOL> initialized = <NUM_LIT:1> <EOL> return initialized <EOL> def ByteSize ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> return n <EOL> def Clear ( self ) : <EOL> pass <EOL> def OutputUnchecked ( self , out ) : <EOL> pass <EOL> def OutputPartial ( self , out ) : <EOL> pass <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <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> 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> _TEXT = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : "<STR_LIT>" , <EOL> } , <NUM_LIT:0> ) <EOL> _TYPES = _BuildTagLookupTable ( { <EOL> <NUM_LIT:0> : ProtocolBuffer . Encoder . NUMERIC , <EOL> } , <NUM_LIT:0> , ProtocolBuffer . Encoder . MAX_TYPE ) <EOL> _STYLE = """<STR_LIT>""" <EOL> _STYLE_CONTENT_TYPE = """<STR_LIT>""" <EOL> _PROTO_DESCRIPTOR_NAME = '<STR_LIT>' <EOL> class GetCapabilitiesResponse ( ProtocolBuffer . ProtocolMessage ) : <EOL> has_shuffle_available_ = <NUM_LIT:0> <EOL> shuffle_available_ = <NUM_LIT:0> <EOL> def __init__ ( self , contents = None ) : <EOL> self . filesystem_ = [ ] <EOL> if contents is not None : self . MergeFromString ( contents ) <EOL> def filesystem_size ( self ) : return len ( self . filesystem_ ) <EOL> def filesystem_list ( self ) : return self . filesystem_ <EOL> def filesystem ( self , i ) : <EOL> return self . filesystem_ [ i ] <EOL> def set_filesystem ( self , i , x ) : <EOL> self . filesystem_ [ i ] = x <EOL> def add_filesystem ( self , x ) : <EOL> self . filesystem_ . append ( x ) <EOL> def clear_filesystem ( self ) : <EOL> self . filesystem_ = [ ] <EOL> def shuffle_available ( self ) : return self . shuffle_available_ <EOL> def set_shuffle_available ( self , x ) : <EOL> self . has_shuffle_available_ = <NUM_LIT:1> <EOL> self . shuffle_available_ = x <EOL> def clear_shuffle_available ( self ) : <EOL> if self . has_shuffle_available_ : <EOL> self . has_shuffle_available_ = <NUM_LIT:0> <EOL> self . shuffle_available_ = <NUM_LIT:0> <EOL> def has_shuffle_available ( self ) : return self . has_shuffle_available_ <EOL> def MergeFrom ( self , x ) : <EOL> assert x is not self <EOL> for i in xrange ( x . filesystem_size ( ) ) : self . add_filesystem ( x . filesystem ( i ) ) <EOL> if ( x . has_shuffle_available ( ) ) : self . set_shuffle_available ( x . shuffle_available ( ) ) <EOL> def Equals ( self , x ) : <EOL> if x is self : return <NUM_LIT:1> <EOL> if len ( self . filesystem_ ) != len ( x . filesystem_ ) : return <NUM_LIT:0> <EOL> for e1 , e2 in zip ( self . filesystem_ , x . filesystem_ ) : <EOL> if e1 != e2 : return <NUM_LIT:0> <EOL> if self . has_shuffle_available_ != x . has_shuffle_available_ : return <NUM_LIT:0> <EOL> if self . has_shuffle_available_ and self . shuffle_available_ != x . shuffle_available_ : 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_shuffle_available_ ) : <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 += <NUM_LIT:1> * len ( self . filesystem_ ) <EOL> for i in xrange ( len ( self . filesystem_ ) ) : n += self . lengthString ( len ( self . filesystem_ [ i ] ) ) <EOL> return n + <NUM_LIT:2> <EOL> def ByteSizePartial ( self ) : <EOL> n = <NUM_LIT:0> <EOL> n += <NUM_LIT:1> * len ( self . filesystem_ ) <EOL> for i in xrange ( len ( self . filesystem_ ) ) : n += self . lengthString ( len ( self . filesystem_ [ i ] ) ) <EOL> if ( self . has_shuffle_available_ ) : <EOL> n += <NUM_LIT:2> <EOL> return n <EOL> def Clear ( self ) : <EOL> self . clear_filesystem ( ) <EOL> self . clear_shuffle_available ( ) <EOL> def OutputUnchecked ( self , out ) : <EOL> for i in xrange ( len ( self . filesystem_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filesystem_ [ i ] ) <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putBoolean ( self . shuffle_available_ ) <EOL> def OutputPartial ( self , out ) : <EOL> for i in xrange ( len ( self . filesystem_ ) ) : <EOL> out . putVarInt32 ( <NUM_LIT:10> ) <EOL> out . putPrefixedString ( self . filesystem_ [ i ] ) <EOL> if ( self . has_shuffle_available_ ) : <EOL> out . putVarInt32 ( <NUM_LIT:16> ) <EOL> out . putBoolean ( self . shuffle_available_ ) <EOL> def TryMerge ( self , d ) : <EOL> while d . avail ( ) > <NUM_LIT:0> : <EOL> tt = d . getVarInt32 ( ) <EOL> if tt == <NUM_LIT:10> : <EOL> self . add_filesystem ( d . getPrefixedString ( ) ) <EOL> continue <EOL> if tt == <NUM_LIT:16> : <EOL> self . set_shuffle_available ( d . getBoolean ( ) ) <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> cnt = <NUM_LIT:0> <EOL> for e in self . filesystem_ : <EOL> elm = "<STR_LIT>" <EOL> if printElemNumber : elm = "<STR_LIT>" % cnt <EOL> res += prefix + ( "<STR_LIT>" % ( elm , self . DebugFormatString ( e ) ) ) <EOL> cnt += <NUM_LIT:1> <EOL> if self . has_shuffle_available_ : res += prefix + ( "<STR_LIT>" % self . DebugFormatBool ( self . shuffle_available_ ) ) <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> kfilesystem = <NUM_LIT:1> <EOL> kshuffle_available = <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 . STRING , <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> if _extension_runtime : <EOL> pass <EOL> __all__ = [ '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' , '<STR_LIT>' ] </s>
