From 416cd968b93effdcd6c65c47ae2abb84a9a3f0a9 Mon Sep 17 00:00:00 2001
From: Sage Weil <sage@newdream.net>
Date: Thu, 8 Oct 2009 10:34:09 -0700
Subject: [PATCH] osd: use fast_fail() policy to connect to osd

---
 src/cfuse.cc          | 2 +-
 src/client/libceph.cc | 2 +-
 src/cmds.cc           | 2 +-
 src/csyn.cc           | 2 +-
 src/librados.cc       | 2 +-
 5 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/cfuse.cc b/src/cfuse.cc
index f7420df4c99..0d358990437 100644
--- a/src/cfuse.cc
+++ b/src/cfuse.cc
@@ -77,7 +77,7 @@ int main(int argc, const char **argv, const char *envp[]) {
 
   rank.set_policy(entity_name_t::TYPE_MON, SimpleMessenger::Policy::lossy_fail_after(1.0));
   rank.set_policy(entity_name_t::TYPE_MDS, SimpleMessenger::Policy::lossless());
-  rank.set_policy(entity_name_t::TYPE_OSD, SimpleMessenger::Policy::lossless());
+  rank.set_policy(entity_name_t::TYPE_OSD, SimpleMessenger::Policy::lossy_fast_fail());
 
   // start client
   client->init();
diff --git a/src/client/libceph.cc b/src/client/libceph.cc
index f298129f3f4..b1c0524c097 100644
--- a/src/client/libceph.cc
+++ b/src/client/libceph.cc
@@ -57,7 +57,7 @@ extern "C" int ceph_initialize(int argc, const char **argv)
     rank->start();
     rank->set_policy(entity_name_t::TYPE_MON, SimpleMessenger::Policy::lossy_fast_fail());
     rank->set_policy(entity_name_t::TYPE_MDS, SimpleMessenger::Policy::lossless());
-    rank->set_policy(entity_name_t::TYPE_OSD, SimpleMessenger::Policy::lossless());
+    rank->set_policy(entity_name_t::TYPE_OSD, SimpleMessenger::Policy::lossy_fast_fail());
 
     client->init();
   }
diff --git a/src/cmds.cc b/src/cmds.cc
index a3831afa2d3..e572068ceef 100644
--- a/src/cmds.cc
+++ b/src/cmds.cc
@@ -81,7 +81,7 @@ int main(int argc, const char **argv)
   rank.set_default_policy(SimpleMessenger::Policy::stateful_server());
   rank.set_policy(entity_name_t::TYPE_MON, SimpleMessenger::Policy::lossy_fail_after(1.0));
   rank.set_policy(entity_name_t::TYPE_MDS, SimpleMessenger::Policy::lossless());
-  rank.set_policy(entity_name_t::TYPE_OSD, SimpleMessenger::Policy::lossless());
+  rank.set_policy(entity_name_t::TYPE_OSD, SimpleMessenger::Policy::lossy_fast_fail());
 
   rank.start();
   
diff --git a/src/csyn.cc b/src/csyn.cc
index f42281b9d93..715c3ec9e6e 100644
--- a/src/csyn.cc
+++ b/src/csyn.cc
@@ -60,7 +60,7 @@ int main(int argc, const char **argv, char *envp[])
 
   rank.set_policy(entity_name_t::TYPE_MON, SimpleMessenger::Policy::lossy_fail_after(2.0));
   rank.set_policy(entity_name_t::TYPE_MDS, SimpleMessenger::Policy::lossless());
-  rank.set_policy(entity_name_t::TYPE_OSD, SimpleMessenger::Policy::lossless());
+  rank.set_policy(entity_name_t::TYPE_OSD, SimpleMessenger::Policy::lossy_fast_fail());
 
   list<Client*> clients;
   list<SyntheticClient*> synclients;
diff --git a/src/librados.cc b/src/librados.cc
index d29c039523d..f9469f41b27 100644
--- a/src/librados.cc
+++ b/src/librados.cc
@@ -294,7 +294,7 @@ bool RadosClient::init()
 
   rank.set_policy(entity_name_t::TYPE_MON, SimpleMessenger::Policy::lossy_fail_after(1.0));
   rank.set_policy(entity_name_t::TYPE_MDS, SimpleMessenger::Policy::lossless());
-  rank.set_policy(entity_name_t::TYPE_OSD, SimpleMessenger::Policy::lossless());
+  rank.set_policy(entity_name_t::TYPE_OSD, SimpleMessenger::Policy::lossy_fast_fail());
   rank.set_policy(entity_name_t::TYPE_CLIENT, SimpleMessenger::Policy::lossless());  // mds does its own timeout/markdown
 
   rank.start(1);
-- 
2.47.3