Instead of ceph::make_message() because conn::send() in crimson expects
a std::unique_ptr and not boost::intrusive_ptr
Signed-off-by: Amnon Hanuhov <ahanukov@redhat.com>
{
std::cout << "server got ping " << *m << std::endl;
// reply with a pong
- return c->send(make_message<MPing>()).then([this] {
+ return c->send(crimson::make_message<MPing>()).then([this] {
++count;
on_reply.signal();
return seastar::now();
return seastar::do_until(
[&disp,count] { return disp.count >= count; },
[&disp,conn] {
- return conn->send(make_message<MPing>()).then([&] {
+ return conn->send(crimson::make_message<MPing>()).then([&] {
return disp.on_reply.wait();
});
}