config: remove osd_rep

We always use primary copy replication mode.

diff --git a/src/config.cc b/src/config.cc
index 5e3c23dd8e983c9f623e1d763565f0d61e14c13f..08eac2e930f79cd4ed796c7aa39a19deec4b3055 100644 (file)
--- a/src/config.cc
+++ b/src/config.cc
@@ -387,8 +387,6 @@ md_config_t g_conf = {
   mds_hack_log_expire_for_better_stats: false,
 
   // --- osd ---
-  osd_rep: OSD_REP_PRIMARY,
-
   osd_balance_reads: false,  // send from client to replica
   osd_flash_crowd_iat_threshold: 0,//100,
   osd_flash_crowd_iat_alpha: 0.125,
@@ -760,7 +758,6 @@ void parse_config_file(ConfFile *cf, bool auto_update)
   CF_READ("mds", "dump cache after rejoin", mds_dump_cache_after_rejoin);
   CF_READ("mds", "hack log expire for better stats", mds_hack_log_expire_for_better_stats);
 
-  CF_READ("osd", "rep", osd_rep);
   CF_READ("osd", "balance reads", osd_balance_reads);
   CF_READ("osd", "flash crowd iat threshold", osd_flash_crowd_iat_threshold);
   CF_READ("osd", "flash crowd iat alpha", osd_flash_crowd_iat_alpha);
@@ -1271,14 +1268,6 @@ void parse_config_options(std::vector<const char*>& args, bool open)
     else if ( strcmp(args[i],"--osd_stat_refresh_interval" ) == 0 && isarg)
       g_conf.osd_stat_refresh_interval = atof(args[++i]);
 
-    else if (strcmp(args[i], "--osd_rep") == 0 && isarg) 
-      g_conf.osd_rep = atoi(args[++i]);
-    else if (strcmp(args[i], "--osd_rep_chain") == 0) 
-      g_conf.osd_rep = OSD_REP_CHAIN;
-    else if (strcmp(args[i], "--osd_rep_splay") == 0) 
-      g_conf.osd_rep = OSD_REP_SPLAY;
-    else if (strcmp(args[i], "--osd_rep_primary") == 0) 
-      g_conf.osd_rep = OSD_REP_PRIMARY;
     else if (strcmp(args[i], "--osd_heartbeat_interval") == 0 && isarg) 
       g_conf.osd_heartbeat_interval = atoi(args[++i]);
     else if (strcmp(args[i], "--osd_heartbeat_grace") == 0 && isarg) 

diff --git a/src/config.h b/src/config.h
index f5a48c806dc9bb50eeeaa391c2ee24b0d852448d..4fac7eda50c952cf4397ae9d3e96358cf5dad516 100644 (file)
--- a/src/config.h
+++ b/src/config.h
@@ -247,8 +247,6 @@ struct md_config_t {
   bool mds_hack_log_expire_for_better_stats;
 
   // osd
-  int   osd_rep;
-
   bool osd_balance_reads;
   int osd_flash_crowd_iat_threshold;  // flash crowd interarrival time threshold in ms
   double osd_flash_crowd_iat_alpha;

diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc
index 343c0aa71c1d1a98660aae2b85c38727599ca096..766e0dcedb6b5d24e58469d72c69d2ee2eab0cf1 100644 (file)
--- a/src/osd/ReplicatedPG.cc
+++ b/src/osd/ReplicatedPG.cc
@@ -120,8 +120,7 @@ bool ReplicatedPG::preprocess_op(MOSDOp *op, utime_t now)
   pobject_t poid(info.pgid.pool(), 0, oid);
 
   // -- load balance reads --
-  if (is_primary() &&
-      g_conf.osd_rep == OSD_REP_PRIMARY) {
+  if (is_primary()) {
     // -- read on primary+acker ---
     
     // test

diff --git a/src/osdc/Objecter.h b/src/osdc/Objecter.h
index 6d22f2d0a5b42b8f13bf7471e6bbb3a4bd2f0c4a..121197fcd3adc484aa9c02efbcac37fd05d83e09 100644 (file)
--- a/src/osdc/Objecter.h
+++ b/src/osdc/Objecter.h
@@ -140,10 +140,7 @@ class Objecter {
     // acker - where i read, and receive acks from
     int acker() {
       if (acting.empty()) return -1;
-      if (g_conf.osd_rep == OSD_REP_PRIMARY)
-        return acting[0];
-      else
-        return acting[acting.size() > 1 ? 1:0];
+      return acting[0];
     }
   };