#ifdef WITH_SEASTAR
-using namespace seastar;
-
seastar::future<> MonMap::read_monmap(const std::string& monmap)
{
+ using namespace seastar;
return open_file_dma(monmap, open_flags::ro).then([this] (file f) {
return f.size().then([this, f = std::move(f)](size_t s) {
return do_with(make_file_input_stream(f), [this, s](input_stream<char>& in) {
return seastar::net::dns::get_srv_records(
seastar::net::dns_resolver::srv_proto::tcp,
service, domain).then([this](seastar::net::dns_resolver::srv_records records) {
- return parallel_for_each(records, [this](auto record) {
+ return seastar::parallel_for_each(records, [this](auto record) {
return seastar::net::dns::resolve_name(record.target).then(
[record,this](seastar::net::inet_address a) {
// the resolved address does not contain ceph specific info like nonce
{
// -m foo?
if (maybe_init_with_mon_host(conf.get_val<std::string>("mon_host"), for_mkfs)) {
- return make_ready_future<>();
+ return seastar::make_ready_future<>();
}
// What monitors are in the config file?
throw std::runtime_error(errout.str());
}
if (size() > 0) {
- return make_ready_future<>();
+ return seastar::make_ready_future<>();
}
// no info found from conf options lets try use DNS SRV records
const string srv_name = conf.get_val<std::string>("mon_dns_srv_name");
// mon_host_override?
if (maybe_init_with_mon_host(conf.get_val<std::string>("mon_host_override"),
for_mkfs)) {
- return make_ready_future<>();
+ return seastar::make_ready_future<>();
}
// file?