12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667 |
- #ifndef DEF_DBDIRPROC
- #define DEF_DBDIRPROC
- #include "DBHandler.hpp"
- #include <boost/interprocess/sync/interprocess_semaphore.hpp>
- #include <boost/thread.hpp>
- #include <dirent.h>
- #include <vector>
- #include <string>
- #include <iostream>
- #include <fstream>
- #include <stdio.h>
- #include <string.h>
- #define DEFAULT_DIR_NAME "db/"
- #define NB_FILE_DESCRIPTORS 50
- class DBDirectoryProcessor : public DBHandler
- {
- private:
- boost::mutex mutex;
- std::string directory;
- std::vector<std::ifstream*> fdPool;
- std::vector <std::string> file_list;
- bool filesSplitting;
- std::string realFileName;
-
- public:
- DBDirectoryProcessor();
- DBDirectoryProcessor(uint64_t nbStreams);
- virtual ~DBDirectoryProcessor();
-
- std::string getCatalog(const bool typeOfCatalog);
-
- uint64_t getDBSizeBits();
- uint64_t getNbStream();
- uint64_t getmaxFileBytesize();
-
- std::ifstream* openStream(uint64_t streamNb, uint64_t requested_offset);
- uint64_t readStream(std::ifstream* s,char * buf, uint64_t size);
- void readAggregatedStream(uint64_t streamNb, uint64_t alpha, uint64_t offset, uint64_t bytes_per_file, char* rawBits);
- void closeStream(std::ifstream* s);
-
-
- std::streampos getFileSize( std::string filePath );
- private:
- uint64_t maxFileBytesize;
- };
- #endif
|