]>
git.proxmox.com Git - ceph.git/blob - ceph/src/test/libcephfs/multiclient.cc
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));