mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2025-01-09 03:01:19 +00:00
17a43c1158
* new stategen.StateReplayer/ReplayerBuilder to give more fine-grained control of replaying state+block history * all rpc/api methods updated to use the new interface, return post-state Co-authored-by: Kasey Kirkham <kasey@users.noreply.github.com> Co-authored-by: Radosław Kapka <rkapka@wp.pl> Co-authored-by: terence tsao <terence@prysmaticlabs.com>
65 lines
2.3 KiB
Go
65 lines
2.3 KiB
Go
// Package debug defines a gRPC server implementation of a debugging service
|
|
// which allows for helpful endpoints to debug a beacon node at runtime, this server is
|
|
// gated behind the feature flag --enable-debug-rpc-endpoints.
|
|
package debug
|
|
|
|
import (
|
|
"context"
|
|
"os"
|
|
|
|
gethlog "github.com/ethereum/go-ethereum/log"
|
|
"github.com/golang/protobuf/ptypes/empty"
|
|
golog "github.com/ipfs/go-log/v2"
|
|
"github.com/prysmaticlabs/prysm/beacon-chain/blockchain"
|
|
"github.com/prysmaticlabs/prysm/beacon-chain/db"
|
|
"github.com/prysmaticlabs/prysm/beacon-chain/p2p"
|
|
"github.com/prysmaticlabs/prysm/beacon-chain/state/stategen"
|
|
pbrpc "github.com/prysmaticlabs/prysm/proto/prysm/v1alpha1"
|
|
"github.com/sirupsen/logrus"
|
|
"google.golang.org/grpc/codes"
|
|
"google.golang.org/grpc/status"
|
|
)
|
|
|
|
// Server defines a server implementation of the gRPC Debug service,
|
|
// providing RPC endpoints for runtime debugging of a node, this server is
|
|
// gated behind the feature flag --enable-debug-rpc-endpoints.
|
|
type Server struct {
|
|
BeaconDB db.NoHeadAccessDatabase
|
|
GenesisTimeFetcher blockchain.TimeFetcher
|
|
StateGen *stategen.State
|
|
HeadFetcher blockchain.HeadFetcher
|
|
PeerManager p2p.PeerManager
|
|
PeersFetcher p2p.PeersProvider
|
|
ReplayerBuilder stategen.ReplayerBuilder
|
|
}
|
|
|
|
// SetLoggingLevel of a beacon node according to a request type,
|
|
// either INFO, DEBUG, or TRACE.
|
|
func (_ *Server) SetLoggingLevel(_ context.Context, req *pbrpc.LoggingLevelRequest) (*empty.Empty, error) {
|
|
var verbosity string
|
|
switch req.Level {
|
|
case pbrpc.LoggingLevelRequest_INFO:
|
|
verbosity = "info"
|
|
case pbrpc.LoggingLevelRequest_DEBUG:
|
|
verbosity = "debug"
|
|
case pbrpc.LoggingLevelRequest_TRACE:
|
|
verbosity = "trace"
|
|
default:
|
|
return nil, status.Error(codes.InvalidArgument, "Expected valid verbosity level as argument")
|
|
}
|
|
level, err := logrus.ParseLevel(verbosity)
|
|
if err != nil {
|
|
return nil, status.Error(codes.Internal, "Could not parse verbosity level")
|
|
}
|
|
logrus.SetLevel(level)
|
|
if level == logrus.TraceLevel {
|
|
// Libp2p specific logging.
|
|
golog.SetAllLoggers(golog.LevelDebug)
|
|
// Geth specific logging.
|
|
glogger := gethlog.NewGlogHandler(gethlog.StreamHandler(os.Stderr, gethlog.TerminalFormat(true)))
|
|
glogger.Verbosity(gethlog.LvlTrace)
|
|
gethlog.Root().SetHandler(glogger)
|
|
}
|
|
return &empty.Empty{}, nil
|
|
}
|