Renamed project to wfs and memfs to FileStore.

This commit is contained in:
2016-06-02 20:58:50 -05:00
parent b58ca52bce
commit 9a393df4fc
8 changed files with 91 additions and 69 deletions
+13 -1
View File
@@ -1,3 +1,15 @@
cmake_minimum_required(VERSION 2.8.8) cmake_minimum_required(VERSION 2.8.8)
add_subdirectory(memphis) add_library(
Memphis
filestore.cpp
_memops.cpp
)
install(
FILES
filestore.hpp
_memops.hpp
DESTINATION
include/Memphis
)
+3 -1
View File
@@ -7,7 +7,8 @@
*/ */
#include "_memops.hpp" #include "_memops.hpp"
namespace memphis { namespace wombat {
namespace fs {
void memcpy(void *src, void *dest, int size) { void memcpy(void *src, void *dest, int size) {
char *srcBuf = (char*) src; char *srcBuf = (char*) src;
@@ -25,3 +26,4 @@ void memset(void *ptr, char val, int size) {
} }
} }
}
+5 -3
View File
@@ -5,15 +5,17 @@
* License, v. 2.0. If a copy of the MPL was not distributed with this * License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. * file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/ */
#ifndef MEMPHIS_MEMOPS_HPP #ifndef WOMBAT_FS_MEMOPS_HPP
#define MEMPHIS_MEMOPS_HPP #define WOMBAT_FS_MEMOPS_HPP
namespace memphis { namespace wombat {
namespace fs {
void memcpy(void *src, void *dest, int size); void memcpy(void *src, void *dest, int size);
void memset(void *ptr, char val, int size); void memset(void *ptr, char val, int size);
}
} }
#endif #endif
+7 -4
View File
@@ -5,10 +5,13 @@
* License, v. 2.0. If a copy of the MPL was not distributed with this * License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. * file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/ */
#ifndef MEMPHIS_TYPES_HPP #ifndef WOMBAT_FS_TYPES_HPP
#define MEMPHIS_TYPES_HPP #define WOMBAT_FS_TYPES_HPP
namespace memphis { #define offsetof(st, m) ((size_t)(&((st *)0)->m))
namespace wombat {
namespace fs {
typedef char int8_t; typedef char int8_t;
typedef unsigned char uint8_t; typedef unsigned char uint8_t;
@@ -28,7 +31,7 @@ typedef uint64_t size_t;
typedef uint32_t size_t; typedef uint32_t size_t;
#endif #endif
}
} }
#endif #endif
+22 -22
View File
@@ -7,37 +7,36 @@
*/ */
#include <stdlib.h> #include <stdlib.h>
#include "_memops.hpp" #include "_memops.hpp"
#include "memfs.hpp" #include "filestore.hpp"
#define offsetof(st, m) ((size_t)(&((st *)0)->m)) namespace wombat {
namespace fs {
namespace memphis { uint32_t FileStore::version = 0;
uint32_t MemFs::version = 0;
uint8_t *initFs(uint8_t *buffer, size_t size, bool hasDirectories) { uint8_t *initFs(uint8_t *buffer, size_t size, bool hasDirectories) {
auto fs = (MemFsHeader*) (buffer ? buffer : malloc(size)); auto fs = (MemFsHeader*) (buffer ? buffer : malloc(size));
fs->version = MemFs::version; fs->version = FileStore::version;
return (uint8_t*) fs; return (uint8_t*) fs;
} }
MemFsPtr MemFs::Record::size() { MemFsPtr FileStore::Record::size() {
return offsetof(MemFs::Record, m_id) + dataLen; return offsetof(FileStore::Record, m_id) + dataLen;
} }
void MemFs::Record::setId(RecordId id) { void FileStore::Record::setId(RecordId id) {
this->m_id = id; this->m_id = id;
} }
void MemFs::Record::setData(uint8_t *data, int size) { void FileStore::Record::setData(uint8_t *data, int size) {
memcpy(this + m_data, data, size); memcpy(this + m_data, data, size);
m_data = size; m_data = size;
} }
// MemFs // FileStore
MemFs::MemFs(uint8_t *begin, uint8_t *end, Error *error): m_version(*((uint32_t*) begin)), m_lastRec(*(MemFsPtr*) (begin + sizeof(m_version))) { FileStore::FileStore(uint8_t *begin, uint8_t *end, Error *error): m_version(*((uint32_t*) begin)), m_lastRec(*(MemFsPtr*) (begin + sizeof(m_version))) {
if (version != m_version) { if (version != m_version) {
// version mismatch // version mismatch
if (error) { if (error) {
@@ -54,19 +53,19 @@ MemFs::MemFs(uint8_t *begin, uint8_t *end, Error *error): m_version(*((uint32_t*
} }
} }
void MemFs::init() { void FileStore::init() {
memset(m_begin, 0, m_end - m_begin); memset(m_begin, 0, m_end - m_begin);
m_version = version; m_version = version;
} }
void MemFs::write(RecordId id, uint8_t *data, MemFsPtr dataLen) { void FileStore::write(RecordId id, uint8_t *data, MemFsPtr dataLen) {
const MemFsPtr size = offsetof(MemFs::Record, m_id) + dataLen; const MemFsPtr size = offsetof(FileStore::Record, m_id) + dataLen;
auto rec = (Record*) alloc(size); auto rec = (Record*) alloc(size);
rec->dataLen = dataLen; rec->dataLen = dataLen;
insert(m_root, rec); insert(m_root, rec);
} }
int MemFs::read(RecordId id, uint8_t **data, MemFsPtr *size) { int FileStore::read(RecordId id, uint8_t **data, MemFsPtr *size) {
auto rec = getRecord(m_root, id); auto rec = getRecord(m_root, id);
int retval = 1; int retval = 1;
if (rec) { if (rec) {
@@ -78,7 +77,7 @@ int MemFs::read(RecordId id, uint8_t **data, MemFsPtr *size) {
return retval; return retval;
} }
MemFs::Record *MemFs::getRecord(MemFs::Record *root, RecordId id) { FileStore::Record *FileStore::getRecord(FileStore::Record *root, RecordId id) {
auto cmp = root->m_id > id; auto cmp = root->m_id > id;
MemFsPtr recPt; MemFsPtr recPt;
if (cmp) { if (cmp) {
@@ -95,7 +94,7 @@ MemFs::Record *MemFs::getRecord(MemFs::Record *root, RecordId id) {
} }
} }
void *MemFs::alloc(MemFsPtr size) { void *FileStore::alloc(MemFsPtr size) {
const auto iterator = this->iterator(); const auto iterator = this->iterator();
if ((iterator + size) > (uint64_t) m_end) { if ((iterator + size) > (uint64_t) m_end) {
compress(); compress();
@@ -112,7 +111,7 @@ void *MemFs::alloc(MemFsPtr size) {
return rec; return rec;
} }
void MemFs::compress() { void FileStore::compress() {
auto current = m_root; auto current = m_root;
while (current->next) { while (current->next) {
auto prevEnd = current + current->size(); auto prevEnd = current + current->size();
@@ -124,7 +123,7 @@ void MemFs::compress() {
} }
} }
bool MemFs::insert(Record *root, Record *insertValue, MemFsPtr *rootParentPtr) { bool FileStore::insert(Record *root, Record *insertValue, MemFsPtr *rootParentPtr) {
auto cmp = root->m_id > insertValue->m_id; auto cmp = root->m_id > insertValue->m_id;
if (cmp) { if (cmp) {
if (root->left) { if (root->left) {
@@ -156,12 +155,13 @@ bool MemFs::insert(Record *root, Record *insertValue, MemFsPtr *rootParentPtr) {
return false; return false;
} }
MemFsPtr MemFs::iterator() { MemFsPtr FileStore::iterator() {
return m_lastRec + ((Record*) m_begin + m_lastRec)->size(); return m_lastRec + ((Record*) m_begin + m_lastRec)->size();
} }
MemFsPtr MemFs::ptr(void *ptr) { MemFsPtr FileStore::ptr(void *ptr) {
return ((uint8_t*) ptr) - m_begin; return ((uint8_t*) ptr) - m_begin;
} }
} }
}
+30 -19
View File
@@ -5,22 +5,32 @@
* License, v. 2.0. If a copy of the MPL was not distributed with this * License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. * file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/ */
#ifndef MEMPHIS_MEMFS_HPP #ifndef WOMBAT_FS_FILESTORE_HPP
#define MEMPHIS_MEMFS_HPP #define WOMBAT_FS_FILESTORE_HPP
#include "_types.hpp" #include "_types.hpp"
namespace memphis { namespace wombat {
namespace fs {
typedef uint32_t MemFsPtr; typedef uint32_t MemFsPtr;
typedef uint32_t RecordId; typedef uint32_t RecordId;
struct MemFsHeader { struct MemFsHeader {
uint32_t version; uint32_t version;
bool hasDirectories; MemFsPtr rootDir = -1;
}; };
class MemFs { class DirectoryHeader {
/**
* Count of the number of files listed in this directory.
*/
MemFsPtr files;
const char* operator[](int i);
};
class FileStore {
public: public:
static uint32_t version; static uint32_t version;
private: private:
@@ -40,48 +50,48 @@ class MemFs {
uint8_t *m_begin, *m_end; uint8_t *m_begin, *m_end;
uint32_t &m_version; uint32_t &m_version;
// the last Record in the MemFs's memory chunk // the last Record in the FileStore's memory chunk
MemFsPtr &m_lastRec; MemFsPtr &m_lastRec;
Record *m_root; Record *m_root;
public: public:
/** /**
* Constructor * Constructor
* @param begin pointer to the beginning of this MemFs's memory chunk * @param begin pointer to the beginning of this FileStore's memory chunk
* @param end pointer to the end of this MemFs's memory chunk * @param end pointer to the end of this FileStore's memory chunk
* @param error pointer to a integer return errors into * @param error pointer to a integer return errors into
*/ */
MemFs(uint8_t *begin, uint8_t *end, Error *error = nullptr); FileStore(uint8_t *begin, uint8_t *end, Error *error = nullptr);
/** /**
* Initializes the memory chunk of this MemFs was given. * Initializes the memory chunk of this FileStore was given.
* This clears the previous contents. * This clears the previous contents.
*/ */
void init(); void init();
/** /**
* Writes the given data to a "file" with the given path. * Writes the given data to a "file" with the given id.
* @param path the path of the file * @param id the id of the file
* @param data the contents of the file * @param data the contents of the file
* @param dataLen the number of bytes data points to * @param dataLen the number of bytes data points to
*/ */
void write(RecordId path, uint8_t *data, MemFsPtr dataLen); void write(RecordId id, uint8_t *data, MemFsPtr dataLen);
/** /**
* Reads the "file" at the given path. You are responsible for freeing * Reads the "file" at the given id. You are responsible for freeing
* the data when done with it. * the data when done with it.
* @param path path of the "file" * @param id id of the "file"
* @param data pointer to the pointer where the data is stored * @param data pointer to the pointer where the data is stored
* @param size pointer to a value that will be assigned the size of data * @param size pointer to a value that will be assigned the size of data
* @return 0 if read is a success * @return 0 if read is a success
*/ */
int read(RecordId path, uint8_t **data, MemFsPtr *size); int read(RecordId id, uint8_t **data, MemFsPtr *size);
private: private:
/** /**
* Gets the record at the given path. * Gets the record at the given id.
* @param root the root node to start comparing on * @param root the root node to start comparing on
* @param path path of the "file" * @param id id of the "file"
* @param pathLen number of characters in pathLen * @param pathLen number of characters in pathLen
* @return the requested Record, if available * @return the requested Record, if available
*/ */
@@ -124,12 +134,13 @@ class MemFs {
}; };
template<typename T> template<typename T>
T MemFs::ptr(MemFsPtr ptr) { T FileStore::ptr(MemFsPtr ptr) {
return (T) m_begin + ptr; return (T) m_begin + ptr;
} }
uint8_t *initFs(uint8_t *buffer, size_t size, bool hasDirectories); uint8_t *initFs(uint8_t *buffer, size_t size, bool hasDirectories);
}
} }
#endif #endif
-15
View File
@@ -1,15 +0,0 @@
cmake_minimum_required(VERSION 2.8.8)
add_library(
Memphis
memfs.cpp
_memops.cpp
)
install(
FILES
memfs.hpp
_memops.hpp
DESTINATION
include/Memphis
)
+11 -4
View File
@@ -1,12 +1,19 @@
#include <memphis/memfs.hpp> /*
* Copyright 2015 gtalent2@gmail.com
*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/
#include <filestore.hpp>
using namespace memphis; using namespace wombat::fs;
int main() { int main() {
const auto size = 1024; const auto size = 1 << 16;
uint8_t volume[size]; uint8_t volume[size];
uint32_t err; uint32_t err;
initFs(volume, size, false); initFs(volume, size, false);
MemFs memfs(volume, volume + size, &err); FileStore(volume, volume + size, &err);
return err; return err;
} }