1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
4 * Ceph - scalable distributed file system
6 * Copyright (C) 2011 New Dream Network
8 * This is free software; you can redistribute it and/or
9 * modify it under the terms of the GNU Lesser General Public
10 * License version 2.1, as published by the Free Software
11 * Foundation. See file COPYING.
15 #include "gtest/gtest.h"
16 #include "include/cephfs/libcephfs.h"
20 #include <sys/types.h>
23 #include <sys/xattr.h>
25 TEST(LibCephFS, MulticlientSimple) {
26 struct ceph_mount_info *ca, *cb;
27 ASSERT_EQ(ceph_create(&ca, NULL), 0);
28 ASSERT_EQ(ceph_conf_read_file(ca, NULL), 0);
29 ASSERT_EQ(0, ceph_conf_parse_env(ca, NULL));
30 ASSERT_EQ(ceph_mount(ca, NULL), 0);
32 ASSERT_EQ(ceph_create(&cb, NULL), 0);
33 ASSERT_EQ(ceph_conf_read_file(cb, NULL), 0);
34 ASSERT_EQ(0, ceph_conf_parse_env(cb, NULL));
35 ASSERT_EQ(ceph_mount(cb, NULL), 0);
38 snprintf(name, sizeof(name), "foo.%d", getpid());
39 int fda = ceph_open(ca, name, O_CREAT|O_RDWR, 0644);
41 int fdb = ceph_open(cb, name, O_CREAT|O_RDWR, 0644);
47 for (int i=0; i<10; i++) {
49 ASSERT_EQ((int)sizeof(bufa), ceph_write(ca, fda, bufa, sizeof(bufa), i*6));
50 ASSERT_EQ((int)sizeof(bufa), ceph_read(cb, fdb, bufb, sizeof(bufa), i*6));
51 ASSERT_EQ(0, memcmp(bufa, bufb, sizeof(bufa)));
53 ASSERT_EQ((int)sizeof(bufb), ceph_write(cb, fdb, bufb, sizeof(bufb), i*6+3));
54 ASSERT_EQ((int)sizeof(bufb), ceph_read(ca, fda, bufa, sizeof(bufb), i*6+3));
55 ASSERT_EQ(0, memcmp(bufa, bufb, sizeof(bufa)));
65 TEST(LibCephFS, MulticlientHoleEOF) {
66 struct ceph_mount_info *ca, *cb;
67 ASSERT_EQ(ceph_create(&ca, NULL), 0);
68 ASSERT_EQ(ceph_conf_read_file(ca, NULL), 0);
69 ASSERT_EQ(0, ceph_conf_parse_env(ca, NULL));
70 ASSERT_EQ(ceph_mount(ca, NULL), 0);
72 ASSERT_EQ(ceph_create(&cb, NULL), 0);
73 ASSERT_EQ(ceph_conf_read_file(cb, NULL), 0);
74 ASSERT_EQ(0, ceph_conf_parse_env(cb, NULL));
75 ASSERT_EQ(ceph_mount(cb, NULL), 0);
78 snprintf(name, sizeof(name), "foo.%d", getpid());
79 int fda = ceph_open(ca, name, O_CREAT|O_RDWR, 0644);
81 int fdb = ceph_open(cb, name, O_CREAT|O_RDWR, 0644);
84 ASSERT_EQ(3, ceph_write(ca, fda, "foo", 3, 0));
85 ASSERT_EQ(0, ceph_ftruncate(ca, fda, 1000000));
88 ASSERT_EQ(2, ceph_read(cb, fdb, buf, sizeof(buf), 1000000-2));