1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* Copyright (C) 2014 FUJITSU LIMITED
* Copyright (C) 2013, 2014 Cloudwatt <libre.licensing@cloudwatt.com>
* Copyright (C) 2014 Red Hat <contact@redhat.com>
*
* Author: Takanori Nakao <nakao.takanori@jp.fujitsu.com>
* Author: Takeshi Miyamae <miyamae.takeshi@jp.fujitsu.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_SHEC_H
#define CEPH_ERASURE_CODE_SHEC_H
#include "erasure-code/ErasureCode.h"
#include "ErasureCodeShecTableCache.h"
class ErasureCodeShec : public ceph::ErasureCode {
public:
enum {
MULTIPLE = 0,
SINGLE = 1
};
ErasureCodeShecTableCache &tcache;
int k;
int DEFAULT_K;
int m;
int DEFAULT_M;
int c;
int DEFAULT_C;
int w;
int DEFAULT_W;
int technique;
int *matrix;
ErasureCodeShec(const int _technique,
ErasureCodeShecTableCache &_tcache) :
tcache(_tcache),
k(0),
DEFAULT_K(4),
m(0),
DEFAULT_M(3),
c(0),
DEFAULT_C(2),
w(0),
DEFAULT_W(8),
technique(_technique),
matrix(0)
{}
~ErasureCodeShec() 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 _minimum_to_decode(const std::set<int> &want_to_read,
const std::set<int> &available_chunks,
std::set<int> *minimum);
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 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, 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(ceph::ErasureCodeProfile &profile, std::ostream *ss) override;
virtual void shec_encode(char **data,
char **coding,
int blocksize) = 0;
virtual int shec_decode(int *erasures,
int *avails,
char **data,
char **coding,
int blocksize) = 0;
virtual unsigned get_alignment() const = 0;
virtual void prepare() = 0;
virtual int shec_matrix_decode(int *erased, int *avails,
char **data_ptrs, char **coding_ptrs, int size);
virtual int* shec_reedsolomon_coding_matrix(int is_single);
private:
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,
int *want, int *avails,
int *decoding_matrix,
int *dm_row, int *dm_column,
int *minimum);
};
class ErasureCodeShecReedSolomonVandermonde final : public ErasureCodeShec {
public:
ErasureCodeShecReedSolomonVandermonde(ErasureCodeShecTableCache &_tcache,
int technique = MULTIPLE) :
ErasureCodeShec(technique, _tcache)
{}
~ErasureCodeShecReedSolomonVandermonde() override {
}
void shec_encode(char **data,
char **coding,
int blocksize) override;
int shec_decode(int *erasures,
int *avails,
char **data,
char **coding,
int blocksize) override;
unsigned get_alignment() const override;
void prepare() override;
private:
int parse(const ceph::ErasureCodeProfile &profile) override;
};
#endif
|
