modules/platforms/cpp/binary/include/ignite/impl/binary/binary_type_manager.h

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#ifndef _IGNITE_IMPL_BINARY_BINARY_TYPE_MANAGER
#define _IGNITE_IMPL_BINARY_BINARY_TYPE_MANAGER

#include <vector>

#include <ignite/ignite_error.h>
#include "ignite/impl/binary/binary_type_handler.h"
#include "ignite/impl/binary/binary_type_updater.h"

namespace ignite
{    
    namespace impl
    {
        namespace binary
        {
            /**
             * Type manager.
             */
            class IGNITE_IMPORT_EXPORT BinaryTypeManager
            {
            public:
                /**
                 * Constructor.
                 */
                BinaryTypeManager();

                /**
                 * Destructor.
                 */
                ~BinaryTypeManager();

                /**
                 * Get handler.
                 *
                 * @param typeName Type name.
                 * @param affFieldName Affinity field name.
                 * @param typeId Type ID.
                 */
                common::concurrent::SharedPointer<BinaryTypeHandler> GetHandler(const std::string& typeName,
                    const std::string& affFieldName, int32_t typeId);

                /**
                 * Submit handler for processing.
                 *
                 * @param hnd Handler.
                 */
                void SubmitHandler(BinaryTypeHandler& hnd);

                /**
                 * Get current type manager version.
                 *
                 * @return Version.
                 */
                int32_t GetVersion() const;

                /**
                 * Check whether something is updated since the given version.
                 *
                 * @param oldVer Old version.
                 * @return True if updated and it is very likely that pending type exists.
                 */
                bool IsUpdatedSince(int32_t oldVer) const;

                /**
                 * Process pending updates.
                 *
                 * @param err Error.
                 * @return In case of success.
                 */
                bool ProcessPendingUpdates(IgniteError& err);

                /**
                 * Set updater.
                 *
                 * @param updater Updater.
                 */
                void SetUpdater(BinaryTypeUpdater* updater);

                /**
                 * Get metadata snapshop for the type.
                 *
                 * @param typeId Type ID.
                 * @return Metadata snapshot.
                 */
                SPSnap GetMeta(int32_t typeId);

            private:
                /** Current snapshots. */
                std::map<int32_t, SPSnap>* snapshots;

                /** Pending snapshots. */
                std::vector<SPSnap>* pending;

                /** Critical section. */
                common::concurrent::CriticalSection cs;

                /** Type updater */
                BinaryTypeUpdater* updater;

                /** Version of pending changes. */
                int32_t pendingVer;

                /** Latest version. */
                int32_t ver;

                IGNITE_NO_COPY_ASSIGNMENT(BinaryTypeManager);
            };
        }
    }    
}

#endif //_IGNITE_IMPL_BINARY_BINARY_TYPE_MANAGER