/**
 * Tencent is pleased to support the open source community by making Tars available.
 *
 * Copyright (C) 2016THL A29 Limited, a Tencent company. All rights reserved.
 *
 * Licensed under the BSD 3-Clause License (the "License"); you may not use this file except 
 * in compliance with the License. You may obtain a copy of the License at
 *
 * https://opensource.org/licenses/BSD-3-Clause
 *
 * 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 __TC_HASHMAP_H__
#define __TC_HASHMAP_H__

#include <vector>
#include <memory>
#include <cassert>
#include <iostream>
#include <functional>
#include "util/tc_ex.h"
#include "util/tc_mem_vector.h"
#include "util/tc_pack.h"
#include "util/tc_mem_chunk.h"
#include "util/tc_hash_fun.h"

namespace tars
{
/////////////////////////////////////////////////
/**
* @file tc_hashmap.h 
* @brief  hashmap类 
* @brief  hashmap class
*/            
/////////////////////////////////////////////////
/**
* @brief Hash map异常类
* @brief Hash Map Exception Class
*/
struct TC_HashMap_Exception : public TC_Exception
{
    TC_HashMap_Exception(const string &buffer) : TC_Exception(buffer){};
    ~TC_HashMap_Exception() throw(){};
};

////////////////////////////////////////////////////////////////////////////////////
/**
 * @brief  基于内存的hashmap, 所有操作需要自己加锁 
 * @brief  Memory-based hashmap, all operations require their own locks
 *  
 *内存hashmap，不要直接使用该类，通过jmem组件来使用. 
 *Memory hashmap, do not use this class directly, use it through jmem components.
 * 
 *该hashmap通过TC_MemMutilChunkAllocator来分配空间，支持不同大小的内存块的分配； 
 *The HashMap allocates space by TC_MemMutilChunkAllocator in order to support allocation of memory blocks of different sizes; 
 * 
 *支持内存和共享内存,对接口的所有操作都需要加锁,*内部有脏数据链，支持数据缓写； 
 *Support memory and shared memory.All operations on the interface need to be locked.* If there are dirty data chains inside, data slow-write is supported;
 * 
 *当数据超过一个数据块时，则会拼接多个数据块； 
 *When there is more than one data block, multiple data blocks are stitched together.
 * 
 *Set时当数据块用完，自动淘汰最长时间没有访问的数据，也可以不淘汰，直接返回错误； 
 *When set, if the data blocks are exhausted, data that has not been accessed for the longest time will be automatically eliminated or not eliminated, and errors can be returned directly.
 * 
 *支持dump到文件，或从文件load； 
 *Support dump to file or load from file;
 */
class TC_HashMap
{
public:
    struct HashMapIterator;
    struct HashMapLockIterator;

    /**
     * @brief 操作数据
     * @brief Operate data
     */
    struct BlockData
    {
        /*data key*/
        string  _key;       /**数据Key*/
        /*date value*/
        string  _value;     /**数据value*/
        /*whether it is dirty data*/
        bool    _dirty;     /**是否是脏数据*/
        /*sync time, not necessarily true writeback time*/
        time_t  _synct;     /**sync time, 不一定是真正的回写时间*/
        BlockData()
        : _dirty(false)
        , _synct(0)
        {
        }
    };

    ///////////////////////////////////////////////////////////////////////////////////
    /**
    * @brief 内存数据块,读取和存放数据 
    * @brief Memory data blocks for reading and storing data
    */
    class Block
    {
    public:

        /**
         * @brief block数据头
         * @brief block header
         */
#pragma pack(1) 

        struct tagBlockHead
        {
            /*capacity size of block*/
            uint32_t    _iSize;         /**block的容量大小*/
            /*hash index*/
            uint32_t    _iIndex;        /**hash的索引*/
            /*Next Block, tagBlockHead, none:0*/
            size_t      _iBlockNext;    /**下一个Block,tagBlockHead, 没有则为0*/
            /*Last Block, tagBlockHead, none:0*/
            size_t      _iBlockPrev;    /**上一个Block,tagBlockHead, 没有则为0*/
            /*next block on set chain*/
            size_t      _iSetNext;      /**Set链上的下一个Block*/
            /*last block on set chain*/
            size_t      _iSetPrev;      /**Set链上的上一个Block*/
            /*next block on get chain*/
            size_t      _iGetNext;      /**Get链上的下一个Block*/
            /*last block on get chain*/
            size_t      _iGetPrev;      /**Get链上的上一个Block*/
            /*Last slow write time*/
            time_t      _iSyncTime;     /**上次缓写时间*/
            /*whether it is dirty data*/
            bool        _bDirty;        /**是否是脏数据*/
            /*Is there only key, no content*/
            bool        _bOnlyKey;      /**是否只有key, 没有内容*/
            /*Is there the next chunk*/
            bool        _bNextChunk;    /**是否有下一个chunk*/
            union
            {
                /*Next Chunk block, it is valid when _bNextChunk=true, tagChunkHead*/
                size_t  _iNextChunk;    /**下一个Chunk块, _bNextChunk=true时有效, tagChunkHead*/
                /*Length used in current data block, it is valid when _bNextChunk=false*/
                size_t  _iDataLen;      /**当前数据块中使用了的长度, _bNextChunk=false时有效*/
            };
            /*beginning of data*/
            char        _cData[0];      /**数据开始部分*/
        };

        /**
         * @brief 非头部的block, 称为chunk
         * @brief A non-headed block, called a chunk
         */
        struct tagChunkHead
        {
            /*capacity size of block*/
            uint32_t    _iSize;         /**block的容量大小*/
            /*Is there another chunk*/
            bool        _bNextChunk;    /**是否还有下一个chunk*/
            union
            {
                /*next data block, it is valid when _bNextChunk=true, tagChunkHead*/
                size_t  _iNextChunk;    /**下一个数据块, _bNextChunk=true时有效, tagChunkHead*/\
                /*Length used in current data block, it is valid when _bNextChunk=true*/
                size_t  _iDataLen;      /**当前数据块中使用了的长度, _bNextChunk=false时有效*/
            };
            /*beginning of data*/
            char        _cData[0];      /**数据开始部分*/
        };
#pragma pack() 

        /**
         * @brief 构造函数
         * @brief constructor
         * @param Map
         * @param iAddr 当前MemBlock的地址
         * @param iAddr current MemBlock address
         */
        Block(TC_HashMap *pMap, size_t iAddr)
        : _pMap(pMap)
        , _iHead(iAddr)
        {
        }

        /**
         * @brief copy
         * @param mb
         */
        Block(const Block &mb)
        : _pMap(mb._pMap)
        , _iHead(mb._iHead)
        {
        }

        /**
         *
         * @param mb
         *
         * @return Block&
         */
        Block& operator=(const Block &mb)
        {
            _iHead  = mb._iHead;
            _pMap   = mb._pMap;
            return (*this);
        }

        /**
         *
         * @param mb
         *
         * @return bool
         */
        bool operator==(const Block &mb) const { return _iHead == mb._iHead && _pMap == mb._pMap; }

        /**
         *
         * @param mb
         *
         * @return bool
         */
        bool operator!=(const Block &mb) const { return _iHead != mb._iHead || _pMap != mb._pMap; }

        /**
         * 获取block头绝对地址
         * Get Block Header Absolute Address
         * @param iAddr
         *
         * @return tagChunkHead*
         */
        tagBlockHead *getBlockHead(size_t iAddr) { return ((tagBlockHead*)_pMap->getAbsolute(iAddr)); }

        /**
         * 获取MemBlock头地址
         * Get MemBlock Header Absolute Address
         *
         * @return void*
         */
        tagBlockHead *getBlockHead() {return getBlockHead(_iHead);}

        /**
         * 头部
         * Header
         *
         * @return size_t
         */
        size_t getHead() { return _iHead;}

        /**
         * @brief 当前桶链表最后一个block的头部
         * @brief Head of last block in current bucket chain list
         *
         * @return size_t
         */
        size_t getLastBlockHead();

        /**
         * @brief 最新Get时间
         * @brief the latest Get time
         *
         * @return time_t
         */
        time_t getSyncTime() { return getBlockHead()->_iSyncTime; }

        /**
         * @brief 设置回写时间
         * @brief Set Writeback Time 
         * @param iSyncTime
         */
        void setSyncTime(time_t iSyncTime) { getBlockHead()->_iSyncTime = iSyncTime; }

