// Protocol Buffers - Google's data interchange format // Copyright 2008 Google Inc. All rights reserved. // https://developers.google.com/protocol-buffers/ // // Redistribution and use in source and binary forms, with or without // modification, are permitted provided that the following conditions are // met: // // * Redistributions of source code must retain the above copyright // notice, this list of conditions and the following disclaimer. // * Redistributions in binary form must reproduce the above // copyright notice, this list of conditions and the following disclaimer // in the documentation and/or other materials provided with the // distribution. // * Neither the name of Google Inc. nor the names of its // contributors may be used to endorse or promote products derived from // this software without specific prior written permission. // // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. #ifndef GOOGLE_PROTOBUF_MAP_FIELD_H__ #define GOOGLE_PROTOBUF_MAP_FIELD_H__ #include #include #include #include #include #include #include #include #include #include namespace google { namespace protobuf { namespace internal { class ContendedMapCleanTest; class GeneratedMessageReflection; class MapFieldAccessor; // This class provides accesss to map field using reflection, which is the same // as those provided for RepeatedPtrField. It is used for internal // reflection implentation only. Users should never use this directly. class LIBPROTOBUF_EXPORT MapFieldBase { public: MapFieldBase() : arena_(NULL), repeated_field_(NULL), entry_descriptor_(NULL), assign_descriptor_callback_(NULL), state_(STATE_MODIFIED_MAP) {} explicit MapFieldBase(Arena* arena) : arena_(arena), repeated_field_(NULL), entry_descriptor_(NULL), assign_descriptor_callback_(NULL), state_(STATE_MODIFIED_MAP) {} virtual ~MapFieldBase(); // Returns reference to internal repeated field. Data written using // google::protobuf::Map's api prior to calling this function is guarantted to be // included in repeated field. const RepeatedPtrFieldBase& GetRepeatedField() const; // Like above. Returns mutable pointer to the internal repeated field. RepeatedPtrFieldBase* MutableRepeatedField(); // Returns the number of bytes used by the repeated field, excluding // sizeof(*this) int SpaceUsedExcludingSelf() const; protected: // Gets the size of space used by map field. virtual int SpaceUsedExcludingSelfNoLock() const; // Synchronizes the content in Map to RepeatedPtrField if there is any change // to Map after last synchronization. void SyncRepeatedFieldWithMap() const; virtual void SyncRepeatedFieldWithMapNoLock() const; // Synchronizes the content in RepeatedPtrField to Map if there is any change // to RepeatedPtrField after last synchronization. void SyncMapWithRepeatedField() const; virtual void SyncMapWithRepeatedFieldNoLock() const {} // Tells MapFieldBase that there is new change to Map. void SetMapDirty(); // Tells MapFieldBase that there is new change to RepeatedPTrField. void SetRepeatedDirty(); // Provides derived class the access to repeated field. void* MutableRepeatedPtrField() const; // Creates descriptor for only one time. void InitMetadataOnce() const; enum State { STATE_MODIFIED_MAP = 0, // map has newly added data that has not been // synchronized to repeated field STATE_MODIFIED_REPEATED = 1, // repeated field has newly added data that // has not been synchronized to map CLEAN = 2, // data in map and repeated field are same }; Arena* arena_; mutable RepeatedPtrField* repeated_field_; // MapEntry can only be created from MapField. To create MapEntry, MapField // needs to know its descriptor, because MapEntry is not generated class which // cannot initialize its own descriptor by calling generated // descriptor-assign-function. Thus, we need to register a callback to // initialize MapEntry's descriptor. const Descriptor** entry_descriptor_; void (*assign_descriptor_callback_)(); mutable Mutex mutex_; // The thread to synchronize map and repeated field // needs to get lock first; mutable volatile Atomic32 state_; // 0: STATE_MODIFIED_MAP // 1: STATE_MODIFIED_REPEATED // 2: CLEAN private: friend class ContendedMapCleanTest; friend class GeneratedMessageReflection; friend class MapFieldAccessor; }; // This class provides accesss to map field using generated api. It is used for // internal generated message implentation only. Users should never use this // directly. template class LIBPROTOBUF_EXPORT MapField : public MapFieldBase, public MapFieldLite { // Handlers for key/value wire type. Provide utilities to parse/serialize // key/value. typedef MapWireFieldTypeHandler KeyWireHandler; typedef MapWireFieldTypeHandler ValueWireHandler; // Define key/value's internal stored type. static const bool kIsKeyMessage = KeyWireHandler::kIsMessage; static const bool kIsValMessage = ValueWireHandler::kIsMessage; typedef typename KeyWireHandler::CppType KeyInternalType; typedef typename ValueWireHandler::CppType ValueInternalType; typedef typename MapIf::type KeyCpp; typedef typename MapIf::type ValCpp; // Handlers for key/value's internal stored type. typedef MapCppTypeHandler KeyHandler; typedef MapCppTypeHandler ValHandler; // Define message type for internal repeated field. typedef MapEntry EntryType; typedef MapEntryLite EntryLiteType; // Define abbreviation for parent MapFieldLite typedef MapFieldLite MapFieldLiteType; // Enum needs to be handled differently from other types because it has // different exposed type in google::protobuf::Map's api and repeated field's api. For // details see the comment in the implementation of // SyncMapWithRepeatedFieldNoLocki. static const bool kIsValueEnum = ValueWireHandler::kIsEnum; typedef typename MapIf::type CastValueType; public: MapField(); explicit MapField(Arena* arena); // MapField doesn't own the default_entry, which means default_entry must // outlive the lifetime of MapField. MapField(const Message* default_entry); // For tests only. MapField(Arena* arena, const Message* default_entry); ~MapField(); // Accessors const Map& GetMap() const; Map* MutableMap(); // Convenient methods for generated message implementation. int size() const; void Clear(); void MergeFrom(const MapFieldLiteType& other); void Swap(MapFieldLiteType* other); // Allocates metadata only if this MapField is part of a generated message. void SetEntryDescriptor(const Descriptor** descriptor); void SetAssignDescriptorCallback(void (*callback)()); private: typedef void DestructorSkippable_; // MapField needs MapEntry's default instance to create new MapEntry. void InitDefaultEntryOnce() const; // Manually set default entry instance. For test only. void SetDefaultEntryOnce(const EntryType* default_entry) const; // Convenient methods to get internal google::protobuf::Map const Map& GetInternalMap() const; Map* MutableInternalMap(); // Implements MapFieldBase void SyncRepeatedFieldWithMapNoLock() const; void SyncMapWithRepeatedFieldNoLock() const; int SpaceUsedExcludingSelfNoLock() const; mutable const EntryType* default_entry_; friend class ::google::protobuf::Arena; }; } // namespace internal } // namespace protobuf } // namespace google #endif // GOOGLE_PROTOBUF_MAP_FIELD_H__