update ceph source to reef 18.1.2

[ceph.git] / ceph / src / crimson / common / operation.cc

// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab

#include "operation.h"

namespace crimson {

void Operation::dump(ceph::Formatter* f) const
{
  f->open_object_section("operation");
  f->dump_string("type", get_type_name());
  f->dump_unsigned("id", id);
  {
    f->open_object_section("detail");
    dump_detail(f);
    f->close_section();
  }
  f->close_section();
}

void Operation::dump_brief(ceph::Formatter* f) const
{
  f->open_object_section("operation");
  f->dump_string("type", get_type_name());
  f->dump_unsigned("id", id);
  f->close_section();
}

std::ostream &operator<<(std::ostream &lhs, const Operation &rhs) {
  lhs << rhs.get_type_name() << "(id=" << rhs.get_id() << ", detail=";
  rhs.print(lhs);
  lhs << ")";
  return lhs;
}

void Blocker::dump(ceph::Formatter* f) const
{
  f->open_object_section("blocker");
  f->dump_string("op_type", get_type_name());
  {
    f->open_object_section("detail");
    dump_detail(f);
    f->close_section();
  }
  f->close_section();
}

namespace detail {
void dump_time_event(const char* name,
		     const utime_t& timestamp,
		     ceph::Formatter* f)
{
  assert(f);
  f->open_object_section("time_event");
  f->dump_string("name", name);
  f->dump_stream("initiated_at") << timestamp;
  f->close_section();
}

void dump_blocking_event(const char* name,
			 const utime_t& timestamp,
			 const Blocker* const blocker,
			 ceph::Formatter* f)
{
  assert(f);
  f->open_object_section("blocking_event");
  f->dump_string("name", name);
  f->dump_stream("initiated_at") << timestamp;
  if (blocker) {
    blocker->dump(f);
  }
  f->close_section();
}
} // namespace detail
} // namespace crimson