Skip to content
This repository has been archived by the owner on Jun 23, 2022. It is now read-only.

refactor: move aio tests out from service_api_c #323

Merged
merged 9 commits into from
Oct 12, 2019
Merged

refactor: move aio tests out from service_api_c #323

Show file tree
Hide file tree
Changes from 7 commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
48bed3a
refactor: rename task::is_empty to is_callback_empty & move aio tests…
Sep 30, 2019
bbb1e23
fix build
Oct 8, 2019
6c9efbd
Merge branch 'master' into refactor
Oct 8, 2019
3589e3a
Merge branch 'master' into refactor
Oct 9, 2019
a2252e3
revert changes on task::is_empty
Oct 10, 2019
3d5fa0b
Merge branch 'master' of https://github.com/XiaoMi/rdsn into refactor
Oct 10, 2019
aba03ca
Merge branch 'refactor' of github.com:neverchanje/rdsn into refactor
Oct 10, 2019
20cb75d
Merge branch 'master' into refactor
Oct 11, 2019
2e25d65
Merge branch 'master' into refactor
Oct 12, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
91 changes: 91 additions & 0 deletions src/core/tests/aio.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -203,3 +203,94 @@ TEST(core, operation_failed)

EXPECT_TRUE(utils::filesystem::remove_path("tmp_test_file"));
}

DEFINE_TASK_CODE_AIO(LPC_AIO_TEST_READ, TASK_PRIORITY_COMMON, THREAD_POOL_DEFAULT)
DEFINE_TASK_CODE_AIO(LPC_AIO_TEST_WRITE, TASK_PRIORITY_COMMON, THREAD_POOL_DEFAULT)
struct aio_result
{
dsn::error_code err;
size_t sz;
};
TEST(core, dsn_file)
{
if (task::get_current_disk() == nullptr)
return;

int64_t fin_size, fout_size;
ASSERT_TRUE(utils::filesystem::file_size("command.txt", fin_size));
ASSERT_LT(0, fin_size);

dsn::disk_file *fin = file::open("command.txt", O_RDONLY, 0);
ASSERT_NE(nullptr, fin);
dsn::disk_file *fout = file::open("command.copy.txt", O_RDWR | O_CREAT | O_TRUNC, 0666);
ASSERT_NE(nullptr, fout);
char buffer[1024];
uint64_t offset = 0;
while (true) {
aio_result rin;
aio_task_ptr tin = file::read(fin,
buffer,
1024,
offset,
LPC_AIO_TEST_READ,
nullptr,
[&rin](dsn::error_code err, size_t sz) {
rin.err = err;
rin.sz = sz;
},
0);
ASSERT_NE(nullptr, tin);

if (dsn::tools::get_current_tool()->name() != "simulator") {
// at least 1 for tin, but if already read completed, then only 1
ASSERT_LE(1, tin->get_count());
}

tin->wait();
ASSERT_EQ(rin.err, tin->error());
if (rin.err != ERR_OK) {
ASSERT_EQ(ERR_HANDLE_EOF, rin.err);
break;
}
ASSERT_LT(0u, rin.sz);
ASSERT_EQ(rin.sz, tin->get_transferred_size());
// this is only true for simulator
if (dsn::tools::get_current_tool()->name() == "simulator") {
ASSERT_EQ(1, tin->get_count());
}

aio_result rout;
aio_task_ptr tout = file::write(fout,
buffer,
rin.sz,
offset,
LPC_AIO_TEST_WRITE,
nullptr,
[&rout](dsn::error_code err, size_t sz) {
rout.err = err;
rout.sz = sz;
},
0);
ASSERT_NE(nullptr, tout);
tout->wait();
ASSERT_EQ(ERR_OK, rout.err);
ASSERT_EQ(ERR_OK, tout->error());
ASSERT_EQ(rin.sz, rout.sz);
ASSERT_EQ(rin.sz, tout->get_transferred_size());
// this is only true for simulator
if (dsn::tools::get_current_tool()->name() == "simulator") {
ASSERT_EQ(1, tout->get_count());
}

ASSERT_EQ(ERR_OK, file::flush(fout));

offset += rin.sz;
}

ASSERT_EQ((uint64_t)fin_size, offset);
ASSERT_EQ(ERR_OK, file::close(fout));
ASSERT_EQ(ERR_OK, file::close(fin));

ASSERT_TRUE(utils::filesystem::file_size("command.copy.txt", fout_size));
ASSERT_EQ(fin_size, fout_size);
}
91 changes: 0 additions & 91 deletions src/core/tests/service_api_c.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -196,97 +196,6 @@ TEST(core, dsn_semaphore)
s.wait();
}

