sync: minor optimization

std/sync/svs_alo.go

@@ -161,9 +161,8 @@ func (s *SvsALO) deliver(out svsPubOut) {
 	}
 
 	// Commit the successful delivery
-	hash := out.pub.Publisher.String()
-	prev := s.delivered.Get(hash, out.pub.BootTime)
+	prev := s.delivered.Get(out.hash, out.pub.BootTime)
 	if out.pub.SeqNum > prev {
-		s.delivered.Set(hash, out.pub.BootTime, out.pub.SeqNum)
+		s.delivered.Set(out.hash, out.pub.BootTime, out.pub.SeqNum)
 	}
 }

std/sync/svs_alo_data.go

@@ -23,6 +23,7 @@ type seqFetchState struct {
 }
 
 type svsPubOut struct {
+	hash string
 	pub  SvsPub
 	subs []func(SvsPub)
 }
@@ -149,6 +150,9 @@ func (s *SvsALO) consumeObject(node enc.Name, boot uint64, seq uint64) {
 			// it's okay to delete all the pending data.
 			delete(entry.PendingData, nextSeq)
 			deliver = append(deliver, pub)
+
+			// Only updating the local copy of the state
+			// The state will be updated only after finding some subs.
 			entry.Known = nextSeq
 		}
 
@@ -165,7 +169,7 @@ func (s *SvsALO) consumeObject(node enc.Name, boot uint64, seq uint64) {
 			// we WILL deliver it, update known state
 			s.state.Set(hash, boot, entry)
 			for _, pub := range deliver {
-				s.outpipe <- svsPubOut{pub, subs}
+				s.outpipe <- svsPubOut{hash, pub, subs}
 			}
 		}