summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGreg Farnum <greg@inktank.com>2013-10-09 10:08:24 -0700
committerGreg Farnum <greg@inktank.com>2013-10-17 13:11:44 -0700
commitc6d980c36db928be1ae17c7bc35e463cc3cbea44 (patch)
tree5d5a623e8063a1fdb5b6fa5a505a369b9dee3260
parent06c12accd21b2a7b4813501b8278435ae1750c2f (diff)
downloadceph-c6d980c36db928be1ae17c7bc35e463cc3cbea44.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.cc2
-rw-r--r--src/include/rados.h2
-rw-r--r--src/osd/ReplicatedPG.cc7
-rw-r--r--src/osd/ReplicatedPG.h3
-rw-r--r--src/osd/osd_types.cc2
-rw-r--r--src/osdc/Objecter.h2
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 4255bd9f012..a7c49bebb67 100644
--- a/src/osd/ReplicatedPG.h
+++ b/src/osd/ReplicatedPG.h
@@ -821,7 +821,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);