rados_watch2(ioctx, notify_oid, &handle,
watch_notify2_test_cb,
watch_notify2_test_errcb, NULL));
- ASSERT_TRUE(rados_watch_check(ioctx, handle) > 0);
+ ASSERT_GT(rados_watch_check(ioctx, handle), 0);
// and now a notify will work.
ASSERT_EQ(0, rados_notify2(ioctx, notify_oid,
ASSERT_EQ(0, strncmp("reply", reply_map.begin()->second.c_str(), 5));
}
ASSERT_EQ(1u, notify_cookies.size());
- ASSERT_TRUE(rados_watch_check(ioctx, handle) > 0);
+ ASSERT_GT(rados_watch_check(ioctx, handle), 0);
rados_unwatch2(ioctx, handle);
}
rados_watch2(ioctx, notify_oid, &handle,
watch_notify2_test_cb,
watch_notify2_test_errcb, NULL));
- ASSERT_TRUE(rados_watch_check(ioctx, handle) > 0);
+ ASSERT_GT(rados_watch_check(ioctx, handle), 0);
char *reply_buf = 0;
size_t reply_buf_len;
ASSERT_EQ(0, rados_notify2(ioctx, notify_oid,
ASSERT_EQ(1u, notify_cookies.count(handle));
ASSERT_EQ(5u, reply_map.begin()->second.length());
ASSERT_EQ(0, strncmp("reply", reply_map.begin()->second.c_str(), 5));
- ASSERT_TRUE(rados_watch_check(ioctx, handle) > 0);
+ ASSERT_GT(rados_watch_check(ioctx, handle), 0);
rados_buffer_free(reply_buf);
// try it on a non-existent object ... our buffer pointers
uint64_t handle;
WatchNotifyTestCtx2 ctx;
ASSERT_EQ(0, ioctx.watch(notify_oid, &handle, &ctx));
- ASSERT_TRUE(ioctx.watch_check(handle) > 0);
+ ASSERT_GT(ioctx.watch_check(handle), 0);
std::list<obj_watch_t> watches;
ASSERT_EQ(0, ioctx.list_watchers(notify_oid, &watches));
ASSERT_EQ(watches.size(), 1u);
ASSERT_EQ(5, reply_map.begin()->second.length());
ASSERT_EQ(0, strncmp("reply", reply_map.begin()->second.c_str(), 5));
ASSERT_EQ(0, missed_map.size());
- ASSERT_TRUE(ioctx.watch_check(handle) > 0);
+ ASSERT_GT(ioctx.watch_check(handle), 0);
ioctx.unwatch(handle);
}
rados_watch2(ioctx, notify_oid, &handle2,
watch_notify2_test_cb,
watch_notify2_test_errcb, NULL));
- ASSERT_TRUE(rados_watch_check(ioctx, handle1) > 0);
- ASSERT_TRUE(rados_watch_check(ioctx, handle2) > 0);
+ ASSERT_GT(rados_watch_check(ioctx, handle1), 0);
+ ASSERT_GT(rados_watch_check(ioctx, handle2), 0);
ASSERT_NE(handle1, handle2);
char *reply_buf = 0;
size_t reply_buf_len;
ASSERT_EQ(1, notify_cookies.count(handle1));
ASSERT_EQ(1, notify_cookies.count(handle2));
ASSERT_EQ(0, strncmp("reply", reply_map.begin()->second.c_str(), 5));
- ASSERT_TRUE(rados_watch_check(ioctx, handle1) > 0);
- ASSERT_TRUE(rados_watch_check(ioctx, handle2) > 0);
+ ASSERT_GT(rados_watch_check(ioctx, handle1), 0);
+ ASSERT_GT(rados_watch_check(ioctx, handle2), 0);
rados_buffer_free(reply_buf);
rados_unwatch2(ioctx, handle1);
rados_unwatch2(ioctx, handle2);
rados_watch2(ioctx, notify_oid, &handle,
watch_notify2_test_cb,
watch_notify2_test_errcb, NULL));
- ASSERT_TRUE(rados_watch_check(ioctx, handle) > 0);
+ ASSERT_GT(rados_watch_check(ioctx, handle), 0);
char *reply_buf = 0;
size_t reply_buf_len;
ASSERT_EQ(-ETIMEDOUT, rados_notify2(ioctx, notify_oid,
"notify", 6, 30000, // 30s
&reply_buf, &reply_buf_len));
ASSERT_EQ(1u, notify_cookies.size());
- ASSERT_TRUE(rados_watch_check(ioctx, handle) > 0);
+ ASSERT_GT(rados_watch_check(ioctx, handle), 0);
rados_unwatch2(ioctx, handle);
}
uint64_t handle;
WatchNotifyTestCtx2 ctx;
ASSERT_EQ(0, ioctx.watch(notify_oid, &handle, &ctx));
- ASSERT_TRUE(ioctx.watch_check(handle) > 0);
+ ASSERT_GT(ioctx.watch_check(handle), 0);
std::list<obj_watch_t> watches;
ASSERT_EQ(0, ioctx.list_watchers(notify_oid, &watches));
ASSERT_EQ(watches.size(), 1u);
bufferlist bl2, bl_reply;
ASSERT_EQ(-ETIMEDOUT, ioctx.notify(notify_oid, bl2, 1000 /* 1s */,
&bl_reply));
- ASSERT_TRUE(ioctx.watch_check(handle) > 0);
+ ASSERT_GT(ioctx.watch_check(handle), 0);
ioctx.unwatch(handle);
}