Compiler disambiguates based on the rest of the signature.
Signed-off-by: Sage Weil <sage@redhat.com>
bufferlist *pbl);
// watch/notify
- int watch2(const std::string& o, uint64_t *handle,
- librados::WatchCtx2 *ctx);
+ int watch(const std::string& o, uint64_t *handle,
+ librados::WatchCtx2 *ctx);
int unwatch(const std::string& o, uint64_t handle);
- int notify2(const std::string& o, ///< object
- bufferlist& bl, ///< optional broadcast payload
- uint64_t timeout_ms, ///< timeout (in ms)
- bufferlist *pbl); ///< reply buffer
+ int notify(const std::string& o, ///< object
+ bufferlist& bl, ///< optional broadcast payload
+ uint64_t timeout_ms, ///< timeout (in ms)
+ bufferlist *pbl); ///< reply buffer
int list_watchers(const std::string& o, std::list<obj_watch_t> *out_watchers);
int list_snaps(const std::string& o, snap_set_t *out_snaps);
void set_notify_timeout(uint32_t timeout);
return io_ctx_impl->watch(obj, cookie, ctx, NULL);
}
-int librados::IoCtx::watch2(const string& oid, uint64_t *cookie,
- librados::WatchCtx2 *ctx2)
+int librados::IoCtx::watch(const string& oid, uint64_t *cookie,
+ librados::WatchCtx2 *ctx2)
{
object_t obj(oid);
return io_ctx_impl->watch(obj, cookie, NULL, ctx2);
return io_ctx_impl->notify(obj, bl, 0, NULL, NULL, NULL);
}
-int librados::IoCtx::notify2(const string& oid, bufferlist& bl,
- uint64_t timeout_ms, bufferlist *preplybl)
+int librados::IoCtx::notify(const string& oid, bufferlist& bl,
+ uint64_t timeout_ms, bufferlist *preplybl)
{
object_t obj(oid);
return io_ctx_impl->notify(obj, bl, timeout_ms, preplybl, NULL, NULL);
ASSERT_EQ(0, ioctx.write(notify_oid, bl1, sizeof(buf), 0));
uint64_t handle;
WatchNotifyTestCtx2 ctx;
- ASSERT_EQ(0, ioctx.watch2(notify_oid, &handle, &ctx));
+ ASSERT_EQ(0, ioctx.watch(notify_oid, &handle, &ctx));
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(0, ioctx.notify2(notify_oid, bl2, 0, &bl_reply));
+ ASSERT_EQ(0, ioctx.notify(notify_oid, bl2, 0, &bl_reply));
bufferlist::iterator p = bl_reply.begin();
std::multimap<uint64_t,bufferlist> reply_map;
::decode(reply_map, p);
ASSERT_EQ(0, ioctx.write(notify_oid, bl1, sizeof(buf), 0));
uint64_t handle;
WatchNotifyTestCtx2 ctx;
- ASSERT_EQ(0, ioctx.watch2(notify_oid, &handle, &ctx));
+ ASSERT_EQ(0, ioctx.watch(notify_oid, &handle, &ctx));
std::list<obj_watch_t> watches;
ASSERT_EQ(0, ioctx.list_watchers(notify_oid, &watches));
ASSERT_EQ(watches.size(), 1u);
ASSERT_EQ(0u, notify_cookies.size());
bufferlist bl2, bl_reply;
- ASSERT_EQ(-ETIMEDOUT, ioctx.notify2(notify_oid, bl2, 1000 /* 1s */,
- &bl_reply));
+ ASSERT_EQ(-ETIMEDOUT, ioctx.notify(notify_oid, bl2, 1000 /* 1s */,
+ &bl_reply));
int wait = 10;
while (!notify_failed && --wait)
sleep(1);
string oid(nargs[1]);
RadosWatchCtx ctx(io_ctx, oid.c_str());
uint64_t cookie;
- ret = io_ctx.watch2(oid, &cookie, &ctx);
+ ret = io_ctx.watch(oid, &cookie, &ctx);
if (ret != 0)
cerr << "error calling watch: " << ret << std::endl;
else {