mirror/dolt
1
0
Fork 0
mirror of https://github.com/dolthub/dolt.git synced 2026-01-07 00:39:44 -06:00
Code Issues Packages Projects Releases 115 Wiki Activity

In pubsub, skip replication work on same hash notification

Browse Source
This commit is contained in:
Dan Willhite
2017-08-25 17:19:02 -07:00
committed by Dan Willhite
parent 500a33eb51
commit 996741a669
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
samples/go/ipfs-chat/pubsub.go
View File

@@ -19,13 +19,18 @@ import (
)
func Replicate(sub *floodsub.Subscription, source, dest datas.Dataset, didChange func(ds datas.Dataset)) {
lastHash := ""
for {
dbg.Debug("looking for msgs")
msg, err := sub.Next(context.Background())
d.PanicIfError(err)
h := hash.Parse(string(msg.Data))
dbg.Debug("got update: %s from %s", h.String(), base64.StdEncoding.EncodeToString(msg.From))
if lastHash == h.String() {
continue
}
lastHash = h.String()
dbg.Debug("got update: %s from %s", h.String(), base64.StdEncoding.EncodeToString(msg.From))
destDB := dest.Database()
destDB.Rebase()
dest = destDB.GetDataset(dest.ID())