Method entry

src/ceph_fuse.cc:203–253

      }
      ~RemountTest() override {}
      void *entry() override {
#if defined(__linux__)
        bool can_invalidate_dentries = g_conf().get_val<bool>(
	  "client_try_dentry_invalidate");
        uint64_t max_retries = g_conf().get_val<uint64_t>(
          "client_max_retries_on_remount_failure");
        std::pair<int, bool> test_result;
        uint64_t i = 0;
        int tr = 0;
        do {
          test_result = client->test_dentry_handling(can_invalidate_dentries);
          tr = test_result.first;
          if (tr) {
            sleep(1);
          }
        } while (++i < max_retries && tr);

	bool abort_on_failure = test_result.second;
        bool client_die_on_failed_dentry_invalidate = g_conf().get_val<bool>(
          "client_die_on_failed_dentry_invalidate");
	if (tr != 0 && client_die_on_failed_dentry_invalidate) {
	  cerr << "ceph-fuse[" << getpid()
	       << "]: fuse failed dentry invalidate/remount test with error "
	       << cpp_strerror(tr) << ", stopping" << std::endl;

	  char buf[5050];
	  string mountpoint = cfuse->get_mount_point();
	  snprintf(buf, sizeof(buf), "fusermount -u -z %s", mountpoint.c_str());
	  int umount_r = system(buf);
	  if (umount_r) {
	    if (umount_r != -1) {
	      if (WIFEXITED(umount_r)) {
		umount_r = WEXITSTATUS(umount_r);
		cerr << "got error " << umount_r
		     << " when unmounting Ceph on failed remount test!" << std::endl;
	      } else {
		cerr << "attempt to umount on failed remount test failed (on a signal?)" << std::endl;
	      }
	    } else {
	      cerr << "system() invocation failed during remount test" << std::endl;
	    }
	  }
	}
	if(abort_on_failure) {
	  ceph_abort();
	}
	return reinterpret_cast<void*>(tr);
#else
	return reinterpret_cast<void*>(0);
#endif
      }
    } tester;