Skip to content

Commit

Permalink
check sds state
Browse files Browse the repository at this point in the history
  • Loading branch information
osalyk committed Jul 31, 2024
1 parent 0b5645a commit 869b119
Showing 1 changed file with 19 additions and 0 deletions.
19 changes: 19 additions & 0 deletions src/tests/ras/unsafe_shutdown/local_basic_tests.cc
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ void UnsafeShutdownBasic::SetUp() {
us_dimm_pool_path_ = test_phase_.GetUnsafeDimmNamespaces()[0].GetTestDir() +
GetNormalizedTestName() + "_pool";
}
bool sds_state;

/**
* TRY_OPEN_OBJ
Expand All @@ -58,6 +59,9 @@ TEST_F(UnsafeShutdownBasic, TRY_OPEN_OBJ_phase_1) {
ASSERT_TRUE(pop_ != nullptr) << "Pool creating failed. Errno: " << errno
<< std::endl
<< pmemobj_errormsg();
/* check SDS state */
int ret = pmemobj_ctl_get(pop_ , "sds.at_create", &sds_state);
std::cout << "1| SDS after create: " << sds_state << std::endl;

/* Step2 */
ObjData<int> pd{pop_};
Expand Down Expand Up @@ -108,6 +112,11 @@ TEST_F(UnsafeShutdownBasic, TC_TRY_OPEN_AFTER_DOUBLE_US_phase_1) {
ASSERT_TRUE(pop_ != nullptr)
<< "Opening pool after shutdown failed. Errno: " << errno << std::endl
<< pmemobj_errormsg();

/* check SDS state */
int ret = pmemobj_ctl_get(pop_ , "sds.at_create", &sds_state);
std::cout << "2| SDS after create: " << sds_state << std::endl;

/* Step2 */
ObjData<int> pd{pop_};
ASSERT_EQ(0, pd.Write(obj_data_)) << "Writing to pool failed";
Expand Down Expand Up @@ -162,6 +171,11 @@ TEST_F(UnsafeShutdownBasicClean, TC_OPEN_CLEAN_phase_1) {
ASSERT_TRUE(pop_ != nullptr) << "Pool creating failed. Errno: " << errno
<< std::endl
<< pmemobj_errormsg();

/* check SDS state */
int ret = pmemobj_ctl_get(pop_ , "sds.at_create", &sds_state);
std::cout << "3| SDS after create: " << sds_state << std::endl;

/* Step2 */
ObjData<int> pd{pop_};
ASSERT_EQ(0, pd.Write(obj_data_)) << "Writing to pool failed";
Expand Down Expand Up @@ -205,6 +219,11 @@ TEST_F(UnsafeShutdownBasicWithoutUS, TC_OPEN_DIRTY_NO_US_phase_1) {
ASSERT_TRUE(pop_ != nullptr) << "Pool creating failed. Errno: " << errno
<< std::endl
<< pmemobj_errormsg();

/* check SDS state */
int ret = pmemobj_ctl_get(pop_ , "sds.at_create", &sds_state);
std::cout << "4| SDS after create: " << sds_state << std::endl;

/* Step2 */
ObjData<int> pd{pop_};
ASSERT_EQ(0, pd.Write(obj_data_)) << "Writing to pool failed";
Expand Down

0 comments on commit 869b119

Please sign in to comment.