← Back
Editing: python_message.pyo
� ���hc @ s! d Z d Z d d l m Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z e j Z d Z d e f d � � YZ d � Z d � Z d � Z d � Z! d � Z" d � Z# d � Z$ d � Z% d � Z& d � Z' d � Z( d � Z) d � Z* d! � Z+ d" � Z, d# � Z- d$ � Z. d% � Z/ d& � Z0 d' � Z1 d( � Z2 d) � Z3 d* � Z4 d+ Z5 d, Z6 d- � Z7 d. � Z8 d/ � Z9 d0 � Z: d1 � Z; d2 � Z< d3 � Z= d4 � Z> d5 � Z? d6 � Z@ d7 � ZA d8 � ZB d9 � ZC d: � ZD d; � ZE d< � ZF d= � ZG d> � ZH d? � ZI d@ � ZJ dA � ZK dB � ZL dC � ZM dD eN f dE � � YZO dF eO f dG � � YZP dH eN f dI � � YZQ d S(J s Contains a metaclass and helper functions used to create protocol message classes from Descriptor objects at runtime. Recall that a metaclass is the "type" of a class. (A class is to a metaclass what an instance is to a class.) In this case, we use the GeneratedProtocolMessageType metaclass to inject all the useful functionality into the classes output by the protocol compiler at compile-time. The upshot of all this is that the real implementation details for ALL pure-Python protocol buffers are *here in this file*. s# robinson@google.com (Will Robinson)i����( t BytesION( t api_implementation( t containers( t decoder( t encoder( t enum_type_wrapper( t message_listener( t type_checkers( t well_known_types( t wire_format( t descriptor( t message( t text_formats google.protobuf.Anyt GeneratedProtocolMessageTypec B s& e Z d Z d Z d � Z d � Z RS( sQ Metaclass for protocol message classes created at runtime from Descriptors. We add implementations for all methods described in the Message class. We also create properties to allow getting/setting all fields in the protocol message. Finally, we create slots to prevent users from accidentally "setting" nonexistent fields in the protocol message, which then wouldn't get serialized / deserialized properly. The protocol compiler currently uses this metaclass to create protocol message classes at runtime. Clients can also manually create their own classes at runtime, as in this example: mydescriptor = Descriptor(.....) factory = symbol_database.Default() factory.pool.AddDescriptor(mydescriptor) MyProtoClass = factory.GetPrototype(mydescriptor) myproto_instance = MyProtoClass() myproto.foo_field = 23 ... t DESCRIPTORc C s~ | t j } | j t j k r9 | t j | j f 7} n t | | � t | | � t t | � } | j | | | | � } | S( s Custom allocation for runtime-generated class types. We override __new__ because this is apparently the only place where we can meaningfully set __slots__ on the class we're creating(?). (The interplay between metaclasses and slots is not very well-documented). Args: name: Name of the class (ignored, but required by the metaclass protocol). bases: Base classes of the class we're constructing. (Should be message.Message). We ignore this field, but it's required by the metaclass protocol dictionary: The class dictionary of the class we're constructing. dictionary[_DESCRIPTOR_KEY] must contain a Descriptor object describing this protocol message type. Returns: Newly-allocated class. ( R t _DESCRIPTOR_KEYt full_nameR t WKTBASESt& _AddClassAttributesForNestedExtensionst _AddSlotst supert __new__( t clst namet basest dictionaryR t superclasst new_class( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR i s c C s� | t j } i | _ | j rP | j � j rP t j | � d f | j t j <n x | j D] } t | | � qZ W| | _ t | | � t | | � t | | � t | | � t | � t | | � t | | � t t | � } | j | | | � d S( s� Here we perform the majority of our work on the class. We add enum getters, an __init__ method, implementations of all Message methods, and properties for all fields in the protocol type. Args: name: Name of the class (ignored, but required by the metaclass protocol). bases: Base classes of the class we're constructing. (Should be message.Message). We ignore this field, but it's required by the metaclass protocol dictionary: The class dictionary of the class we're constructing. dictionary[_DESCRIPTOR_KEY] must contain a Descriptor object describing this protocol message type. N( R R t _decoders_by_tagt has_optionst GetOptionst message_set_wire_formatR t MessageSetItemDecodert Nonet MESSAGE_SET_ITEM_TAGt fieldst _AttachFieldHelperst _concrete_classt _AddEnumValuest _AddInitMethodt _AddPropertiesForFieldst _AddPropertiesForExtensionst _AddStaticMethodst _AddMessageMethodst _AddPrivateHelperMethodsR t __init__( R R R R R t fieldR ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR- � s" " ( t __name__t __module__t __doc__R R R- ( ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR N s c C s | S( s Returns the name of the public property attribute which clients can use to get and (in some cases) set the value of a protocol message field. Args: proto_field_name: The protocol message field name, exactly as it appears (or would appear) in a .proto file. ( ( t proto_field_name( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _PropertyName� s c C s� t | t � s" t d | � � n | j sA t d | j � � n | j s` t d | j � � n | j | j k r� t d | j | j j | j j f � � n d S( s0 Verify that the given extension handle is valid.s3 HasExtension() expects an extension handle, got: %ss "%s" is not an extension.s" "%s" is missing a containing_type.sK Extension "%s" extends message type "%s", but this message is of type "%s".N( t isinstancet _FieldDescriptort KeyErrort is_extensionR t containing_typeR ( R t extension_handle( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _VerifyExtensionHandle� s c C s) d d d d d d d d d g | d <d S( s Adds a __slots__ entry to dictionary, containing the names of all valid attributes for this message type. Args: message_descriptor: A Descriptor instance describing this message type. dictionary: Class dictionary to which we'll add a '__slots__' entry. t _cached_byte_sizet _cached_byte_size_dirtyt _fieldst _unknown_fieldst _is_present_in_parentt _listenert _listener_for_childrent __weakref__t _oneofst __slots__N( ( t message_descriptorR ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR � s c C sI | j oH | j j oH | j j � j oH | j t j k oH | j t j k S( N( R7 R8 R R R t typeR5 t TYPE_MESSAGEt labelt LABEL_OPTIONAL( R. ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _IsMessageSetExtension� s c C s. | j t j k o- | j j o- | j j � j S( N( RF R5 RG t message_typeR R t map_entry( R. ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _IsMapField s c C s | j j d } | j t j k S( Nt value( RK t fields_by_namet cpp_typeR5 t CPPTYPE_MESSAGE( R. t value_type( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _IsMessageMapField s c s� � j t j k � � o' t j � j � } | s9 t } ng � j j d k rf � j o` � j � j } n: � j o� � j � j d � o� � j � j t k } | } t � � � � r� t j � � } t j � t � � � } nq t � � rt j � j � } t j � j � } n> t j � j � j � | � } t j � j � j � | � } | � _ | � _ t � � � _ � � � � f d � } | t j � j t � � r�t j � j � r�| t j t � n d S( Nt proto2t packedc s� t j � j | � } � j } | t j k rH t j � � rH t j } n d } � j d k rf � } n � r� t � � } t j � t � � | � } n% t j | � j � | � � j � } | | f � j | <d S( N( R t TagBytest numberRF R5 t TYPE_ENUMR t SupportsOpenEnumst TYPE_INT32R! t containing_oneofRS R t MapDecodert _GetInitializeDefaultForMapt TYPE_TO_DECODERt _default_constructorR ( t wiretypet is_packedt tag_bytest decode_typet oneof_descriptort is_message_mapt field_decoder( R t field_descriptort is_map_entryt is_repeated( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt AddDecoder4 s" ( RH R5 t LABEL_REPEATEDR t IsTypePackableRF t FalseR8 t syntaxR R RU t HasFieldRM R t MapEncodert MapSizerRS RJ t MessageSetItemEncoderRW t MessageSetItemSizerR t TYPE_TO_ENCODERt TYPE_TO_SIZERt _encodert _sizert _DefaultValueConstructorForFieldR_ t FIELD_TYPE_TO_WIRE_TYPEt WIRETYPE_LENGTH_DELIMITEDt True( R Rg t is_packableRa t has_packed_falset field_encodert sizerRj ( ( R Rg Rh Ri sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR$ sB c C s4 | j } x$ | j � D] \ } } | | | <q Wd S( N( t extensions_by_namet items( R R t extension_dictt extension_namet extension_field( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR U s c C s^ xW | j D]L } t | | j t j | � � x' | j D] } t | | j | j � q6 Wq Wd S( s Sets class-level attributes for all enum fields defined in this message. Also exporting a class-level object that can name enum values. Args: descriptor: Descriptor object for this message type. cls: Class we're constructing for this message type. N( t enum_typest setattrR R t EnumTypeWrappert valuesRW ( R R t enum_typet enum_value( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR& \ s c s� � j t j k r( t d � j � � n � j j } t j | d � � | d � t � � rv � � � f d � } | St j � � � � � � f d � } | Sd S( Ns& map_entry set on non-repeated field %st keyRN c s t j | j � j � � j � S( N( R t MessageMapRA RK ( R ( R. t key_checkert value_field( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt MakeMessageMapDefaultt s c s t j | j � � � j � S( N( R t ScalarMapRA RK ( R ( R. R� t value_checker( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt MakePrimitiveMapDefault{ s ( RH R5 Rk t ValueErrorR RK RO R t GetTypeCheckerRS ( R. RO R� R� ( ( R. R� R� R� sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR] k s c s� t � � r t � � S� j t j k r� � j rV � j g k rV t d � j � � n � j t j k r� � j � � f d � } | St j � � � � f d � } | Sn � j t j k r� � j � � � f d � } | S� f d � } | S( s� Returns a function which returns a default value for a field. Args: field: FieldDescriptor object for this field. The returned function has one argument: message: Message instance containing this field, or a weakref proxy of same. That function in turn returns a default value for this field. The default value may refer back to |message| via a weak reference. s/ Repeated field default value not empty list: %sc s t j | j � j � S( N( R t RepeatedCompositeFieldContainerRA RK ( R ( R. ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt MakeRepeatedMessageDefault� s c s t j | j � � S( N( R t RepeatedScalarFieldContainerRA ( R ( t type_checker( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt MakeRepeatedScalarDefault� s c s> � j � } | j � j d k r0 t | � � n | j � | S( N( R% t _SetListenerR[ R! t _OneofListenerRA ( R t result( R. RK ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt MakeSubMessageDefault� s c s � j S( N( t default_value( R ( R. ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt MakeScalarDefault� s ( RM R] RH R5 Rk t has_default_valueR� R� RP RQ RK R R� ( R. R� R� R� R� ( ( R. RK R� sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyRx � s& c C s� t j � d } t | j � d k rY t | � t k rY t d t | � | | f � } n t j t | � | t j � d � d S( sC Re-raise the currently-handled TypeError with the field name added.i s %s for field %s.%si N( t syst exc_infot lent argsRF t TypeErrort strt sixt reraise( t message_namet field_namet exc( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _ReraiseTypeErrorWithFieldName� s '"c s: d � � � � f d � } d | _ d | _ | | _ d S( s Adds an __init__ method to cls.c S sX t | t j � rT y | j | j SWqT t k rP t d | j | f � � qT Xn | S( s Convert a string or integer enum value to an integer. If the value is a string, it is converted to the enum value in enum_type with the same name. If the value is not a string, it's returned as-is. (No conversion or bounds-checking is done.) s Enum type %s: unknown label "%s"( R4 R� t string_typest values_by_nameRW R6 R� R ( R� RN ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _GetIntegerEnumValue� s c s� d | _ t | � d k | _ i | _ i | _ d | _ t | _ t j � | _ t | � | _ xs| j � D]e\ } } t � | � } | d k r� t d � j | f � � n | d k r� qm n | j t j k r�| j | � } | j t j k r�t | � rFt | � r6x3 | D] } | | j | | � qWq�| j | � q�x� | D]8 } t | t � rr| j | � qM| j � j | � qMWnG | j t j k r�g | D] } � | j | � ^ q�} n | j! | � | | j | <qm | j t j k rs| j | � } | } t | t � r.| j" j# | � } n y | j | � Wn! t k rbt$ � j | � n X| | j | <qm | j t j k r�� | j | � } n y t% | | | � Wqm t k r�t$ � j | � qm Xqm Wd S( Ni s, %s() got an unexpected keyword argument '%s'( (& R; R� R< R= RC R> Rm R? t message_listener_modt NullMessageListenerR@ t _ListenerRA R� t _GetFieldByNameR! R� R RH R5 Rk R_ RP RQ RM RS t MergeFromt updateR4 t dictt addt CPPTYPE_ENUMR� t extendRK R% R� R� ( t selft kwargsR� t field_valueR. t copyR� t valt new_val( R� RE ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt init� s` % N( R! R0 R1 R- ( RE R R� ( ( R� RE sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR' � s = c C s@ y | j | SWn* t k r; t d | j | f � � n Xd S( s� Returns a field descriptor by field name. Args: message_descriptor: A Descriptor describing all fields in message. field_name: The name of the field to retrieve. Returns: The field descriptor associated with the field name. s& Protocol message %s has no "%s" field.N( RO R6 R� R ( RE R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� s c C sC x | j D] } t | | � q W| j r? t d � � | _ n d S( s= Adds properties for all fields in this protocol message type.c S s t | � S( N( t _ExtensionDict( R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt <lambda>/ t N( R# t _AddPropertiesForFieldt is_extendablet propertyt Extensions( R R R. ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR( ' s c C s{ | j j � d } t | | | j � | j t j k rH t | | � n/ | j t j k rj t | | � n t | | � d S( s# Adds a public property for a protocol message field. Clients can use this property to get and (in the case of non-repeated scalar fields) directly set the value of a protocol message field. Args: field: A FieldDescriptor for this field. cls: The class we're constructing. t _FIELD_NUMBERN( R t upperR� RW RH R5 Rk t _AddPropertiesForRepeatedFieldRP RQ t* _AddPropertiesForNonRepeatedCompositeFieldt' _AddPropertiesForNonRepeatedScalarField( R. R t constant_name( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� 2 s c sv � j � t � � } � f d � } d | _ d � | _ � f d � } d � } t | | t | | d | �� d S( s Adds a public property for a "repeated" protocol message field. Clients can use this property to get the value of the field, which will be either a _RepeatedScalarFieldContainer or _RepeatedCompositeFieldContainer (see below). Note that when clients add values to these containers, we perform type-checking in the case of repeated scalar fields, and we also set any necessary "has" bits as a side-effect. Args: field: A FieldDescriptor for this field. cls: The class we're constructing. c sI | j j � � } | d k rE � j | � } | j j � | � } n | S( N( R= t getR! R_ t setdefault( R� R� ( R. ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt getter\ s s Getter for %s.c s t d � � � d S( NsI Assignment not allowed to repeated field "%s" in protocol message object.( t AttributeError( R� t new_value( R2 ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt settero s s/ Magic attribute generated for "%s" proto field.t docN( R R3 R! R0 R1 R� R� ( R. R t property_nameR� R� R� ( ( R. R2 sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� K s c s� � j } t | � } t j � � � � j � t � } � j j d k } � � f d � } d | _ d | | _ | o} � j � � � � f d � � � j r� � � f d � } n � } d | _ d | | _ d | } t | | t | | d | �� d S( s� Adds a public property for a nonrepeated, scalar protocol message field. Clients can use this property to get and directly set the value of the field. Note that when the client sets the value of a field by using this property, all necessary "has" bits are set as a side-effect, and we also perform type-checking. Args: field: A FieldDescriptor for this field. cls: The class we're constructing. t proto3c s | j j � � � S( N( R= R� ( R� ( R� R. ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� � s s Getter for %s.c sY � j | � } � r2 | r2 | j j � d � n | | j � <| j sU | j � n d S( N( t CheckValueR= t popR! R< t _Modified( R� R� ( t clear_when_set_to_defaultR. R� ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt field_setter� s c s � | | � | j � � d S( N( t _UpdateOneofState( R� R� ( R. R� ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� � s s Setter for %s.s/ Magic attribute generated for "%s" proto field.R� N( R R3 R R� R� t setR8 Rn R! R0 R1 R[ R� R� ( R. R R2 R� t valid_valuest is_proto3R� R� R� ( ( R� R� R. R� R� sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� w s$ c sv � j � t � � } � f d � } d | _ d � | _ � f d � } d � } t | | t | | d | �� d S( sN Adds a public property for a nonrepeated, composite protocol message field. A composite field is a "group" or "message" field. Clients can use this property to get the value of the field, but cannot assign to the property directly. Args: field: A FieldDescriptor for this field. cls: The class we're constructing. c sI | j j � � } | d k rE � j | � } | j j � | � } n | S( N( R= R� R! R_ R� ( R� R� ( R. ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� � s s Getter for %s.c s t d � � � d S( NsJ Assignment not allowed to composite field "%s" in protocol message object.( R� ( R� R� ( R2 ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� � s s/ Magic attribute generated for "%s" proto field.R� N( R R3 R! R0 R1 R� R� ( R. R R� R� R� R� ( ( R. R2 sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� � s c C s� | j } x= | j � D]/ \ } } | j � d } t | | | j � q W| j d k r� | j j } | j | | _ | j | | _ n d S( s= Adds properties for all fields in this protocol message type.R� N( R� R� R� R� RW t fileR! t poolt _extensions_by_numbert _extensions_by_name( R R R� R� R� R� R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR) � s c s@ � f d � } t | � � _ � f d � } t | � � _ d S( Nc s3 � j | _ � j j j j | � t � | � d S( N( R R8 R� R� t AddExtensionDescriptorR$ ( R9 ( R ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt RegisterExtension� s c s � � } | j | � | S( N( t MergeFromString( t sR ( R ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt FromString� s ( t staticmethodR� R� ( R R� R� ( ( R sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR* � s c C sM | d j t j k r$ t | d � S| d j t j k rE | d j St Sd S( s� Given a (FieldDescriptor, value) tuple from _fields, return true if the value should be included in the list returned by ListFields().i i N( RH R5 Rk t boolRP RQ R? R{ ( t item( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _IsPresent� s c C s d � } | | _ d S( s Helper for _AddMessageMethods().c S sE g | j j � D] } t | � r | ^ q } | j d d � � | S( NR� c S s | d j S( Ni ( RW ( R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� R� ( R= R� R� t sort( R� R� t all_fields( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt ListFields s .N( R� ( RE R R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddListFieldsMethod s s: Protocol message has no non-repeated submessage field "%s"s/ Protocol message has no non-repeated field "%s"c s� | j d k } | r t n t � i � x^ | j D]S } | j t j k rO q1 n | rw | j t j k rw | j rw q1 n | � | j <q1 W| s� x! | j D] } | � | j <q� Wn � � � f d � � � | _ d S( s Helper for _AddMessageMethods().R� c s� y � | } Wn! t k r1 t � | � � n Xt | t j � rw y � | | j | j � SWq� t k rs t SXnD | j t j k r� | j j | � } | d k o� | j S| | j k Sd S( N( R6 R� R4 t descriptor_modt OneofDescriptorRC R Rm RP R5 RQ R= R� R! R? ( R� R� R. RN ( Ro t error_msgt hassable_fields( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyRo ( s N( Rn t _Proto3HasErrort _Proto2HasErrorR# RH R5 Rk RP RQ R[ R t oneofsRo ( RE R R� R. t oneof( ( Ro R� R� sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddHasFieldMethod s c s � f d � } | | _ d S( s Helper for _AddMessageMethods().c s y � j | } Wnr t k r� y4 � j | } | | j k rP | j | } n d SWq� t k r� t d � j | f � � q� Xn X| | j k r� t | j | d � r� | j | j � n | j | =| j j | j d � | k r� | j | j =q� n | j � d S( Ns( Protocol message %s() has no "%s" field.t InvalidateIterators( RO R6 t oneofs_by_nameRC R� R R= t hasattrR� R� R[ R! R� ( R� R� R. ( RE ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt ClearField? s$ N( R� ( RE R R� ( ( RE sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddClearFieldMethod= s !c C s d � } | | _ d S( s Helper for _AddMessageMethods().c S s7 t | | � | | j k r) | j | =n | j � d S( N( R: R= R� ( R� R9 ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt ClearExtensione s N( R� ( R R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddClearExtensionMethodc s c C s d � } | | _ d S( s Helper for _AddMessageMethods().c S s} t | | � | j t j k r5 t d | j � � n | j t j k rl | j j | � } | d k ok | j S| | j k Sd S( Ns "%s" is repeated.( R: RH R5 Rk R6 R RP RQ R= R� R! R? ( R� R9 RN ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt HasExtensionq s N( R ( R R ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddHasExtensionMethodo s c C s� d d l m } | j � } | j } | s/ d S| j d � d } | j j | � } | d k rd d S| j | � } | � } | j | j � | S( st Unpacks Any message and returns the unpacked message. This internal method is different from public Any Unpack method which takes the target message as argument. _InternalUnpackAny method does not have target message type and need to find the message type in descriptor pool. Args: msg: An Any message to be unpacked. Returns: The unpacked message. i����( t symbol_databaset /N( t google.protobufR t Defaultt type_urlR! t splitR� t FindMessageTypeByNamet GetPrototypet ParseFromStringRN ( t msgR t factoryR t type_nameR t message_classR ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _InternalUnpackAny} s c C s d � } | | _ d S( s Helper for _AddMessageMethods().c S s� t | t j � s% | j | j k r) t S| | k r9 t S| j j t k r| t | � } t | � } | r| | r| | | k Sn | j � | j � k s� t St | j � } | j � t | j � } | j � | | k S( N( R4 t message_modt MessageR Rm R{ R t _AnyFullTypeNameR R� t listR> R� ( R� t othert any_at any_bt unknown_fieldst other_unknown_fields( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt __eq__� s" N( R ( RE R R ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddEqualsMethod� s c C s d � } | | _ d S( s Helper for _AddMessageMethods().c S s t j | � S( N( R t MessageToString( R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt __str__� s N( R ( RE R R ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddStrMethod� s c C s d � } | | _ d S( s Helper for _AddMessageMethods().c S s t j | � S( N( R R ( R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt __repr__� s N( R ( RE R R ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddReprMethod� s c C s d � } | | _ d S( s Helper for _AddMessageMethods().c S s t j | d t �j d � S( Nt as_utf8s utf-8( R R R{ t decode( R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt __unicode__� s N( R# ( t unused_message_descriptorR R# ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddUnicodeMethod� s c C sI y t j | } | | | � SWn$ t k rD t j d | � � n Xd S( s Returns the number of bytes needed to serialize a non-repeated element. The returned byte count includes space for tag information and any other additional space associated with serializing value. Args: value: Value we're serializing. field_number: Field number of this value. (Since the field number is stored as part of a varint-encoded tag, this has an impact on the total bytes required to serialize the value). field_type: The type of the field. One of the TYPE_* constants within FieldDescriptor. s Unrecognized field type: %dN( R t TYPE_TO_BYTE_SIZE_FNR6 R t EncodeError( RN t field_numbert field_typet fn( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _BytesForNonRepeatedElement� s c C s d � } | | _ d S( s Helper for _AddMessageMethods().c S s� | j s | j Sd } | j } | j � j rg | j d j | j � } | | j d j | j � 7} nd x- | j � D] \ } } | | j | � 7} qt Wx1 | j D]& \ } } | t | � t | � 7} q� W| | _ t | _ t | j _ | S( Ni R� RN ( R< R; R R RL RO Rw R� RN R� R> R� Rm RA t dirty( R� t sizeR Rg R� Rb t value_bytes( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt ByteSize� s N( R/ ( RE R R/ ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddByteSizeMethod� s c C s d � } | | _ d S( s Helper for _AddMessageMethods().c [ sP g } | j � sC t j d | j j d j | j � � f � � n | j | � S( Ns) Message %s is missing required fields: %st ,( t IsInitializedR R' R R t joint FindInitializationErrorst SerializePartialToString( R� R� t errors( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt SerializeToString s (N( R7 ( RE R R7 ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddSerializeToStringMethod s c C s+ d � } | | _ d d � } | | _ d S( s Helper for _AddMessageMethods().c [ s& t � } | j | j | � | j � S( N( R t _InternalSerializet writet getvalue( R� R� t out( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR5 s c S s� | d k r t j � } n t | � } | j } | j � j r| | j d j | | j | � | j d j | | j | � n^ x- | j � D] \ } } | j | | | � q� Wx+ | j D] \ } } | | � | | � q� Wd S( NR� RN ( R! R t) IsPythonDefaultSerializationDeterministicR� R R RL RO Rv R� RN R� R> ( R� t write_bytest deterministicR Rg R� Rb R. ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt InternalSerialize s N( R5 R! R9 ( RE R R5 R@ ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt" _AddSerializePartialToStringMethod s c sa d � } | | _ t j � t j � | j � | j d k � � � � � f d � } | | _ d S( s Helper for _AddMessageMethods().c S s� t | � } y1 | j | d | � | k r< t j d � � n WnJ t t f k re t j d � � n% t j k r� } t j | � � n X| S( Ni s Unexpected end-group tag.s Truncated message.( R� t _InternalParseR t DecodeErrort IndexErrorR� t structt error( R� t serializedt lengtht e( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� 8 s R� c s | j � | j } | j } x� | | k r� | | � \ } } � j | d � \ } } | d k r� | } � | | | | � } | d k r� | S� s� t j � r� | s� g } | _ n | j | | | | !f � n | } q | | | | | | � } | r | j | � q q W| S( Ni����( NN( R� R= R> R� R! R t& GetPythonProto3PreserveUnknownsDefaultt appendR� ( R� t buffert post endt field_dictt unknown_field_listRb t new_posRf t field_desct value_start_pos( t decoders_by_tagR� t local_ReadTagt local_SkipField( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt InternalParseL s, N( R� R t ReadTagt SkipFieldR Rn RB ( RE R R� RW ( ( RT R� RU RV sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddMergeFromStringMethod6 s c se g | j D] } | j t j k r | ^ q � d � f d � } | | _ � f d � } | | _ d S( s[ Adds the IsInitialized and FindInitializationError methods to the protocol message class.c s` xf � D]^ } | | j k s? | j t j k r | j | j r | d k ra | j | j � � n t Sq Wx� t | j j � � D]� \ } } | j t j k r | j t j k r| j j r� | j j � j r� q n x | D]8 } | j � s� | d k r| j | j � � n t Sq� WqX| j rX| j � rX| d k rQ| j | j � � n t Sq q Wt S( s Checks if all required fields of a message are set. Args: errors: A list which, if provided, will be populated with the field paths of all missing required fields. Returns: True iff the specified message has all required fields set. N( R= RP R5 RQ R? R! R� R4 Rm R R� RH Rk RK R R RL R2 R{ ( R� R6 R. RN t element( t required_fields( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR2 n s. " c s� g } x3 � D]+ } | j | j � s | j | j � q q Wxw| j � D]i\ } } | j t j k rI | j r� d | j } n | j } t | � r� t | � r�xX | D]M } | | } d | | f } | j � } | g | D] } | | ^ q� 7} q� Wq�q�| j t j k rxx� t t | � � D]M } | | } d | | f } | j � } | g | D] } | | ^ qZ7} q$Wq�| d } | j � } | g | D] } | | ^ q�7} qI qI W| S( s� Finds required fields which are not initialized. Returns: A list of strings. Each string is a path to an uninitialized field from the top-level message, e.g. "foo.bar[5].baz". s (%s)s %s[%s].s %s[%d].t .( Ro R RK R� RP R5 RQ R7 R RM RS R4 RH Rk t rangeR� ( R� R6 R. RN R R� R[ t prefixt sub_errorsRF t i( R\ ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR4 � s6 ( ( (N( R# RH R5 t LABEL_REQUIREDR! R2 R4 ( RE R R. R2 R4 ( ( R\ sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddIsInitializedMethodg s ' ,c s4 t j � t j � � � � f d � } | � _ d S( Nc sz t | � � s1 t d � j | j j f � � n | j � | j } x� | j j � D]� \ } } | j � k r� | j | � } | d k r� | j | � } | | | <n | j | � qT | j � k r| j r>| j | � } | d k r| j | � } | | | <n | j | � q>qT | | j | <| j rT | j | � qT qT W| j rv| j s`g | _ n | j j | j � n d S( NsL Parameter to MergeFrom() must be instance of same class: expected %s got %s.( R4 R� R/ t __class__R� R= R� RH R� R! R_ R� RP R? R[ R� R> R� ( R� R R# R. RN R� ( RQ Rk R ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� � s6 ( R5 Rk RQ R� ( R R� ( ( RQ Rk R sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddMergeFromMethod� s %c s � f d � } | | _ d S( Nc sw y � j | } Wn! t k r4 t d | � � n X| j j | d � } | d k ro | j | j � ro | j Sd Sd S( sD Returns the name of the currently set field inside a oneof, or None.s) Protocol message has no oneof "%s" field.N( R� R6 R� RC R� R! Ro R ( R� t oneof_nameR. t nested_field( RE ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt WhichOneof� s ( Rh ( RE R Rh ( ( RE sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddWhichOneofMethod� s c C s d � } | | _ d S( Nc S s t | � d | j � f S( N( ( RF t __getstate__( R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt __reduce__ s ( Rk ( R Rk ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _AddReduceMethod s c C s) i | _ d | _ i | _ | j � d S( N( ( R= R> RC R� ( R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _Clear s c C sy g | _ xi | j � D][ \ } } | j t j k r | j t j k rd x% | D] } | j � qM Wqq | j � q q Wd S( N( R> R� RP R5 RQ RH Rk t DiscardUnknownFields( R� R. RN t sub_message( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _DiscardUnknownFields s c C s+ | d k r t j � | _ n | | _ d S( N( R! R� R� R@ ( R� t listener( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� s c C s� t | | � t | | � t | | � | j rG t | � t | � n t | | � t | | � t | | � t | | � t | | � t | | � t | | � t | | � t | | � t | � t | | � t | � t | _ t | _ t | _ d S( s3 Adds implementations of all Message methods to cls.N( R� R� R� R� R R R R R R% R0 R8 RA RZ Rc Re Ri Rl Rm t ClearRp Rn R� ( RE R ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR+ $ s* c C s1 d � } d � } | | _ | | _ | | _ d S( s5 Adds implementation of private helper methods to cls.c S s; | j s7 t | _ t | j _ t | _ | j j � n d S( sw Sets the _cached_byte_size_dirty bit to true, and propagates this to our listener iff this was a state change. N( R< R{ RA R, R? R@ t Modified( R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyRs A s c S sE | j j | j | � } | | k rA | j | =| | j | j <n d S( s� Sets field as the active field in its containing oneof. Will also delete currently active field in the oneof, if it is different from the argument. Does not mark the message as modified. N( RC R� R[ R= ( R� R. t other_field( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� P s N( R� t SetInParentR� ( RE R Rs R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR, > s R� c B s e Z d Z d � Z d � Z RS( s0 MessageListener implementation that a parent message registers with its child message. In order to support semantics like: foo.bar.baz.qux = 23 assert foo.HasField('bar') ...child objects must have back references to their parents. This helper class is at the heart of this support. c C s= t | t j � r | | _ n t j | � | _ t | _ d S( s� Args: parent_message: The message whose _Modified() method we should call when we receive Modified() messages. N( R4 t weakreft ProxyTypet _parent_message_weakreft proxyRm R, ( R� t parent_message( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR- n s c C s6 | j r d Sy | j j � Wn t k r1 n Xd S( N( R, Rx R� t ReferenceError( R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyRs � s ( R/ R0 R1 R- Rs ( ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� ` s R� c B s e Z d Z d � Z d � Z RS( sC Special listener implementation for setting composite oneof fields.c C s# t t | � j | � | | _ d S( s� Args: parent_message: The message whose _Modified() method we should call when we receive Modified() messages. field: The descriptor of the field being set in the parent message. N( R R� R- t _field( R� Rz R. ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR- � s c C sB y* | j j | j � t t | � j � Wn t k r= n Xd S( sE Also updates the state of the containing oneof in the parent message.N( Rx R� R| R R� Rs R{ ( R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyRs � s ( R/ R0 R1 R- Rs ( ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� � s R� c B sV e Z d Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s� Dict-like container for supporting an indexable "Extensions" field on proto instances. Note that in all cases we expect extension handles to be FieldDescriptors. c C s | | _ d S( sM extended_message: Message instance for which we are the Extensions dict. N( t _extended_message( R� t extended_message( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR- � s c C s� t | j | � | j j j | � } | d k r5 | S| j t j k r\ | j | j � } nV | j t j k r� | j j � } y | j | j j � Wq� t k r� q� Xn | j S| j j j | | � } | S( s8 Returns the current value of the given extension handle.N( R: R} R= R� R! RH R5 Rk R_ RP RQ RK R% R� RA R{ R� R� ( R� R9 R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt __getitem__� s c C s� t | | j � s t S| j j � } | j j � } g | D] } | j r; | ^ q; } g | D] } | j r] | ^ q] } | | k S( N( R4 Rd Rm R} R� R7 ( R� R t my_fieldst other_fieldsR. ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR � s ""c C s | | k S( N( ( R� R ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt __ne__� s c C s t d � � d S( Ns unhashable object( R� ( R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt __hash__� s c C s� t | j | � | j t j k s4 | j t j k rJ t d | j � � n t j | � } | j | � | j j | <| j j � d S( sl If extension_handle specifies a non-repeated, scalar extension field, sets the value of that field. sK Cannot assign to extension "%s" because it is a repeated or composite type.N( R: R} RH R5 Rk RP RQ R� R R R� R� R= R� ( R� R9 RN R� ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt __setitem__� s c C s | j j j | d � S( s� Tries to find a known extension with the specified name. Args: name: Extension full name. Returns: Extension field descriptor. N( R} R� R� R! ( R� R ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _FindExtensionByName s c C s | j j j | d � S( s� Tries to find a known extension with the field number. Args: number: Extension field number. Returns: Extension field descriptor. N( R} R� R� R! ( R� RW ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt _FindExtensionByNumber s ( R/ R0 R1 R- R R R� R� R� R� R� ( ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyR� � s ! (R R1 t __author__t ioR RE R� Rv R� t google.protobuf.internalR R R R R R R� R R R R R R� R R R t FieldDescriptorR5 R RF R R3 R: R RJ RM RS R$ R R& R] Rx R� R' R� R( R� R� R� R� R) R* R� R� R� R� R� R� R R R R R R R% R+ R0 R8 RA RZ Rc Re Ri Rl Rm Rp R� R+ R, t objectR� R� R� ( ( ( sK /usr/lib/python2.7/site-packages/google/protobuf/internal/python_message.pyt <module>1 s� k C 7 T , 8 , * & ( 1 _ , ".
Save File
Cancel