mirror of
https://github.com/luxfi/evmgpu.git
synced 2026-10-30 16:57:11 +00:00
zeekay
060d77569e
Mirrors luxfi/evm Wave 1C cascade. 18 files. Same migration patterns:
plugin/evm/message/codec.go local Manager interface, sync/* swap,
customrawdb/* + validators/state/* hand-rolled binary, vm.go +
network.go + plugin/evm/network_handler.go call-site fixups, plus
core/parallel/gpu_{ecrecover,evm}.go GPU dispatch wiring.
Builds clean: go build ./...
54 lines
2.0 KiB
Go
54 lines
2.0 KiB
Go
// Copyright (C) 2019-2025, Lux Industries, Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package evm
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/luxfi/evmgpu/plugin/evm/message"
|
|
syncHandlers "github.com/luxfi/evmgpu/sync/handlers"
|
|
syncStats "github.com/luxfi/evmgpu/sync/handlers/stats"
|
|
"github.com/luxfi/evmgpu/warp"
|
|
"github.com/luxfi/geth/ethdb"
|
|
"github.com/luxfi/geth/metrics"
|
|
"github.com/luxfi/geth/triedb"
|
|
"github.com/luxfi/ids"
|
|
)
|
|
|
|
var _ message.RequestHandler = (*networkHandler)(nil)
|
|
|
|
type networkHandler struct {
|
|
leafRequestHandler *syncHandlers.LeafsRequestHandler
|
|
blockRequestHandler *syncHandlers.BlockRequestHandler
|
|
codeRequestHandler *syncHandlers.CodeRequestHandler
|
|
}
|
|
|
|
// newNetworkHandler constructs the handler for serving network requests.
|
|
func newNetworkHandler(
|
|
provider syncHandlers.SyncDataProvider,
|
|
diskDB ethdb.KeyValueReader,
|
|
evmTrieDB *triedb.Database,
|
|
warpBackend warp.Backend,
|
|
networkCodec message.Manager,
|
|
) message.RequestHandler {
|
|
syncStats := syncStats.NewHandlerStats(metrics.Enabled())
|
|
return &networkHandler{
|
|
leafRequestHandler: syncHandlers.NewLeafsRequestHandler(evmTrieDB, nil, networkCodec, syncStats),
|
|
blockRequestHandler: syncHandlers.NewBlockRequestHandler(provider, networkCodec, syncStats),
|
|
codeRequestHandler: syncHandlers.NewCodeRequestHandler(diskDB, networkCodec, syncStats),
|
|
}
|
|
}
|
|
|
|
func (n networkHandler) HandleStateTrieLeafsRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, leafsRequest message.LeafsRequest) ([]byte, error) {
|
|
return n.leafRequestHandler.OnLeafsRequest(ctx, nodeID, requestID, leafsRequest)
|
|
}
|
|
|
|
func (n networkHandler) HandleBlockRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, blockRequest message.BlockRequest) ([]byte, error) {
|
|
return n.blockRequestHandler.OnBlockRequest(ctx, nodeID, requestID, blockRequest)
|
|
}
|
|
|
|
func (n networkHandler) HandleCodeRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, codeRequest message.CodeRequest) ([]byte, error) {
|
|
return n.codeRequestHandler.OnCodeRequest(ctx, nodeID, requestID, codeRequest)
|
|
}
|