King_DuckZ/dindexer
1
0
Fork 0
mirror of https://github.com/KingDuckZ/dindexer.git synced 2025-02-20 12:14:55 +00:00
Code Issues Releases Wiki Activity

Add support for single chars to the run() method.

Browse source
This commit is contained in:
King_DuckZ 2016-06-14 09:10:45 +01:00
parent 9a69b8de10
commit efd7118189
4 changed files with 42 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/backends/redis/arg_to_bin_safe.hpp
View file

@ -55,6 +55,16 @@ namespace redis {
const std::size_t m_size;
};
template<>
struct MakeCharInfo<char> {
MakeCharInfo ( char parData ) : m_data(parData) {}
const char* data ( void ) const { return &m_data; }
std::size_t size ( void ) const { return 1; }
private:
const char m_data;
};
template <typename T>
inline const char* arg_to_bin_safe_char (const T& parArg) {
return MakeCharInfo<T>(parArg).data();

35
src/backends/redis/backend_redis.cpp
View file

@ -91,9 +91,6 @@ namespace dindb {
}
void BackendRedis::tag_files (const std::vector<std::string>& parRegexes, const std::vector<boost::string_ref>& parTags, GroupIDType parSet) {
for (const auto& file_path : m_redis.scan()) {
//std::cout << file_path << '\n';
}
}
void BackendRedis::delete_tags (const std::vector<FileIDType>& parFiles, const std::vector<boost::string_ref>& parTags, GroupIDType parSet) {
@ -114,9 +111,35 @@ namespace dindb {
void BackendRedis::write_files (const std::vector<mchlib::FileRecordData>& parData, const mchlib::SetRecordDataFull& parSetData, const std::string& parSignature) {
using boost::lexical_cast;
auto incr_reply = m_redis.run("HINCRBY " PROGRAM_NAME ":indices set 1");
const std::string set_key = PROGRAM_NAME ":set:" + lexical_cast<std::string>(redis::get_integer(incr_reply));
auto insert_set_reply = m_redis.run("HMSET %b name %b disk_label %b fs_uuid %b", set_key, parSetData.name, parSetData.disk_label, parSetData.fs_uuid);
redis::Reply set_id_reply = m_redis.run("HINCRBY " PROGRAM_NAME ":indices set 1");
const std::string set_key = PROGRAM_NAME ":set:" + lexical_cast<std::string>(redis::get_integer(set_id_reply));
redis::Reply insert_set_reply = m_redis.run(
"HMSET %b name %b disk_label %b fs_uuid %b type %b content_type %b",
set_key,
parSetData.name,
parSetData.disk_label,
parSetData.fs_uuid,
parSetData.type,
parSetData.content_type
);
for (const auto& file_data : parData) {
redis::Reply file_id_reply = m_redis.run("HINCRBY " PROGRAM_NAME ":indices files 1");
const std::string file_key = PROGRAM_NAME ":file:" + lexical_cast<std::string>(redis::get_integer(file_id_reply));
redis::Reply insert_file_reply = m_redis.run(
"HMSET %b hash %b path %b size %b level %b mime_type %b mime_charset %b is_directory %b is_symlink %b is_unreadable %b hash_valid %b",
file_key,
tiger_to_string(file_data.hash),
lexical_cast<std::string>(file_data.size),
lexical_cast<std::string>(file_data.level),
file_data.mime_type(),
file_data.mime_charset(),
(file_data.is_directory ? '1' : '0'),
(file_data.is_symlink ? '1' : '0'),
(file_data.unreadable ? '1' : '0'),
(file_data.hash_valid ? '1' : '0')
);
}
}
bool BackendRedis::search_file_by_hash (mchlib::FileRecordData& parItem, mchlib::SetRecordDataFull& parSet, const mchlib::TigerHash& parHash) {

3
src/backends/redis/command.hpp
View file

@ -81,11 +81,12 @@ namespace redis {
using LengthArray = std::array<std::size_t, arg_count>;
using implem::arg_to_bin_safe_char;
using implem::arg_to_bin_safe_length;
using implem::MakeCharInfo;
using boost::string_ref;
return this->run_pvt(
static_cast<int>(arg_count),
CharPointerArray{ arg_to_bin_safe_char(string_ref(parCommand)), arg_to_bin_safe_char(std::forward<Args>(parArgs))... }.data(),
CharPointerArray{ (arg_to_bin_safe_char(string_ref(parCommand))), MakeCharInfo<typename std::remove_const<typename std::remove_reference<Args>::type>::type>(std::forward<Args>(parArgs)).data()... }.data(),
LengthArray{ arg_to_bin_safe_length(string_ref(parCommand)), arg_to_bin_safe_length(std::forward<Args>(parArgs))... }.data()
);
}

2
src/backends/redis/reply.hpp
View file

@ -23,7 +23,7 @@
#include <vector>
namespace redis {
class Reply;
struct Reply;
namespace implem {
using RedisVariantType = boost::variant<