        /**
         * @brief 获取Block中的数据
         * @brief Get data from Block
         *
         * @return int
         *          TC_HashMap::RT_OK, 正常, normal,other exception
         *          TC_HashMap::RT_ONLY_KEY, 只有Key, only key
         *          其他异常 other exception
         */
        int getBlockData(TC_HashMap::BlockData &data);

        /**
         * @brief 获取数据
         * @brief Get Data
         * @param pData
         * @param iDatalen
         * @return int,
         *          TC_HashMap::RT_OK, 正常 normal
         *          其他异常 other exception
         */
        int get(void *pData, size_t &iDataLen);

        /**
         * @brief 获取数据
         * @brief Get Data
         * @param s
         * @return int
         *          TC_HashMap::RT_OK, 正常, normal
         *          其他异常 other exception
         */
        int get(string &s);

        /**
         * @brief 设置数据
         * @brief Set Data
         * @param pData
         * @param iDatalen
         * @param vtData, 淘汰的数据
         * @param vtData eliminated data
         */
        int set(const void *pData, size_t iDataLen, bool bOnlyKey, vector<TC_HashMap::BlockData> &vtData);

        /**
         * @brief 是否是脏数据
         * @brief Is there dirty data
         *
         * @return bool
         */
        bool isDirty()      { return getBlockHead()->_bDirty; }

        /**
         * @brief 设置数据
         * @brief Set Data
         * @param b
         */
        void setDirty(bool b);

        /**
         * @brief 是否只有key
         * @brief Is there only key
         *
         * @return bool
         */
        bool isOnlyKey()    { return getBlockHead()->_bOnlyKey; }

        /**
         * @brief 当前元素移动到下一个block
         * @brief Move the current element to the next block
         * @return true, 移到下一个block了, false, 没有下一个block
         * @return true, moved to the next block, false, no next block
         *
         */
        bool nextBlock();

        /**
         * @brief 当前元素移动到上一个block
         * @brief The current element moves to the previous block
         * @return true, 移到上一个block了, false, 没有上一个block
         * @return true, moved to the previous block, false, no previous block
         *
         */
        bool prevBlock();

        /**
         * @brief 释放block的所有空间
         * @brief Release all space from the block
         */
        void deallocate();

        /**
         * @brief 新block时调用该函数,分配一个新的block 
         * @brief This function is called when a new block is created, and a new block is assigned
         * @param index, hash索引
         * @param index hash index
         * @param iAllocSize, 内存大小
         * @param iAllocSize the memory capacity
         */
        void makeNew(size_t index, size_t iAllocSize);

        /**
         * @brief 从Block链表中删除当前Block,只对Block有效, 
         *        对Chunk是无效的
         * @brief Delete the current block from the block list, only valid for Block.
         *        invalid for Chunk
         * @return
         */
        void erase();

        /**
         * @brief 刷新set链表, 放在Set链表头部
         * @brief Refresh the set list and place it at the head of the set list
         */
        void refreshSetList();

        /**
         * @brief 刷新get链表, 放在Get链表头部
         * @brief Refresh the get list and place it at the head of the get list
         */
        void refreshGetList();

    protected:

        /**
         * @brief 获取Chunk头绝对地址
         * @brief Get absolute Chunk header address
         *
         * @return tagChunkHead*
         */
        tagChunkHead *getChunkHead() {return getChunkHead(_iHead);}

        /**
         * @brief 获取chunk头绝对地址
         * @brief Get absolute Chunk header address
         * @param iAddr
         *
         * @return tagChunkHead*
         */
        tagChunkHead *getChunkHead(size_t iAddr) { return ((tagChunkHead*)_pMap->getAbsolute(iAddr)); }

        /**
         * @brief 从当前的chunk开始释放
         * @brief Release from current chunk
         * @param iChunk 释放地址
         * @param iChunk Release address
         */
        void deallocate(size_t iChunk);

        /**
         * @brief 如果数据容量不够, 则新增加chunk, 不影响原有数据
         * 使新增加的总容量大于iDataLen,释放多余的chunk 
         * @brief If the data capacity is insufficient, add a new chunk without affecting the original data
         * Make the newly added total capacity larger than iDataLen, releasing extra chunks
         * @param iDataLen
         *
         * @return int,
         */
        int allocate(size_t iDataLen, vector<TC_HashMap::BlockData> &vtData);

        /**
         * @brief 挂接chunk, 如果core则挂接失败, 保证内存块还可以用
         * @brief Hook chunk, if core fails to hook, ensuring that memory blocks are still available
         * @param pChunk
         * @param chunks
         *
         * @return int
         */
        int joinChunk(tagChunkHead *pChunk, const vector<size_t> chunks);

        /**
         * @brief 分配n个chunk地址, 
         *        注意释放内存的时候不能释放正在分配的对象
         * @brief Assign n chunk addresses,
         * Note that objects being allocated cannot be freed when memory is freed
         * @param fn, 分配空间大小
         * @param fn Allocate space size
         * @param chunks, 分配成功返回的chunks地址列表
         * @param chunks A list of chunks addresses that were successfully assigned back
         * @param vtData, 淘汰的数据
         * @param vtData eliminated data
         * @return int
         */
        int allocateChunk(size_t fn, vector<size_t> &chunks, vector<TC_HashMap::BlockData> &vtData);

        /**
         * @brief 获取数据长度
         * @brief Get the data length
         *
         * @return size_t
         */
        size_t getDataLen();

    public:

        /**
         * Map
         */
        TC_HashMap         *_pMap;

        /**
         * block区块首地址, 相对地址
         * Block block header address, relative address
         */
        size_t              _iHead;

    };

    ////////////////////////////////////////////////////////////////////////
    /*
    * 内存数据块分配器
    * Memory Data Block Allocator
    *
    */
    class BlockAllocator
    {
    public:

        /**
         * @brief 构造函数
         * @brief Contructor
         */
        BlockAllocator(TC_HashMap *pMap)
        : _pMap(pMap)
        , _pChunkAllocator(new TC_MemMultiChunkAllocator())
        {
        }

        /**
         * @brief 析够函数
         * @brief Destructor
         */
        ~BlockAllocator()
        {
            if(_pChunkAllocator != NULL)
            {
                delete _pChunkAllocator;
            }
            _pChunkAllocator = NULL;
        }


        /**
         * @brief 初始化
         * @brief Initialization
         * @param pHeadAddr, 地址, 换到应用程序的绝对地址
         * @param pHeadAddr address,change to the absolute address of the application
         * @param iSize, 内存大小
         * @param iSize memory capacity size
         * @param iMinBlockSize, 最小数据块大小
         * @param iMinBlockSize Minimum data block size
         * @param iMaxBlockSize, 最大数据块大小
         * @param iMaxBlockSize Maximum data block size
         * @param fFactor, 因子
         * @param fFactor factor
         */
        void create(void *pHeadAddr, size_t iSize, size_t iMinBlockSize, size_t iMaxBlockSize, float fFactor)
        {
            _pChunkAllocator->create(pHeadAddr, iSize, iMinBlockSize, iMaxBlockSize, fFactor);
        }

        /**
         * @brief 连接上
         * @brief Connect
         * @param pAddr, 地址, 换到应用程序的绝对地址
         * @param pAddr address,Change to the absolute address of the application
         */
        void connect(void *pHeadAddr)
        {
            _pChunkAllocator->connect(pHeadAddr);
        }

        /**
         * @brief 扩展空间
         * @brief Expand space
         * @param pAddr
         * @param iSize
         */
        void append(void *pAddr, size_t iSize)
        {
            _pChunkAllocator->append(pAddr, iSize);
        }

        /**
         * @brief 重建
         * @brief reconstruction
         */
        void rebuild()
        {
            _pChunkAllocator->rebuild();
        }

        /**
         * @brief 获取每种数据块头部信息
         * @brief Get header information for each data block
         *
         * @return TC_MemChunk::tagChunkHead
         */
        vector<TC_MemChunk::tagChunkHead> getBlockDetail() const  { return _pChunkAllocator->getBlockDetail(); }

        /**
         * @brief 获取内存大小
         * @brief Get Memory Size
         *
         * @return size_t
         */
        size_t getMemSize() const       { return _pChunkAllocator->getMemSize(); }

