Skip to content

H
HEPnOS
Commit c71d3a17 authored by Matthieu Dorier's avatar Matthieu Dorier
Browse files
Options

added comments to DataSet.hpp

parent 2127dacf
Hide whitespace changes
Inline Side-by-side
Showing with 223 additions and 66 deletions
include/hepnos/DataSet.hpp
View file @ c71d3a17
......@@ -12,79 +12,236 @@
namespace hepnos {
/**
* @brief The DataSet class represents a handle to a named dataset
* stored either at the root of an HEPnOS DataStore service, or within
* another dataset. It provides functionalities to navigate nested
* datasets and to load/store data products.
*/
class DataSet {
friend class DataStore;
private:
DataSet(DataStore& ds, uint8_t level, const std::string& fullname);
DataSet(DataStore& ds, uint8_t level, const std::string& container, const std::string& name);
bool storeBuffer(const std::string& key, const std::vector<char>& buffer);
bool loadBuffer(const std::string& key, std::vector<char>& buffer) const;
class Impl;
std::unique_ptr<Impl> m_impl;
/**
* @brief Constructor.
*
* @param ds DataStore to which this DataSet belongs.
* @param level Level of nesting.
* @param fullname Full name of the DataSet.
*/
DataSet(DataStore& ds, uint8_t level, const std::string& fullname);
/**
* @brief Constructor.
*
* @param ds DataStore to which this DataSet belongs.
* @param level Level of nesting.
* @param container Full name of the parent DataSet ("" if no parent).
* @param name Name of the DataSet.
*/
DataSet(DataStore& ds, uint8_t level, const std::string& container, const std::string& name);
/**
* @brief Stores binary data associated with a particular key into this DataSet.
* This function will return true if the key did not already exist and the
* write succeeded. It will return false otherwise.
*
* @param key Key.
* @param buffer Binary data to insert.
*
* @return trye if the key did not already exist and the write succeeded,
* false otherwise.
*/
bool storeBuffer(const std::string& key, const std::vector<char>& buffer);
/**
* @brief Loads binary data associated with a particular key from the DataSet.
* This function will return true if the key exists and the read succeeded.
* It will return false otherwise.
*
* @param key Key.
* @param buffer Buffer in which to put the binary data.
*
* @return true if the key exists and the read succeeded,
* false otherwise.
*/
bool loadBuffer(const std::string& key, std::vector<char>& buffer) const;
/**
* @brief Implementation class (used for the Pimpl idiom).
*/
class Impl;
std::unique_ptr<Impl> m_impl; /*!< Pointer to implementation. */
public:
DataSet();
DataSet(const DataSet&);
DataSet(DataSet&&);
DataSet& operator=(const DataSet&);
DataSet& operator=(DataSet&&);
~DataSet();
const std::string& name() const;
const std::string& container() const;
std::string fullname() const;
DataSet next() const;
bool valid() const;
template<typename K, typename V>
bool store(const K& key, const V& value) {
std::stringstream ss_key, ss_value;
ss_key << key;
boost::archive::binary_oarchive oa(ss_value);
try {
oa << value;
} catch(...) {
throw Exception("Exception occured during serialization");
}
std::string serialized = ss_value.str();
std::vector<char> buffer(serialized.begin(), serialized.end());
return storeBuffer(ss_key.str(), buffer);
/**
* @brief Default constructor.
*/
DataSet();
/**
* @brief Copy-constructor.
*
* @param other DataSet to copy.
*/
DataSet(const DataSet& other);
/**
* @brief Move-constructor.
*
* @param other DataSet to move.
*/
DataSet(DataSet&& other);
/**
* @brief Copy-assignment operator.
*
* @param other DataSet to copy.
*
* @return this.
*/
DataSet& operator=(const DataSet& other);
/**
* @brief Move-assignment operator.
*
* @param other DataSet to move.
*
* @return this.
*/
DataSet& operator=(DataSet&& other);
/**
* @brief Destructor.
*/
~DataSet();
/**
* @brief Name of the DataSet.
*
* @return the name of the DataSet.
*/
const std::string& name() const;
/**
* @brief Name of the container of the DataSet.
*
* @return the name of the container of the DataSet.
*/
const std::string& container() const;
/**
* @brief Full name of the DataSet
* (container() + "/" + name() if container() is not empty,
* name() otherwise)
*
* @return the full name of the DataSet.
*/
std::string fullname() const;
/**
* @brief Gets the next DataSet from this DataSet in
* alphabetical order within the same container.
* If no such dataset exists, this function returns
* a DataSet instance such that valid() == false.
*
* @return the next DataSet from this DataSet.
*/
DataSet next() const;
/**
* @brief Check if a DataSet is valid, i.e. if it
* corresponds to a DataSet that exists in the
* underlying DataStore.
*
* @return true if the DataSet is valid, false otherwise.
*/
bool valid() const;
/**
* @brief Stores a key/value pair into the DataSet.
* The type of the key should have operator<< available
* to stream it into a std::stringstream for the purpose
* of converting it into an std::string. The resulting
* string must not have the "/" or "#" characters. The
* type of the value must be serializable using Boost.
*
* @tparam K type of the key.
* @tparam V type of the value.
* @param key Key to store.
* @param value Value to store.
*
* @return true if the key was found. false otherwise.
*/
template<typename K, typename V>
bool store(const K& key, const V& value) {
std::stringstream ss_value;
boost::archive::binary_oarchive oa(ss_value);
try {
oa << value;
} catch(...) {
throw Exception("Exception occured during serialization");
}
template<typename K, typename V>
bool load(const K& key, V& value) const {
std::stringstream ss_key;
ss_key << key;
std::vector<char> buffer;
if(!loadBuffer(key, buffer)) {
return false;
}
try {
std::string serialized(buffer.begin(), buffer.end());
std::stringstream ss(serialized);
boost::archive::binary_iarchive ia(ss);
ia >> value;
} catch(...) {
throw Exception("Exception occured during serialization");
}
return true;
std::string serialized = ss_value.str();
std::vector<char> buffer(serialized.begin(), serialized.end());
return storeBuffer(key, buffer);
}
/**
* @brief Loads a value associated with a key from the DataSet.
* The type of the key should have operator<< available
* to stream it into a std::stringstream for the purpose
* of converting it into an std::string. The resulting
* string must not have the "/" or "#" characters. The
* type of the value must be serializable using Boost.
*
* @tparam K type of the key.
* @tparam V type of the value.
* @param key Key to load.
* @param value Value to load.
*
* @return bool if the
*/
template<typename K, typename V>
bool load(const K& key, V& value) const {
std::vector<char> buffer;
if(!loadBuffer(key, buffer)) {
return false;
}
bool operator==(const DataSet& other) const;
try {
std::string serialized(buffer.begin(), buffer.end());
std::stringstream ss(serialized);
boost::archive::binary_iarchive ia(ss);
ia >> value;
} catch(...) {
throw Exception("Exception occured during serialization");
}
return true;
}
/**
* @brief Comparison operator.
*
* @param other DataSet to compare with.
*
* @return true of both DataSets point to the same
* entry in the HEPnOS service, false otherwise.
*/
bool operator==(const DataSet& other) const;
/**
* @brief Comparison operator.
*
* @param other DataSet to compare with.
*
* @return false of both DataSets point to the same
* entry in the HEPnOS service, true otherwise.
*/
bool operator!=(const DataSet& other) const;
};
}
......
src/DataSet.cpp
View file @ c71d3a17
......@@ -78,10 +78,6 @@ bool DataSet::loadBuffer(const std::string& key, std::vector<char>& buffer) cons
throw Exception("Calling load() on invalid DataSet");
}
// forward the call to the datastore's load function
std::stringstream ss;
if(m_impl->m_container.size() != 0)
ss << m_impl->m_container << "/";
ss << m_impl->m_name;
return m_impl->m_datastore->load(0, fullname(), key, buffer);
}
......@@ -92,6 +88,10 @@ bool DataSet::operator==(const DataSet& other) const {
&& m_impl->m_name == other.m_impl->m_name;
}
bool DataSet::operator!=(const DataSet& other) const {
return !(*this == other);
}
const std::string& DataSet::name() const {
return m_impl->m_name;
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment