summaryrefslogtreecommitdiffstats
path: root/src/test/libcephfs/reclaim.cc
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/test/libcephfs/reclaim.cc161
1 files changed, 161 insertions, 0 deletions
diff --git a/src/test/libcephfs/reclaim.cc b/src/test/libcephfs/reclaim.cc
new file mode 100644
index 00000000..7b2f7b76
--- /dev/null
+++ b/src/test/libcephfs/reclaim.cc
@@ -0,0 +1,161 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
+/*
+ * Tests for Ceph delegation handling
+ *
+ * (c) 2017, Jeff Layton <jlayton@redhat.com>
+ */
+
+#include "gtest/gtest.h"
+#include "include/cephfs/libcephfs.h"
+#include "include/stat.h"
+#include <errno.h>
+#include <fcntl.h>
+#include <unistd.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <dirent.h>
+#include <sys/uio.h>
+#include <libgen.h>
+#include <stdlib.h>
+
+#ifdef __linux__
+#include <sys/xattr.h>
+#include <limits.h>
+#endif
+
+#ifdef __FreeBSD__
+#include <sys/wait.h>
+#endif
+
+
+#include <map>
+#include <vector>
+#include <thread>
+#include <atomic>
+
+#define CEPHFS_RECLAIM_TIMEOUT 60
+
+static int dying_client(int argc, char **argv)
+{
+ struct ceph_mount_info *cmount;
+
+ /* Caller must pass in the uuid */
+ if (argc < 2)
+ return 1;
+
+ if (ceph_create(&cmount, nullptr) != 0)
+ return 1;
+
+ if (ceph_conf_read_file(cmount, nullptr) != 0)
+ return 1;
+
+ if (ceph_conf_parse_env(cmount, nullptr) != 0)
+ return 1;
+
+ if (ceph_init(cmount) != 0)
+ return 1;
+
+ ceph_set_session_timeout(cmount, CEPHFS_RECLAIM_TIMEOUT);
+
+ if (ceph_start_reclaim(cmount, argv[1], CEPH_RECLAIM_RESET) != -ENOENT)
+ return 1;
+
+ ceph_set_uuid(cmount, argv[1]);
+
+ if (ceph_mount(cmount, "/") != 0)
+ return 1;
+
+ Inode *root, *file;
+ if (ceph_ll_lookup_root(cmount, &root) != 0)
+ return 1;
+
+ Fh *fh;
+ struct ceph_statx stx;
+ UserPerm *perms = ceph_mount_perms(cmount);
+
+ if (ceph_ll_create(cmount, root, argv[1], 0666, O_RDWR|O_CREAT|O_EXCL,
+ &file, &fh, &stx, 0, 0, perms) != 0)
+ return 1;
+
+ return 0;
+}
+
+TEST(LibCephFS, ReclaimReset) {
+ pid_t pid;
+ char uuid[256];
+ const char *exe = "/proc/self/exe";
+
+ sprintf(uuid, "simplereclaim:%x", getpid());
+
+ pid = fork();
+ ASSERT_GE(pid, 0);
+ if (pid == 0) {
+ errno = 0;
+ execl(exe, exe, uuid, nullptr);
+ /* It won't be zero of course, which is sort of the point... */
+ ASSERT_EQ(errno, 0);
+ }
+
+ /* parent - wait for child to exit */
+ int ret;
+ pid_t wp = wait(&ret);
+ ASSERT_GE(wp, 0);
+ ASSERT_EQ(WIFEXITED(ret), true);
+ ASSERT_EQ(WEXITSTATUS(ret), 0);
+
+ struct ceph_mount_info *cmount;
+ ASSERT_EQ(ceph_create(&cmount, nullptr), 0);
+ ASSERT_EQ(ceph_conf_read_file(cmount, nullptr), 0);
+ ASSERT_EQ(0, ceph_conf_parse_env(cmount, nullptr));
+ ASSERT_EQ(ceph_init(cmount), 0);
+ ceph_set_session_timeout(cmount, CEPHFS_RECLAIM_TIMEOUT);
+ ASSERT_EQ(ceph_start_reclaim(cmount, uuid, CEPH_RECLAIM_RESET), 0);
+ ceph_set_uuid(cmount, uuid);
+ ASSERT_EQ(ceph_mount(cmount, "/"), 0);
+
+ Inode *root, *file;
+ ASSERT_EQ(ceph_ll_lookup_root(cmount, &root), 0);
+ UserPerm *perms = ceph_mount_perms(cmount);
+ struct ceph_statx stx;
+ ASSERT_EQ(ceph_ll_lookup(cmount, root, uuid, &file, &stx, 0, 0, perms), 0);
+ Fh *fh;
+ ASSERT_EQ(ceph_ll_open(cmount, file, O_WRONLY, &fh, perms), 0);
+
+ ceph_unmount(cmount);
+ ceph_release(cmount);
+}
+
+static int update_root_mode()
+{
+ struct ceph_mount_info *admin;
+ int r = ceph_create(&admin, nullptr);
+ if (r < 0)
+ return r;
+ ceph_conf_read_file(admin, nullptr);
+ ceph_conf_parse_env(admin, nullptr);
+ ceph_conf_set(admin, "client_permissions", "false");
+ r = ceph_mount(admin, "/");
+ if (r < 0)
+ goto out;
+ r = ceph_chmod(admin, "/", 01777);
+out:
+ ceph_shutdown(admin);
+ return r;
+}
+
+int main(int argc, char **argv)
+{
+ int r = update_root_mode();
+ if (r < 0)
+ exit(1);
+
+ ::testing::InitGoogleTest(&argc, argv);
+
+ if (argc > 1)
+ return dying_client(argc, argv);
+
+ srand(getpid());
+
+ return RUN_ALL_TESTS();
+}