X-Git-Url: http://git.vrable.net/?a=blobdiff_plain;f=store.h;h=75c2008c51368a794ba6764f3da6dae23a30cfbf;hb=4c7c830e38130011d1f5cc68934a31619e3b8a85;hp=aa961600fa4122d513e462bf4de3d710341faa33;hpb=ac33ae99de4a6aa9cfaca2f7fd6746758264758e;p=cumulus.git diff --git a/store.h b/store.h index aa96160..75c2008 100644 --- a/store.h +++ b/store.h @@ -3,14 +3,12 @@ * * Backup data is stored in a collection of objects, which are grouped together * into segments for storage purposes. This implementation of the object store - * is built on top of libtar, and represents segments as TAR files and objects - * as files within them. */ + * represents segments as TAR files and objects as files within them. */ #ifndef _LBS_STORE_H #define _LBS_STORE_H #include -#include #include #include @@ -41,6 +39,30 @@ public: std::string getError() const { return error; } }; +/* Simplified TAR header--we only need to store regular files, don't need to + * handle long filenames, etc. */ +static const int TAR_BLOCK_SIZE = 512; + +struct tar_header +{ + char name[100]; + char mode[8]; + char uid[8]; + char gid[8]; + char size[12]; + char mtime[12]; + char chksum[8]; + char typeflag; + char linkname[100]; + char magic[8]; + char uname[32]; + char gname[32]; + char devmajor[8]; + char devminor[8]; + char prefix[155]; + char padding[12]; +}; + /* A simple wrapper around a single TAR file to represent a segment. Objects * may only be written out all at once, since the tar header must be written * first; incremental writing is not supported. */ @@ -61,11 +83,13 @@ public: private: size_t size; std::string segment_name; - TAR *t; /* Filter support. */ int real_fd, filter_fd; pid_t filter_pid; + + // Write data to the tar file + void tar_write(const char *data, size_t size); }; class TarSegmentStore { @@ -84,6 +108,9 @@ public: // Ensure all segments have been fully written. void sync(); + // Dump statistics to stdout about how much data has been written + void dump_stats(); + private: struct segment_info { Tarfile *file; @@ -144,4 +171,11 @@ private: ObjectReference ref; }; +/* Program through which segment data is piped before being written to file. */ +extern const char *filter_program; + +/* Extension which should be appended to segments written out (.tar is already + * included; this adds to it) */ +extern const char *filter_extension; + #endif // _LBS_STORE_H