Method encode

src/test/erasure-code/ceph_erasure_code_benchmark.cc:165–195

}

int ErasureCodeBench::encode()
{
  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);
  }
  utime_t begin_time = ceph_clock_now();
  for (int i = 0; i < max_iterations; i++) {
    shard_id_map<bufferlist> encoded(erasure_code->get_chunk_count());
    code = erasure_code->encode(want_to_encode, in, &encoded);
    if (code)
      return code;
  }
  utime_t end_time = ceph_clock_now();
  cout << (end_time - begin_time) << "\t" << (max_iterations * (in_size / 1024)) << std::endl;
  return 0;
}

static void display_chunks(const shard_id_map<bufferlist> &chunks,
			   unsigned int chunk_count) {