X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Frgw%2Frgw_compression.h;fp=src%2Fceph%2Fsrc%2Frgw%2Frgw_compression.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=721c510f02ab538be96bdb36ff30ea19ae644ecf;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/rgw/rgw_compression.h b/src/ceph/src/rgw/rgw_compression.h deleted file mode 100644 index 721c510..0000000 --- a/src/ceph/src/rgw/rgw_compression.h +++ /dev/null @@ -1,52 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab - -#ifndef CEPH_RGW_COMPRESSION_H -#define CEPH_RGW_COMPRESSION_H - -#include - -#include "compressor/Compressor.h" -#include "rgw_op.h" - -class RGWGetObj_Decompress : public RGWGetObj_Filter -{ - CephContext* cct; - CompressorRef compressor; - RGWCompressionInfo* cs_info; - bool partial_content; - vector::iterator first_block, last_block; - off_t q_ofs, q_len; - uint64_t cur_ofs; - bufferlist waiting; -public: - RGWGetObj_Decompress(CephContext* cct_, - RGWCompressionInfo* cs_info_, - bool partial_content_, - RGWGetDataCB* next); - ~RGWGetObj_Decompress() override {} - - int handle_data(bufferlist& bl, off_t bl_ofs, off_t bl_len) override; - int fixup_range(off_t& ofs, off_t& end) override; - -}; - -class RGWPutObj_Compress : public RGWPutObj_Filter -{ - CephContext* cct; - bool compressed{false}; - CompressorRef compressor; - std::vector blocks; -public: - RGWPutObj_Compress(CephContext* cct_, CompressorRef compressor, - RGWPutObjDataProcessor* next) - : RGWPutObj_Filter(next), cct(cct_), compressor(compressor) {} - ~RGWPutObj_Compress() override{} - int handle_data(bufferlist& bl, off_t ofs, void **phandle, rgw_raw_obj *pobj, bool *again) override; - - bool is_compressed() { return compressed; } - vector& get_compression_blocks() { return blocks; } - -}; /* RGWPutObj_Compress */ - -#endif /* CEPH_RGW_COMPRESSION_H */