#include <dirent.h>
#include <sys/uio.h>
#include <sys/time.h>
+
+#ifndef _WIN32
#include <sys/resource.h>
+#endif
#include "common/Clock.h"
#include <thread>
#include <regex>
-#ifndef ALLPERMS
-#define ALLPERMS (S_ISUID|S_ISGID|S_ISVTX|S_IRWXU|S_IRWXG|S_IRWXO)
-#endif
-
using namespace std;
TEST(LibCephFS, OpenEmptyComponent) {
fd = ceph_open(cmount, path.c_str(), O_RDONLY, 0);
ASSERT_LE(0, fd);
- ASSERT_EQ(ceph_ftruncate(cmount, fd, 0), -EBADF);
- ASSERT_EQ(ceph_ftruncate(cmount, fd, 1), -EBADF);
+ ASSERT_EQ(ceph_ftruncate(cmount, fd, 0), -CEPHFS_EBADF);
+ ASSERT_EQ(ceph_ftruncate(cmount, fd, 1), -CEPHFS_EBADF);
ASSERT_EQ(0, ceph_close(cmount, fd));
ceph_shutdown(cmount);
size_t size = strlen(out_buf);
char in_buf[100];
ASSERT_EQ(ceph_write(cmount, fd, out_buf, size, 0), (int)size);
- ASSERT_EQ(ceph_read(cmount, fd, in_buf, sizeof(in_buf), 0), -EBADF);
+ ASSERT_EQ(ceph_read(cmount, fd, in_buf, sizeof(in_buf), 0), -CEPHFS_EBADF);
ASSERT_EQ(0, ceph_close(cmount, fd));
fd = ceph_open(cmount, c_path, O_RDONLY, 0);
ASSERT_LT(0, fd);
- ASSERT_EQ(ceph_write(cmount, fd, out_buf, size, 0), -EBADF);
+ ASSERT_EQ(ceph_write(cmount, fd, out_buf, size, 0), -CEPHFS_EBADF);
ASSERT_EQ(ceph_read(cmount, fd, in_buf, sizeof(in_buf), 0), (int)size);
ASSERT_EQ(0, ceph_close(cmount, fd));
ASSERT_EQ(0, ceph_conf_read_file(cmount, NULL));
ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
ASSERT_EQ(0, ceph_mount(cmount, "/"));
- ASSERT_EQ(-EISCONN, ceph_mount(cmount, "/"));
+ ASSERT_EQ(-CEPHFS_EISCONN, ceph_mount(cmount, "/"));
ceph_shutdown(cmount);
}
ASSERT_EQ(0, ceph_create(&cmount, NULL));
ASSERT_EQ(0, ceph_conf_read_file(cmount, NULL));
ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
- ASSERT_EQ(-ENOTCONN, ceph_unmount(cmount));
+ ASSERT_EQ(-CEPHFS_ENOTCONN, ceph_unmount(cmount));
ceph_shutdown(cmount);
}
ASSERT_EQ(0, ceph_conf_read_file(cmount, NULL));
ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
ASSERT_EQ(0, ceph_mount(cmount, "/"));
- ASSERT_EQ(-EISCONN, ceph_release(cmount));
+ ASSERT_EQ(-CEPHFS_EISCONN, ceph_release(cmount));
ASSERT_EQ(0, ceph_unmount(cmount));
ASSERT_EQ(0, ceph_release(cmount));
}
ASSERT_LT(0, ceph_get_file_pool_name(cmount, fd, poolname, sizeof(poolname)));
ASSERT_LT(0, ceph_get_file_pool_name(cmount, fd, poolname, 0));
- /* on already-written file (ENOTEMPTY) */
+ /* on already-written file (CEPHFS_ENOTEMPTY) */
ceph_write(cmount, fd, "hello world", 11, 0);
ceph_close(cmount, fd);
char xattrv[128];
sprintf(xattrk, "ceph.file.layout.stripe_unit");
sprintf(xattrv, "65536");
- ASSERT_EQ(-ENOTEMPTY, ceph_setxattr(cmount, test_layout_file, xattrk, (void *)xattrv, 5, 0));
+ ASSERT_EQ(-CEPHFS_ENOTEMPTY, ceph_setxattr(cmount, test_layout_file, xattrk, (void *)xattrv, 5, 0));
/* invalid layout */
sprintf(test_layout_file, "test_layout_%d_c", getpid());
fd = ceph_open_layout(cmount, test_layout_file, O_CREAT, 0666, (1<<20), 1, 19, NULL);
- ASSERT_EQ(fd, -EINVAL);
+ ASSERT_EQ(fd, -CEPHFS_EINVAL);
/* with data pool */
sprintf(test_layout_file, "test_layout_%d_d", getpid());
/* with metadata pool (invalid) */
sprintf(test_layout_file, "test_layout_%d_e", getpid());
fd = ceph_open_layout(cmount, test_layout_file, O_CREAT, 0666, (1<<20), 7, (1<<20), "metadata");
- ASSERT_EQ(fd, -EINVAL);
+ ASSERT_EQ(fd, -CEPHFS_EINVAL);
/* with metadata pool (does not exist) */
sprintf(test_layout_file, "test_layout_%d_f", getpid());
fd = ceph_open_layout(cmount, test_layout_file, O_CREAT, 0666, (1<<20), 7, (1<<20), "asdfjasdfjasdf");
- ASSERT_EQ(fd, -EINVAL);
+ ASSERT_EQ(fd, -CEPHFS_EINVAL);
ceph_shutdown(cmount);
}
struct ceph_dir_result *ls_dir = NULL;
char foostr[256];
sprintf(foostr, "dir_ls%d", mypid);
- ASSERT_EQ(ceph_opendir(cmount, foostr, &ls_dir), -ENOENT);
+ ASSERT_EQ(ceph_opendir(cmount, foostr, &ls_dir), -CEPHFS_ENOENT);
ASSERT_EQ(ceph_mkdir(cmount, foostr, 0777), 0);
struct ceph_statx stx;
char barstr[256];
sprintf(barstr, "dir_ls2%d", mypid);
- ASSERT_EQ(ceph_statx(cmount, barstr, &stx, 0, AT_SYMLINK_NOFOLLOW), -ENOENT);
+ ASSERT_EQ(ceph_statx(cmount, barstr, &stx, 0, AT_SYMLINK_NOFOLLOW), -CEPHFS_ENOENT);
// insert files into directory and test open
char bazstr[256];
sscanf(name, "dirf%d", &size);
ASSERT_TRUE(stx.stx_mask & CEPH_STATX_SIZE);
ASSERT_EQ(stx.stx_size, (size_t)size);
+ // On Windows, dirent uses long (4B) inodes, which get trimmed
+ // and can't be used.
+ // TODO: consider defining ceph_dirent.
+ #ifndef _WIN32
ASSERT_EQ(stx.stx_ino, rdent.d_ino);
+ #endif
//ASSERT_EQ(st.st_mode, (mode_t)0666);
}
ASSERT_EQ(found, entries);
ASSERT_GT(fd, 0);
// test removing non-existent xattr
- ASSERT_EQ(-ENODATA, ceph_removexattr(cmount, test_xattr_file, "user.nosuchxattr"));
+ ASSERT_EQ(-CEPHFS_ENODATA, ceph_removexattr(cmount, test_xattr_file, "user.nosuchxattr"));
char i = 'a';
char xattrk[128];
char xattrlist[128*26];
ASSERT_GT(sizeof(xattrlist), (size_t)len_needed);
int len = ceph_listxattr(cmount, test_xattr_file, xattrlist, len_needed - 1);
- ASSERT_EQ(-ERANGE, len);
+ ASSERT_EQ(-CEPHFS_ERANGE, len);
len = ceph_listxattr(cmount, test_xattr_file, xattrlist, sizeof(xattrlist));
ASSERT_EQ(len, len_needed);
sprintf(xattrv, "testxattr%c", i);
ASSERT_TRUE(!strncmp(xattrv, gxattrv, alen));
- n = index(p, '\0');
+ n = strchr(p, '\0');
n++;
len -= (n - p);
p = n;
ASSERT_EQ(ceph_chmod(cmount, test_file, 0400), 0);
fd = ceph_open(cmount, test_file, O_RDWR, 0);
- ASSERT_EQ(fd, -EACCES);
+ ASSERT_EQ(fd, -CEPHFS_EACCES);
fd = ceph_open(cmount, test_file, O_RDONLY, 0);
ASSERT_GT(fd, -1);
buf[ret] = '\0';
ASSERT_STREQ(buf, bytes);
- ASSERT_EQ(ceph_write(cmount, fd, bytes, strlen(bytes), 0), -EBADF);
+ ASSERT_EQ(ceph_write(cmount, fd, bytes, strlen(bytes), 0), -CEPHFS_EBADF);
ceph_close(cmount, fd);
ceph_close(cmount, fd);
- ASSERT_EQ(ceph_open(cmount, test_file, O_RDWR, 0), -EACCES);
+ ASSERT_EQ(ceph_open(cmount, test_file, O_RDWR, 0), -CEPHFS_EACCES);
// reset back to writeable
ASSERT_EQ(ceph_chmod(cmount, test_file, 0600), 0);
ceph_close(cmount, fd);
+ // "nobody" will be ignored on Windows
+ #ifndef _WIN32
fd = ceph_open(cmount, test_file, O_RDWR, 0);
- ASSERT_EQ(fd, -EACCES);
+ ASSERT_EQ(fd, -CEPHFS_EACCES);
+ #endif
ceph_shutdown(cmount);
}
sprintf(test_file, "test_oflag_%d", getpid());
int fd = ceph_open(cmount, test_file, O_CREAT|O_RDWR|O_PATH, 0666);
- ASSERT_EQ(-ENOENT, fd);
+ ASSERT_EQ(-CEPHFS_ENOENT, fd);
fd = ceph_open(cmount, test_file, O_CREAT|O_RDWR, 0666);
ASSERT_GT(fd, 0);
ASSERT_GT(fd, 0);
char buf[128];
- ASSERT_EQ(-EBADF, ceph_read(cmount, fd, buf, sizeof(buf), 0));
- ASSERT_EQ(-EBADF, ceph_write(cmount, fd, buf, sizeof(buf), 0));
+ ASSERT_EQ(-CEPHFS_EBADF, ceph_read(cmount, fd, buf, sizeof(buf), 0));
+ ASSERT_EQ(-CEPHFS_EBADF, ceph_write(cmount, fd, buf, sizeof(buf), 0));
// set perms to readable and writeable only by owner
- ASSERT_EQ(-EBADF, ceph_fchmod(cmount, fd, 0600));
+ ASSERT_EQ(-CEPHFS_EBADF, ceph_fchmod(cmount, fd, 0600));
// change ownership to nobody -- we assume nobody exists and id is always 65534
- ASSERT_EQ(-EBADF, ceph_fchown(cmount, fd, 65534, 65534));
+ ASSERT_EQ(-CEPHFS_EBADF, ceph_fchown(cmount, fd, 65534, 65534));
// try to sync
- ASSERT_EQ(-EBADF, ceph_fsync(cmount, fd, false));
+ ASSERT_EQ(-CEPHFS_EBADF, ceph_fsync(cmount, fd, false));
struct ceph_statx stx;
ASSERT_EQ(0, ceph_fstatx(cmount, fd, &stx, 0, 0));
// test the O_NOFOLLOW case
fd = ceph_open(cmount, test_symlink, O_NOFOLLOW, 0);
- ASSERT_EQ(fd, -ELOOP);
+ ASSERT_EQ(fd, -CEPHFS_ELOOP);
// stat the original file
struct ceph_statx stx_orig;
char test_file[256];
sprintf(test_file, "/dir1_loopsym_%d/loop_dir/symdir/test_loopsym_file", getpid());
int fd = ceph_open(cmount, test_file, O_CREAT|O_RDWR, 0600);
- ASSERT_EQ(fd, -ELOOP);
+ ASSERT_EQ(fd, -CEPHFS_ELOOP);
// loop: /a -> /b, /b -> /c, /c -> /a
char a[264], b[264], c[264];
ASSERT_EQ(ceph_symlink(cmount, a, b), 0);
ASSERT_EQ(ceph_symlink(cmount, b, c), 0);
ASSERT_EQ(ceph_symlink(cmount, c, a), 0);
- ASSERT_EQ(ceph_open(cmount, a, O_RDWR, 0), -ELOOP);
+ ASSERT_EQ(ceph_open(cmount, a, O_RDWR, 0), -CEPHFS_ELOOP);
ceph_shutdown(cmount);
}
ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
ASSERT_EQ(ceph_mount(cmount, NULL), 0);
- ASSERT_EQ(ceph_fchmod(cmount, -1, 0655), -EBADF);
- ASSERT_EQ(ceph_close(cmount, -1), -EBADF);
- ASSERT_EQ(ceph_lseek(cmount, -1, 0, SEEK_SET), -EBADF);
+ ASSERT_EQ(ceph_fchmod(cmount, -1, 0655), -CEPHFS_EBADF);
+ ASSERT_EQ(ceph_close(cmount, -1), -CEPHFS_EBADF);
+ ASSERT_EQ(ceph_lseek(cmount, -1, 0, SEEK_SET), -CEPHFS_EBADF);
char buf[0];
- ASSERT_EQ(ceph_read(cmount, -1, buf, 0, 0), -EBADF);
- ASSERT_EQ(ceph_write(cmount, -1, buf, 0, 0), -EBADF);
+ ASSERT_EQ(ceph_read(cmount, -1, buf, 0, 0), -CEPHFS_EBADF);
+ ASSERT_EQ(ceph_write(cmount, -1, buf, 0, 0), -CEPHFS_EBADF);
- ASSERT_EQ(ceph_ftruncate(cmount, -1, 0), -EBADF);
- ASSERT_EQ(ceph_fsync(cmount, -1, 0), -EBADF);
+ ASSERT_EQ(ceph_ftruncate(cmount, -1, 0), -CEPHFS_EBADF);
+ ASSERT_EQ(ceph_fsync(cmount, -1, 0), -CEPHFS_EBADF);
struct ceph_statx stx;
- ASSERT_EQ(ceph_fstatx(cmount, -1, &stx, 0, 0), -EBADF);
+ ASSERT_EQ(ceph_fstatx(cmount, -1, &stx, 0, 0), -CEPHFS_EBADF);
struct sockaddr_storage addr;
- ASSERT_EQ(ceph_get_file_stripe_address(cmount, -1, 0, &addr, 1), -EBADF);
+ ASSERT_EQ(ceph_get_file_stripe_address(cmount, -1, 0, &addr, 1), -CEPHFS_EBADF);
- ASSERT_EQ(ceph_get_file_stripe_unit(cmount, -1), -EBADF);
- ASSERT_EQ(ceph_get_file_pool(cmount, -1), -EBADF);
+ ASSERT_EQ(ceph_get_file_stripe_unit(cmount, -1), -CEPHFS_EBADF);
+ ASSERT_EQ(ceph_get_file_pool(cmount, -1), -CEPHFS_EBADF);
char poolname[80];
- ASSERT_EQ(ceph_get_file_pool_name(cmount, -1, poolname, sizeof(poolname)), -EBADF);
- ASSERT_EQ(ceph_get_file_replication(cmount, -1), -EBADF);
- ASSERT_EQ(ceph_get_file_object_size(cmount, -1), -EBADF);
+ ASSERT_EQ(ceph_get_file_pool_name(cmount, -1, poolname, sizeof(poolname)), -CEPHFS_EBADF);
+ ASSERT_EQ(ceph_get_file_replication(cmount, -1), -CEPHFS_EBADF);
+ ASSERT_EQ(ceph_get_file_object_size(cmount, -1), -CEPHFS_EBADF);
int stripe_unit, stripe_count, object_size, pg_pool;
- ASSERT_EQ(ceph_get_file_layout(cmount, -1, &stripe_unit, &stripe_count, &object_size, &pg_pool), -EBADF);
- ASSERT_EQ(ceph_get_file_stripe_count(cmount, -1), -EBADF);
+ ASSERT_EQ(ceph_get_file_layout(cmount, -1, &stripe_unit, &stripe_count, &object_size, &pg_pool), -CEPHFS_EBADF);
+ ASSERT_EQ(ceph_get_file_stripe_count(cmount, -1), -CEPHFS_EBADF);
ceph_shutdown(cmount);
}
ASSERT_EQ(0, ceph_statx(cmount, path_dst, &stx, 0, 0));
/* test that src path doesn't exist */
- ASSERT_EQ(-ENOENT, ceph_statx(cmount, path_src, &stx, 0, AT_SYMLINK_NOFOLLOW));
+ ASSERT_EQ(-CEPHFS_ENOENT, ceph_statx(cmount, path_src, &stx, 0, AT_SYMLINK_NOFOLLOW));
/* rename with non-existent source path */
- ASSERT_EQ(-ENOENT, ceph_rename(cmount, path_src, path_dst));
+ ASSERT_EQ(-CEPHFS_ENOENT, ceph_rename(cmount, path_src, path_dst));
ASSERT_EQ(0, ceph_unlink(cmount, path_dst));
ceph_shutdown(cmount);
ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
struct statvfs stvfs;
- EXPECT_EQ(-ENOTCONN, ceph_statfs(cmount, "/", &stvfs));
- EXPECT_EQ(-ENOTCONN, ceph_get_local_osd(cmount));
- EXPECT_EQ(-ENOTCONN, ceph_chdir(cmount, "/"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_statfs(cmount, "/", &stvfs));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_local_osd(cmount));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_chdir(cmount, "/"));
struct ceph_dir_result *dirp;
- EXPECT_EQ(-ENOTCONN, ceph_opendir(cmount, "/", &dirp));
- EXPECT_EQ(-ENOTCONN, ceph_closedir(cmount, dirp));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_opendir(cmount, "/", &dirp));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_closedir(cmount, dirp));
ceph_readdir(cmount, dirp);
- EXPECT_EQ(ENOTCONN, errno);
+ EXPECT_EQ(CEPHFS_ENOTCONN, errno);
struct dirent rdent;
- EXPECT_EQ(-ENOTCONN, ceph_readdir_r(cmount, dirp, &rdent));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_readdir_r(cmount, dirp, &rdent));
struct ceph_statx stx;
- EXPECT_EQ(-ENOTCONN, ceph_readdirplus_r(cmount, dirp, &rdent, &stx, 0, 0, NULL));
- EXPECT_EQ(-ENOTCONN, ceph_getdents(cmount, dirp, NULL, 0));
- EXPECT_EQ(-ENOTCONN, ceph_getdnames(cmount, dirp, NULL, 0));
- EXPECT_EQ(-ENOTCONN, ceph_telldir(cmount, dirp));
- EXPECT_EQ(-ENOTCONN, ceph_link(cmount, "/", "/link"));
- EXPECT_EQ(-ENOTCONN, ceph_unlink(cmount, "/path"));
- EXPECT_EQ(-ENOTCONN, ceph_rename(cmount, "/path", "/path"));
- EXPECT_EQ(-ENOTCONN, ceph_mkdir(cmount, "/", 0655));
- EXPECT_EQ(-ENOTCONN, ceph_mkdirs(cmount, "/", 0655));
- EXPECT_EQ(-ENOTCONN, ceph_rmdir(cmount, "/path"));
- EXPECT_EQ(-ENOTCONN, ceph_readlink(cmount, "/path", NULL, 0));
- EXPECT_EQ(-ENOTCONN, ceph_symlink(cmount, "/path", "/path"));
- EXPECT_EQ(-ENOTCONN, ceph_statx(cmount, "/path", &stx, 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_setattrx(cmount, "/path", &stx, 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_getxattr(cmount, "/path", "name", NULL, 0));
- EXPECT_EQ(-ENOTCONN, ceph_lgetxattr(cmount, "/path", "name", NULL, 0));
- EXPECT_EQ(-ENOTCONN, ceph_listxattr(cmount, "/path", NULL, 0));
- EXPECT_EQ(-ENOTCONN, ceph_llistxattr(cmount, "/path", NULL, 0));
- EXPECT_EQ(-ENOTCONN, ceph_removexattr(cmount, "/path", "name"));
- EXPECT_EQ(-ENOTCONN, ceph_lremovexattr(cmount, "/path", "name"));
- EXPECT_EQ(-ENOTCONN, ceph_setxattr(cmount, "/path", "name", NULL, 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_lsetxattr(cmount, "/path", "name", NULL, 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_fsetattrx(cmount, 0, &stx, 0));
- EXPECT_EQ(-ENOTCONN, ceph_chmod(cmount, "/path", 0));
- EXPECT_EQ(-ENOTCONN, ceph_fchmod(cmount, 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_chown(cmount, "/path", 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_lchown(cmount, "/path", 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_fchown(cmount, 0, 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_readdirplus_r(cmount, dirp, &rdent, &stx, 0, 0, NULL));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_getdents(cmount, dirp, NULL, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_getdnames(cmount, dirp, NULL, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_telldir(cmount, dirp));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_link(cmount, "/", "/link"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_unlink(cmount, "/path"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_rename(cmount, "/path", "/path"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_mkdir(cmount, "/", 0655));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_mkdirs(cmount, "/", 0655));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_rmdir(cmount, "/path"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_readlink(cmount, "/path", NULL, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_symlink(cmount, "/path", "/path"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_statx(cmount, "/path", &stx, 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_setattrx(cmount, "/path", &stx, 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_getxattr(cmount, "/path", "name", NULL, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_lgetxattr(cmount, "/path", "name", NULL, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_listxattr(cmount, "/path", NULL, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_llistxattr(cmount, "/path", NULL, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_removexattr(cmount, "/path", "name"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_lremovexattr(cmount, "/path", "name"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_setxattr(cmount, "/path", "name", NULL, 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_lsetxattr(cmount, "/path", "name", NULL, 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_fsetattrx(cmount, 0, &stx, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_chmod(cmount, "/path", 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_fchmod(cmount, 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_chown(cmount, "/path", 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_lchown(cmount, "/path", 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_fchown(cmount, 0, 0, 0));
struct utimbuf utb;
- EXPECT_EQ(-ENOTCONN, ceph_utime(cmount, "/path", &utb));
- EXPECT_EQ(-ENOTCONN, ceph_truncate(cmount, "/path", 0));
- EXPECT_EQ(-ENOTCONN, ceph_mknod(cmount, "/path", 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_open(cmount, "/path", 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_open_layout(cmount, "/path", 0, 0, 0, 0, 0, "pool"));
- EXPECT_EQ(-ENOTCONN, ceph_close(cmount, 0));
- EXPECT_EQ(-ENOTCONN, ceph_lseek(cmount, 0, 0, SEEK_SET));
- EXPECT_EQ(-ENOTCONN, ceph_read(cmount, 0, NULL, 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_write(cmount, 0, NULL, 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_ftruncate(cmount, 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_fsync(cmount, 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_fstatx(cmount, 0, &stx, 0, 0));
- EXPECT_EQ(-ENOTCONN, ceph_sync_fs(cmount));
- EXPECT_EQ(-ENOTCONN, ceph_get_file_stripe_unit(cmount, 0));
- EXPECT_EQ(-ENOTCONN, ceph_get_file_stripe_count(cmount, 0));
- EXPECT_EQ(-ENOTCONN, ceph_get_file_layout(cmount, 0, NULL, NULL ,NULL ,NULL));
- EXPECT_EQ(-ENOTCONN, ceph_get_file_object_size(cmount, 0));
- EXPECT_EQ(-ENOTCONN, ceph_get_file_pool(cmount, 0));
- EXPECT_EQ(-ENOTCONN, ceph_get_file_pool_name(cmount, 0, NULL, 0));
- EXPECT_EQ(-ENOTCONN, ceph_get_file_replication(cmount, 0));
- EXPECT_EQ(-ENOTCONN, ceph_get_path_replication(cmount, "/path"));
- EXPECT_EQ(-ENOTCONN, ceph_get_path_layout(cmount, "/path", NULL, NULL, NULL, NULL));
- EXPECT_EQ(-ENOTCONN, ceph_get_path_object_size(cmount, "/path"));
- EXPECT_EQ(-ENOTCONN, ceph_get_path_stripe_count(cmount, "/path"));
- EXPECT_EQ(-ENOTCONN, ceph_get_path_stripe_unit(cmount, "/path"));
- EXPECT_EQ(-ENOTCONN, ceph_get_path_pool(cmount, "/path"));
- EXPECT_EQ(-ENOTCONN, ceph_get_path_pool_name(cmount, "/path", NULL, 0));
- EXPECT_EQ(-ENOTCONN, ceph_get_pool_name(cmount, 0, NULL, 0));
- EXPECT_EQ(-ENOTCONN, ceph_get_file_stripe_address(cmount, 0, 0, NULL, 0));
- EXPECT_EQ(-ENOTCONN, ceph_localize_reads(cmount, 0));
- EXPECT_EQ(-ENOTCONN, ceph_debug_get_fd_caps(cmount, 0));
- EXPECT_EQ(-ENOTCONN, ceph_debug_get_file_caps(cmount, "/path"));
- EXPECT_EQ(-ENOTCONN, ceph_get_stripe_unit_granularity(cmount));
- EXPECT_EQ(-ENOTCONN, ceph_get_pool_id(cmount, "data"));
- EXPECT_EQ(-ENOTCONN, ceph_get_pool_replication(cmount, 1));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_utime(cmount, "/path", &utb));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_truncate(cmount, "/path", 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_mknod(cmount, "/path", 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_open(cmount, "/path", 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_open_layout(cmount, "/path", 0, 0, 0, 0, 0, "pool"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_close(cmount, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_lseek(cmount, 0, 0, SEEK_SET));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_read(cmount, 0, NULL, 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_write(cmount, 0, NULL, 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_ftruncate(cmount, 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_fsync(cmount, 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_fstatx(cmount, 0, &stx, 0, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_sync_fs(cmount));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_file_stripe_unit(cmount, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_file_stripe_count(cmount, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_file_layout(cmount, 0, NULL, NULL ,NULL ,NULL));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_file_object_size(cmount, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_file_pool(cmount, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_file_pool_name(cmount, 0, NULL, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_file_replication(cmount, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_path_replication(cmount, "/path"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_path_layout(cmount, "/path", NULL, NULL, NULL, NULL));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_path_object_size(cmount, "/path"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_path_stripe_count(cmount, "/path"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_path_stripe_unit(cmount, "/path"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_path_pool(cmount, "/path"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_path_pool_name(cmount, "/path", NULL, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_pool_name(cmount, 0, NULL, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_file_stripe_address(cmount, 0, 0, NULL, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_localize_reads(cmount, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_debug_get_fd_caps(cmount, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_debug_get_file_caps(cmount, "/path"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_stripe_unit_granularity(cmount));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_pool_id(cmount, "data"));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_pool_replication(cmount, 1));
ceph_release(cmount);
}
memset(name, 0, sizeof(name));
ASSERT_LE(0, ceph_get_path_pool_name(cmount, "/", name, sizeof(name)));
ASSERT_GE(ceph_get_pool_id(cmount, name), 0);
- ASSERT_EQ(ceph_get_pool_id(cmount, "weflkjwelfjwlkejf"), -ENOENT);
+ ASSERT_EQ(ceph_get_pool_id(cmount, "weflkjwelfjwlkejf"), -CEPHFS_ENOENT);
ceph_shutdown(cmount);
}
ASSERT_EQ(ceph_mount(cmount, NULL), 0);
/* negative pools */
- ASSERT_EQ(ceph_get_pool_replication(cmount, -10), -ENOENT);
+ ASSERT_EQ(ceph_get_pool_replication(cmount, -10), -CEPHFS_ENOENT);
/* valid pool */
int pool_id;
struct ceph_mount_info *cmount;
ASSERT_EQ(ceph_create(&cmount, NULL), 0);
- EXPECT_EQ(-ENOTCONN, ceph_get_file_extent_osds(cmount, 0, 0, NULL, NULL, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_file_extent_osds(cmount, 0, 0, NULL, NULL, 0));
ASSERT_EQ(ceph_conf_read_file(cmount, NULL), 0);
ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
/* only when more than 1 osd */
if (ret > 1) {
- EXPECT_EQ(-ERANGE, ceph_get_file_extent_osds(cmount, fd, 0, NULL, osds, 1));
+ EXPECT_EQ(-CEPHFS_ERANGE, ceph_get_file_extent_osds(cmount, fd, 0, NULL, osds, 1));
}
ceph_close(cmount, fd);
struct ceph_mount_info *cmount;
ASSERT_EQ(ceph_create(&cmount, NULL), 0);
- EXPECT_EQ(-ENOTCONN, ceph_get_osd_crush_location(cmount, 0, NULL, 0));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_osd_crush_location(cmount, 0, NULL, 0));
ASSERT_EQ(ceph_conf_read_file(cmount, NULL), 0);
ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
ASSERT_EQ(ceph_mount(cmount, NULL), 0);
- ASSERT_EQ(ceph_get_osd_crush_location(cmount, 0, NULL, 1), -EINVAL);
+ ASSERT_EQ(ceph_get_osd_crush_location(cmount, 0, NULL, 1), -CEPHFS_EINVAL);
char path[256];
- ASSERT_EQ(ceph_get_osd_crush_location(cmount, 9999999, path, 0), -ENOENT);
- ASSERT_EQ(ceph_get_osd_crush_location(cmount, -1, path, 0), -EINVAL);
+ ASSERT_EQ(ceph_get_osd_crush_location(cmount, 9999999, path, 0), -CEPHFS_ENOENT);
+ ASSERT_EQ(ceph_get_osd_crush_location(cmount, -1, path, 0), -CEPHFS_EINVAL);
char test_file[256];
sprintf(test_file, "test_osds_loc_%d", getpid());
EXPECT_EQ(ret, ceph_get_file_extent_osds(cmount, fd, 0, NULL, osds, ret));
ASSERT_GT(ceph_get_osd_crush_location(cmount, 0, path, 0), 0);
- ASSERT_EQ(ceph_get_osd_crush_location(cmount, 0, path, 1), -ERANGE);
+ ASSERT_EQ(ceph_get_osd_crush_location(cmount, 0, path, 1), -CEPHFS_ERANGE);
for (int i = 0; i < ret; i++) {
int len = ceph_get_osd_crush_location(cmount, osds[i], path, sizeof(path));
struct ceph_mount_info *cmount;
ASSERT_EQ(ceph_create(&cmount, NULL), 0);
- EXPECT_EQ(-ENOTCONN, ceph_get_osd_addr(cmount, 0, NULL));
+ EXPECT_EQ(-CEPHFS_ENOTCONN, ceph_get_osd_addr(cmount, 0, NULL));
ASSERT_EQ(ceph_conf_read_file(cmount, NULL), 0);
ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
ASSERT_EQ(ceph_mount(cmount, NULL), 0);
- ASSERT_EQ(-EINVAL, ceph_get_osd_addr(cmount, 0, NULL));
+ ASSERT_EQ(-CEPHFS_EINVAL, ceph_get_osd_addr(cmount, 0, NULL));
struct sockaddr_storage addr;
- ASSERT_EQ(-ENOENT, ceph_get_osd_addr(cmount, -1, &addr));
- ASSERT_EQ(-ENOENT, ceph_get_osd_addr(cmount, 9999999, &addr));
+ ASSERT_EQ(-CEPHFS_ENOENT, ceph_get_osd_addr(cmount, -1, &addr));
+ ASSERT_EQ(-CEPHFS_ENOENT, ceph_get_osd_addr(cmount, 9999999, &addr));
ASSERT_EQ(0, ceph_get_osd_addr(cmount, 0, &addr));
ceph_shutdown(cmount);
}
-TEST(LibCephFS, ClearSetuid) {
- struct ceph_mount_info *cmount;
- ASSERT_EQ(ceph_create(&cmount, NULL), 0);
- ASSERT_EQ(ceph_conf_read_file(cmount, NULL), 0);
- ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
- ASSERT_EQ(ceph_mount(cmount, "/"), 0);
-
- Inode *root;
- ASSERT_EQ(ceph_ll_lookup_root(cmount, &root), 0);
-
- char filename[32];
- sprintf(filename, "clearsetuid%x", getpid());
-
- Fh *fh;
- Inode *in;
- struct ceph_statx stx;
- const mode_t after_mode = S_IRWXU;
- const mode_t before_mode = S_IRWXU | S_ISUID | S_ISGID;
- const unsigned want = CEPH_STATX_UID|CEPH_STATX_GID|CEPH_STATX_MODE;
- UserPerm *usercred = ceph_mount_perms(cmount);
-
- ceph_ll_unlink(cmount, root, filename, usercred);
- ASSERT_EQ(ceph_ll_create(cmount, root, filename, before_mode,
- O_RDWR|O_CREAT|O_EXCL, &in, &fh, &stx, want, 0,
- usercred), 0);
-
- ASSERT_EQ(stx.stx_mode & (mode_t)ALLPERMS, before_mode);
-
- // write
- ASSERT_EQ(ceph_ll_write(cmount, fh, 0, 3, "foo"), 3);
- ASSERT_EQ(ceph_ll_getattr(cmount, in, &stx, CEPH_STATX_MODE, 0, usercred), 0);
- ASSERT_TRUE(stx.stx_mask & CEPH_STATX_MODE);
- ASSERT_EQ(stx.stx_mode & (mode_t)ALLPERMS, after_mode);
-
- // reset mode
- stx.stx_mode = before_mode;
- ASSERT_EQ(ceph_ll_setattr(cmount, in, &stx, CEPH_STATX_MODE, usercred), 0);
- ASSERT_EQ(ceph_ll_getattr(cmount, in, &stx, CEPH_STATX_MODE, 0, usercred), 0);
- ASSERT_TRUE(stx.stx_mask & CEPH_STATX_MODE);
- ASSERT_EQ(stx.stx_mode & (mode_t)ALLPERMS, before_mode);
-
- // truncate
- stx.stx_size = 1;
- ASSERT_EQ(ceph_ll_setattr(cmount, in, &stx, CEPH_SETATTR_SIZE, usercred), 0);
- ASSERT_EQ(ceph_ll_getattr(cmount, in, &stx, CEPH_STATX_MODE, 0, usercred), 0);
- ASSERT_TRUE(stx.stx_mask & CEPH_STATX_MODE);
- ASSERT_EQ(stx.stx_mode & (mode_t)ALLPERMS, after_mode);
-
- // reset mode
- stx.stx_mode = before_mode;
- ASSERT_EQ(ceph_ll_setattr(cmount, in, &stx, CEPH_STATX_MODE, usercred), 0);
- ASSERT_EQ(ceph_ll_getattr(cmount, in, &stx, CEPH_STATX_MODE, 0, usercred), 0);
- ASSERT_TRUE(stx.stx_mask & CEPH_STATX_MODE);
- ASSERT_EQ(stx.stx_mode & (mode_t)ALLPERMS, before_mode);
-
- // chown -- for this we need to be "root"
- UserPerm *rootcred = ceph_userperm_new(0, 0, 0, NULL);
- ASSERT_TRUE(rootcred);
- stx.stx_uid++;
- stx.stx_gid++;
- ASSERT_EQ(ceph_ll_setattr(cmount, in, &stx, CEPH_SETATTR_UID|CEPH_SETATTR_GID, rootcred), 0);
- ASSERT_EQ(ceph_ll_getattr(cmount, in, &stx, CEPH_STATX_MODE, 0, usercred), 0);
- ASSERT_TRUE(stx.stx_mask & CEPH_STATX_MODE);
- ASSERT_EQ(stx.stx_mode & (mode_t)ALLPERMS, after_mode);
-
- /* test chown with supplementary groups, and chown with/without exe bit */
- uid_t u = 65534;
- gid_t g = 65534;
- gid_t gids[] = {65533,65532};
- UserPerm *altcred = ceph_userperm_new(u, g, sizeof gids / sizeof gids[0], gids);
- stx.stx_uid = u;
- stx.stx_gid = g;
- mode_t m = S_ISGID|S_ISUID|S_IRUSR|S_IWUSR;
- stx.stx_mode = m;
- ASSERT_EQ(ceph_ll_setattr(cmount, in, &stx, CEPH_STATX_MODE|CEPH_SETATTR_UID|CEPH_SETATTR_GID, rootcred), 0);
- ASSERT_EQ(ceph_ll_getattr(cmount, in, &stx, CEPH_STATX_MODE, 0, altcred), 0);
- ASSERT_EQ(stx.stx_mode&(mode_t)ALLPERMS, m);
- /* not dropped without exe bit */
- stx.stx_gid = gids[0];
- ASSERT_EQ(ceph_ll_setattr(cmount, in, &stx, CEPH_SETATTR_GID, altcred), 0);
- ASSERT_EQ(ceph_ll_getattr(cmount, in, &stx, CEPH_STATX_MODE, 0, altcred), 0);
- ASSERT_EQ(stx.stx_mode&(mode_t)ALLPERMS, m);
- /* now check dropped with exe bit */
- m = S_ISGID|S_ISUID|S_IRWXU;
- stx.stx_mode = m;
- ASSERT_EQ(ceph_ll_setattr(cmount, in, &stx, CEPH_STATX_MODE, altcred), 0);
- ASSERT_EQ(ceph_ll_getattr(cmount, in, &stx, CEPH_STATX_MODE, 0, altcred), 0);
- ASSERT_EQ(stx.stx_mode&(mode_t)ALLPERMS, m);
- stx.stx_gid = gids[1];
- ASSERT_EQ(ceph_ll_setattr(cmount, in, &stx, CEPH_SETATTR_GID, altcred), 0);
- ASSERT_EQ(ceph_ll_getattr(cmount, in, &stx, CEPH_STATX_MODE, 0, altcred), 0);
- ASSERT_EQ(stx.stx_mode&(mode_t)ALLPERMS, m&(S_IRWXU|S_IRWXG|S_IRWXO));
- ceph_userperm_destroy(altcred);
-
- ASSERT_EQ(ceph_ll_close(cmount, fh), 0);
- ceph_shutdown(cmount);
-}
-
TEST(LibCephFS, OperationsOnRoot)
{
struct ceph_mount_info *cmount;
ASSERT_EQ(ceph_mkdir(cmount, dirname, 0755), 0);
- ASSERT_EQ(ceph_rmdir(cmount, "/"), -EBUSY);
+ ASSERT_EQ(ceph_rmdir(cmount, "/"), -CEPHFS_EBUSY);
- ASSERT_EQ(ceph_link(cmount, "/", "/"), -EEXIST);
- ASSERT_EQ(ceph_link(cmount, dirname, "/"), -EEXIST);
- ASSERT_EQ(ceph_link(cmount, "nonExisitingDir", "/"), -ENOENT);
+ ASSERT_EQ(ceph_link(cmount, "/", "/"), -CEPHFS_EEXIST);
+ ASSERT_EQ(ceph_link(cmount, dirname, "/"), -CEPHFS_EEXIST);
+ ASSERT_EQ(ceph_link(cmount, "nonExisitingDir", "/"), -CEPHFS_ENOENT);
- ASSERT_EQ(ceph_unlink(cmount, "/"), -EISDIR);
+ ASSERT_EQ(ceph_unlink(cmount, "/"), -CEPHFS_EISDIR);
- ASSERT_EQ(ceph_rename(cmount, "/", "/"), -EBUSY);
- ASSERT_EQ(ceph_rename(cmount, dirname, "/"), -EBUSY);
- ASSERT_EQ(ceph_rename(cmount, "nonExistingDir", "/"), -EBUSY);
- ASSERT_EQ(ceph_rename(cmount, "/", dirname), -EBUSY);
- ASSERT_EQ(ceph_rename(cmount, "/", "nonExistingDir"), -EBUSY);
+ ASSERT_EQ(ceph_rename(cmount, "/", "/"), -CEPHFS_EBUSY);
+ ASSERT_EQ(ceph_rename(cmount, dirname, "/"), -CEPHFS_EBUSY);
+ ASSERT_EQ(ceph_rename(cmount, "nonExistingDir", "/"), -CEPHFS_EBUSY);
+ ASSERT_EQ(ceph_rename(cmount, "/", dirname), -CEPHFS_EBUSY);
+ ASSERT_EQ(ceph_rename(cmount, "/", "nonExistingDir"), -CEPHFS_EBUSY);
- ASSERT_EQ(ceph_mkdir(cmount, "/", 0777), -EEXIST);
+ ASSERT_EQ(ceph_mkdir(cmount, "/", 0777), -CEPHFS_EEXIST);
- ASSERT_EQ(ceph_mknod(cmount, "/", 0, 0), -EEXIST);
+ ASSERT_EQ(ceph_mknod(cmount, "/", 0, 0), -CEPHFS_EEXIST);
- ASSERT_EQ(ceph_symlink(cmount, "/", "/"), -EEXIST);
- ASSERT_EQ(ceph_symlink(cmount, dirname, "/"), -EEXIST);
- ASSERT_EQ(ceph_symlink(cmount, "nonExistingDir", "/"), -EEXIST);
+ ASSERT_EQ(ceph_symlink(cmount, "/", "/"), -CEPHFS_EEXIST);
+ ASSERT_EQ(ceph_symlink(cmount, dirname, "/"), -CEPHFS_EEXIST);
+ ASSERT_EQ(ceph_symlink(cmount, "nonExistingDir", "/"), -CEPHFS_EEXIST);
ceph_shutdown(cmount);
}
+// no rlimits on Windows
+#ifndef _WIN32
static void shutdown_racer_func()
{
const int niter = 32;
*/
// ASSERT_EQ(setrlimit(RLIMIT_NOFILE, &rold), 0);
}
+#endif
static void get_current_time_utimbuf(struct utimbuf *utb)
{
sprintf(c_temp, "/oodd_temp_%d", mypid);
ASSERT_EQ(0, ceph_mkdir(cmount, c_dir, 0777));
- ASSERT_EQ(-EEXIST, ceph_mkdir(cmount, c_dir_dot, 0777));
- ASSERT_EQ(-EEXIST, ceph_mkdir(cmount, c_dir_dotdot, 0777));
+ ASSERT_EQ(-CEPHFS_EEXIST, ceph_mkdir(cmount, c_dir_dot, 0777));
+ ASSERT_EQ(-CEPHFS_EEXIST, ceph_mkdir(cmount, c_dir_dotdot, 0777));
ASSERT_EQ(0, ceph_mkdirs(cmount, c_non_existent_dirs, 0777));
- ASSERT_EQ(-ENOTEMPTY, ceph_rmdir(cmount, c_dir_dot));
- ASSERT_EQ(-ENOTEMPTY, ceph_rmdir(cmount, c_dir_dotdot));
- // non existent directory should return -ENOENT
- ASSERT_EQ(-ENOENT, ceph_rmdir(cmount, c_non_existent_dir));
+ ASSERT_EQ(-CEPHFS_ENOTEMPTY, ceph_rmdir(cmount, c_dir_dot));
+ ASSERT_EQ(-CEPHFS_ENOTEMPTY, ceph_rmdir(cmount, c_dir_dotdot));
+ // non existent directory should return -CEPHFS_ENOENT
+ ASSERT_EQ(-CEPHFS_ENOENT, ceph_rmdir(cmount, c_non_existent_dir));
- ASSERT_EQ(-EBUSY, ceph_rename(cmount, c_dir_dot, c_temp));
+ ASSERT_EQ(-CEPHFS_EBUSY, ceph_rename(cmount, c_dir_dot, c_temp));
ASSERT_EQ(0, ceph_chdir(cmount, c_dir));
ASSERT_EQ(0, ceph_mkdir(cmount, c_temp, 0777));
- ASSERT_EQ(-EBUSY, ceph_rename(cmount, c_temp, ".."));
+ ASSERT_EQ(-CEPHFS_EBUSY, ceph_rename(cmount, c_temp, ".."));
ceph_shutdown(cmount);
}
ASSERT_LT(0, alen);
ASSERT_LT(alen, xbuflen);
gxattrv[alen] = '\0';
- char *s = strchrnul(gxattrv, '.');
+ char *s = strchr(gxattrv, '.');
+ char *q = NULL;
+ ASSERT_NE(q, s);
ASSERT_LT(s, gxattrv + alen);
ASSERT_EQ('.', *s);
*s = '\0';
// non-snap file shouldn't carry the xattr
alen = ceph_getxattr(cmount, test_snap_xattr_file, "ceph.snap.btime", (void *)gxattrv2, xbuflen);
- ASSERT_EQ(-ENODATA, alen);
+ ASSERT_EQ(-CEPHFS_ENODATA, alen);
// create a second snapshot
sprintf(c_temp, "/.snap/test_snap_xattr_snap2_%d", mypid);
ASSERT_LT(0, alen);
ASSERT_LT(alen, xbuflen);
gxattrv2[alen] = '\0';
- s = strchrnul(gxattrv2, '.');
+ s = strchr(gxattrv2, '.');
+ ASSERT_NE(q, s);
ASSERT_LT(s, gxattrv2 + alen);
ASSERT_EQ('.', *s);
*s = '\0';
utime_t new_btime = utime_t(strtoull(gxattrv2, NULL, 10), strtoull(s + 1, NULL, 10));
+ #ifndef _WIN32
+ // This assertion sometimes fails on Windows, possibly due to the clock precision.
ASSERT_LT(btime, new_btime);
+ #endif
// listxattr() shouldn't return snap.btime vxattr
char xattrlist[512];
ceph_shutdown(cmount);
}
-TEST(LibCephFS, SnapQuota) {
- struct ceph_mount_info *cmount;
- ASSERT_EQ(ceph_create(&cmount, NULL), 0);
- ASSERT_EQ(ceph_conf_read_file(cmount, NULL), 0);
- ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
- ASSERT_EQ(ceph_mount(cmount, NULL), 0);
-
- char test_snap_dir_quota_xattr[256];
- char test_snap_subdir_quota_xattr[256];
- char test_snap_subdir_noquota_xattr[256];
- char xattrk[128];
- char xattrv[128];
- char c_temp[PATH_MAX];
- char gxattrv[128];
- int xbuflen = sizeof(gxattrv);
- pid_t mypid = getpid();
-
- // create dir and set quota
- sprintf(test_snap_dir_quota_xattr, "test_snap_dir_quota_xattr_%d", mypid);
- ASSERT_EQ(0, ceph_mkdir(cmount, test_snap_dir_quota_xattr, 0777));
-
- sprintf(xattrk, "ceph.quota.max_bytes");
- sprintf(xattrv, "65536");
- ASSERT_EQ(0, ceph_setxattr(cmount, test_snap_dir_quota_xattr, xattrk, (void *)xattrv, 5, XATTR_CREATE));
-
- // create subdir and set quota
- sprintf(test_snap_subdir_quota_xattr, "test_snap_dir_quota_xattr_%d/subdir_quota", mypid);
- ASSERT_EQ(0, ceph_mkdirs(cmount, test_snap_subdir_quota_xattr, 0777));
-
- sprintf(xattrk, "ceph.quota.max_bytes");
- sprintf(xattrv, "32768");
- ASSERT_EQ(0, ceph_setxattr(cmount, test_snap_subdir_quota_xattr, xattrk, (void *)xattrv, 5, XATTR_CREATE));
-
- // create subdir with no quota
- sprintf(test_snap_subdir_noquota_xattr, "test_snap_dir_quota_xattr_%d/subdir_noquota", mypid);
- ASSERT_EQ(0, ceph_mkdirs(cmount, test_snap_subdir_noquota_xattr, 0777));
-
- // snapshot dir
- sprintf(c_temp, "/.snap/test_snap_dir_quota_xattr_snap_%d", mypid);
- ASSERT_EQ(0, ceph_mkdirs(cmount, c_temp, 0777));
-
- // check dir quota under snap
- sprintf(c_temp, "/.snap/test_snap_dir_quota_xattr_snap_%d/test_snap_dir_quota_xattr_%d", mypid, mypid);
- int alen = ceph_getxattr(cmount, c_temp, "ceph.quota.max_bytes", (void *)gxattrv, xbuflen);
- ASSERT_LT(0, alen);
- ASSERT_LT(alen, xbuflen);
- gxattrv[alen] = '\0';
- ASSERT_STREQ(gxattrv, "65536");
-
- // check subdir quota under snap
- sprintf(c_temp, "/.snap/test_snap_dir_quota_xattr_snap_%d/test_snap_dir_quota_xattr_%d/subdir_quota", mypid, mypid);
- alen = ceph_getxattr(cmount, c_temp, "ceph.quota.max_bytes", (void *)gxattrv, xbuflen);
- ASSERT_LT(0, alen);
- ASSERT_LT(alen, xbuflen);
- gxattrv[alen] = '\0';
- ASSERT_STREQ(gxattrv, "32768");
-
- // ensure subdir noquota xattr under snap
- sprintf(c_temp, "/.snap/test_snap_dir_quota_xattr_snap_%d/test_snap_dir_quota_xattr_%d/subdir_noquota", mypid, mypid);
- EXPECT_EQ(-ENODATA, ceph_getxattr(cmount, c_temp, "ceph.quota.max_bytes", (void *)gxattrv, xbuflen));
-
- // listxattr() shouldn't return ceph.quota.max_bytes vxattr
- sprintf(c_temp, "/.snap/test_snap_dir_quota_xattr_snap_%d/test_snap_dir_quota_xattr_%d", mypid, mypid);
- char xattrlist[512];
- int len = ceph_listxattr(cmount, c_temp, xattrlist, sizeof(xattrlist));
- ASSERT_GE(sizeof(xattrlist), (size_t)len);
- char *p = xattrlist;
- int found = 0;
- while (len > 0) {
- if (strcmp(p, "ceph.quota.max_bytes") == 0)
- found++;
- len -= strlen(p) + 1;
- p += strlen(p) + 1;
- }
- ASSERT_EQ(found, 0);
-
- ceph_shutdown(cmount);
-}
-
TEST(LibCephFS, Lseek) {
struct ceph_mount_info *cmount;
ASSERT_EQ(0, ceph_create(&cmount, NULL));
/* Test basic functionality and out of bounds conditions for SEEK_HOLE/DATA */
#ifdef SEEK_HOLE
ASSERT_EQ(size, ceph_lseek(cmount, fd, 0, SEEK_HOLE));
- ASSERT_EQ(-ENXIO, ceph_lseek(cmount, fd, -1, SEEK_HOLE));
- ASSERT_EQ(-ENXIO, ceph_lseek(cmount, fd, size + 1, SEEK_HOLE));
+ ASSERT_EQ(-CEPHFS_ENXIO, ceph_lseek(cmount, fd, -1, SEEK_HOLE));
+ ASSERT_EQ(-CEPHFS_ENXIO, ceph_lseek(cmount, fd, size + 1, SEEK_HOLE));
#endif
#ifdef SEEK_DATA
ASSERT_EQ(0, ceph_lseek(cmount, fd, 0, SEEK_DATA));
- ASSERT_EQ(-ENXIO, ceph_lseek(cmount, fd, -1, SEEK_DATA));
- ASSERT_EQ(-ENXIO, ceph_lseek(cmount, fd, size + 1, SEEK_DATA));
+ ASSERT_EQ(-CEPHFS_ENXIO, ceph_lseek(cmount, fd, -1, SEEK_DATA));
+ ASSERT_EQ(-CEPHFS_ENXIO, ceph_lseek(cmount, fd, size + 1, SEEK_DATA));
#endif
ASSERT_EQ(0, ceph_close(cmount, fd));
ASSERT_EQ(ceph_mount(cmount, NULL), 0);
struct snap_info info;
- ASSERT_EQ(-EINVAL, ceph_get_snap_info(cmount, "/", &info));
+ ASSERT_EQ(-CEPHFS_EINVAL, ceph_get_snap_info(cmount, "/", &info));
ceph_shutdown(cmount);
}
Inode *inode;
auto ino = inodeno_t(0x100); /* rank 0 ~mdsdir */
- ASSERT_EQ(-ESTALE, ceph_ll_lookup_inode(cmount, ino, &inode));
+ ASSERT_EQ(-CEPHFS_ESTALE, ceph_ll_lookup_inode(cmount, ino, &inode));
ino = inodeno_t(0x600); /* rank 0 first stray dir */
- ASSERT_EQ(-ESTALE, ceph_ll_lookup_inode(cmount, ino, &inode));
+ ASSERT_EQ(-CEPHFS_ESTALE, ceph_ll_lookup_inode(cmount, ino, &inode));
ceph_shutdown(cmount);
}
int fd1 = ceph_open(cmount, file_path, O_WRONLY|O_CREAT, 0666);
ASSERT_LE(0, fd1);
ASSERT_EQ(0, ceph_close(cmount, fd1));
- ASSERT_EQ(ceph_statxat(cmount, fd, rel_file_name_1, &stx, 0, 0), -ENOENT);
+ ASSERT_EQ(ceph_statxat(cmount, fd, rel_file_name_1, &stx, 0, 0), -CEPHFS_ENOENT);
ASSERT_EQ(0, ceph_close(cmount, fd));
ASSERT_EQ(0, ceph_unlink(cmount, file_path));
ASSERT_LE(0, fd);
struct ceph_dir_result *ls_dir = NULL;
- ASSERT_EQ(ceph_fdopendir(cmount, fd, &ls_dir), -ENOTDIR);
+ ASSERT_EQ(ceph_fdopendir(cmount, fd, &ls_dir), -CEPHFS_ENOTDIR);
ASSERT_EQ(0, ceph_close(cmount, fd));
ASSERT_EQ(0, ceph_unlink(cmount, bazstr));
fd = ceph_open(cmount, dir_path, O_DIRECTORY | O_RDONLY, 0);
ASSERT_LE(0, fd);
- ASSERT_EQ(-ENOTDIR, ceph_unlinkat(cmount, fd, rel_file_path, AT_REMOVEDIR));
+ ASSERT_EQ(-CEPHFS_ENOTDIR, ceph_unlinkat(cmount, fd, rel_file_path, AT_REMOVEDIR));
ASSERT_EQ(0, ceph_unlinkat(cmount, fd, rel_file_path, 0));
ASSERT_EQ(0, ceph_close(cmount, fd));
fd = ceph_open(cmount, "/", O_DIRECTORY | O_RDONLY, 0);
- ASSERT_EQ(-EISDIR, ceph_unlinkat(cmount, fd, dir_name, 0));
+ ASSERT_EQ(-CEPHFS_EISDIR, ceph_unlinkat(cmount, fd, dir_name, 0));
ASSERT_EQ(0, ceph_unlinkat(cmount, fd, dir_name, AT_REMOVEDIR));
ASSERT_LE(0, fd);
ASSERT_EQ(0, ceph_close(cmount, fd));
ASSERT_EQ(0, ceph_chdir(cmount, dir_path));
- ASSERT_EQ(-ENOTDIR, ceph_unlinkat(cmount, CEPHFS_AT_FDCWD, rel_file_path, AT_REMOVEDIR));
+ ASSERT_EQ(-CEPHFS_ENOTDIR, ceph_unlinkat(cmount, CEPHFS_AT_FDCWD, rel_file_path, AT_REMOVEDIR));
ASSERT_EQ(0, ceph_unlinkat(cmount, CEPHFS_AT_FDCWD, rel_file_path, 0));
ASSERT_EQ(0, ceph_chdir(cmount, "/"));
- ASSERT_EQ(-EISDIR, ceph_unlinkat(cmount, CEPHFS_AT_FDCWD, dir_name, 0));
+ ASSERT_EQ(-CEPHFS_EISDIR, ceph_unlinkat(cmount, CEPHFS_AT_FDCWD, dir_name, 0));
ASSERT_EQ(0, ceph_unlinkat(cmount, CEPHFS_AT_FDCWD, dir_name, AT_REMOVEDIR));
ceph_shutdown(cmount);
ASSERT_EQ(ceph_conf_set(cmount, "client_permissions", "1"), 0);
ceph_close(cmount, fd);
+ // "nobody" will be ignored on Windows
+ #ifndef _WIN32
fd = ceph_open(cmount, file_path, O_RDWR, 0);
- ASSERT_EQ(fd, -EACCES);
+ ASSERT_EQ(fd, -CEPHFS_EACCES);
+ #endif
ASSERT_EQ(ceph_conf_set(cmount, "client_permissions", "0"), 0);
ASSERT_EQ(0, ceph_unlink(cmount, file_path));
ASSERT_EQ(ceph_chownat(cmount, CEPHFS_AT_FDCWD, rel_file_path, 65534, 65534, 0), 0);
ASSERT_EQ(ceph_conf_set(cmount, "client_permissions", "1"), 0);
+ // "nobody" will be ignored on Windows
+ #ifndef _WIN32
fd = ceph_open(cmount, file_path, O_RDWR, 0);
- ASSERT_EQ(fd, -EACCES);
+ ASSERT_EQ(fd, -CEPHFS_EACCES);
+ #endif
ASSERT_EQ(ceph_conf_set(cmount, "client_permissions", "0"), 0);
ASSERT_EQ(0, ceph_unlink(cmount, file_path));
// set perms to read but can't write
ASSERT_EQ(ceph_chmodat(cmount, fd, rel_file_path, 0400, 0), 0);
- ASSERT_EQ(ceph_open(cmount, file_path, O_RDWR, 0), -EACCES);
+ ASSERT_EQ(ceph_open(cmount, file_path, O_RDWR, 0), -CEPHFS_EACCES);
// reset back to writeable
ASSERT_EQ(ceph_chmodat(cmount, fd, rel_file_path, 0600, 0), 0);
// set perms to read but can't write
ASSERT_EQ(0, ceph_chdir(cmount, dir_path));
ASSERT_EQ(ceph_chmodat(cmount, CEPHFS_AT_FDCWD, rel_file_path, 0400, 0), 0);
- ASSERT_EQ(ceph_open(cmount, file_path, O_RDWR, 0), -EACCES);
+ ASSERT_EQ(ceph_open(cmount, file_path, O_RDWR, 0), -CEPHFS_EACCES);
// reset back to writeable
ASSERT_EQ(ceph_chmodat(cmount, CEPHFS_AT_FDCWD, rel_file_path, 0600, 0), 0);
Inode *inode;
for (int ino = 0; ino < MDS_INO_SYSTEM_BASE; ino++) {
if (MDS_IS_PRIVATE_INO(ino)) {
- ASSERT_EQ(-ESTALE, ceph_ll_lookup_inode(cmount, ino, &inode));
+ ASSERT_EQ(-CEPHFS_ESTALE, ceph_ll_lookup_inode(cmount, ino, &inode));
} else if (ino == CEPH_INO_ROOT || ino == CEPH_INO_GLOBAL_SNAPREALM) {
ASSERT_EQ(0, ceph_ll_lookup_inode(cmount, ino, &inode));
ceph_ll_put(cmount, inode);
} else if (ino == CEPH_INO_LOST_AND_FOUND) {
// the ino 3 will only exists after the recovery tool ran, so
- // it may return -ESTALE with a fresh fs cluster
+ // it may return -CEPHFS_ESTALE with a fresh fs cluster
int r = ceph_ll_lookup_inode(cmount, ino, &inode);
if (r == 0) {
ceph_ll_put(cmount, inode);
} else {
- ASSERT_TRUE(r == -ESTALE);
+ ASSERT_TRUE(r == -CEPHFS_ESTALE);
}
} else {
// currently the ino 0 and 4~99 is not useded yet.
- ASSERT_EQ(-ESTALE, ceph_ll_lookup_inode(cmount, ino, &inode));
+ ASSERT_EQ(-CEPHFS_ESTALE, ceph_ll_lookup_inode(cmount, ino, &inode));
}
}
ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
ASSERT_EQ(ceph_mount(cmount, NULL), 0);
- ASSERT_EQ(-EINVAL, ceph_set_mount_timeout(cmount, 5));
+ ASSERT_EQ(-CEPHFS_EINVAL, ceph_set_mount_timeout(cmount, 5));
ceph_shutdown(cmount);
}
ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
ASSERT_EQ(0, ceph_set_mount_timeout(cmount, 5));
ASSERT_EQ(ceph_mount(cmount, NULL), 0);
+ ceph_shutdown(cmount);
+}
+
+TEST(LibCephFS, FsCrypt) {
+ struct ceph_mount_info *cmount;
+ ASSERT_EQ(ceph_create(&cmount, NULL), 0);
+ ASSERT_EQ(ceph_conf_read_file(cmount, NULL), 0);
+ ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
+ ASSERT_EQ(ceph_mount(cmount, NULL), 0);
+
+ char test_xattr_file[NAME_MAX];
+ sprintf(test_xattr_file, "test_fscrypt_%d", getpid());
+ int fd = ceph_open(cmount, test_xattr_file, O_RDWR|O_CREAT, 0666);
+ ASSERT_GT(fd, 0);
+
+ ASSERT_EQ(0, ceph_fsetxattr(cmount, fd, "ceph.fscrypt.auth", "foo", 3, CEPH_XATTR_CREATE));
+ ASSERT_EQ(0, ceph_fsetxattr(cmount, fd, "ceph.fscrypt.file", "foo", 3, CEPH_XATTR_CREATE));
+
+ char buf[64];
+ ASSERT_EQ(3, ceph_fgetxattr(cmount, fd, "ceph.fscrypt.auth", buf, sizeof(buf)));
+ ASSERT_EQ(3, ceph_fgetxattr(cmount, fd, "ceph.fscrypt.file", buf, sizeof(buf)));
+ ASSERT_EQ(0, ceph_close(cmount, fd));
+
+ ASSERT_EQ(0, ceph_unmount(cmount));
+ ASSERT_EQ(0, ceph_mount(cmount, NULL));
+
+ fd = ceph_open(cmount, test_xattr_file, O_RDWR, 0666);
+ ASSERT_GT(fd, 0);
+ ASSERT_EQ(3, ceph_fgetxattr(cmount, fd, "ceph.fscrypt.auth", buf, sizeof(buf)));
+ ASSERT_EQ(3, ceph_fgetxattr(cmount, fd, "ceph.fscrypt.file", buf, sizeof(buf)));
+ ASSERT_EQ(0, ceph_close(cmount, fd));
+ ASSERT_EQ(0, ceph_unmount(cmount));
ceph_shutdown(cmount);
}
Inode *dir, *root;
struct ceph_statx stx_dir;
struct ceph_statx stx_snap_dir;
+ struct ceph_statx stx_root_snap_dir;
UserPerm *perms = ceph_mount_perms(cmount);
ASSERT_EQ(ceph_ll_lookup_root(cmount, &root), 0);
CEPH_STATX_MTIME|CEPH_STATX_ATIME|CEPH_STATX_MODE|CEPH_STATX_MODE|CEPH_STATX_GID|CEPH_STATX_VERSION, 0), 0);
ASSERT_EQ(ceph_statx(cmount, snap_dir_path, &stx_snap_dir,
CEPH_STATX_MTIME|CEPH_STATX_ATIME|CEPH_STATX_MODE|CEPH_STATX_MODE|CEPH_STATX_GID|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_EQ(ceph_statx(cmount, "/.snap", &stx_root_snap_dir,
+ CEPH_STATX_MTIME|CEPH_STATX_ATIME|CEPH_STATX_MODE|CEPH_STATX_MODE|CEPH_STATX_GID|CEPH_STATX_VERSION, 0), 0);
- ASSERT_EQ(utime_t(stx_dir.stx_atime), utime_t(stx_snap_dir.stx_atime));
- ASSERT_EQ(utime_t(stx_dir.stx_mtime), utime_t(stx_snap_dir.stx_mtime));
+ // these should match the parent directories attrs
ASSERT_EQ(stx_dir.stx_mode, stx_snap_dir.stx_mode);
ASSERT_EQ(stx_dir.stx_uid, stx_snap_dir.stx_uid);
ASSERT_EQ(stx_dir.stx_gid, stx_snap_dir.stx_gid);
- ASSERT_EQ(stx_dir.stx_version, stx_snap_dir.stx_version);
+ ASSERT_EQ(utime_t(stx_dir.stx_atime), utime_t(stx_snap_dir.stx_atime));
+ // these should match the closest snaprealm ancestor (root in this
+ // case) attrs
+ ASSERT_EQ(utime_t(stx_root_snap_dir.stx_mtime), utime_t(stx_snap_dir.stx_mtime));
+ ASSERT_EQ(utime_t(stx_root_snap_dir.stx_ctime), utime_t(stx_snap_dir.stx_ctime));
+ ASSERT_EQ(stx_root_snap_dir.stx_version, stx_snap_dir.stx_version);
// chown -- for this we need to be "root"
UserPerm *rootcred = ceph_userperm_new(0, 0, 0, NULL);
ASSERT_EQ(ceph_statx(cmount, snap_dir_path, &stx_snap_dir,
CEPH_STATX_MTIME|CEPH_STATX_ATIME|CEPH_STATX_MODE|CEPH_STATX_MODE|CEPH_STATX_GID|CEPH_STATX_VERSION, 0), 0);
- ASSERT_EQ(utime_t(stx_dir.stx_atime), utime_t(stx_snap_dir.stx_atime));
- ASSERT_EQ(utime_t(stx_dir.stx_mtime), utime_t(stx_snap_dir.stx_mtime));
ASSERT_EQ(stx_dir.stx_mode, stx_snap_dir.stx_mode);
ASSERT_EQ(stx_dir.stx_uid, stx_snap_dir.stx_uid);
ASSERT_EQ(stx_dir.stx_gid, stx_snap_dir.stx_gid);
- ASSERT_EQ(stx_dir.stx_version, stx_snap_dir.stx_version);
+ ASSERT_EQ(utime_t(stx_dir.stx_atime), utime_t(stx_snap_dir.stx_atime));
+ ASSERT_EQ(utime_t(stx_root_snap_dir.stx_mtime), utime_t(stx_snap_dir.stx_mtime));
+ ASSERT_EQ(utime_t(stx_root_snap_dir.stx_ctime), utime_t(stx_snap_dir.stx_ctime));
+ ASSERT_EQ(stx_root_snap_dir.stx_version, stx_snap_dir.stx_version);
ASSERT_EQ(ceph_ll_rmdir(cmount, root, dir_name, rootcred), 0);
ASSERT_EQ(0, ceph_unmount(cmount));
ceph_shutdown(cmount);
}
+
+TEST(LibCephFS, SnapdirAttrsOnSnapCreate) {
+ struct ceph_mount_info *cmount;
+ ASSERT_EQ(ceph_create(&cmount, NULL), 0);
+ ASSERT_EQ(ceph_conf_read_file(cmount, NULL), 0);
+ ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
+ ASSERT_EQ(ceph_mount(cmount, NULL), 0);
+
+ char dir_name[128];
+ char dir_path[256];
+ char snap_dir_path[512];
+
+ pid_t mypid = getpid();
+ sprintf(dir_name, "dir_%d", mypid);
+ sprintf(dir_path, "/%s", dir_name);
+ sprintf(snap_dir_path, "%s/.snap", dir_path);
+
+ ASSERT_EQ(ceph_mkdir(cmount, dir_path, 0777), 0);
+
+ struct ceph_statx stx_dir;
+ struct ceph_statx stx_snap_dir;
+ struct ceph_statx stx_root_snap_dir;
+ ASSERT_EQ(ceph_statx(cmount, dir_path, &stx_dir, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_EQ(ceph_statx(cmount, snap_dir_path, &stx_snap_dir, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_EQ(ceph_statx(cmount, "/.snap", &stx_root_snap_dir, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_EQ(utime_t(stx_root_snap_dir.stx_mtime), utime_t(stx_snap_dir.stx_mtime));
+ ASSERT_EQ(utime_t(stx_root_snap_dir.stx_ctime), utime_t(stx_snap_dir.stx_ctime));
+ ASSERT_EQ(stx_root_snap_dir.stx_version, stx_snap_dir.stx_version);
+
+ char snap_path[1024];
+ sprintf(snap_path, "%s/snap_a", snap_dir_path);
+ ASSERT_EQ(ceph_mkdir(cmount, snap_path, 0777), 0);
+
+ struct ceph_statx stx_snap_dir_1;
+ ASSERT_EQ(ceph_statx(cmount, snap_dir_path, &stx_snap_dir_1, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_LT(utime_t(stx_root_snap_dir.stx_mtime), utime_t(stx_snap_dir_1.stx_mtime));
+ ASSERT_LT(utime_t(stx_root_snap_dir.stx_ctime), utime_t(stx_snap_dir_1.stx_ctime));
+ ASSERT_LT(stx_root_snap_dir.stx_version, stx_snap_dir_1.stx_version);
+
+ ASSERT_EQ(0, ceph_rmdir(cmount, snap_path));
+ ASSERT_EQ(0, ceph_rmdir(cmount, dir_path));
+ ASSERT_EQ(0, ceph_unmount(cmount));
+ ceph_shutdown(cmount);
+}
+
+
+TEST(LibCephFS, SnapdirAttrsOnSnapDelete) {
+ struct ceph_mount_info *cmount;
+ ASSERT_EQ(ceph_create(&cmount, NULL), 0);
+ ASSERT_EQ(ceph_conf_read_file(cmount, NULL), 0);
+ ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
+ ASSERT_EQ(ceph_mount(cmount, NULL), 0);
+
+ char dir_name[128];
+ char dir_path[256];
+ char snap_dir_path[512];
+
+ pid_t mypid = getpid();
+ sprintf(dir_name, "dir_%d", mypid);
+ sprintf(dir_path, "/%s", dir_name);
+ sprintf(snap_dir_path, "%s/.snap", dir_path);
+
+ ASSERT_EQ(ceph_mkdir(cmount, dir_path, 0777), 0);
+
+ struct ceph_statx stx_dir;
+ struct ceph_statx stx_snap_dir;
+ struct ceph_statx stx_root_snap_dir;
+ ASSERT_EQ(ceph_statx(cmount, dir_path, &stx_dir, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_EQ(ceph_statx(cmount, snap_dir_path, &stx_snap_dir, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_EQ(ceph_statx(cmount, "/.snap", &stx_root_snap_dir, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_EQ(utime_t(stx_root_snap_dir.stx_mtime), utime_t(stx_snap_dir.stx_mtime));
+ ASSERT_EQ(utime_t(stx_root_snap_dir.stx_ctime), utime_t(stx_snap_dir.stx_mtime));
+ ASSERT_EQ(stx_root_snap_dir.stx_version, stx_snap_dir.stx_version);
+
+ char snap_path[1024];
+ sprintf(snap_path, "%s/snap_a", snap_dir_path);
+ ASSERT_EQ(ceph_mkdir(cmount, snap_path, 0777), 0);
+
+ struct ceph_statx stx_snap_dir_1;
+ ASSERT_EQ(ceph_statx(cmount, snap_dir_path, &stx_snap_dir_1, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_LT(utime_t(stx_root_snap_dir.stx_mtime), utime_t(stx_snap_dir_1.stx_mtime));
+ ASSERT_LT(utime_t(stx_root_snap_dir.stx_ctime), utime_t(stx_snap_dir_1.stx_ctime));
+ ASSERT_LT(stx_root_snap_dir.stx_version, stx_snap_dir_1.stx_version);
+
+ ASSERT_EQ(0, ceph_rmdir(cmount, snap_path));
+
+ struct ceph_statx stx_snap_dir_2;
+ ASSERT_EQ(ceph_statx(cmount, snap_dir_path, &stx_snap_dir_2, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_LT(utime_t(stx_snap_dir_1.stx_mtime), utime_t(stx_snap_dir_2.stx_mtime));
+ ASSERT_LT(utime_t(stx_snap_dir_1.stx_ctime), utime_t(stx_snap_dir_2.stx_ctime));
+ ASSERT_LT(stx_snap_dir_1.stx_version, stx_snap_dir_2.stx_version);
+
+ ASSERT_EQ(0, ceph_rmdir(cmount, dir_path));
+ ASSERT_EQ(0, ceph_unmount(cmount));
+ ceph_shutdown(cmount);
+}
+
+TEST(LibCephFS, SnapdirAttrsOnSnapRename) {
+ struct ceph_mount_info *cmount;
+ ASSERT_EQ(ceph_create(&cmount, NULL), 0);
+ ASSERT_EQ(ceph_conf_read_file(cmount, NULL), 0);
+ ASSERT_EQ(0, ceph_conf_parse_env(cmount, NULL));
+ ASSERT_EQ(ceph_mount(cmount, NULL), 0);
+
+ char dir_name[128];
+ char dir_path[256];
+ char snap_dir_path[512];
+
+ pid_t mypid = getpid();
+ sprintf(dir_name, "dir_%d", mypid);
+ sprintf(dir_path, "/%s", dir_name);
+ sprintf(snap_dir_path, "%s/.snap", dir_path);
+
+ ASSERT_EQ(ceph_mkdir(cmount, dir_path, 0777), 0);
+
+ struct ceph_statx stx_dir;
+ struct ceph_statx stx_snap_dir;
+ struct ceph_statx stx_root_snap_dir;
+ ASSERT_EQ(ceph_statx(cmount, dir_path, &stx_dir, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_EQ(ceph_statx(cmount, snap_dir_path, &stx_snap_dir, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_EQ(ceph_statx(cmount, "/.snap", &stx_root_snap_dir, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_EQ(utime_t(stx_root_snap_dir.stx_mtime), utime_t(stx_snap_dir.stx_mtime));
+ ASSERT_EQ(utime_t(stx_root_snap_dir.stx_ctime), utime_t(stx_snap_dir.stx_ctime));
+ ASSERT_EQ(stx_root_snap_dir.stx_version, stx_snap_dir.stx_version);
+
+ char snap_path[1024];
+ sprintf(snap_path, "%s/snap_a", snap_dir_path);
+ ASSERT_EQ(ceph_mkdir(cmount, snap_path, 0777), 0);
+
+ struct ceph_statx stx_snap_dir_1;
+ ASSERT_EQ(ceph_statx(cmount, snap_dir_path, &stx_snap_dir_1, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_LT(utime_t(stx_root_snap_dir.stx_mtime), utime_t(stx_snap_dir_1.stx_mtime));
+ ASSERT_LT(utime_t(stx_root_snap_dir.stx_ctime), utime_t(stx_snap_dir_1.stx_ctime));
+ ASSERT_LT(stx_root_snap_dir.stx_version, stx_snap_dir_1.stx_version);
+
+ char snap_path_r[1024];
+ sprintf(snap_path_r, "%s/snap_b", snap_dir_path);
+ ASSERT_EQ(ceph_rename(cmount, snap_path, snap_path_r), 0);
+
+ struct ceph_statx stx_snap_dir_2;
+ ASSERT_EQ(ceph_statx(cmount, snap_dir_path, &stx_snap_dir_2, CEPH_STATX_MTIME|CEPH_STATX_CTIME|CEPH_STATX_VERSION, 0), 0);
+ ASSERT_LT(utime_t(stx_snap_dir_1.stx_mtime), utime_t(stx_snap_dir_2.stx_mtime));
+ ASSERT_LT(utime_t(stx_snap_dir_1.stx_ctime), utime_t(stx_snap_dir_2.stx_ctime));
+ ASSERT_LT(stx_snap_dir_1.stx_version, stx_snap_dir_2.stx_version);
+
+ ASSERT_EQ(0, ceph_rmdir(cmount, snap_path_r));
+ ASSERT_EQ(0, ceph_rmdir(cmount, dir_path));
+ ASSERT_EQ(0, ceph_unmount(cmount));
+ ceph_shutdown(cmount);
+}
projects / ceph.git / blobdiff