Method decode_erasures

src/test/erasure-code/ceph_erasure_code_benchmark.cc:211–258

}

int ErasureCodeBench::decode_erasures(const shard_id_map<bufferlist> &all_chunks,
				      const shard_id_map<bufferlist> &chunks,
				      shard_id_t shard,
				      unsigned want_erasures,
				      ErasureCodeInterfaceRef erasure_code)
{
  int code = 0;

  if (want_erasures == 0) {
    if (verbose)
      display_chunks(chunks, erasure_code->get_chunk_count());
    shard_id_set want_to_read;
    for (shard_id_t chunk; chunk < erasure_code->get_chunk_count(); ++chunk)
      if (chunks.count(chunk) == 0)
	want_to_read.insert(chunk);

    shard_id_map<bufferlist> decoded(erasure_code->get_chunk_count());
    code = erasure_code->decode(want_to_read, chunks, &decoded, 0);
    if (code)
      return code;
    for (shard_id_set::const_iterator chunk = want_to_read.begin();
	 chunk != want_to_read.end();
	 ++chunk) {
      if (all_chunks.find(*chunk)->second.length() != decoded[*chunk].length()) {
	cerr << "chunk " << *chunk << " length=" << all_chunks.find(*chunk)->second.length()
	     << " decoded with length=" << decoded[*chunk].length() << std::endl;
	return -1;
      }
      bufferlist tmp = all_chunks.find(*chunk)->second;
      if (!tmp.contents_equal(decoded[*chunk])) {
	cerr << "chunk " << *chunk
	     << " content and recovered content are different" << std::endl;
	return -1;
      }
    }
    return 0;
  }

  for (; shard < erasure_code->get_chunk_count(); ++shard) {
    shard_id_map<bufferlist> one_less = chunks;
    one_less.erase(shard);
    code = decode_erasures(all_chunks, one_less, shard + 1, want_erasures - 1, erasure_code);
    if (code)
      return code;
  }

  return 0;
}

int ErasureCodeBench::decode()
{