From 2980b112cd387aa98e144ee7e4cddf6c9af6dd85 Mon Sep 17 00:00:00 2001 From: shawn Date: Wed, 25 May 2016 22:22:35 -0400 Subject: [PATCH] compressor: optimize header file dependency Signed-off-by: Xiaowei Chen Signed-off-by: Brad Hubbard --- src/compressor/AsyncCompressor.h | 4 +--- src/compressor/CompressionPlugin.h | 3 ++- src/compressor/Compressor.cc | 6 +++++- src/compressor/Compressor.h | 16 ++++++++++------ src/compressor/snappy/CompressionPluginSnappy.cc | 2 +- src/compressor/snappy/SnappyCompressor.h | 2 +- 6 files changed, 20 insertions(+), 13 deletions(-) diff --git a/src/compressor/AsyncCompressor.h b/src/compressor/AsyncCompressor.h index 81321fdd511e5..37f70f98eb280 100644 --- a/src/compressor/AsyncCompressor.h +++ b/src/compressor/AsyncCompressor.h @@ -16,13 +16,11 @@ #define CEPH_ASYNCCOMPRESSOR_H #include - +#include #include "include/atomic.h" -#include "include/str_list.h" #include "Compressor.h" #include "common/WorkQueue.h" - class AsyncCompressor { private: CompressorRef compressor; diff --git a/src/compressor/CompressionPlugin.h b/src/compressor/CompressionPlugin.h index d2e253f2dc100..5e0ed777b85ea 100644 --- a/src/compressor/CompressionPlugin.h +++ b/src/compressor/CompressionPlugin.h @@ -18,8 +18,9 @@ #ifndef COMPRESSION_PLUGIN_H #define COMPRESSION_PLUGIN_H +#include #include -#include "common/Mutex.h" + #include "common/PluginRegistry.h" #include "Compressor.h" diff --git a/src/compressor/Compressor.cc b/src/compressor/Compressor.cc index 6b49b788f838f..3279ac660ac0c 100644 --- a/src/compressor/Compressor.cc +++ b/src/compressor/Compressor.cc @@ -13,8 +13,12 @@ */ #include -#include "Compressor.h" +#include + #include "CompressionPlugin.h" +#include "Compressor.h" +#include "common/ceph_context.h" +#include "common/debug.h" #include "common/dout.h" const char * Compressor::get_comp_alg_name(int a) { diff --git a/src/compressor/Compressor.h b/src/compressor/Compressor.h index 8be13043d69db..3430281bdae47 100644 --- a/src/compressor/Compressor.h +++ b/src/compressor/Compressor.h @@ -15,13 +15,17 @@ #ifndef CEPH_COMPRESSOR_H #define CEPH_COMPRESSOR_H -#include + #include -#include "include/memory.h" +#include +#include + #include "include/buffer.h" +#include "include/int_types.h" class Compressor; -typedef shared_ptr CompressorRef; +typedef std::shared_ptr CompressorRef; +class CephContext; class Compressor { public: @@ -55,11 +59,11 @@ public: CompressionAlgorithm get_type() const { return alg; } - virtual int compress(const bufferlist &in, bufferlist &out) = 0; - virtual int decompress(const bufferlist &in, bufferlist &out) = 0; + virtual int compress(const ceph::bufferlist &in, ceph::bufferlist &out) = 0; + virtual int decompress(const ceph::bufferlist &in, ceph::bufferlist &out) = 0; // this is a bit weird but we need non-const iterator to be in // alignment with decode methods - virtual int decompress(bufferlist::iterator &p, size_t compressed_len, bufferlist &out) = 0; + virtual int decompress(ceph::bufferlist::iterator &p, size_t compressed_len, ceph::bufferlist &out) = 0; static CompressorRef create(CephContext *cct, const std::string &type); static CompressorRef create(CephContext *cct, int alg); diff --git a/src/compressor/snappy/CompressionPluginSnappy.cc b/src/compressor/snappy/CompressionPluginSnappy.cc index f4e8c3819d9ea..6d67c41c746d5 100644 --- a/src/compressor/snappy/CompressionPluginSnappy.cc +++ b/src/compressor/snappy/CompressionPluginSnappy.cc @@ -38,4 +38,4 @@ int __ceph_plugin_init(CephContext *cct, return instance->add(type, name, new CompressionPluginSnappy(cct)); } -#endif // !BUILDING_FOR_EMBEDDED \ No newline at end of file +#endif // !BUILDING_FOR_EMBEDDED diff --git a/src/compressor/snappy/SnappyCompressor.h b/src/compressor/snappy/SnappyCompressor.h index aa377b510ac36..44348f72bb9e6 100644 --- a/src/compressor/snappy/SnappyCompressor.h +++ b/src/compressor/snappy/SnappyCompressor.h @@ -17,8 +17,8 @@ #include #include -#include "include/buffer.h" #include "compressor/Compressor.h" +#include "include/buffer.h" class CEPH_BUFFER_API BufferlistSource : public snappy::Source { bufferlist::iterator pb; -- 2.39.5