kea/src/lib/cache/message_cache.cc

// Copyright (C) 2010  Internet Systems Consortium, Inc. ("ISC")
//
// Permission to use, copy, modify, and/or distribute this software for any
// purpose with or without fee is hereby granted, provided that the above
// copyright notice and this permission notice appear in all copies.
//
// THE SOFTWARE IS PROVIDED "AS IS" AND ISC DISCLAIMS ALL WARRANTIES WITH
// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
// AND FITNESS.  IN NO EVENT SHALL ISC BE LIABLE FOR ANY SPECIAL, DIRECT,
// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE
// OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
// PERFORMANCE OF THIS SOFTWARE.

// $Id$

#include <nsas/nsas_entry_compare.h>
#include <nsas/hash_table.h>
#include <nsas/hash_deleter.h>
#include "message_cache.h"
#include "cache_entry_key.h"

using namespace isc::nsas;
using namespace isc::dns;

namespace isc {
namespace cache {

MessageCache::MessageCache(boost::shared_ptr<RRsetCache> rrset_cache,
    uint32_t cache_size, uint16_t message_class):
    message_class_(message_class),
    rrset_cache_(rrset_cache),
    message_table_(new NsasEntryCompare<MessageEntry>, cache_size),
    message_lru_((3 * cache_size),
                  new HashDeleter<MessageEntry>(message_table_))

{
}
    
bool
MessageCache::lookup(const isc::dns::Name& qname,
                     const isc::dns::RRType& qtype,
                     const uint16_t query_header,
                     isc::dns::Message& response)
{
    std::pair<const char*, const uint32_t> keydata = genCacheEntryKey(qname, qtype);

    //TODO, HashKey need to be refactored, since we don't need query class
    // as the parameters.
    boost::shared_ptr<MessageEntry> msg_entry = message_table_.get(HashKey(
                keydata.first, keydata.second, RRClass(message_class_)));
    if(msg_entry) {
       return msg_entry->genMessage(time(NULL), query_header, response);
    }

    return false;
}

bool
MessageCache::update(const Message&) {
    return true;
}

void
MessageCache::dump(const std::string&) {
}

void
MessageCache::load(const std::string&) {
}

bool
MessageCache::resize(uint32_t) {
    return true;
}

} // namespace cache
} // namespace isc