        /**
         * @brief 获取真正的数据容量
         * @brief Get real data capacity
         *
         * @return size_t
         */
        size_t getCapacity() const      { return _pChunkAllocator->getCapacity(); }

        /**
         * @brief 每种block中的chunk个数(每种block中的chunk个数相同)
         * @brief Number of chunks per block (same number of chunks per block)
         *
         * @return vector<size_t>
         */
        vector<size_t> singleBlockChunkCount() const { return _pChunkAllocator->singleBlockChunkCount(); }

        /**
         * @brief 获取所有block的chunk个数
         * @brief Get the number of chunks for all blocks
         *
         * @return size_t
         */
        size_t allBlockChunkCount() const    { return _pChunkAllocator->allBlockChunkCount(); }

        /**
         * @brief 在内存中分配一个新的Block
         * @brief Allocate a new block in memory
         *
         * @param index, block hash索引
         * @param index block hash index
         * @param iAllocSize: in/需要分配的大小, out/分配的块大小
         * @param iAllocSize in/size to be allocated, out/block size to be allocated
         * @param vtData, 返回释放的内存块数据
         * @param vtData return freed memory block data
         * @return size_t, 相对地址,0表示没有空间可以分配
         * @return size_t Relative address, 0 means no space to allocate
         */
        size_t allocateMemBlock(size_t index, size_t &iAllocSize, vector<TC_HashMap::BlockData> &vtData);

        /**
         * @brief 为地址为iAddr的Block分配一个chunk
         * @brief Assign a chunk to a block whose address is iAddr
         *
         * @param iAddr,分配的Block的地址
         * @param iAddr The address of the assigned block
         * @param iAllocSize, in/需要分配的大小, out/分配的块大小
         * @param iAllocSize in/size to be allocated, out/block size to be allocated
         * @param vtData 返回释放的内存块数据
         * @param vtData return freed memory block data
         * @return size_t, 相对地址,0表示没有空间可以分配
         * @return size_t Relative address, 0 means no space to allocate
         */
        size_t allocateChunk(size_t iAddr, size_t &iAllocSize, vector<TC_HashMap::BlockData> &vtData);

        /**
         * @brief 释放Block
         * @brief Release Block
         * @param v
         */
        void deallocateMemBlock(const vector<size_t> &v);

        /**
         * @brief 释放Block
         * @brief Release Block
         * @param v
         */
        void deallocateMemBlock(size_t v);

    protected:
        //不允许copy构造
        //Copy construction not allowed
        BlockAllocator(const BlockAllocator &);
        //不允许赋值
        //Assignment not allowed
        BlockAllocator& operator=(const BlockAllocator &);
        bool operator==(const BlockAllocator &mba) const;
        bool operator!=(const BlockAllocator &mba) const;
    public:
        /**
         * map
         */
        TC_HashMap                  *_pMap;

        /**
         * chunk分配器
         * Chunk allocator
         */
        TC_MemMultiChunkAllocator   *_pChunkAllocator;
    };

    ////////////////////////////////////////////////////////////////
    /** 
      * @brief map的数据项 
      * @brief data items of map
       */ 
    class HashMapLockItem
    {
    public:

        /**
         *
         * @param pMap
         * @param iAddr
         */
        HashMapLockItem(TC_HashMap *pMap, size_t iAddr);

        /**
         *
         * @param mcmdi
         */
        HashMapLockItem(const HashMapLockItem &mcmdi);

        /**
         *
         * @param mcmdi
         *
         * @return HashMapLockItem&
         */
        HashMapLockItem &operator=(const HashMapLockItem &mcmdi);

        /**
         *
         * @param mcmdi
         *
         * @return bool
         */
        bool operator==(const HashMapLockItem &mcmdi);

        /**
         *
         * @param mcmdi
         *
         * @return bool
         */
        bool operator!=(const HashMapLockItem &mcmdi);

        /**
         * @brief 是否是脏数据
         * @brief Is there dirty data
         *
         * @return bool
         */
        bool isDirty();

        /**
         * @brief 是否只有Key
         * @brief Is there only key
         *
         * @return bool
         */
        bool isOnlyKey();

        /**
         * @brief 获取最后Sync时间
         * @brief Get Last Sync Time
         *
         * @return time_t
         */
        time_t getSyncTime();

        /**
         * 获取值, 如果只有Key(isOnlyKey)的情况下, v为空
         * Gets the value, if only Key (isOnlyKey) is present, V is empty
         * @return int
         *          RT_OK:数据获取OK
         *          RT_OK:Data Acquisition OK
         *          RT_ONLY_KEY: key有效, v无效为空
         *          RT_ONLY_KEY: Key is valid, V is invalid is empty
         *          其他值, 异常
         *          Other values, exceptions
         *
         */
        int get(string& k, string& v);

        /**
         * @brief 获取值
         * @brief Get value
         * @return int
         *          RT_OK:数据获取OK
         *          RT_OK:Data Acquisition OK
         *          其他值, 异常
         *          Other values, exceptions
         */
        int get(string& k);

        /**
         * @brief 获取数据块相对地址
         * @brief Get relative address of data block
         *
         * @return size_t
         */
        size_t getAddr() const { return _iAddr; }

    protected:

        /**
         * @brief 设置数据
         * @brief Set data
         * @param k
         * @param v
         * @param vtData, 淘汰的数据
         * @param vtData eliminated data
         * @return int
         */
        int set(const string& k, const string& v, vector<TC_HashMap::BlockData> &vtData);

        /**
         * @brief 设置Key, 无数据
         * @brief Set key , no data
         * @param k
         * @param vtData
         *
         * @return int
         */
        int set(const string& k, vector<TC_HashMap::BlockData> &vtData);

        /**
         *
         * @param pKey
         * @param iKeyLen
         *
         * @return bool
         */
        bool equal(const string &k, string &v, int &ret);

        /**
         *
         * @param pKey
         * @param iKeyLen
         *
         * @return bool
         */
        bool equal(const string& k, int &ret);

        /**
         * @brief 下一个item
         * @brief next item
         *
         * @return HashMapLockItem
         */
        void nextItem(int iType);

        /**
         * 上一个item
         * last item
         * @param iType
         */
        void prevItem(int iType);

        friend class TC_HashMap;
        friend struct TC_HashMap::HashMapLockIterator;

    private:
        /**
         * map
         */
        TC_HashMap *_pMap;

        /**
         * block的地址
         * the block address
         */
        size_t      _iAddr;
    };

    /////////////////////////////////////////////////////////////////////////
    /** 
      * @brief 定义迭代器 
      * @brief Define Iterator
      */ 
    struct HashMapLockIterator
    {
    public:

        /**
         *@brief 定义遍历方式
         *@brief Define traversal
         */
        enum
        {
            /*Ordinary order*/
            IT_BLOCK    = 0,        /**普通的顺序*/
            /*Set chronological order*/
            IT_SET      = 1,        /**Set时间顺序*/
            /*Get chronological order*/
            IT_GET      = 2,        /**Get时间顺序*/
        };

        /**
         * 迭代器的顺序
         * Order of iterators
         */
        enum
        {
            /*seriation*/
            IT_NEXT     = 0,        /**顺序*/
            /*reverse*/
            IT_PREV     = 1,        /**逆序*/
        };

        /**
         *
         */
        HashMapLockIterator();

        /**
         * @brief 构造函数
         * @brief Constructor
         * @param iAddr, 地址
         * @param iAddr, Address
         * @param type
         */
        HashMapLockIterator(TC_HashMap *pMap, size_t iAddr, int iType, int iOrder);

        /**
         * @brief copy
         * @param it
         */
        HashMapLockIterator(const HashMapLockIterator &it);

        /**
         * @brief 复制
         * @brief Copy
         * @param it
         *
         * @return HashMapLockIterator&
         */
        HashMapLockIterator& operator=(const HashMapLockIterator &it);

        /**
         *
         * @param mcmi
         *
         * @return bool
         */
        bool operator==(const HashMapLockIterator& mcmi);

        /**
         *
         * @param mv
         *
         * @return bool
         */
        bool operator!=(const HashMapLockIterator& mcmi);

        /**
         * @brief 前置++
         * @brief Pre++
         *
         * @return HashMapLockIterator&
         */
        HashMapLockIterator& operator++();

