certusone
/
wormhole
mirror of https://github.com/certusone/wormhole.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

hack/repair_solana: improve sequence guessing (#1003)

This commit is contained in:
Leopold Schabel 2022-04-11 21:07:09 +02:00 committed by GitHub
parent 8dd3536fb2
commit d68232c447
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 21 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
node/hack/repair_solana/repair.go
View File

@ -128,16 +128,24 @@ func main() {
break
}
last := txs[len(txs)-1].Signature
var lastSeq, firstSeq uint64
_, lastSeq, err := fetchTxSeq(ctx, sr, last)
if err != nil {
log.Fatalf("fetch last tx seq: %v", err)
var last solana.Signature
for i := 0; lastSeq == 0; i-- {
log.Printf("lastSeq offset: %d", i)
last = txs[len(txs)-1+i].Signature
_, lastSeq, err = fetchTxSeq(ctx, sr, last)
if err != nil {
log.Fatalf("fetch last tx seq: %v", err)
}
}
_, firstSeq, err := fetchTxSeq(ctx, sr, txs[0].Signature)
if err != nil {
log.Fatalf("fetch first tx seq: %v", err)
for i := 0; firstSeq == 0; i++ {
log.Printf("firstSeq offset: %d", i)
_, firstSeq, err = fetchTxSeq(ctx, sr, txs[i].Signature)
if err != nil {
log.Fatalf("fetch first tx seq: %v", err)
}
}
log.Printf("fetched %d transactions, from %s (%d) to %s (%d)",
@ -153,7 +161,7 @@ func main() {
}
for _, p := range msgs {
if p.Sequence > lastSeq && p.Sequence < firstSeq {
offset := firstSeq - p.Sequence
offset := firstSeq - p.Sequence - 10
log.Printf("repairing: %d (offset %d)", p.Sequence, offset)
var tx *rpc.TransactionWithMeta
@ -161,6 +169,9 @@ func main() {
var err error
for {
if offset >= uint64(len(txs)) {
log.Fatalf("out of range at offset %d", offset)
}
tx, nseq, err = fetchTxSeq(ctx, sr, txs[offset].Signature)
if err != nil {
log.Fatalf("failed to fetch %s at offset %d: %v", txs[offset].Signature, offset, err)
@ -172,8 +183,8 @@ func main() {
continue
}
if nseq != p.Sequence {
log.Printf("%d != %d, offset +%d", nseq, p.Sequence, nseq-p.Sequence)
offset += nseq - p.Sequence
offset += 1
log.Printf("%d != %d, delta +%d, offset +%d", nseq, p.Sequence, nseq-p.Sequence, offset)
time.Sleep(1 * time.Second)
continue
} else {