#include "erasure-code/ErasureCode.h"
-class ErasureCodeJerasure : public ErasureCode {
+class ErasureCodeJerasure : public ceph::ErasureCode {
public:
int k;
std::string DEFAULT_K;
unsigned int get_chunk_size(unsigned int object_size) const override;
int encode_chunks(const std::set<int> &want_to_encode,
- std::map<int, bufferlist> *encoded) override;
+ std::map<int, ceph::buffer::list> *encoded) override;
int decode_chunks(const std::set<int> &want_to_read,
- const std::map<int, bufferlist> &chunks,
- std::map<int, bufferlist> *decoded) override;
+ const std::map<int, ceph::buffer::list> &chunks,
+ std::map<int, ceph::buffer::list> *decoded) override;
- int init(ErasureCodeProfile &profile, std::ostream *ss) override;
+ int init(ceph::ErasureCodeProfile &profile, std::ostream *ss) override;
virtual void jerasure_encode(char **data,
char **coding,
virtual void prepare() = 0;
static bool is_prime(int value);
protected:
- virtual int parse(ErasureCodeProfile &profile, std::ostream *ss);
+ virtual int parse(ceph::ErasureCodeProfile &profile, std::ostream *ss);
};
-
class ErasureCodeJerasureReedSolomonVandermonde : public ErasureCodeJerasure {
public:
int *matrix;
unsigned get_alignment() const override;
void prepare() override;
private:
- int parse(ErasureCodeProfile &profile, std::ostream *ss) override;
+ int parse(ceph::ErasureCodeProfile& profile, std::ostream *ss) override;
};
class ErasureCodeJerasureReedSolomonRAID6 : public ErasureCodeJerasure {
unsigned get_alignment() const override;
void prepare() override;
private:
- int parse(ErasureCodeProfile &profile, std::ostream *ss) override;
+ int parse(ceph::ErasureCodeProfile& profile, std::ostream *ss) override;
};
#define DEFAULT_PACKETSIZE "2048"
unsigned get_alignment() const override;
void prepare_schedule(int *matrix);
private:
- int parse(ErasureCodeProfile &profile, std::ostream *ss) override;
+ int parse(ceph::ErasureCodeProfile& profile, std::ostream *ss) override;
};
class ErasureCodeJerasureCauchyOrig : public ErasureCodeJerasureCauchy {
virtual bool check_w(std::ostream *ss) const;
virtual bool check_packetsize_set(std::ostream *ss) const;
virtual bool check_packetsize(std::ostream *ss) const;
- virtual int revert_to_default(ErasureCodeProfile &profile,
+ virtual int revert_to_default(ceph::ErasureCodeProfile& profile,
std::ostream *ss);
void prepare() override;
private:
- int parse(ErasureCodeProfile &profile, std::ostream *ss) override;
+ int parse(ceph::ErasureCodeProfile& profile, std::ostream *ss) override;
};
class ErasureCodeJerasureBlaumRoth : public ErasureCodeJerasureLiberation {
void prepare() override;
private:
- int parse(ErasureCodeProfile &profile, std::ostream *ss) override;
+ int parse(ceph::ErasureCodeProfile& profile, std::ostream *ss) override;
};
#endif
#undef dout_prefix
#define dout_prefix _prefix(_dout)
-static ostream& _prefix(std::ostream* _dout)
+static std::ostream& _prefix(std::ostream* _dout)
{
return *_dout << "ErasureCodePluginJerasure: ";
}
int ErasureCodePluginJerasure::factory(const std::string& directory,
- ErasureCodeProfile &profile,
- ErasureCodeInterfaceRef *erasure_code,
- std::ostream *ss) {
+ ceph::ErasureCodeProfile &profile,
+ ceph::ErasureCodeInterfaceRef *erasure_code,
+ std::ostream *ss) {
ErasureCodeJerasure *interface;
std::string t;
if (profile.find("technique") != profile.end())
delete interface;
return r;
}
- *erasure_code = ErasureCodeInterfaceRef(interface);
+ *erasure_code = ceph::ErasureCodeInterfaceRef(interface);
return 0;
}
int __erasure_code_init(char *plugin_name, char *directory)
{
- ErasureCodePluginRegistry &instance = ErasureCodePluginRegistry::instance();
+ auto& instance = ceph::ErasureCodePluginRegistry::instance();
int w[] = { 4, 8, 16, 32 };
int r = jerasure_init(4, w);
if (r) {