DEFINE_TASK_CODE_AIO(LPC_AIO_TEST_READ, TASK_PRIORITY_COMMON, THREAD_POOL_DEFAULT)
DEFINE_TASK_CODE_AIO(LPC_AIO_TEST_WRITE, TASK_PRIORITY_COMMON, THREAD_POOL_DEFAULT)
struct aio_result
{
dsn::error_code err;
size_t sz;
};
TEST(core, dsn_file)
{
if (task::get_current_disk() == nullptr)
return;

int64_t fin_size, fout_size;
ASSERT_TRUE(utils::filesystem::file_size("command.txt", fin_size));
ASSERT_LT(0, fin_size);

dsn::disk_file *fin = file::open("command.txt", O_RDONLY, 0);
ASSERT_NE(nullptr, fin);
dsn::disk_file *fout = file::open("command.copy.txt", O_RDWR | O_CREAT | O_TRUNC, 0666);
ASSERT_NE(nullptr, fout);
char buffer[1024];
uint64_t offset = 0;
while (true) {
aio_result rin;
aio_task_ptr tin = file::read(fin,
buffer,
1024,
offset,
LPC_AIO_TEST_READ,
nullptr,
[&rin](dsn::error_code err, size_t sz) {
rin.err = err;
rin.sz = sz;
},
0);
ASSERT_NE(nullptr, tin);

if (dsn::tools::get_current_tool()->name() != "simulator") {
// at least 1 for tin, but if already read completed, then only 1
ASSERT_LE(1, tin->get_count());
}

tin->wait();
ASSERT_EQ(rin.err, tin->error());
if (rin.err != ERR_OK) {
ASSERT_EQ(ERR_HANDLE_EOF, rin.err);
break;
}
ASSERT_LT(0u, rin.sz);
ASSERT_EQ(rin.sz, tin->get_transferred_size());
// this is only true for simulator
if (dsn::tools::get_current_tool()->name() == "simulator") {
ASSERT_EQ(1, tin->get_count());
}

aio_result rout;
aio_task_ptr tout = file::write(fout,
buffer,
rin.sz,
offset,
LPC_AIO_TEST_WRITE,
nullptr,
[&rout](dsn::error_code err, size_t sz) {
rout.err = err;
rout.sz = sz;
},
0);
ASSERT_NE(nullptr, tout);
tout->wait();
ASSERT_EQ(ERR_OK, rout.err);
ASSERT_EQ(ERR_OK, tout->error());
ASSERT_EQ(rin.sz, rout.sz);
ASSERT_EQ(rin.sz, tout->get_transferred_size());
// this is only true for simulator
if (dsn::tools::get_current_tool()->name() == "simulator") {
ASSERT_EQ(1, tout->get_count());
}

ASSERT_EQ(ERR_OK, file::flush(fout));

offset += rin.sz;
}

ASSERT_EQ((uint64_t)fin_size, offset);
ASSERT_EQ(ERR_OK, file::close(fout));
ASSERT_EQ(ERR_OK, file::close(fin));

ASSERT_TRUE(utils::filesystem::file_size("command.copy.txt", fout_size));
ASSERT_EQ(fin_size, fout_size);
}

TEST(core, dsn_env)
{
if (dsn::service_engine::instance().spec().tool == "simulator")
Expand Down