mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-11-27 01:51:59 +00:00
439 lines
12 KiB
C++
439 lines
12 KiB
C++
|
|
#include <zstd.h>
|
|
#include <sys/mman.h>
|
|
#include <fcntl.h>
|
|
#include <unistd.h>
|
|
#include <cstdlib>
|
|
#include <cstdio>
|
|
#include <cstring>
|
|
#include <cerrno>
|
|
#include <memory>
|
|
#include <iostream>
|
|
|
|
#include "types.h"
|
|
|
|
/// blocking write
|
|
ssize_t write_data(int fd, const void *buf, size_t count)
|
|
{
|
|
for (size_t n = 0; n < count;)
|
|
{
|
|
ssize_t sz = write(fd, reinterpret_cast<const char*>(buf) + n, count - n);
|
|
if (sz < 0)
|
|
{
|
|
if (errno == EINTR)
|
|
continue;
|
|
return sz;
|
|
}
|
|
n += sz;
|
|
}
|
|
return count;
|
|
}
|
|
|
|
/// blocking read
|
|
ssize_t read_data(int fd, void *buf, size_t count)
|
|
{
|
|
for (size_t n = 0; n < count;)
|
|
{
|
|
ssize_t sz = read(fd, reinterpret_cast<char*>(buf) + n, count - n);
|
|
if (sz < 0)
|
|
{
|
|
if (errno == EINTR)
|
|
continue;
|
|
return sz;
|
|
}
|
|
if (sz == 0)
|
|
return count - n;
|
|
n += sz;
|
|
}
|
|
return count;
|
|
}
|
|
|
|
/// Main compression part
|
|
int doCompress(char * input, char * output, off_t & in_offset, off_t & out_offset,
|
|
off_t input_size, off_t output_size, ZSTD_CCtx * cctx)
|
|
{
|
|
size_t compressed_size = ZSTD_compress2(cctx, output + out_offset, output_size, input + in_offset, input_size);
|
|
if (ZSTD_isError(compressed_size))
|
|
{
|
|
std::cerr << "Error (ZSTD): " << compressed_size << " " << ZSTD_getErrorName(compressed_size) << std::endl;
|
|
return 1;
|
|
}
|
|
in_offset += input_size;
|
|
out_offset += compressed_size;
|
|
return 0;
|
|
}
|
|
|
|
/// compress data from opened file into output file
|
|
int compress(int in_fd, int out_fd, int level, off_t & pointer, const struct stat & info_in)
|
|
{
|
|
off_t in_offset = 0;
|
|
|
|
/// mmap files
|
|
char * input = static_cast<char*>(mmap(nullptr, info_in.st_size, PROT_READ, MAP_PRIVATE, in_fd, 0));
|
|
if (input == MAP_FAILED)
|
|
{
|
|
perror(nullptr);
|
|
return 1;
|
|
}
|
|
|
|
/// Create context
|
|
ZSTD_CCtx * cctx = ZSTD_createCCtx();
|
|
if (cctx == nullptr)
|
|
{
|
|
std::cerr << "Error (ZSTD): failed to create compression context" << std::endl;
|
|
return 1;
|
|
}
|
|
|
|
size_t check_result;
|
|
|
|
/// Set level and enable checksums
|
|
check_result = ZSTD_CCtx_setParameter(cctx, ZSTD_c_compressionLevel, level);
|
|
if (ZSTD_isError(check_result))
|
|
{
|
|
std::cerr << "Error (ZSTD): " << check_result << " " << ZSTD_getErrorName(check_result) << std::endl;
|
|
return 1;
|
|
}
|
|
check_result = ZSTD_CCtx_setParameter(cctx, ZSTD_c_checksumFlag, 1);
|
|
if (ZSTD_isError(check_result))
|
|
{
|
|
std::cerr << "Error (ZSTD): " << check_result << " " << ZSTD_getErrorName(check_result) << std::endl;
|
|
return 1;
|
|
}
|
|
|
|
/// limits for size of block to prevent high memory usage or bad compression
|
|
off_t max_block_size = 1ull<<27;
|
|
off_t min_block_size = 1ull<<23;
|
|
off_t size = 0;
|
|
off_t current_block_size = 0;
|
|
|
|
/// Create buffer for compression
|
|
/// Block can't become much bigger after compression.
|
|
char * output = static_cast<char*>(
|
|
mmap(nullptr, 2 * max_block_size,
|
|
PROT_READ | PROT_WRITE, MAP_ANON | MAP_PRIVATE,
|
|
-1,
|
|
0)
|
|
);
|
|
if (output == MAP_FAILED)
|
|
{
|
|
perror(nullptr);
|
|
return 1;
|
|
}
|
|
if (-1 == lseek(out_fd, 0, SEEK_END))
|
|
{
|
|
perror(nullptr);
|
|
return 1;
|
|
}
|
|
|
|
/// Compress data
|
|
while (in_offset < info_in.st_size)
|
|
{
|
|
/// take blocks of maximum size
|
|
/// optimize last block (it can be bigger, if it is not too huge)
|
|
if (info_in.st_size - in_offset < max_block_size || info_in.st_size - in_offset < max_block_size + min_block_size)
|
|
size = info_in.st_size - in_offset;
|
|
else
|
|
size = max_block_size;
|
|
|
|
/// Compress data or exit if error happens
|
|
if (0 != doCompress(input, output, in_offset, current_block_size, size, ZSTD_compressBound(size), cctx))
|
|
{
|
|
if (0 != munmap(input, info_in.st_size))
|
|
perror(nullptr);
|
|
if (0 != munmap(output, 2 * max_block_size))
|
|
perror(nullptr);
|
|
return 1;
|
|
}
|
|
|
|
/// Save data into file and refresh pointer
|
|
if (current_block_size != write_data(out_fd, output, current_block_size))
|
|
{
|
|
perror(nullptr);
|
|
return 1;
|
|
}
|
|
pointer += current_block_size;
|
|
printf("...block compression rate: %.2f%%\n", static_cast<float>(current_block_size) / size * 100);
|
|
current_block_size = 0;
|
|
}
|
|
|
|
if (0 != munmap(input, info_in.st_size) ||
|
|
0 != munmap(output, 2 * max_block_size))
|
|
{
|
|
perror(nullptr);
|
|
return 1;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
/// Save Metadata at the end of file
|
|
int saveMetaData(char* filenames[], int count, int output_fd, const MetaData& metadata,
|
|
FileData* files_data, size_t pointer, size_t sum_file_size)
|
|
{
|
|
/// Allocate memory for metadata
|
|
if (0 != ftruncate(output_fd, pointer + count * sizeof(FileData) + sum_file_size + sizeof(MetaData)))
|
|
{
|
|
perror(nullptr);
|
|
return 1;
|
|
}
|
|
|
|
char * output = static_cast<char*>(
|
|
mmap(nullptr,
|
|
pointer + count * sizeof(FileData) + sum_file_size + sizeof(MetaData),
|
|
PROT_READ | PROT_WRITE, MAP_SHARED,
|
|
output_fd,
|
|
0)
|
|
);
|
|
if (output == MAP_FAILED)
|
|
{
|
|
perror(nullptr);
|
|
return 1;
|
|
}
|
|
|
|
/// save information about files and their names
|
|
for (int i = 0; i < count; ++i)
|
|
{
|
|
/// Save file data
|
|
memcpy(output + pointer, reinterpret_cast<char*>(files_data + i), sizeof(FileData));
|
|
pointer += sizeof(FileData);
|
|
|
|
/// Save file name
|
|
memcpy(output + pointer, filenames[i], files_data[i].name_length);
|
|
pointer += files_data[i].name_length;
|
|
}
|
|
|
|
/// Save metadata
|
|
memcpy(output + pointer, reinterpret_cast<const char*>(&metadata), sizeof(MetaData));
|
|
return 0;
|
|
}
|
|
|
|
/// Fills metadata and calls compression function for each file
|
|
int compressFiles(char* filenames[], int count, int output_fd, int level, const struct stat& info_out)
|
|
{
|
|
MetaData metadata;
|
|
size_t sum_file_size = 0;
|
|
metadata.number_of_files = count;
|
|
off_t pointer = info_out.st_size;
|
|
|
|
/// Store information about each file and compress it
|
|
FileData* files_data = new FileData[count];
|
|
char * names[count];
|
|
for (int i = 0; i < count; ++i)
|
|
{
|
|
printf("Compressing: %s\n", filenames[i]);
|
|
|
|
int input_fd = open(filenames[i], O_RDONLY);
|
|
if (input_fd == -1)
|
|
{
|
|
perror(nullptr);
|
|
delete [] files_data;
|
|
return 1;
|
|
}
|
|
|
|
/// Remember information about file name
|
|
/// This should be made after the file is opened
|
|
/// because filename should be extracted from path
|
|
names[i] = strrchr(filenames[i], '/');
|
|
if (names[i])
|
|
++names[i];
|
|
else
|
|
names[i] = filenames[i];
|
|
files_data[i].name_length = strlen(names[i]) + 1;
|
|
sum_file_size += files_data[i].name_length;
|
|
|
|
/// read data about input file
|
|
struct stat info_in;
|
|
if (0 != fstat(input_fd, &info_in))
|
|
{
|
|
perror(nullptr);
|
|
delete [] files_data;
|
|
return 1;
|
|
}
|
|
|
|
if (info_in.st_size == 0)
|
|
{
|
|
printf("...empty file, skipped.\n");
|
|
continue;
|
|
}
|
|
|
|
std::cout << "Size: " << info_in.st_size << std::endl;
|
|
|
|
/// Save umask
|
|
files_data[i].umask = info_in.st_mode;
|
|
|
|
/// Remember information about uncompressed size of file and
|
|
/// start of it's compression version
|
|
files_data[i].uncompressed_size = info_in.st_size;
|
|
files_data[i].start = pointer;
|
|
|
|
/// Compressed data will be added to the end of file
|
|
/// It will allow to create self extracting executable from file
|
|
if (0 != compress(input_fd, output_fd, level, pointer, info_in))
|
|
{
|
|
perror(nullptr);
|
|
delete [] files_data;
|
|
return 1;
|
|
}
|
|
|
|
/// This error is less important, than others.
|
|
/// If file cannot be closed, in some cases it will lead to
|
|
/// error in other function that will stop compression process
|
|
if (0 != close(input_fd))
|
|
perror(nullptr);
|
|
|
|
files_data[i].end = pointer;
|
|
}
|
|
|
|
/// save location of files information
|
|
metadata.start_of_files_data = pointer;
|
|
|
|
if (0 != saveMetaData(names, count, output_fd, metadata, files_data, pointer, sum_file_size))
|
|
{
|
|
delete [] files_data;
|
|
return 1;
|
|
}
|
|
|
|
delete [] files_data;
|
|
return 0;
|
|
}
|
|
|
|
int copy_decompressor(const char *self, int output_fd)
|
|
{
|
|
int input_fd = open(self, O_RDONLY);
|
|
if (input_fd == -1)
|
|
{
|
|
perror(nullptr);
|
|
return 1;
|
|
}
|
|
|
|
if (-1 == lseek(input_fd, -15, SEEK_END))
|
|
{
|
|
perror(nullptr);
|
|
close(input_fd);
|
|
return 1;
|
|
}
|
|
|
|
char size_str[16] = {0};
|
|
if (ssize_t sz = read_data(input_fd, size_str, 15); sz < 15)
|
|
{
|
|
if (sz < 0)
|
|
perror(nullptr);
|
|
else
|
|
std::cerr << "Error: unable to extract decompressor" << std::endl;
|
|
close(input_fd);
|
|
return 1;
|
|
}
|
|
|
|
int decompressor_size = atoi(size_str);
|
|
|
|
if (-1 == lseek(input_fd, -(decompressor_size + 15), SEEK_END))
|
|
{
|
|
perror(nullptr);
|
|
close(input_fd);
|
|
return 1;
|
|
}
|
|
|
|
auto buf_memory = std::make_unique<char[]>(1ul<<19);
|
|
char * buf = buf_memory.get();
|
|
ssize_t n = 0;
|
|
do
|
|
{
|
|
n = read(input_fd, buf, sizeof(buf));
|
|
|
|
if (0 == n)
|
|
break;
|
|
|
|
if (n < 0)
|
|
{
|
|
if (errno == EINTR)
|
|
continue;
|
|
perror(nullptr);
|
|
close(input_fd);
|
|
return 1;
|
|
}
|
|
|
|
if (n != write_data(output_fd, buf, n))
|
|
{
|
|
perror(nullptr);
|
|
close(input_fd);
|
|
return 1;
|
|
}
|
|
} while (true);
|
|
|
|
close(input_fd);
|
|
return 0;
|
|
}
|
|
|
|
inline void usage(FILE * out, const char * name)
|
|
{
|
|
fprintf(out,
|
|
"%s [--level=<level>] <output_file> <input_file> [... <input_file>]\n"
|
|
"\t--level - compression level, max is %d, negative - prefer speed over compression\n"
|
|
"\t default is 5\n",
|
|
name, ZSTD_maxCLevel());
|
|
}
|
|
|
|
int main(int argc, char* argv[])
|
|
{
|
|
if (argc == 1)
|
|
{
|
|
usage(stdout, argv[0]);
|
|
return 0;
|
|
}
|
|
|
|
int start_of_files = 1;
|
|
|
|
/// Set compression level
|
|
int level = 5;
|
|
if (0 == memcmp(argv[1], "--level=", 8))
|
|
{
|
|
level = atoi(argv[1] + 8);
|
|
++start_of_files;
|
|
}
|
|
|
|
if (argc < start_of_files + 1)
|
|
{
|
|
usage(stderr, argv[0]);
|
|
return 1;
|
|
}
|
|
|
|
struct stat info_out;
|
|
if (stat(argv[start_of_files], &info_out) != -1 || errno != ENOENT)
|
|
{
|
|
std::cerr << "Error: output file [" << argv[start_of_files] << "] already exists" << std::endl;
|
|
return 1;
|
|
}
|
|
|
|
int output_fd = open(argv[start_of_files], O_RDWR | O_CREAT, 0775);
|
|
if (output_fd == -1)
|
|
{
|
|
perror(nullptr);
|
|
return 1;
|
|
}
|
|
++start_of_files;
|
|
|
|
if (copy_decompressor(argv[0], output_fd))
|
|
return 1;
|
|
|
|
if (0 != fstat(output_fd, &info_out))
|
|
{
|
|
perror(nullptr);
|
|
return 1;
|
|
}
|
|
|
|
std::cout << "Compression with level: " << level << std::endl;
|
|
if (0 != compressFiles(&argv[start_of_files], argc - start_of_files, output_fd, level, info_out))
|
|
{
|
|
printf("Compression failed.\n");
|
|
close(output_fd);
|
|
unlink(argv[start_of_files - 1]);
|
|
return 1;
|
|
}
|
|
|
|
printf("Successfully compressed.\n");
|
|
|
|
if (0 != close(output_fd))
|
|
perror(nullptr);
|
|
|
|
return 0;
|
|
}
|