osd: pass in data to do_command

Signed-off-by: Sage Weil <[email protected]>
siplabs · Feb 24, 2012 · 0361a3c · 0361a3c
1 parent c9416e6
commit 0361a3c
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 5 deletions.
diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc
@@ -2411,7 +2411,7 @@ void OSD::do_command(Connection *con, tid_t tid, vector<string>& cmd, bufferlist
 	r = -ENOENT;
       } else {
 	cmd.erase(cmd.begin(), cmd.begin() + 2);
-	r = pg->do_command(cmd, ss, odata);
+	r = pg->do_command(cmd, ss, data, odata);
       }
       pg->unlock();
     }

diff --git a/src/osd/PG.h b/src/osd/PG.h
@@ -1399,7 +1399,8 @@ class PG {
   virtual void do_backfill(OpRequest *op) = 0;
   virtual bool snap_trimmer() = 0;
 
-  virtual int do_command(vector<string>& cmd, ostream& ss, bufferlist& data) = 0;
+  virtual int do_command(vector<string>& cmd, ostream& ss,
+			 bufferlist& idata, bufferlist& odata) = 0;
 
   virtual bool same_for_read_since(epoch_t e) = 0;
   virtual bool same_for_modify_since(epoch_t e) = 0;

diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc
@@ -251,7 +251,8 @@ int ReplicatedPG::get_pgls_filter(bufferlist::iterator& iter, PGLSFilter **pfilt
 
 // ==========================================================
 
-int ReplicatedPG::do_command(vector<string>& cmd, ostream& ss, bufferlist& data)
+int ReplicatedPG::do_command(vector<string>& cmd, ostream& ss,
+			     bufferlist& idata, bufferlist& odata)
 {
   if (cmd.size() && cmd[0] == "query") {
     JSONFormatter jsf(true);
@@ -271,7 +272,7 @@ int ReplicatedPG::do_command(vector<string>& cmd, ostream& ss, bufferlist& data)
     jsf.close_section();
     stringstream dss;
     jsf.flush(dss);
-    data.append(dss);
+    odata.append(dss);
     return 0;
   }
   else if (cmd.size() > 1 &&

diff --git a/src/osd/ReplicatedPG.h b/src/osd/ReplicatedPG.h
@@ -789,7 +789,7 @@ class ReplicatedPG : public PG {
   ReplicatedPG(OSD *o, PGPool *_pool, pg_t p, const hobject_t& oid, const hobject_t& ioid);
   ~ReplicatedPG() {}
 
-  int do_command(vector<string>& cmd, ostream& ss, bufferlist& data);
+  int do_command(vector<string>& cmd, ostream& ss, bufferlist& idata, bufferlist& odata);
 
   void do_op(OpRequest *op);
   bool pg_op_must_wait(MOSDOp *op);