From a9e172717216794b97619dfd389921d97d36a1e1 Mon Sep 17 00:00:00 2001
From: Greg Farnum <gregf@hq.newdream.net>
Date: Wed, 26 May 2010 16:44:17 -0700
Subject: [PATCH] objecter: add optional crush_rule parameter; set in
 pool_op_submit as needed

---
 src/osdc/Objecter.cc | 5 ++++-
 src/osdc/Objecter.h  | 6 ++++--
 2 files changed, 8 insertions(+), 3 deletions(-)

diff --git a/src/osdc/Objecter.cc b/src/osdc/Objecter.cc
index 616a874ebf30b..cf07e6a3b1520 100644
--- a/src/osdc/Objecter.cc
+++ b/src/osdc/Objecter.cc
@@ -738,7 +738,8 @@ int Objecter::delete_selfmanaged_snap(int pool, snapid_t snap,
   return 0;
 }
 
-int Objecter::create_pool(string& name, Context *onfinish, uint64_t auid)
+int Objecter::create_pool(string& name, Context *onfinish, uint64_t auid,
+			  __u8 crush_rule)
 {
   dout(10) << "create_pool name=" << name << dendl;
   PoolOp *op = new PoolOp;
@@ -751,6 +752,7 @@ int Objecter::create_pool(string& name, Context *onfinish, uint64_t auid)
   op->pool_op = POOL_OP_CREATE;
   op_pool[op->tid] = op;
   op->auid = auid;
+  op->crush_rule = crush_rule;
 
   pool_op_submit(op);
 
@@ -805,6 +807,7 @@ void Objecter::pool_op_submit(PoolOp *op) {
 			   op->name, op->pool_op,
 			   op->auid, last_seen_osdmap_version);
   if (op->snapid) m->snapid = op->snapid;
+  if (op->crush_rule) m->crush_rule = op->crush_rule;
   monc->send_mon_message(m);
   op->last_submit = g_clock.now();
 }
diff --git a/src/osdc/Objecter.h b/src/osdc/Objecter.h
index 0b71176edf87f..8a3e2ba165567 100644
--- a/src/osdc/Objecter.h
+++ b/src/osdc/Objecter.h
@@ -340,12 +340,13 @@ public:
     Context *onfinish;
     int pool_op;
     uint64_t auid;
+    __u8 crush_rule;
     snapid_t snapid;
     bufferlist *blp;
 
     utime_t last_submit;
     PoolOp() : tid(0), pool(0), onfinish(0), pool_op(0),
-	       auid(0), snapid(0), blp(NULL) {}
+	       auid(0), crush_rule(0), snapid(0), blp(NULL) {}
   };
 
 
@@ -676,7 +677,8 @@ public:
   int delete_pool_snap(int pool, string& snapName, Context *onfinish);
   int delete_selfmanaged_snap(int pool, snapid_t snap, Context *onfinish);
 
-  int create_pool(string& name, Context *onfinish, uint64_t auid=0);
+  int create_pool(string& name, Context *onfinish, uint64_t auid=0,
+		  __u8 crush_rule=0);
   int delete_pool(int pool, Context *onfinish);
   int change_pool_auid(int pool, Context *onfinish, uint64_t auid);
 
-- 
2.39.5