@@ -300,9 +300,11 @@ void NodeImpl::processing_shares_phase2(HandleSharesData& data, NetService addr)
300300
301301 // Log received share BEFORE add (add may move/invalidate the variant)
302302 share.ACTION ({
303+ auto as = addr.to_string ();
304+ std::string source = (addr.port () == 0 ) ? as.substr (0 , as.rfind (' :' )) : as;
303305 LOG_INFO << " Received share: hash=" << obj->m_hash .GetHex ().substr (0 , 16 )
304306 << " height=" << obj->m_absheight
305- << " from " << addr. to_string () ;
307+ << " from " << source ;
306308 });
307309
308310 m_tracker.add (share);
@@ -350,9 +352,11 @@ void NodeImpl::processing_shares_phase2(HandleSharesData& data, NetService addr)
350352 }
351353
352354 if (new_count > 0 ) {
353- LOG_INFO << " [Pool] Processed " << new_count << " new shares from "
354- << addr.to_string () << " (dup=" << dup_count << " total_chain="
355- << m_tracker.chain .size () << " )" ;
355+ auto as2 = addr.to_string ();
356+ std::string source = (addr.port () == 0 ) ? as2.substr (0 , as2.rfind (' :' )) : as2;
357+ LOG_INFO << " Processing " << new_count << " shares from "
358+ << source << " ... (dup=" << dup_count
359+ << " chain=" << m_tracker.chain .size () << " )" ;
356360 }
357361
358362 // NOTE: Do NOT call run_think() here. During download sync, the chain is
@@ -632,7 +636,7 @@ void NodeImpl::load_persisted_shares()
632636 std::vector<unsigned char > share_bytes (data.begin () + 8 , data.end ());
633637 PackStream ps (share_bytes);
634638
635- auto share = ltc::load_share (static_cast <int64_t >(ver), ps, NetService{" 0.0.0.0 " , 0 });
639+ auto share = ltc::load_share (static_cast <int64_t >(ver), ps, NetService{" database " , 0 });
636640 if (!m_chain->contains (share.hash ()))
637641 {
638642 m_tracker.add (share);
0 commit comments