// **********************************************************************
//
// Copyright (c) 2003-2017 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************

#ifndef ICE_GRID_CACHE_H
#define ICE_GRID_CACHE_H

#include <IceUtil/Mutex.h>
#include <IceUtil/Shared.h>
#include <IceGrid/Util.h>
#include <IceGrid/TraceLevels.h>

namespace IceGrid
{

class SynchronizationCallback : public virtual IceUtil::Shared
{
public:

    virtual void synchronized() = 0;

    virtual void synchronized(const Ice::Exception&) = 0;
};
typedef IceUtil::Handle<SynchronizationCallback> SynchronizationCallbackPtr;

template<typename Key, typename Value>
class Cache : public IceUtil::Monitor<IceUtil::Mutex>
{
    typedef IceUtil::Handle<Value> ValuePtr;
    typedef std::map<Key, ValuePtr> ValueMap;

public:

    Cache() : _entriesHint(_entries.end())
    {
    }

    virtual 
    ~Cache()
    {
    }

    bool 
    has(const Key& key) const
    {
        Lock sync(*this);
        return getImpl(key);
    }

    void
    remove(const Key& key)
    {
        Lock sync(*this);
        removeImpl(key);
    }

    void 
    setTraceLevels(const TraceLevelsPtr& traceLevels)
    { 
        _traceLevels = traceLevels;
    }

    const TraceLevelsPtr& getTraceLevels() const { return _traceLevels; }

protected:

    virtual ValuePtr 
    getImpl(const Key& key) const
    {
        typename ValueMap::iterator p = const_cast<ValueMap&>(_entries).end();
        if(_entriesHint != p)
        {
            if(_entriesHint->first == key)
            {
                p = _entriesHint;
            }
        }
        
        if(p == const_cast<ValueMap&>(_entries).end())
        {
            p = const_cast<ValueMap&>(_entries).find(key);
        }
        
        if(p != const_cast<ValueMap&>(_entries).end())
        {
            const_cast<typename ValueMap::iterator&>(_entriesHint) = p;
            return p->second;
        }
        else
        {
            return 0;
        }
    }

    virtual ValuePtr
    addImpl(const Key& key, const ValuePtr& entry)
    {
        typename ValueMap::value_type v(key, entry);
        _entriesHint = _entries.insert(_entriesHint, v);
        return entry;
    }

    virtual void
    removeImpl(const Key& key)
    {
        typename ValueMap::iterator p = _entries.end();
        if(_entriesHint != _entries.end())
        {
            if(_entriesHint->first == key)
            {
                p = _entriesHint;
            }
        }
        
        if(p == _entries.end())
        {
            p = _entries.find(key);
        }
        
        assert(p != _entries.end());
        if(p->second->canRemove())
        {
            _entries.erase(p);
            _entriesHint = _entries.end();
        }
        else
        {
            _entriesHint = p;
        }
    }

    TraceLevelsPtr _traceLevels;
    ValueMap _entries;
    typename ValueMap::iterator _entriesHint;    
};

template<typename T>
class CacheByString : public Cache<std::string, T>
{
    typedef IceUtil::Handle<T> TPtr;

public:

    virtual std::vector<std::string>
    getAll(const std::string& expr)
    {
        IceUtil::Monitor<IceUtil::Mutex>::Lock sync(*this);
        return getMatchingKeys<std::map<std::string,TPtr> >(Cache<std::string, T>::_entries, expr);
    }
};

};

#endif