hadoop: re-add ceph_set_default_preferred_pg

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

diff --git a/src/client/hadoop/CephFSInterface.cc b/src/client/hadoop/CephFSInterface.cc
index 907785987cb80e08d05b0dfb870cb3bf20abd225..6c2a7b3aaca901751740b96070f27e7a9bb92bb9 100644 (file)
--- a/src/client/hadoop/CephFSInterface.cc
+++ b/src/client/hadoop/CephFSInterface.cc
@@ -102,7 +102,7 @@ JNIEXPORT jboolean JNICALL Java_org_apache_hadoop_fs_ceph_CephTalker_ceph_1initi
   if (ret)
     return false;
   if (set_local_writes) {
-    // ???
+    ceph_set_default_preferred_pg(cmount, ceph_get_local_osd(cmount));
   }
 
   set_ceph_mount_t(env, obj, cmount);