        /**
         * @brief 后置++
         * @brief Post++
         *
         * @return HashMapLockIterator&
         */
        HashMapLockIterator operator++(int);

        /**
         *
         *
         * @return HashMapLockItem&i
         */
        HashMapLockItem& operator*() { return _iItem; }

        /**
         *
         *
         * @return HashMapLockItem*
         */
        HashMapLockItem* operator->() { return &_iItem; }

    public:
        /**
         *
         */
        TC_HashMap  *_pMap;

        /**
         *
         */
        HashMapLockItem _iItem;

        /**
         * 迭代器的方式
         * The way iterators work
         */
        int        _iType;

        /**
         * 迭代器的顺序
         * Order of iterators
         */
        int        _iOrder;

    };

    ////////////////////////////////////////////////////////////////
    /** 
     * @brief map的HashItem项, 一个HashItem对应多个数据项
     * @brief Map's HashItem item, one HashItem corresponds to more than one data item
     */
    class HashMapItem
    {
    public:

        /**
         *
         * @param pMap
         * @param iIndex
         */
        HashMapItem(TC_HashMap *pMap, size_t iIndex);

        /**
         *
         * @param mcmdi
         */
        HashMapItem(const HashMapItem &mcmdi);

        /**
         *
         * @param mcmdi
         *
         * @return HashMapItem&
         */
        HashMapItem &operator=(const HashMapItem &mcmdi);

        /**
         *
         * @param mcmdi
         *
         * @return bool
         */
        bool operator==(const HashMapItem &mcmdi);

        /**
         *
         * @param mcmdi
         *
         * @return bool
         */
        bool operator!=(const HashMapItem &mcmdi);

        /**
         * @brief 获取当前hash桶的所有数量, 注意只获取有key/value的数据
         * 对于只有key的数据, 不获取
         * @brief Get all the current hash buckets, note that only key/value data is available
         * do not get key-only data
         * 
         * @return
         */
        void get(vector<TC_HashMap::BlockData> &vtData);

        /**
         * 
         * 
         * @return int
         */
        int getIndex() const { return (int)_iIndex; }

        /**
         * @brief 下一个item
         * @brief next item
         *
         */
        void nextItem();

        /**
         * 设置当前hash桶下所有数据为脏数据，注意只设置有key/value的数据
         * 对于只有key的数据, 不设置
         * Set all data under the current hash bucket as dirty, note that only key/value data is set
         * do not set key-only data
         * @param
         * @return int
         */
        int setDirty();

        friend class TC_HashMap;
        friend struct TC_HashMap::HashMapIterator;

    private:
        /**
         * map
         */
        TC_HashMap *_pMap;

        /**
         * 数据块地址
         * Data block address
         */
        size_t      _iIndex;
    };

    /////////////////////////////////////////////////////////////////////////
    /**
    * @brief 定义迭代器
    * @brief define iterator
    */
    struct HashMapIterator
    {
    public:

        /**
         * @brief 构造函数
         * @brief Constructor
         */
        HashMapIterator();

        /**
         * @brief 构造函数
         * @brief Constructor
         * @param iIndex, 地址
         * @param iIndex, Address
         * @param type
         */
        HashMapIterator(TC_HashMap *pMap, size_t iIndex);

        /**
         * @brief copy
         * @param it
         */
        HashMapIterator(const HashMapIterator &it);

        /**
         * @brief 复制
         * @brief Copy
         * @param it
         *
         * @return HashMapLockIterator&
         */
        HashMapIterator& operator=(const HashMapIterator &it);

        /**
         *
         * @param mcmi
         *
         * @return bool
         */
        bool operator==(const HashMapIterator& mcmi);

        /**
         *
         * @param mv
         *
         * @return bool
         */
        bool operator!=(const HashMapIterator& mcmi);

        /**
         * @brief 前置++
         * @brief Pre++
         *
         * @return HashMapIterator&
         */
        HashMapIterator& operator++();

        /**
         * @brief 后置++
         * @brief Post++
         *
         * @return HashMapIterator&
         */
        HashMapIterator operator++(int);

        /**
         *
         *
         * @return HashMapItem&i
         */
        HashMapItem& operator*() { return _iItem; }

        /**
         *
         *
         * @return HashMapItem*
         */
        HashMapItem* operator->() { return &_iItem; }

    public:
        /**
         *
         */
        TC_HashMap  *_pMap;

        /**
         *
         */
        HashMapItem _iItem;
    };

    //////////////////////////////////////////////////////////////////////////////////////////////////
 
    /**
     * @brief map头
     * @brief map header
     */
#pragma pack(1) 
    struct tagMapHead
    {
        /*large version*/
        char   _cMaxVersion;        /**大版本*/
        /*small version*/
        char   _cMinVersion;         /**小版本*/
        /*Is it read-only*/
        bool   _bReadOnly;           /**是否只读*/
        /*Is it possible to phase out automatically*/
        bool   _bAutoErase;          /**是否可以自动淘汰*/
        /*elimination method: 0x00: Eliminate by Get chain, 0x01: Eliminate by Set chain*/
        char   _cEraseMode;          /**淘汰方式:0x00:按照Get链淘汰, 0x01:按照Set链淘汰*/
        /*mamory size*/
        size_t _iMemSize;            /**内存大小*/
        /*Minimum data block size*/
        size_t _iMinDataSize;        /**最小数据块大小*/
        /*Maximum data block size*/
        size_t _iMaxDataSize;        /**最大数据块大小*/
        /*factor*/
        float  _fFactor;             /**因子*/
        /*number of chunks/hash*/
        float   _fRadio;              /**chunks个数/hash个数*/
        /*total number of elements*/
        size_t _iElementCount;       /**总元素个数*/
        /*number of deletions at a time*/
        size_t _iEraseCount;         /**每次删除个数*/
        /*number of dirty data*/
        size_t _iDirtyCount;         /**脏数据个数*/
        /*Set Time Chain Header*/
        size_t _iSetHead;            /**Set时间链表头部*/
        /*Set Time Chain Tail*/
        size_t _iSetTail;            /**Set时间链表尾部*/
        /*Get Time Chain Header*/
        size_t _iGetHead;            /**Get时间链表头部*/
        /*Get Time Chain Tail*/
        size_t _iGetTail;            /**Get时间链表尾部*/
        /*Dirty end of data chain*/
        size_t _iDirtyTail;          /**脏数据链尾部*/
        /*Writeback time*/
        time_t _iSyncTime;           /**回写时间*/
        /*Memory block used*/
        size_t _iUsedChunk;          /**已经使用的内存块*/
        /*Get times*/
        size_t _iGetCount;           /**get次数*/
        /*Hit Counts*/
        size_t _iHitCount;           /**命中次数*/
        /*Hot backup pointer*/
        size_t _iBackupTail;         /**热备指针*/
        /*Writeback Chain List*/
        size_t _iSyncTail;           /**回写链表*/
        /*Number of OnlyKeys*/
        size_t _iOnlyKeyCount;         /** OnlyKey个数*/
        /*retain*/
        size_t _iReserve[4];        /**保留*/
    };

    /**
     * @brief 需要修改的地址
     * @brief Addresses that need to be modified
     */
    struct tagModifyData
    {
        /*Modified Address*/
        size_t  _iModifyAddr;       /**修改的地址*/
        /*Number of bytes*/
        char    _cBytes;           /**字节数*/
        /*value*/
        size_t  _iModifyValue;      /**值*/
    };

    /**
     * 修改数据块头部
     * Modify the header of the data block
     */
    struct tagModifyHead
    {
        /*Modification Status: 0: No one is modifying at present, 1: Start preparing to modify, 2: Finish modifying, no copy in memory*/
        char            _cModifyStatus;         /**修改状态: 0:目前没有人修改, 1: 开始准备修改, 2:修改完毕, 没有copy到内存中*/
        /*Update to current index, cannot operate on 10*/
        size_t          _iNowIndex;             /**更新到目前的索引, 不能操作10个*/
        /*Up to 20 changes at a time*/
        tagModifyData   _stModifyData[20];      /**一次最多20次修改*/
    };

    /**
     * HashItem
     */
    struct tagHashItem
    {
        /*Offset address to data item*/
        size_t   _iBlockAddr;     /**指向数据项的偏移地址*/
        /*Number of Chain Lists*/
        uint32_t _iListCount;     /**链表个数*/
    };
#pragma pack() 

