diff options
author | Greg Farnum <greg@inktank.com> | 2013-10-09 10:08:24 -0700 |
---|---|---|
committer | Greg Farnum <greg@inktank.com> | 2013-10-09 11:13:55 -0700 |
commit | 12159e452c0919ec9dd6a4677af09ef33c765ebc (patch) | |
tree | 478510e60d94ee93748a6146d676d17758674bad | |
parent | 27026ead1d8fedd1cb66eabf78717b3503d65264 (diff) | |
download | ceph-12159e452c0919ec9dd6a4677af09ef33c765ebc.tar.gz |
OSD: rename CEPH_OSD_OP_COPY_GET -> CEPH_OSD_OP_COPY_GET_CLASSIC
In order to introduce versioning of copy-get, we need to make it a
different op that has the versioning infrastructure from the start.
Signed-off-by: Greg Farnum <greg@inktank.com>
-rw-r--r-- | src/common/ceph_strings.cc | 2 | ||||
-rw-r--r-- | src/include/rados.h | 2 | ||||
-rw-r--r-- | src/osd/ReplicatedPG.cc | 7 | ||||
-rw-r--r-- | src/osd/ReplicatedPG.h | 3 | ||||
-rw-r--r-- | src/osd/osd_types.cc | 2 | ||||
-rw-r--r-- | src/osdc/Objecter.h | 2 |
6 files changed, 10 insertions, 8 deletions
diff --git a/src/common/ceph_strings.cc b/src/common/ceph_strings.cc index 47648ce19b3..858487a6445 100644 --- a/src/common/ceph_strings.cc +++ b/src/common/ceph_strings.cc @@ -48,7 +48,7 @@ const char *ceph_osd_op_name(int op) case CEPH_OSD_OP_TMAPPUT: return "tmapput"; case CEPH_OSD_OP_WATCH: return "watch"; - case CEPH_OSD_OP_COPY_GET: return "copy-get"; + case CEPH_OSD_OP_COPY_GET_CLASSIC: return "copy-get-classic"; case CEPH_OSD_OP_COPY_FROM: return "copy-from"; case CEPH_OSD_OP_UNDIRTY: return "undirty"; case CEPH_OSD_OP_ISDIRTY: return "isdirty"; diff --git a/src/include/rados.h b/src/include/rados.h index e7a32b5afef..48374cd1af9 100644 --- a/src/include/rados.h +++ b/src/include/rados.h @@ -218,7 +218,7 @@ enum { CEPH_OSD_OP_OMAP_CMP = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 25, CEPH_OSD_OP_COPY_FROM = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 26, - CEPH_OSD_OP_COPY_GET = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 27, + CEPH_OSD_OP_COPY_GET_CLASSIC = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 27, CEPH_OSD_OP_UNDIRTY = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 28, CEPH_OSD_OP_ISDIRTY = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 29, diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc index b09b8065720..a14c811605a 100644 --- a/src/osd/ReplicatedPG.cc +++ b/src/osd/ReplicatedPG.cc @@ -3601,9 +3601,9 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops) } break; - case CEPH_OSD_OP_COPY_GET: + case CEPH_OSD_OP_COPY_GET_CLASSIC: ++ctx->num_read; - result = fill_in_copy_get(bp, osd_op, oi); + result = fill_in_copy_get(bp, osd_op, oi, true); if (result == -EINVAL) goto fail; break; @@ -4242,8 +4242,9 @@ struct C_Copyfrom : public Context { }; int ReplicatedPG::fill_in_copy_get(bufferlist::iterator& bp, OSDOp& osd_op, - object_info_t& oi) + object_info_t& oi, bool classic) { + assert(classic); hobject_t& soid = oi.soid; int result = 0; object_copy_cursor_t cursor; diff --git a/src/osd/ReplicatedPG.h b/src/osd/ReplicatedPG.h index aeb3c3612a1..f2775716e58 100644 --- a/src/osd/ReplicatedPG.h +++ b/src/osd/ReplicatedPG.h @@ -815,7 +815,8 @@ protected: // -- copyfrom -- map<hobject_t, CopyOpRef> copy_ops; - int fill_in_copy_get(bufferlist::iterator& bp, OSDOp& op, object_info_t& oi); + int fill_in_copy_get(bufferlist::iterator& bp, OSDOp& op, + object_info_t& oi, bool classic); /** * To copy an object, call start_copy. * diff --git a/src/osd/osd_types.cc b/src/osd/osd_types.cc index 692ac05ff56..5cdd6f6859c 100644 --- a/src/osd/osd_types.cc +++ b/src/osd/osd_types.cc @@ -3608,7 +3608,7 @@ ostream& operator<<(ostream& out, const OSDOp& op) out << (op.op.watch.flag ? " add":" remove") << " cookie " << op.op.watch.cookie << " ver " << op.op.watch.ver; break; - case CEPH_OSD_OP_COPY_GET: + case CEPH_OSD_OP_COPY_GET_CLASSIC: out << " max " << op.op.copy_get.max; case CEPH_OSD_OP_COPY_FROM: out << " ver " << op.op.copy_from.src_version; diff --git a/src/osdc/Objecter.h b/src/osdc/Objecter.h index b48c6bfcc14..a18f9a5bc04 100644 --- a/src/osdc/Objecter.h +++ b/src/osdc/Objecter.h @@ -620,7 +620,7 @@ struct ObjectOperation { bufferlist *out_data, std::map<std::string,bufferlist> *out_omap, int *prval) { - OSDOp& osd_op = add_op(CEPH_OSD_OP_COPY_GET); + OSDOp& osd_op = add_op(CEPH_OSD_OP_COPY_GET_CLASSIC); osd_op.op.copy_get.max = max; ::encode(*cursor, osd_op.indata); ::encode(max, osd_op.indata); |