csyn: implement localize_reads cmdline option

Signed-off-by: Colin McCabe <colin.mccabe@dreamhost.com>

diff --git a/src/client/SyntheticClient.cc b/src/client/SyntheticClient.cc
index 2522e4613db5694b1e156a2c3ebe4f278bed63aa..4c3dc72a5068f23a504e8189d421140af482345b 100644 (file)
--- a/src/client/SyntheticClient.cc
+++ b/src/client/SyntheticClient.cc
@@ -48,6 +48,7 @@ using namespace std;
 list<int> syn_modes;
 list<int> syn_iargs;
 list<string> syn_sargs;
+int syn_filer_flags = 0;
 
 void parse_syn_options(vector<const char*>& args)
 {
@@ -245,6 +246,10 @@ void parse_syn_options(vector<const char*>& args)
         assert(0);
       }
     }
+    else if (strcmp(args[i], "localize_reads") == 0) {
+      cerr << "set CEPH_OSD_FLAG_LOCALIZE_READS" << std::endl;
+      syn_filer_flags |= CEPH_OSD_FLAG_LOCALIZE_READS;
+    }
     else {
       nargs.push_back(args[i]);
     }

diff --git a/src/csyn.cc b/src/csyn.cc
index 29a815c8193f62657c3bbbef380d5308908f9f8d..24053e04a118ac0214418d4ceb03c57e3a2ca373 100644 (file)
--- a/src/csyn.cc
+++ b/src/csyn.cc
@@ -37,6 +37,8 @@ using namespace std;
 #include <sys/stat.h>
 #include <fcntl.h>
 
+extern int syn_filer_flags;
+
 int main(int argc, const char **argv, char *envp[]) 
 {
   //cerr << "csyn starting" << std::endl;
@@ -71,6 +73,7 @@ int main(int argc, const char **argv, char *envp[])
     mclients[i] = new MonClient();
     mclients[i]->build_initial_monmap();
     Client *client = new Client(messengers[i], mclients[i]);
+    client->set_filer_flags(syn_filer_flags);
     SyntheticClient *syn = new SyntheticClient(client);
     clients.push_back(client);
     synclients.push_back(syn);