    //64位操作系统用基数版本号, 32位操作系统用64位版本号
    //Base version number for 64-bit operating systems, 64-bit version number for 32-bit operating systems
#if __WORDSIZE == 64 || defined _WIN64

    //定义版本号
    //Define Version Number
    enum
    {
        /*Large version number of current map*/
        MAX_VERSION         = 0,    /**当前map的大版本号*/
        /*Small version number of current map*/
        MIN_VERSION         = 3,    /**当前map的小版本号*/
    };

#else
    //定义版本号
    //Define Version Number
    enum
    {
        /*Large version number of current map*/
        MAX_VERSION         = 0,    /**当前map的大版本号*/
        /*Small version number of current map*/
        MIN_VERSION         = 2,    /**当前map的小版本号*/
    };

#endif

    /**                            
      *@brief 定义淘汰方式
      *@brief Define the elimination method
      */
    enum
    {
        /*Eliminate by Get Chain List*/
        ERASEBYGET          = 0x00, /**按照Get链表淘汰*/
        /*Eliminate by Set Chain List*/
        ERASEBYSET          = 0x01, /**按照Set链表淘汰*/
    };

    /**
     * @brief get, set等int返回值
     * @brief get, set, etc.   int return value
     */
    enum
    {
        /*success*/
        RT_OK                   = 0,    /**成功*/
        /*dirty data*/
        RT_DIRTY_DATA           = 1,    /**脏数据*/
        /*no data*/
        RT_NO_DATA              = 2,    /**没有数据*/
        /*require writeback */
        RT_NEED_SYNC            = 3,    /**需要回写*/
        /*do not require writeback*/
        RT_NONEED_SYNC          = 4,    /**不需要回写*/
        /*data phase-out success*/
        RT_ERASE_OK             = 5,    /**淘汰数据成功*/
        /*map read-only*/
        RT_READONLY             = 6,    /**map只读*/
        /*insufficient memory*/
        RT_NO_MEMORY            = 7,    /**内存不够*/
        /*Key only, no Value*/
        RT_ONLY_KEY             = 8,    /**只有Key, 没有Value*/
        /*Backup required*/
        RT_NEED_BACKUP          = 9,    /**需要备份*/
        /*no get*/
        RT_NO_GET               = 10,   /**没有GET过*/
        /*decode error*/
        RT_DECODE_ERR           = -1,   /**解析错误*/
        /*exception*/
        RT_EXCEPTION_ERR        = -2,   /**异常*/
        /*data loading error*/
        RT_LOAD_DATA_ERR        = -3,   /**加载数据异常*/
        /*version inconsistency*/
        RT_VERSION_MISMATCH_ERR = -4,   /**版本不一致*/
        /*Dump to file failed*/
        RT_DUMP_FILE_ERR        = -5,   /**dump到文件失败*/
        /*Load file to memory failed*/
        RT_LOAL_FILE_ERR        = -6,   /**load文件到内存失败*/
        /*Not fully replicated*/
        RT_NOTALL_ERR           = -7,   /**没有复制完全*/
    };

    /**
     * @brief 定义迭代器
     * @brief define iterator
     */
    typedef HashMapIterator     hash_iterator;
    typedef HashMapLockIterator lock_iterator;


    /**
     * @brief 定义hash处理器
     * @brief Define hash processor
     */
    using hash_functor = std::function<size_t (const string& )>;

    //////////////////////////////////////////////////////////////////////////////////////////////

    /**
     * @brief 构造函数
     * @brief Constructor
     */
    TC_HashMap()
    : _iMinDataSize(0)
    , _iMaxDataSize(0)
    , _fFactor(1.0)
    , _fRadio(2)
    , _pDataAllocator(new BlockAllocator(this))
    , _lock_end(this, 0, 0, 0)
    , _end(this, (size_t)(-1))
    , _hashf(hash<string>())
    {
    }

    /**
     *  @brief 定义hash处理器初始化数据块平均大小
     *  @brief Define average hash processor initialization block size
     * 表示内存分配的时候，会分配n个最小块， n个（最小快*增长因子）, n个（最小快*增长因子*增长因子）..., 直到n个最大块
     * When memory allocation is indicated, n smallest blocks, n (minimum fast * growth factor), n (minimum fast * growth factor * growth factor)... Are allocated until n largest blocks
     * n是hashmap自己计算出来的
     * N is calculated by HashMap himself
     * 这种分配策略通常是数据块记录变长比较多的使用， 便于节约内存，如果数据记录基本不是变长的， 那最小块=最大快，增长因子=1就可以了
     * This allocation strategy is usually used when the data block records are longer, which saves memory. If the data block records are not longer at all, then the smallest block = the fastest, and the growth factor = 1 are fine.
     * @param iMinDataSize 最小数据块大小
     * @param iMinDataSize Minimum data block size
     * @param iMaxDataSize 最大数据块大小
     * @param iMaxDataSize Maximum data block size
     * @param fFactor      增长因子
     * @param fFactor      Growth factor
     */
    void initDataBlockSize(size_t iMinDataSize, size_t iMaxDataSize, float fFactor);

    /**
     *  @brief 始化chunk数据块/hash项比值,
     *         默认是2,有需要更改必须在create之前调用
     *  @brief Initialize chunk data block/hash item ratio,
     *         Default is 2, changes are required and must be called before create
     *
     * @param fRadio
     */
    void initHashRadio(float fRadio)                { _fRadio = fRadio;}

    /**
     * @brief 初始化, 之前需要调用:initDataAvgSize和initHashRadio
     * @brief Initialization required before: initDataAvgSize and initHashRadio
     * @param pAddr 绝对地址
     * @param pAddr Absolute Address
     * @param iSize 大小
     * @param iSize size
     * @return 失败则抛出异常
     * @return Failure throws an exception
     */
    void create(void *pAddr, size_t iSize);

    /**
     * @brief  链接到内存块
     * @brief  Link to memory block
     * @param pAddr, 地址
     * @param pAddr address
     * @param iSize, 内存大小
     * @param iSize memory size
     * @return 失败则抛出异常
     * @return Failure throws an exception
     */
    void connect(void *pAddr, size_t iSize);

    /**
     *  @brief 原来的数据块基础上扩展内存,注意通常只能对mmap文件生效
     * (如果iSize比本来的内存就小,则返回-1) 
     * @brief Expand memory based on the original data block, note that it is usually only valid for MMAP files
     * (Returns -1 if iSize is smaller than the original memory)
     * @param pAddr, 扩展后的空间
     * @param pAddr expanded space
     * @param iSize
     * @return 0:成功, -1:失败
     * @return 0:success, -1:failure
     */
    int append(void *pAddr, size_t iSize);

    /**
     *  @brief 获取每种大小内存块的头部信息
     * @brief Get header information for each memory block size
     *
     * @return vector<TC_MemChunk::tagChunkHead>: 不同大小内存块头部信息
     * @return vector<TC_MemChunk::tagChunkHead>: Header information for memory blocks of different sizes
     */
    vector<TC_MemChunk::tagChunkHead> getBlockDetail() { return _pDataAllocator->getBlockDetail(); }

    /**
     * @brief 所有block中chunk的个数
     * @brief Number of chunks in all blocks
     *
     * @return size_t
     */
    size_t allBlockChunkCount()                     { return _pDataAllocator->allBlockChunkCount(); }

    /**
     * @brief 每种block中chunk的个数(不同大小内存块的个数相同)
     * @brief Number of chunks in each block (same number of memory blocks of different sizes)
     *
     * @return vector<size_t>
     */
    vector<size_t> singleBlockChunkCount()          { return _pDataAllocator->singleBlockChunkCount(); }

    /**
     * @brief  获取hash桶的个数
     * @brief Get the number of hash buckets
     *
     * @return size_t
     */
    size_t getHashCount()                           { return _hash.size(); }

    /**
     * @brief  获取元素的个数
     * @brief Get the number of elements
     *
     * @return size_t
     */
    size_t size()                                   { return _pHead->_iElementCount; }

    /**
     * @brief  脏数据元素个数
     * @brief Number of dirty data elements
     *
     * @return size_t
     */
    size_t dirtyCount()                             { return _pHead->_iDirtyCount;}

