#undef dout_prefix
#define dout_prefix _prefix(_dout)
-static ostream& _prefix(std::ostream* _dout)
+static std::ostream& _prefix(std::ostream* _dout)
{
return *_dout << "ErasureCodePluginShec: ";
}
int ErasureCodePluginShec::factory(const std::string &directory,
- ErasureCodeProfile &profile,
- ErasureCodeInterfaceRef *erasure_code,
- std::ostream *ss) {
+ ceph::ErasureCodeProfile &profile,
+ ceph::ErasureCodeInterfaceRef *erasure_code,
+ std::ostream *ss) {
ErasureCodeShec *interface;
if (profile.find("technique") == profile.end())
delete interface;
return r;
}
- *erasure_code = ErasureCodeInterfaceRef(interface);
+ *erasure_code = ceph::ErasureCodeInterfaceRef(interface);
dout(10) << "ErasureCodePluginShec: factory() completed" << dendl;
int __erasure_code_init(char *plugin_name, char *directory = (char *)"")
{
- ErasureCodePluginRegistry &instance = ErasureCodePluginRegistry::instance();
+ auto& instance = ceph::ErasureCodePluginRegistry::instance();
int w[] = { 8, 16, 32 };
int r = jerasure_init(3, w);
if (r) {
#include "ErasureCodeShecTableCache.h"
#include "erasure-code/ErasureCodePlugin.h"
-class ErasureCodePluginShec : public ErasureCodePlugin {
+class ErasureCodePluginShec : public ceph::ErasureCodePlugin {
public:
ErasureCodeShecTableCache tcache;
int factory(const std::string &directory,
- ErasureCodeProfile &profile,
- ErasureCodeInterfaceRef *erasure_code,
- ostream *ss) override;
+ ceph::ErasureCodeProfile &profile,
+ ceph::ErasureCodeInterfaceRef *erasure_code,
+ std::ostream *ss) override;
};
#endif
#include "erasure-code/ErasureCode.h"
#include "ErasureCodeShecTableCache.h"
-class ErasureCodeShec : public ErasureCode {
+class ErasureCodeShec : public ceph::ErasureCode {
public:
enum {
const std::set<int> &available_chunks,
std::set<int> *minimum);
- int minimum_to_decode_with_cost(const set<int> &want_to_read,
- const map<int, int> &available,
- set<int> *minimum) override;
+ int minimum_to_decode_with_cost(const std::set<int> &want_to_read,
+ const std::map<int, int> &available,
+ std::set<int> *minimum) override;
- int encode(const set<int> &want_to_encode,
- const bufferlist &in,
- map<int, bufferlist> *encoded) override;
- int encode_chunks(const set<int> &want_to_encode,
- map<int, bufferlist> *encoded) override;
+ int encode(const std::set<int> &want_to_encode,
+ const ceph::buffer::list &in,
+ std::map<int, ceph::buffer::list> *encoded) override;
+ int encode_chunks(const std::set<int> &want_to_encode,
+ std::map<int, ceph::buffer::list> *encoded) override;
int _decode(const std::set<int> &want_to_read,
- const std::map<int, bufferlist> &chunks,
- std::map<int, bufferlist> *decoded) override;
- int decode_chunks(const set<int> &want_to_read,
- const map<int, bufferlist> &chunks,
- map<int, bufferlist> *decoded) override;
+ const std::map<int, ceph::buffer::list> &chunks,
+ std::map<int, ceph::buffer::list> *decoded) override;
+ int decode_chunks(const std::set<int> &want_to_read,
+ const std::map<int, ceph::buffer::list> &chunks,
+ std::map<int, ceph::buffer::list> *decoded) override;
- int init(ErasureCodeProfile &profile, ostream *ss) override;
+ int init(ceph::ErasureCodeProfile &profile, std::ostream *ss) override;
virtual void shec_encode(char **data,
char **coding,
int blocksize) = 0;
virtual int* shec_reedsolomon_coding_matrix(int is_single);
private:
- virtual int parse(const ErasureCodeProfile &profile) = 0;
+ virtual int parse(const ceph::ErasureCodeProfile &profile) = 0;
virtual double shec_calc_recovery_efficiency1(int k, int m1, int m2, int c1, int c2);
virtual int shec_make_decoding_matrix(bool prepare,
unsigned get_alignment() const override;
void prepare() override;
private:
- int parse(const ErasureCodeProfile &profile) override;
+ int parse(const ceph::ErasureCodeProfile &profile) override;
};
#endif