command.go 1.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. // +build !confonly
  2. package command
  3. //go:generate errorgen
  4. import (
  5. "context"
  6. grpc "google.golang.org/grpc"
  7. "v2ray.com/core"
  8. "v2ray.com/core/app/log"
  9. "v2ray.com/core/common"
  10. )
  11. type LoggerServer struct {
  12. V *core.Instance
  13. }
  14. // RestartLogger implements LoggerService.
  15. func (s *LoggerServer) RestartLogger(ctx context.Context, request *RestartLoggerRequest) (*RestartLoggerResponse, error) {
  16. logger := s.V.GetFeature((*log.Instance)(nil))
  17. if logger == nil {
  18. return nil, newError("unable to get logger instance")
  19. }
  20. if err := logger.Close(); err != nil {
  21. return nil, newError("failed to close logger").Base(err)
  22. }
  23. if err := logger.Start(); err != nil {
  24. return nil, newError("failed to start logger").Base(err)
  25. }
  26. return &RestartLoggerResponse{}, nil
  27. }
  28. type service struct {
  29. v *core.Instance
  30. }
  31. func (s *service) Register(server *grpc.Server) {
  32. RegisterLoggerServiceServer(server, &LoggerServer{
  33. V: s.v,
  34. })
  35. }
  36. func init() {
  37. common.Must(common.RegisterConfig((*Config)(nil), func(ctx context.Context, cfg interface{}) (interface{}, error) {
  38. s := core.MustFromContext(ctx)
  39. return &service{v: s}, nil
  40. }))
  41. }