diff --git a/cmd/blsync/block_sync.go b/cmd/blsync/block_sync.go index 146efe9f7c..b85daa8fd3 100755 --- a/cmd/blsync/block_sync.go +++ b/cmd/blsync/block_sync.go @@ -291,7 +291,7 @@ func (s *engineApiUpdater) Process(env *request.Environment) { } else { s.updating = true go func() { - if status, err := callNewPayloadV1(s.client, execBlock); err == nil { + if status, err := callNewPayloadV2(s.client, execBlock); err == nil { log.Info("Successful NewPayload", "block number", execBlock.NumberU64(), "block hash", execRoot, "status", status) } else { log.Error("Failed NewPayload", "block number", execBlock.NumberU64(), "block hash", execRoot, "error", err) diff --git a/cmd/blsync/main.go b/cmd/blsync/main.go index ffe47a2623..8917cc5341 100644 --- a/cmd/blsync/main.go +++ b/cmd/blsync/main.go @@ -149,10 +149,10 @@ func blsync(ctx *cli.Context) error { return nil } -func callNewPayloadV1(client *rpc.Client, block *ctypes.Block) (string, error) { +func callNewPayloadV2(client *rpc.Client, block *ctypes.Block) (string, error) { var resp engine.PayloadStatusV1 ctx, cancel := context.WithTimeout(context.Background(), time.Second*5) - err := client.CallContext(ctx, &resp, "engine_newPayloadV1", *engine.BlockToExecutableData(block, nil).ExecutionPayload) + err := client.CallContext(ctx, &resp, "engine_newPayloadV2", *engine.BlockToExecutableData(block, nil).ExecutionPayload) cancel() return resp.Status, err }