From 2faf6a09bfa0eebf2a9f1b23f05f29508014b27b Mon Sep 17 00:00:00 2001
From: Colin Patrick McCabe <cmccabe@alumni.cmu.edu>
Date: Tue, 1 Feb 2011 10:14:05 -0800
Subject: [PATCH] csyn: implement localize_reads cmdline option

Signed-off-by: Colin McCabe <colin.mccabe@dreamhost.com>
---
 src/client/SyntheticClient.cc | 5 +++++
 src/csyn.cc                   | 3 +++
 2 files changed, 8 insertions(+)

diff --git a/src/client/SyntheticClient.cc b/src/client/SyntheticClient.cc
index 2522e4613db..4c3dc72a506 100644
--- 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 29a815c8193..24053e04a11 100644
--- 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);
-- 
2.47.3