Method decode

src/test/erasure-code/ceph_erasure_code_benchmark.cc:260–326

}

int ErasureCodeBench::decode()
{
  ErasureCodePluginRegistry &instance = ErasureCodePluginRegistry::instance();
  ErasureCodeInterfaceRef erasure_code;
  stringstream messages;
  int code = instance.factory(plugin,
			      g_conf().get_val<std::string>("erasure_code_dir"),
			      profile, &erasure_code, &messages);
  if (code) {
    cerr << messages.str() << std::endl;
    return code;
  }

  bufferlist in;
  in.append(string(in_size, 'X'));
  in.rebuild_aligned(ErasureCode::SIMD_ALIGN);

  shard_id_set want_to_encode;
  for (shard_id_t i; i < k + m; ++i) {
    want_to_encode.insert(i);
  }

  shard_id_map<bufferlist> encoded(erasure_code->get_chunk_count());
  code = erasure_code->encode(want_to_encode, in, &encoded);
  if (code)
    return code;

  shard_id_set want_to_read = want_to_encode;

  if (erased.size() > 0) {
    for (vector<int>::const_iterator i = erased.begin();
	 i != erased.end();
	 ++i)
      encoded.erase(shard_id_t(*i));
    display_chunks(encoded, erasure_code->get_chunk_count());
  }

  utime_t begin_time = ceph_clock_now();
  for (int i = 0; i < max_iterations; i++) {
    if (exhaustive_erasures) {
      code = decode_erasures(encoded, encoded, shard_id_t(0), erasures, erasure_code);
      if (code)
	return code;
    } else if (erased.size() > 0) {
      shard_id_map<bufferlist> decoded(erasure_code->get_chunk_count());
      code = erasure_code->decode(want_to_read, encoded, &decoded, 0);
      if (code)
	return code;
    } else {
      shard_id_map<bufferlist> chunks = encoded;
      for (int j = 0; j < erasures; j++) {
	int erasure;
	do {
	  erasure = rand() % ( k + m );
	} while(chunks.count(shard_id_t(erasure)) == 0);
	chunks.erase(shard_id_t(erasure));
      }
      shard_id_map<bufferlist> decoded(erasure_code->get_chunk_count());