diff --git a/src/crdt/globaldb/pubsub_broadcaster_ext.cpp b/src/crdt/globaldb/pubsub_broadcaster_ext.cpp index 6c593b90..831ea859 100644 --- a/src/crdt/globaldb/pubsub_broadcaster_ext.cpp +++ b/src/crdt/globaldb/pubsub_broadcaster_ext.cpp @@ -193,18 +193,18 @@ outcome::result PubSubBroadcasterExt::Broadcast(const base::Buffer& buff) } } - // auto mas = peer_info.addresses; - // for (auto& address : mas) - // { - // bpi->add_addrs(address.getStringAddress()); - // m_logger->info("Address Broadcast {}", address.getStringAddress()); - // //auto ip_address_opt = address.getFirstValueForProtocol(libp2p::multi::Protocol::Code::IP4); - // //if (ip_address_opt) { - // // auto new_address = libp2p::multi::Multiaddress::create(fmt::format("/ip4/{}/tcp/{}/p2p/{}", ip_address_opt.value(), port, peer_id)); - // // auto addrstr = new_address.value().getStringAddress(); - // // bmsg.add_multiaddress(std::string(addrstr.begin(), addrstr.end())); - // //} - // } + auto mas = peer_info.addresses; + for (auto& address : mas) + { + bpi->add_addrs(address.getStringAddress()); + m_logger->info("Address Broadcast {}", address.getStringAddress()); + //auto ip_address_opt = address.getFirstValueForProtocol(libp2p::multi::Protocol::Code::IP4); + //if (ip_address_opt) { + // auto new_address = libp2p::multi::Multiaddress::create(fmt::format("/ip4/{}/tcp/{}/p2p/{}", ip_address_opt.value(), port, peer_id)); + // auto addrstr = new_address.value().getStringAddress(); + // bmsg.add_multiaddress(std::string(addrstr.begin(), addrstr.end())); + //} + } //If no addresses existed, we don't have anything to broadcast that is not otherwise a local address. if (bpi->addrs_size() <= 0) diff --git a/src/crdt/impl/graphsync_dagsyncer.cpp b/src/crdt/impl/graphsync_dagsyncer.cpp index edb38dd6..f05f36df 100644 --- a/src/crdt/impl/graphsync_dagsyncer.cpp +++ b/src/crdt/impl/graphsync_dagsyncer.cpp @@ -148,7 +148,7 @@ namespace sgns::crdt return res.as_failure(); } auto start_time = std::chrono::steady_clock::now(); - while ( std::chrono::steady_clock::now() - start_time < std::chrono::seconds( 5 ) ) + while ( std::chrono::steady_clock::now() - start_time < std::chrono::seconds( 60 ) ) { auto result = GrabCIDBlock( it->first ); // Call the internal GrabCIDBlock if ( result )