seastar::future<> Watch::send_notify_msg(NotifyRef notify)
{
logger().info("{} for notify(id={})", __func__, notify->ninfo.notify_id);
- return conn->send(make_message<MWatchNotify>(
+ return conn->send(crimson::net::make_message<MWatchNotify>(
winfo.cookie,
notify->user_version,
notify->ninfo.notify_id,
return seastar::now();
}
ceph::bufferlist empty;
- return conn->send(make_message<MWatchNotify>(
+ return conn->send(crimson::net::make_message<MWatchNotify>(
winfo.cookie,
0,
0,
logger().debug("{} sending notify replies: {}", __func__, notify_replies);
ceph::bufferlist empty;
- auto reply = make_message<MWatchNotify>(
+ auto reply = crimson::net::make_message<MWatchNotify>(
ninfo.cookie,
user_version,
ninfo.notify_id,