    /**
     * @brief  OnlyKey数据元素个数
     * @brief Number of OnlyKey data elements
     *
     * @return size_t
     */
    size_t onlyKeyCount()                             { return _pHead->_iOnlyKeyCount;}

    /**
     * @brief 设置每次淘汰数量
     * @brief Set Quantity per Elimination
     * @param n
     */
    void setEraseCount(size_t n)                    { _pHead->_iEraseCount = n; }

    /**
     * @brief  获取每次淘汰数量
     * @brief Get Quantity Eliminated at a Time
     *
     * @return size_t
     */
    size_t getEraseCount()                          { return _pHead->_iEraseCount; }

    /**
     * @brief  设置只读
     * @brief set read-only
     * @param bReadOnly
     */
    void setReadOnly(bool bReadOnly)                { _pHead->_bReadOnly = bReadOnly; }

    /**
     * @brief 是否只读
     * @brief read-only or not
     *
     * @return bool
     */
    bool isReadOnly()                               { return _pHead->_bReadOnly; }

    /**
     * @brief  设置是否可以自动淘汰
     * @brief Set whether auto-elimination is possible
     * @param bAutoErase
     */
    void setAutoErase(bool bAutoErase)              { _pHead->_bAutoErase = bAutoErase; }

    /**
     * @brief  是否可以自动淘汰
     * @brief Is it possible to phase out automatically
     *
     * @return bool
     */
    bool isAutoErase()                              { return _pHead->_bAutoErase; }

    /**
     * @brief  设置淘汰方式
     * @brief Set up elimination method
     * TC_HashMap::ERASEBYGET
     * TC_HashMap::ERASEBYSET
     * @param cEraseMode
     */
    void setEraseMode(char cEraseMode)              { _pHead->_cEraseMode = cEraseMode; }

    /**
     * @brief  获取淘汰方式
     * @brief Get Elimination Methods
     *
     * @return bool
     */
    char getEraseMode()                             { return _pHead->_cEraseMode; }

    /**
     * @brief  设置回写时间(秒)
     * @brief Set Writeback Time (seconds)
     * @param iSyncTime
     */
    void setSyncTime(time_t iSyncTime)              { _pHead->_iSyncTime = iSyncTime; }

    /**
     * @brief  获取回写时间
     * @brief Get Writeback Time
     *
     * @return time_t
     */
    time_t getSyncTime()                            { return _pHead->_iSyncTime; }

    /**
     * @brief  获取头部数据信息
     * @brief Get header data information
     * 
     * @return tagMapHead&
     */
    tagMapHead& getMapHead()                        { return *_pHead; }

    /**
     * @brief  设置hash方式
     * @brief Set hash mode
     * @param hash_of
     */
    void setHashFunctor(hash_functor hashf)         { _hashf = hashf; }

    /**
     * @brief  返回hash处理器
     * @brief Return hash processor
     * 
     * @return hash_functor&
     */
    hash_functor &getHashFunctor()                  { return _hashf; }

    /**
     * @brief  hash item
     * @param index
     *
     * @return tagHashItem&
     */
    tagHashItem *item(size_t iIndex)                { return &_hash[iIndex]; }

    /**
     * @brief  dump到文件
     * @brief Dump to file
     * @param sFile
     *
     * @return int
     *          RT_DUMP_FILE_ERR: dump到文件出错
     *          RT_DUMP_FILE_ERR: dump to file error
     *          RT_OK: dump到文件成功
     *          RT_OK: dump to file succeeded
     */
    int dump2file(const string &sFile);

    /**
     * @brief  从文件load
     * @brief load from file
     * @param sFile
     *
     * @return int
     *          RT_LOAL_FILE_ERR: load出错
     *          RT_LOAL_FILE_ERR: load error  
     *          RT_VERSION_MISMATCH_ERR: 版本不一致
     *          RT_VERSION_MISMATCH_ERR: version inconsistency
     *          RT_OK: load成功
     *          RT_OK: load successfully
     */
    int load5file(const string &sFile);

    /**
     *  @brief 修复hash索引为i的hash链(i不能操作hashmap的索引值)
     * @brief Repair hash chain with hash index I (i cannot manipulate HashMap index values)
     * @param i
     * @param bRepair
     * 
     * @return int
     */
    int recover(size_t i, bool bRepair);

    /**
     * @brief  清空hashmap
     * @brief clear up hashmap
     * 所有map的数据恢复到初始状态
     * Restore all map data to its initial state
     */
    void clear();

    /**
     * @brief  检查数据干净状态
     * @brief Check data cleanliness
     * @param k
     *
     * @return int
     *          RT_NO_DATA: 没有当前数据
     *          RT_NO_DATA: no current data
     *          RT_ONLY_KEY:只有Key
     *          RT_ONLY_KEY: key only
     *          RT_DIRTY_DATA: 是脏数据
     *          RT_DIRTY_DATA: is dirty data
     *          RT_OK: 是干净数据
     *          RT_OK: is clean data
     *          其他返回值: 错误
     *          Other Return Values: Error
     */
    int checkDirty(const string &k);

    /**
     * @brief  设置为脏数据, 修改SET时间链, 会导致数据回写
     * @brief Set to dirty data, modify SET time chain, cause data writeback
     * @param k
     *
     * @return int
     *          RT_READONLY: 只读
     *          RT_READONLY: read-only
     *          RT_NO_DATA: 没有当前数据
     *          RT_NO_DATA: no current data
     *          RT_ONLY_KEY:只有Key
     *          RT_ONLY_KEY: only key
     *          RT_OK: 设置脏数据成功
     *          RT_OK: set dirty data successfully
     *          其他返回值: 错误
     *          Other Return Values: Error
     */
    int setDirty(const string& k);

    /**
     * 数据回写失败后重新设置为脏数据
     * Reset to dirty data after data writeback failure
     * @param k
     *
     * @return int
     *          RT_READONLY: 只读
     *          RT_READONLY: read-only
     *          RT_NO_DATA: 没有当前数据
     *          RT_NO_DATA: no current data
     *          RT_ONLY_KEY:只有Key
     *          RT_ONLY_KEY: only key
     *          RT_OK: 设置脏数据成功
     *          RT_OK: set dirty data successfully
     *          其他返回值: 错误
     *          Other Return Values: Error
     */
    int setDirtyAfterSync(const string& k);

    /**
     * @brief  设置为干净数据, 修改SET链, 导致数据不回写
     * @brief Set to clean data, modify SET chain, result in data not being writeback
     * @param k
     *
     * @return int
     *          RT_READONLY: 只读
     *          RT_READONLY: read-only
     *          RT_NO_DATA: 没有当前数据
     *          RT_NO_DATA: no current data
     *          RT_ONLY_KEY:只有Key
     *          RT_ONLY_KEY: only key
     *          RT_OK: 设置成功
     *          RT_OK: set successfully
     *          其他返回值: 错误
     *          Other Return Values: Error
     */
    int setClean(const string& k);

    /**
     * @brief  获取数据, 修改GET时间链
     * @brief Get data, modify GET time chain
     * @param k
     * @param v
     * @param iSyncTime:数据上次回写的时间
     * @param iSyncTime Time when data was last rewritten
     *
     * @return int:
     *          RT_NO_DATA: 没有数据
     *          RT_NO_DATA: no data
     *          RT_ONLY_KEY:只有Key
     *          RT_ONLY_KEY: key only
     *          RT_OK:获取数据成功
     *          RT_OK:get data successfully
     *          其他返回值: 错误
     *          Other Return Values: Error
     */
    int get(const string& k, string &v, time_t &iSyncTime);

    /**
     * @brief  获取数据, 修改GET时间链
     * @brief Get data, modify GET time chain
     * @param k
     * @param v
     *
     * @return int:
     *          RT_NO_DATA: 没有数据
     *          RT_NO_DATA: no data
     *          RT_ONLY_KEY:只有Key
     *          RT_ONLY_KEY: key only
     *          RT_OK:获取数据成功
     *          RT_OK:get data successfully
     *          其他返回值: 错误
     *          Other Return Values: Error
     */
    int get(const string& k, string &v);

