force fsync after notifications sent (#11244)

erigon-lib/kv/helpers.go

@@ -18,12 +18,14 @@ package kv
 
 import (
 	"context"
+	"encoding/binary"
 	"fmt"
 	"os"
 	"sync"
 	"sync/atomic"
 	"time"
 
+	"github.com/erigontech/erigon-lib/common/hexutility"
 	"github.com/erigontech/mdbx-go/mdbx"
 
 	"github.com/erigontech/erigon-lib/common"
@@ -222,3 +224,16 @@ func NextSubtree(in []byte) ([]byte, bool) {
 	}
 	return nil, false
 }
+
+func IncrementKey(tx RwTx, table string, k []byte) error {
+	v, err := tx.GetOne(table, k)
+	if err != nil {
+		return err
+	}
+	var version uint64
+	if len(v) == 8 {
+		version = binary.BigEndian.Uint64(v)
+	}
+	version++
+	return tx.Put(table, k, hexutility.EncodeTs(version))
+}

turbo/execution/eth1/forkchoice.go

@@ -448,6 +448,15 @@ func (e *EthereumExecutionModule) updateForkChoice(ctx context.Context, original
 				return
 			}
 		}
+
+		// force fsync after notifications are sent
+		if err := e.db.Update(ctx, func(tx kv.RwTx) error {
+			return kv.IncrementKey(tx, kv.DatabaseInfo, []byte("alex"))
+		}); err != nil {
+			sendForkchoiceErrorWithoutWaiting(outcomeCh, err)
+			return
+		}
+
 		if log {
 			e.logger.Info("head updated", "number", *headNumber, "hash", headHash)
 		}