+++ /dev/null
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-/*
- * Ceph distributed storage system
- *
- * Copyright (C) 2013, 2014 Cloudwatt <libre.licensing@cloudwatt.com>
- * Copyright (C) 2014 Red Hat <contact@redhat.com>
- *
- * Author: Loic Dachary <loic@dachary.org>
- *
- * This library is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License as published by the Free Software Foundation; either
- * version 2.1 of the License, or (at your option) any later version.
- *
- */
-
-#ifndef CEPH_ERASURE_CODE_JERASURE_H
-#define CEPH_ERASURE_CODE_JERASURE_H
-
-#include "erasure-code/ErasureCode.h"
-
-class ErasureCodeJerasure : public ErasureCode {
-public:
- int k;
- std::string DEFAULT_K;
- int m;
- std::string DEFAULT_M;
- int w;
- std::string DEFAULT_W;
- const char *technique;
- std::string rule_root;
- std::string rule_failure_domain;
- bool per_chunk_alignment;
-
- explicit ErasureCodeJerasure(const char *_technique) :
- k(0),
- DEFAULT_K("2"),
- m(0),
- DEFAULT_M("1"),
- w(0),
- DEFAULT_W("8"),
- technique(_technique),
- per_chunk_alignment(false)
- {}
-
- ~ErasureCodeJerasure() override {}
-
- unsigned int get_chunk_count() const override {
- return k + m;
- }
-
- unsigned int get_data_chunk_count() const override {
- return 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;
-
- int decode_chunks(const std::set<int> &want_to_read,
- const std::map<int, bufferlist> &chunks,
- std::map<int, bufferlist> *decoded) override;
-
- int init(ErasureCodeProfile &profile, std::ostream *ss) override;
-
- virtual void jerasure_encode(char **data,
- char **coding,
- int blocksize) = 0;
- virtual int jerasure_decode(int *erasures,
- char **data,
- char **coding,
- int blocksize) = 0;
- virtual unsigned get_alignment() const = 0;
- virtual void prepare() = 0;
- static bool is_prime(int value);
-protected:
- virtual int parse(ErasureCodeProfile &profile, std::ostream *ss);
-};
-
-class ErasureCodeJerasureReedSolomonVandermonde : public ErasureCodeJerasure {
-public:
- int *matrix;
-
- ErasureCodeJerasureReedSolomonVandermonde() :
- ErasureCodeJerasure("reed_sol_van"),
- matrix(0)
- {
- DEFAULT_K = "7";
- DEFAULT_M = "3";
- DEFAULT_W = "8";
- }
- ~ErasureCodeJerasureReedSolomonVandermonde() override {
- if (matrix)
- free(matrix);
- }
-
- void jerasure_encode(char **data,
- char **coding,
- int blocksize) override;
- int jerasure_decode(int *erasures,
- char **data,
- char **coding,
- int blocksize) override;
- unsigned get_alignment() const override;
- void prepare() override;
-private:
- int parse(ErasureCodeProfile &profile, std::ostream *ss) override;
-};
-
-class ErasureCodeJerasureReedSolomonRAID6 : public ErasureCodeJerasure {
-public:
- int *matrix;
-
- ErasureCodeJerasureReedSolomonRAID6() :
- ErasureCodeJerasure("reed_sol_r6_op"),
- matrix(0)
- {
- DEFAULT_K = "7";
- DEFAULT_W = "8";
- }
- ~ErasureCodeJerasureReedSolomonRAID6() override {
- if (matrix)
- free(matrix);
- }
-
- void jerasure_encode(char **data,
- char **coding,
- int blocksize) override;
- int jerasure_decode(int *erasures,
- char **data,
- char **coding,
- int blocksize) override;
- unsigned get_alignment() const override;
- void prepare() override;
-private:
- int parse(ErasureCodeProfile &profile, std::ostream *ss) override;
-};
-
-#define DEFAULT_PACKETSIZE "2048"
-
-class ErasureCodeJerasureCauchy : public ErasureCodeJerasure {
-public:
- int *bitmatrix;
- int **schedule;
- int packetsize;
-
- explicit ErasureCodeJerasureCauchy(const char *technique) :
- ErasureCodeJerasure(technique),
- bitmatrix(0),
- schedule(0),
- packetsize(0)
- {
- DEFAULT_K = "7";
- DEFAULT_M = "3";
- DEFAULT_W = "8";
- }
- ~ErasureCodeJerasureCauchy() override {
- if (bitmatrix)
- free(bitmatrix);
- if (schedule)
- free(schedule);
- }
-
- void jerasure_encode(char **data,
- char **coding,
- int blocksize) override;
- int jerasure_decode(int *erasures,
- char **data,
- char **coding,
- int blocksize) override;
- unsigned get_alignment() const override;
- void prepare_schedule(int *matrix);
-private:
- int parse(ErasureCodeProfile &profile, std::ostream *ss) override;
-};
-
-class ErasureCodeJerasureCauchyOrig : public ErasureCodeJerasureCauchy {
-public:
- ErasureCodeJerasureCauchyOrig() :
- ErasureCodeJerasureCauchy("cauchy_orig")
- {}
-
- void prepare() override;
-};
-
-class ErasureCodeJerasureCauchyGood : public ErasureCodeJerasureCauchy {
-public:
- ErasureCodeJerasureCauchyGood() :
- ErasureCodeJerasureCauchy("cauchy_good")
- {}
-
- void prepare() override;
-};
-
-class ErasureCodeJerasureLiberation : public ErasureCodeJerasure {
-public:
- int *bitmatrix;
- int **schedule;
- int packetsize;
-
- explicit ErasureCodeJerasureLiberation(const char *technique = "liberation") :
- ErasureCodeJerasure(technique),
- bitmatrix(0),
- schedule(0),
- packetsize(0)
- {
- DEFAULT_K = "2";
- DEFAULT_M = "2";
- DEFAULT_W = "7";
- }
- ~ErasureCodeJerasureLiberation() override;
-
- void jerasure_encode(char **data,
- char **coding,
- int blocksize) override;
- int jerasure_decode(int *erasures,
- char **data,
- char **coding,
- int blocksize) override;
- unsigned get_alignment() const override;
- virtual bool check_k(std::ostream *ss) const;
- 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,
- std::ostream *ss);
- void prepare() override;
-private:
- int parse(ErasureCodeProfile &profile, std::ostream *ss) override;
-};
-
-class ErasureCodeJerasureBlaumRoth : public ErasureCodeJerasureLiberation {
-public:
- ErasureCodeJerasureBlaumRoth() :
- ErasureCodeJerasureLiberation("blaum_roth")
- {
- }
-
- bool check_w(std::ostream *ss) const override;
- void prepare() override;
-};
-
-class ErasureCodeJerasureLiber8tion : public ErasureCodeJerasureLiberation {
-public:
- ErasureCodeJerasureLiber8tion() :
- ErasureCodeJerasureLiberation("liber8tion")
- {
- DEFAULT_K = "2";
- DEFAULT_M = "2";
- DEFAULT_W = "8";
- }
-
- void prepare() override;
-private:
- int parse(ErasureCodeProfile &profile, std::ostream *ss) override;
-};
-
-#endif
Code Review / stor4nfv.git / blobdiff