summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSage Weil <sage@inktank.com>2013-08-18 21:26:44 -0700
committerSage Weil <sage@inktank.com>2013-08-26 16:17:11 -0700
commit9aa34536e7174454aafb3b90085d175edf0a5abc (patch)
tree75de513d9b4c445e534fe429c1d07a1d16322e98
parent931fc161f98dec7e047b5aceb210b446d66595b0 (diff)
downloadceph-9aa34536e7174454aafb3b90085d175edf0a5abc.tar.gz
osd/ReplicatedPG: add whitespace
Signed-off-by: Sage Weil <sage@inktank.com>
-rw-r--r--src/osd/ReplicatedPG.cc10
1 files changed, 10 insertions, 0 deletions
diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc
index 21dc09848a9..c6ce2b2670a 100644
--- a/src/osd/ReplicatedPG.cc
+++ b/src/osd/ReplicatedPG.cc
@@ -3040,6 +3040,7 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops)
ctx->delta_stats.num_rd++;
}
break;
+
case CEPH_OSD_OP_OMAPGETVALS:
++ctx->num_read;
{
@@ -3104,6 +3105,7 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops)
ctx->delta_stats.num_rd++;
}
break;
+
case CEPH_OSD_OP_OMAPGETHEADER:
++ctx->num_read;
{
@@ -3125,6 +3127,7 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops)
ctx->delta_stats.num_rd++;
}
break;
+
case CEPH_OSD_OP_OMAPGETVALSBYKEYS:
++ctx->num_read;
{
@@ -3165,6 +3168,7 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops)
ctx->delta_stats.num_rd++;
}
break;
+
case CEPH_OSD_OP_OMAP_CMP:
++ctx->num_read;
{
@@ -3230,6 +3234,7 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops)
}
}
break;
+
// OMAP Write ops
case CEPH_OSD_OP_OMAPSETVALS:
++ctx->num_write;
@@ -3260,6 +3265,7 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops)
ctx->delta_stats.num_wr++;
}
break;
+
case CEPH_OSD_OP_OMAPSETHEADER:
++ctx->num_write;
{
@@ -3275,6 +3281,7 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops)
ctx->delta_stats.num_wr++;
}
break;
+
case CEPH_OSD_OP_OMAPCLEAR:
++ctx->num_write;
{
@@ -3290,6 +3297,7 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops)
ctx->delta_stats.num_wr++;
}
break;
+
case CEPH_OSD_OP_OMAPRMKEYS:
++ctx->num_write;
{
@@ -3313,6 +3321,8 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops)
ctx->delta_stats.num_wr++;
}
break;
+
+
default:
dout(1) << "unrecognized osd op " << op.op
<< " " << ceph_osd_op_name(op.op)