    /**
     * @brief  设置数据, 修改时间链, 内存不够时会自动淘汰老的数据
     * @brief  Set up data, modify time chains, and automatically eliminate old data when memory is low
     * @param k: 关键字
     * @param k keyword
     * @param v: 值
     * @param v value
     * @param bDirty: 是否是脏数据
     * @param bDirty Is it dirty data
     * @param vtData: 被淘汰的记录
     * @param vtData Obsolete records
     * @return int:
     *          RT_READONLY: map只读
     *          RT_READONLY: map read-only
     *          RT_NO_MEMORY: 没有空间(不淘汰数据情况下会出现)
     *          RT_NO_MEMORY: no space(occurs without data phasing out)
     *          RT_OK: 设置成功
     *          RT_OK: set successfully
     *          其他返回值: 错误
     *          Other Return Values: Error
     */
    int set(const string& k, const string& v, bool bDirty, vector<BlockData> &vtData);

    /**
     * @brief  设置key, 但无数据
     * @brief  set key , but no data
     * @param k
     * @param vtData
     *
     * @return int
     *          RT_READONLY: map只读
     *          RT_READONLY: map read-only
     *          RT_NO_MEMORY: 没有空间(不淘汰数据情况下会出现)
     *          RT_NO_MEMORY: no space(occurs without data phasing out)
     *          RT_OK: 设置成功
     *          RT_OK: set successfully
     *          其他返回值: 错误
     *          Other Return Values: Error
     */
    int set(const string& k, vector<BlockData> &vtData);

    /**
     * @brief  删除数据
     * @brief delete data
     * @param k, 关键字
     * @param k keyword
     * @param data, 被删除的记录
     * @param data deleted data
     * @return int:
     *          RT_READONLY: map只读
     *          RT_READONLY: map read-only
     *          RT_NO_DATA: 没有当前数据
     *          RT_NO_DATA: no current data
     *          RT_ONLY_KEY:只有Key, 删除成功
     *          RT_ONLY_KEY:key only, delete successfully
     *          RT_OK: 删除数据成功
     *          RT_OK: delete successfully
     *         其他返回值: 错误
     *          Other Return Values: Error
     */
    int del(const string& k, BlockData &data);

    /**
     * @brief  淘汰数据, 每次删除一条, 根据Get时间淘汰
     * @brief Eliminate data, one at a time, according to Get time
     * 外部循环调用该接口淘汰数据
     * External loop calls this interface to phase out data
     * 直到: 元素个数/chunks * 100 < radio, bCheckDirty 为true时，遇到脏数据则淘汰结束
     * Until: Number of elements / chunks * 100 < radio, bCheckDirty is true, the phase-out ends when dirty data is encountered
     * @param radio: 共享内存chunks使用比例 0< radio < 100
     * @param radio Shared memory chunks usage ratio 0 < radio < 100
     * @param data: 当前被删除的一条记录
     * @param data A record that is currently deleted
     * @return int:
     *          RT_READONLY: map只读
     *          RT_READONLY: map rad-only
     *          RT_OK: 不用再继续淘汰了
     *          RT_OK: No need to continue phasing out
     *          RT_ONLY_KEY:只有Key, 删除成功
     *          RT_ONLY_KEY:key only , delete successfully
     *          RT_DIRTY_DATA:数据是脏数据，当bCheckDirty=true时会有可能产生这种返回值
     *          RT_DIRTY_DATA:The data is dirty and this return value is possible when bCheckDirty=true
     *          RT_ERASE_OK:淘汰当前数据成功, 继续淘汰
     *          RT_ERASE_OK:Successful elimination of current data and continued elimination
     *          其他返回值: 错误, 通常忽略, 继续调用erase淘汰
     *          Other Return Values: Error
     */
    int erase(int radio, BlockData &data, bool bCheckDirty = false);

    /**
     * @brief  回写, 每次返回需要回写的一条
     * @brief Write back, one at a time that needs to be written back
     * 数据回写时间与当前时间超过_pHead->_iSyncTime则需要回写
     * Data Writeback Time and Current Time Over _PHead->_ISyncTime needs writeback
     * _pHead->_iSyncTime由setSyncTime函数设定, 默认10分钟
     * _pHead->_iSyncTime is set by setSyncTime function, default 10 minutes

     * 外部循环调用该函数进行回写
     * Outer loop calls this function to rewrite
     * map只读时仍然可以回写
     * Map can still be rewritten when read-only
     * @param iNowTime: 当前时间
     *                  回写时间与当前时间相差_pHead->_iSyncTime都需要回写
     * @param iNowTime  current time
     *                  Writeback time differs from current time_PHead->_ISyncTime needs writeback
     * @param data : 回写的数据
     * @param data Writeback data
     * @return int:
     *          RT_OK: 到脏数据链表头部了, 可以sleep一下再尝试
     *          RT_OK: to the dirty data chain header, sleep and try again
     *          RT_ONLY_KEY:只有Key, 删除成功, 当前数据不要缓写,继续调用sync回写
     *          RT_ONLY_KEY:Only Key, delete succeeded, do not overwrite current data, continue calling sync writeback
     *          RT_NEED_SYNC:当前返回的data数据需要回写
     *          RT_NEED_SYNC:The data currently returned needs to be written back
     *          RT_NONEED_SYNC:当前返回的data数据不需要回写
     *          RT_NONEED_SYNC:data currently returned, requiring writeback
     *          其他返回值: 错误, 通常忽略, 继续调用sync回写
     *          Other return values: Error, usually ignored, continue to call sync writeback
     */
    int sync(time_t iNowTime, BlockData &data);

    /**
     * @brief  开始回写, 调整回写指针
     * @brief Start Writeback, Adjust Writeback Pointer
     */
    void sync();

    /**
     * @brief  开始备份之前调用该函数
     * @brief Call this function before starting backup
     *
     * @param bForceFromBegin: 是否强制重头开始备份
     * @param bForceFromBegin Whether to force a restart to start backup
     * @return void
     */
    void backup(bool bForceFromBegin = false);

    /**
     * @brief  开始备份数据, 每次返回需要备份的一条数据
     * @brief Start backing up the data, returning one data at a time that needs to be backed up
     * @param data
     *
     * @return int
     *          RT_OK: 备份完毕
     *          RT_OK: Backup complete
     *          RT_NEED_BACKUP:当前返回的data数据需要备份
     *          RT_NEED_BACKUP: The data data currently returned needs to be backed up
     *          RT_ONLY_KEY:只有Key, 当前数据不要备份
     *          RT_ONLY_KEY: Key only, do not backup current data
     *          其他返回值: 错误, 通常忽略, 继续调用backup
     *          Other return values: Error, usually ignored, continue to call backup
     */
    int backup(BlockData &data);

    /////////////////////////////////////////////////////////////////////////////////////////
    // 以下是遍历map函数, 需要对map加锁
    // The following is a traversal map function that requires a lock on the map

    /**
     * @brief  结束
     * @brief the end
     *
     * @return
     */
    lock_iterator end() { return _lock_end; }


    /**
     * @brief  根据Key查找数据
     * @brief Find data based on Key
     * @param string
     */
    lock_iterator find(const string& k);

    /**
     * @brief  block正序
     * @brief Block Positive Order
     *
     * @return lock_iterator
     */
    lock_iterator begin();

    /**
     * @brief  block逆序
     * @brief Block reverse order
     *
     * @return lock_iterator
     */
    lock_iterator rbegin();

    /**
     * @brief  以Set时间排序的迭代器
     * @brief Iterators sorted by Set time
     *
     * @return lock_iterator
     */
    lock_iterator beginSetTime();

    /**
     * @brief  Set链逆序的迭代器
     * @brief Set Chain Inverse Iterator
     *
     * @return lock_iterator
     */
    lock_iterator rbeginSetTime();

    /**
     * @brief  以Get时间排序的迭代器
     * @brief Iterator in Get Time
     *
     * @return lock_iterator
     */
    lock_iterator beginGetTime();

    /**
     * @brief  Get链逆序的迭代器
     * @brief Iterator for Get Chain Reverse Order
     *
     * @return lock_iterator
     */
    lock_iterator rbeginGetTime();

    /**
     * @brief  获取脏链表尾部迭代器(最长时间没有操作的脏数据)
     * @brief Get dirty chain list tail iterator (dirty data that has not been operated on for the longest time)
     *
     * 返回的迭代器++表示按照时间顺序==>(最短时间没有操作的脏数据)
     * The returned iterator++ indicates dirty data in chronological order==> (minimum no operation
     *
     * @return lock_iterator
     */
    lock_iterator beginDirty();

