cleaning up the repo a bit
This commit is contained in:
Dominik Tomičević
parent
37fba19cc6
commit
79ec770af3
@ -1,7 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_DATA_MODEL_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_DATA_MODEL_HPP
|
||||
|
||||
#include "node.hpp"
|
||||
#include "edge.hpp"
|
||||
|
||||
#endif
|
||||
@ -1,17 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_EDGE_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_EDGE_HPP
|
||||
|
||||
#include "json/all.hpp"
|
||||
#include "record.hpp"
|
||||
|
||||
struct Node;
|
||||
|
||||
struct Edge : Record
|
||||
{
|
||||
Node* from;
|
||||
Node* to;
|
||||
|
||||
json::Object* data;
|
||||
};
|
||||
|
||||
#endif
|
||||
@ -1,13 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_GRAPH_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_GRAPH_HPP
|
||||
|
||||
#include <vector>
|
||||
|
||||
#include "node.hpp"
|
||||
#include "edge.hpp"
|
||||
|
||||
struct Graph
|
||||
{
|
||||
}
|
||||
|
||||
#endif
|
||||
@ -1,14 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_JSON_ALL_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_JSON_ALL_HPP
|
||||
|
||||
#include "array.hpp"
|
||||
#include "bool.hpp"
|
||||
#include "integral.hpp"
|
||||
#include "json.hpp"
|
||||
#include "null.hpp"
|
||||
#include "object.hpp"
|
||||
#include "primitive.hpp"
|
||||
#include "real.hpp"
|
||||
#include "string.hpp"
|
||||
|
||||
#endif
|
||||
@ -1,84 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_JSON_ARRAY_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_JSON_ARRAY_HPP
|
||||
|
||||
#include <cassert>
|
||||
#include <memory>
|
||||
#include <vector>
|
||||
|
||||
#include "utilities/string/intercalate.hpp"
|
||||
|
||||
#include "json.hpp"
|
||||
|
||||
namespace json
|
||||
{
|
||||
|
||||
class Array final : public Json
|
||||
{
|
||||
public:
|
||||
Array() {}
|
||||
|
||||
template <typename It>
|
||||
Array(It first, It last)
|
||||
: elements(first, last) {}
|
||||
|
||||
Array(std::initializer_list<spJson> elements)
|
||||
: elements(elements) {}
|
||||
|
||||
virtual bool is_array() const;
|
||||
|
||||
size_t size() const;
|
||||
|
||||
Array& push(const std::shared_ptr<Json>& element);
|
||||
|
||||
const spJson& operator[](size_t i) const;
|
||||
spJson operator[](size_t i);
|
||||
|
||||
virtual operator std::string() const;
|
||||
|
||||
private:
|
||||
std::vector<spJson> elements;
|
||||
};
|
||||
|
||||
bool Array::is_array() const
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
size_t Array::size() const
|
||||
{
|
||||
return elements.size();
|
||||
}
|
||||
|
||||
Array& Array::push(const spJson& element)
|
||||
{
|
||||
assert(element);
|
||||
|
||||
elements.push_back(element);
|
||||
return *this;
|
||||
}
|
||||
|
||||
const spJson& Array::operator[](size_t i) const
|
||||
{
|
||||
return elements[i];
|
||||
}
|
||||
|
||||
spJson Array::operator[](size_t i)
|
||||
{
|
||||
return elements[i];
|
||||
}
|
||||
|
||||
Array::operator std::string() const
|
||||
{
|
||||
std::vector<std::string> xs;
|
||||
|
||||
std::transform(elements.begin(), elements.end(), std::back_inserter(xs),
|
||||
[](const spJson& element) {
|
||||
return static_cast<std::string>(*element);
|
||||
});
|
||||
|
||||
return "[" + utils::intercalate(xs.begin(), xs.end(), ",") + "]";
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
#endif
|
||||
@ -1,33 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_JSON_BOOL_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_JSON_BOOL_HPP
|
||||
|
||||
#include "primitive.hpp"
|
||||
|
||||
namespace json {
|
||||
|
||||
class Bool final : public Primitive<bool>
|
||||
{
|
||||
public:
|
||||
Bool() {}
|
||||
|
||||
Bool(bool value)
|
||||
: Primitive<bool>(value) {}
|
||||
|
||||
virtual bool is_boolean() const;
|
||||
|
||||
virtual operator std::string() const;
|
||||
};
|
||||
|
||||
bool Bool::is_boolean() const
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
Bool::operator std::string() const
|
||||
{
|
||||
return value == true ? "true" : "false";
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
#endif
|
||||
@ -1,33 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_JSON_INTEGRAL_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_JSON_INTEGRAL_HPP
|
||||
|
||||
#include "primitive.hpp"
|
||||
|
||||
namespace json {
|
||||
|
||||
class Integral final : public Primitive<int64_t>
|
||||
{
|
||||
public:
|
||||
Integral() {}
|
||||
|
||||
Integral(int64_t value)
|
||||
: Primitive<int64_t>(value) {}
|
||||
|
||||
virtual bool is_integral() const;
|
||||
|
||||
virtual operator std::string() const;
|
||||
};
|
||||
|
||||
bool Integral::is_integral() const
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
Integral::operator std::string() const
|
||||
{
|
||||
return std::to_string(value);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
#endif
|
||||
@ -1,47 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_JSON_JSON_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_JSON_JSON_HPP
|
||||
|
||||
#include <initializer_list>
|
||||
#include <string>
|
||||
#include <memory>
|
||||
|
||||
namespace json {
|
||||
|
||||
class Json;
|
||||
|
||||
typedef std::shared_ptr<Json> spJson;
|
||||
|
||||
class Json
|
||||
{
|
||||
public:
|
||||
Json() {}
|
||||
virtual ~Json() {}
|
||||
|
||||
virtual bool is_object() const { return false; }
|
||||
virtual bool is_array() const { return false; }
|
||||
virtual bool is_real() const { return false; }
|
||||
virtual bool is_integral() const { return false; }
|
||||
virtual bool is_boolean() const { return false; }
|
||||
virtual bool is_null() const { return false; }
|
||||
|
||||
template <typename T> T& as();
|
||||
template <typename T> const T& as() const;
|
||||
|
||||
virtual operator std::string() const = 0;
|
||||
};
|
||||
|
||||
template <typename T>
|
||||
T& Json::as()
|
||||
{
|
||||
return *dynamic_cast<T*>(this);
|
||||
}
|
||||
|
||||
template <typename T>
|
||||
const T& Json::as() const
|
||||
{
|
||||
return *dynamic_cast<T*>(this);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
#endif
|
||||
@ -1,30 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_JSON_NULL_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_JSON_NULL_HPP
|
||||
|
||||
#include "json.hpp"
|
||||
|
||||
namespace json {
|
||||
|
||||
class Null final : public Json
|
||||
{
|
||||
public:
|
||||
Null() {}
|
||||
|
||||
virtual bool is_null() const;
|
||||
|
||||
virtual operator std::string() const;
|
||||
};
|
||||
|
||||
bool Null::is_null() const
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
Null::operator std::string() const
|
||||
{
|
||||
return "null";
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
#endif
|
||||
@ -1,106 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_JSON_OBJECT_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_JSON_OBJECT_HPP
|
||||
|
||||
#include <iostream>
|
||||
|
||||
#include <functional>
|
||||
#include <sstream>
|
||||
#include <cassert>
|
||||
#include <vector>
|
||||
#include <map>
|
||||
|
||||
#include "utilities/string/intercalate.hpp"
|
||||
|
||||
#include "json.hpp"
|
||||
|
||||
namespace json {
|
||||
|
||||
typedef std::pair<const std::string, spJson> const_kv_pair_t;
|
||||
typedef std::pair<std::string, spJson> kv_pair_t;
|
||||
|
||||
class Object;
|
||||
|
||||
typedef std::shared_ptr<Object> spObject;
|
||||
|
||||
class Object : public Json
|
||||
{
|
||||
public:
|
||||
Object() {}
|
||||
|
||||
Object(std::initializer_list<const_kv_pair_t> elements)
|
||||
: props(elements) {}
|
||||
|
||||
virtual bool is_object() const;
|
||||
|
||||
const spJson& at(const std::string& key) const;
|
||||
spJson at(const std::string& key);
|
||||
|
||||
const spJson& operator[](const std::string& key) const;
|
||||
spJson operator[](const std::string& key);
|
||||
|
||||
Object& put(const std::string& key, spJson value);
|
||||
|
||||
Object& operator<<(const kv_pair_t& kv_pair);
|
||||
|
||||
virtual operator std::string() const;
|
||||
|
||||
protected:
|
||||
std::map<std::string, spJson> props;
|
||||
};
|
||||
|
||||
bool Object::is_object() const
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
const spJson& Object::at(const std::string& key) const
|
||||
{
|
||||
return props.at(key);
|
||||
}
|
||||
|
||||
spJson Object::at(const std::string& key)
|
||||
{
|
||||
return props.at(key);
|
||||
}
|
||||
|
||||
const spJson& Object::operator[](const std::string& key) const
|
||||
{
|
||||
return this->at(key);
|
||||
}
|
||||
|
||||
spJson Object::operator[](const std::string& key)
|
||||
{
|
||||
return this->at(key);
|
||||
}
|
||||
|
||||
Object& Object::put(const std::string& key, spJson value)
|
||||
{
|
||||
assert(value);
|
||||
|
||||
props[key] = value;
|
||||
return *this;
|
||||
}
|
||||
|
||||
Object& Object::operator<<(const kv_pair_t& kv_pair)
|
||||
{
|
||||
return this->put(std::get<0>(kv_pair), std::get<1>(kv_pair));
|
||||
}
|
||||
|
||||
Object::operator std::string() const
|
||||
{
|
||||
if(props.empty())
|
||||
return "{}";
|
||||
|
||||
std::vector<std::string> xs;
|
||||
|
||||
std::transform(props.begin(), props.end(), std::back_inserter(xs),
|
||||
[](const kv_pair_t& kvp) {
|
||||
return "\"" + kvp.first + "\":" + static_cast<std::string>(*kvp.second);
|
||||
});
|
||||
|
||||
return "{" + utils::intercalate(xs.begin(), xs.end(), ",") + "}";
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
#endif
|
||||
@ -1,29 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_JSON_PRIMITIVE_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_JSON_PRIMITIVE_HPP
|
||||
|
||||
#include "json.hpp"
|
||||
|
||||
namespace json {
|
||||
|
||||
template <class T>
|
||||
class Primitive : public Json
|
||||
{
|
||||
public:
|
||||
Primitive() {}
|
||||
|
||||
Primitive(const T& value)
|
||||
: value(value) {}
|
||||
|
||||
T get() const { return value; }
|
||||
void set(T value) { this->value = value; }
|
||||
|
||||
operator T() const { return this->get(); }
|
||||
|
||||
protected:
|
||||
T value;
|
||||
};
|
||||
|
||||
|
||||
}
|
||||
|
||||
#endif
|
||||
@ -1,33 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_JSON_REAL_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_JSON_REAL_HPP
|
||||
|
||||
#include "primitive.hpp"
|
||||
|
||||
namespace json {
|
||||
|
||||
class Real final : public Primitive<float>
|
||||
{
|
||||
public:
|
||||
Real() {}
|
||||
|
||||
Real(float value)
|
||||
: Primitive<float>(value) {}
|
||||
|
||||
virtual bool is_real() const;
|
||||
|
||||
virtual operator std::string() const;
|
||||
};
|
||||
|
||||
bool Real::is_real() const
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
Real::operator std::string() const
|
||||
{
|
||||
return std::to_string(value);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
#endif
|
||||
@ -1,34 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_JSON_STRING_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_JSON_STRING_HPP
|
||||
|
||||
#include "primitive.hpp"
|
||||
|
||||
namespace json
|
||||
{
|
||||
|
||||
class String final : public Primitive<std::string>
|
||||
{
|
||||
public:
|
||||
String() {}
|
||||
|
||||
String(const std::string& value)
|
||||
: Primitive<std::string>(value) {}
|
||||
|
||||
virtual bool is_string() const;
|
||||
|
||||
virtual operator std::string() const;
|
||||
};
|
||||
|
||||
bool String::is_string() const
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
String::operator std::string() const
|
||||
{
|
||||
return "\"" + value + "\"";
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
#endif
|
||||
@ -1,18 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_NODE_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_NODE_HPP
|
||||
|
||||
#include <vector>
|
||||
|
||||
#include "json/all.hpp"
|
||||
#include "record.hpp"
|
||||
#include "edge.hpp"
|
||||
|
||||
struct Node : Record
|
||||
{
|
||||
std::vector<Edge*> in;
|
||||
std::vector<Edge*> out;
|
||||
|
||||
json::Object* data;
|
||||
};
|
||||
|
||||
#endif
|
||||
@ -1,14 +0,0 @@
|
||||
#ifndef MEMGRAPH_DATA_MODEL_RECORD_HPP
|
||||
#define MEMGRAPH_DATA_MODEL_RECORD_HPP
|
||||
|
||||
#include <cstdlib>
|
||||
|
||||
class Record
|
||||
{
|
||||
uint64_t id;
|
||||
|
||||
// used by MVCC to keep track of what's visible to transactions
|
||||
uint64_t xmin, xmax;
|
||||
};
|
||||
|
||||
#endif
|
||||
@ -1,6 +0,0 @@
|
||||
#ifndef MEMGRAPH_UTILS_SYNC_ALL_HPP
|
||||
#define MEMGRAPH_UTILS_SYNC_ALL_HPP
|
||||
|
||||
#include "spinlock.hpp"
|
||||
|
||||
#endif
|
||||
@ -1,20 +0,0 @@
|
||||
#ifndef MEMGRAPH_UTILS_SYNC_CASLOCK_HPP
|
||||
#define MEMGRAPH_UTILS_SYNC_CASLOCK_HPP
|
||||
|
||||
#include <atomic>
|
||||
|
||||
struct CasLock
|
||||
{
|
||||
uint8_t lock;
|
||||
|
||||
void lock()
|
||||
{
|
||||
}
|
||||
|
||||
void unlock()
|
||||
{
|
||||
}
|
||||
|
||||
};
|
||||
|
||||
#endif
|
||||
@ -1,31 +0,0 @@
|
||||
#ifndef MEMGRAPH_UTILS_SYNC_SPINLOCK_HPP
|
||||
#define MEMGRAPH_UTILS_SYNC_SPINLOCK_HPP
|
||||
|
||||
#include <atomic>
|
||||
#include <unistd.h>
|
||||
|
||||
class SpinLock
|
||||
{
|
||||
public:
|
||||
void lock();
|
||||
void unlock();
|
||||
|
||||
private:
|
||||
// guaranteed by standard to be lock free!
|
||||
std::atomic_flag lock_flag = ATOMIC_FLAG_INIT;
|
||||
};
|
||||
|
||||
void SpinLock::lock()
|
||||
{
|
||||
// TODO add asm pause and counter first before sleeping
|
||||
// might be faster, but test this and see
|
||||
while(lock_flag.test_and_set(std::memory_order_acquire))
|
||||
usleep(250);
|
||||
}
|
||||
|
||||
void SpinLock::unlock()
|
||||
{
|
||||
lock_flag.clear(std::memory_order_release);
|
||||
}
|
||||
|
||||
#endif
|
||||
Loading…
Reference in New Issue
Block a user