/home/mhx/git/github/libmoost/include/moost/kvstore/detail/kyoto_tycoon_connection_linux.h

Go to the documentation of this file.

/* vim:set ts=3 sw=3 sts=3 et: */



#ifndef MOOST_KVSTORE_DETAIL_KYOTO_TYCOON_CONNECTION_LINUX_H
#define MOOST_KVSTORE_DETAIL_KYOTO_TYCOON_CONNECTION_LINUX_H

#include <string>

#include <boost/shared_ptr.hpp>

#include "../i_kyoto_tycoon_connection.h"

namespace kyototycoon {
   class RemoteDB;
}

namespace moost { namespace kvstore { namespace detail {

class KyotoTycoonConnection : public IKyotoTycoonConnection
{
public:

   KyotoTycoonConnection() : isOpen_(false) { }

   virtual ~KyotoTycoonConnection();

   virtual void open(const std::string& host, int port, int timeoutMs);

   virtual void close();

public:

   // native store methods

   // return value is a C-style string of length vsize
   // (not including the trailing null byte)
   virtual boost::shared_array<char> get(const void* pkey, size_t ksize, size_t& vsize) const;

   // throws on failure
   virtual void set(const void* pkey, size_t ksize, const void* pval, size_t vsize) const;

   // throws on failure
   virtual void cache(const void* pkey, size_t ksize, const void* pval, size_t vsize, boost::int64_t expirySecs) const;

private:

   void throw_kt_exception(const std::string& msg) const;

   void assert_data_store_open() const;

private:

   boost::shared_ptr<kyototycoon::RemoteDB> pDb_;
   bool isOpen_;
};

}}}  // end namespace

#endif