    /////////////////////////////////////////////////////////////////////////////////////////
    // 以下是遍历map函数, 不需要对map加锁
    // The following is a traversal map function that does not require a lock on the map

    /**
     * @brief  根据hash桶遍历
     * @brief Traverse according to hash bucket
     * 
     * @return hash_iterator
     */
    hash_iterator hashBegin();

    /**
     * @brief  结束
     * @brief the end
     *
     * @return
     */
    hash_iterator hashEnd() { return _end; }

    /**
     * 获取指定下标的hash_iterator
     * Get hash_iterator specified subscript
     * @param iIndex
     * 
     * @return hash_iterator
     */
    hash_iterator hashIndex(size_t iIndex);
    
    /**
     * @brief 描述
     * @brief Description
     *
     * @return string
     */
    string desc();

    /**
     * @brief  修改更新到内存中
     * @brief Modify Update to Memory
     */
    void doUpdate(bool bUpdate = false);

protected:

    friend class Block;
    friend class BlockAllocator;
    friend struct HashMapIterator;
    friend class HashMapItem;
    friend struct HashMapLockIterator;
    friend class HashMapLockItem;

    //禁止copy构造
    //Prohibit copy construction
    TC_HashMap(const TC_HashMap &mcm);
    //禁止复制
    //Prohibit copy
    TC_HashMap &operator=(const TC_HashMap &mcm);

    /**
     * @brief  初始化
     * @brief Initialization
     * @param pAddr
     */
    void init(void *pAddr);


    /**
     * @brief  增加脏数据个数
     * @brief Increase the number of dirty data
     */
    void incDirtyCount()    { update(&_pHead->_iDirtyCount, _pHead->_iDirtyCount+1); }

    /**
     * @brief  减少脏数据个数
     * @brief Reduce the number of dirty data
     */
    void delDirtyCount()    { update(&_pHead->_iDirtyCount, _pHead->_iDirtyCount-1); }

    /**
     * @brief  增加数据个数
     * @brief Increase the number of data
     */
    void incElementCount()  { update(&_pHead->_iElementCount, _pHead->_iElementCount+1); }

    /**
     * @brief  减少数据个数
     * @brief Reduce the number of data
     */
    void delElementCount()  { update(&_pHead->_iElementCount, _pHead->_iElementCount-1); }

    /**
     * @brief  增加OnlyKey数据个数
     * @brief Increase the number of OnlyKey data
     */
    void incOnlyKeyCount()    { update(&_pHead->_iOnlyKeyCount, _pHead->_iOnlyKeyCount+1); }

    /**
     * @brief 减少OnlyKey数据个数
     * @brief Reduce the number of OnlyKey data
     */
    void delOnlyKeyCount()    { update(&_pHead->_iOnlyKeyCount, _pHead->_iOnlyKeyCount-1); }

    /**
     * @brief  增加Chunk数
     * @brief Increase the number of Chunks
     * 直接更新, 因为有可能一次分配的chunk个数
     * Update directly because it is possible to allocate the number of chunks at a time
     * 多余更新区块的内存空间, 导致越界错误
     * Excess memory space for updating blocks, causing out-of-bounds errors
     */
    void incChunkCount()    { _pHead->_iUsedChunk++; }

    /**
     * @brief  减少Chunk数
     * @brief Reduce the number of Chunks
     * 直接更新, 因为有可能一次释放的chunk个数
     * Update directly because of the number of chunks that may be released at one time
     * 多余更新区块的内存空间, 导致越界错误
     * Excess memory space for updating blocks, causing out-of-bounds errors
     */
    void delChunkCount()    { _pHead->_iUsedChunk--; }

    /**
     * @brief  增加hit次数
     * @brief Increase hit count
     */
    void incGetCount()      { update(&_pHead->_iGetCount, _pHead->_iGetCount+1); }

    /**
     * @brief  增加命中次数
     * @brief Increase Hits
     */
    void incHitCount()      { update(&_pHead->_iHitCount, _pHead->_iHitCount+1); }

    /**
     * @brief  某hash链表数据个数+1
     * @brief Number of data in a Hash list +1
     * @param index
     */
    void incListCount(uint32_t index) { update(&item(index)->_iListCount, (uint32_t)item(index)->_iListCount+1); }

    /**
     * @brief  某hash链表数据个数+1
     * @brief Number of data in a Hash list +1
     * @param index
     */
    void delListCount(size_t index) { update(&item(index)->_iListCount, (uint32_t)item(index)->_iListCount-1); }

    /**
     * @brief 相对地址换成绝对地址
     * @brief Replace relative address with absolute address
     * @param iAddr
     *
     * @return void*
     */
    void *getAbsolute(size_t iAddr) { return (void *)((char*)_pHead + iAddr); }

    /**
     * @brief  绝对地址换成相对地址
     * @brief Replace absolute address with relative address
     *
     * @return size_t
     */
    size_t getRelative(void *pAddr) { return (char*)pAddr - (char*)_pHead; }

    /**
     * @brief  淘汰iNowAddr之外的数据(根据淘汰策略淘汰)
     * @brief Eliminate data other than iNowAddr (Eliminate by Elimination Strategy)
     * @param iNowAddr, 当前Block不能正在分配空间, 不能被淘汰
     *                  0表示做直接根据淘汰策略淘汰
     * @param iNowAddr The current block cannot allocate space and cannot be phased out
     *                  0 means to phase out directly according to the elimination strategy
     * @param vector<BlockData>, 被淘汰的数据
     * @param vector<BlockData> Eliminated data
     * @return size_t,淘汰的数据个数
     * @return size_t  Number of data eliminated
     */
    size_t eraseExcept(size_t iNowAddr, vector<BlockData> &vtData);

    /**
     * @brief  根据Key计算hash值
     * @brief Calculate the number of hash values based on Key
     * @param pKey
     * @param iKeyLen
     *
     * @return size_t
     */
    size_t hashIndex(const string& k);

    /**
     * @brief  根据Key查找数据
     * @brief Find data based on Key
     *
     */
    lock_iterator find(const string& k, size_t index, string &v, int &ret);

    /**
     * @brief  根据Key查找数据
     * @brief Find data based on Key
     * @param mb
     */
    lock_iterator find(const string& k, size_t index, int &ret);

    /**
     * @brief  分析hash的数据
     * @brief Analyzing hash data
     * @param iMaxHash
     * @param iMinHash
     * @param fAvgHash
     */
    void analyseHash(uint32_t &iMaxHash, uint32_t &iMinHash, float &fAvgHash);

    /**
     * @brief  修改具体的值
     * @brief Modify specific values
     * @param iModifyAddr
     * @param iModifyValue
     */
    void update(void* iModifyAddr, size_t iModifyValue);

#if __WORDSIZE == 64 || defined _WIN64
    void update(void* iModifyAddr, uint32_t iModifyValue);
#endif

    /**
     *
     * @param iModifyAddr
     * @param iModifyValue
     */
    void update(void* iModifyAddr, bool bModifyValue);

    /**
     * @brief  获取大于n且离n最近的素数
     * @brief Gets the nearest prime number greater than n
     * @param n
     *
     * @return size_t
     */
    size_t getMinPrimeNumber(size_t n);

protected:

    /**
     * 区块指针
     * Block Pointer
     */
    tagMapHead                  *_pHead;

    /**
     * 最小的数据块大小
     * Minimum data block size
     */
    size_t                      _iMinDataSize;

    /**
     * 最大的数据块大小
     * Maximum data block size
     */
    size_t                      _iMaxDataSize;

    /**
     * 变化因子
     * changing factors
     */
    float                       _fFactor;

    /**
     * 设置chunk数据块/hash项比值
     * Set chunk data block/hash item ratio
     */
    float                       _fRadio;

    /**
     * hash对象
     * hash object
     */
    TC_MemVector<tagHashItem>   _hash;

    /**
     * 修改数据块
     * Modify Data Block
     */
    tagModifyHead               *_pstModifyHead;

    /**
     * block分配器对象
     * Block allocator object
     */
    BlockAllocator              *_pDataAllocator;

    /**
     * 尾部
     * Tail
     */
    lock_iterator               _lock_end;

    /**
     * 尾部
     * Tail
     */
    hash_iterator               _end;

    /**
     * hash值计算公式
     * Hash Value Formula
     */
    hash_functor                _hashf;
};

}

#endif

