errors.go 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180
  1. // Package errors is a drop-in replacement for Golang lib 'errors'.
  2. package errors // import "v2ray.com/core/common/errors"
  3. import (
  4. "os"
  5. "strings"
  6. "v2ray.com/core/common/log"
  7. "v2ray.com/core/common/serial"
  8. )
  9. type hasInnerError interface {
  10. // Inner returns the underlying error of this one.
  11. Inner() error
  12. }
  13. type hasSeverity interface {
  14. Severity() log.Severity
  15. }
  16. // Error is an error object with underlying error.
  17. type Error struct {
  18. prefix []interface{}
  19. path []string
  20. message []interface{}
  21. inner error
  22. severity log.Severity
  23. }
  24. // Error implements error.Error().
  25. func (v *Error) Error() string {
  26. msg := serial.Concat(v.message...)
  27. if v.inner != nil {
  28. msg += " > " + v.inner.Error()
  29. }
  30. if len(v.path) > 0 {
  31. msg = strings.Join(v.path, "|") + ": " + msg
  32. }
  33. var prefix string
  34. for _, p := range v.prefix {
  35. prefix += "[" + serial.ToString(p) + "] "
  36. }
  37. return prefix + msg
  38. }
  39. // Inner implements hasInnerError.Inner()
  40. func (v *Error) Inner() error {
  41. if v.inner == nil {
  42. return nil
  43. }
  44. return v.inner
  45. }
  46. func (v *Error) Base(err error) *Error {
  47. v.inner = err
  48. return v
  49. }
  50. func (v *Error) atSeverity(s log.Severity) *Error {
  51. v.severity = s
  52. return v
  53. }
  54. func (v *Error) Severity() log.Severity {
  55. if v.inner == nil {
  56. return v.severity
  57. }
  58. if s, ok := v.inner.(hasSeverity); ok {
  59. as := s.Severity()
  60. if as < v.severity {
  61. return as
  62. }
  63. }
  64. return v.severity
  65. }
  66. // AtDebug sets the severity to debug.
  67. func (v *Error) AtDebug() *Error {
  68. return v.atSeverity(log.Severity_Debug)
  69. }
  70. // AtInfo sets the severity to info.
  71. func (v *Error) AtInfo() *Error {
  72. return v.atSeverity(log.Severity_Info)
  73. }
  74. // AtWarning sets the severity to warning.
  75. func (v *Error) AtWarning() *Error {
  76. return v.atSeverity(log.Severity_Warning)
  77. }
  78. // AtError sets the severity to error.
  79. func (v *Error) AtError() *Error {
  80. return v.atSeverity(log.Severity_Error)
  81. }
  82. // Path sets the path to the location where this error happens.
  83. func (v *Error) Path(path ...string) *Error {
  84. v.path = path
  85. return v
  86. }
  87. // String returns the string representation of this error.
  88. func (v *Error) String() string {
  89. return v.Error()
  90. }
  91. // WriteToLog writes current error into log.
  92. func (v *Error) WriteToLog(opts ...ExportOption) {
  93. var holder ExportOptionHolder
  94. for _, opt := range opts {
  95. opt(&holder)
  96. }
  97. if holder.SessionID > 0 {
  98. v.prefix = append(v.prefix, holder.SessionID)
  99. }
  100. log.Record(&log.GeneralMessage{
  101. Severity: GetSeverity(v),
  102. Content: v,
  103. })
  104. }
  105. type ExportOptionHolder struct {
  106. SessionID uint32
  107. }
  108. type ExportOption func(*ExportOptionHolder)
  109. // New returns a new error object with message formed from given arguments.
  110. func New(msg ...interface{}) *Error {
  111. return &Error{
  112. message: msg,
  113. severity: log.Severity_Info,
  114. }
  115. }
  116. // Cause returns the root cause of this error.
  117. func Cause(err error) error {
  118. if err == nil {
  119. return nil
  120. }
  121. L:
  122. for {
  123. switch inner := err.(type) {
  124. case hasInnerError:
  125. if inner.Inner() == nil {
  126. break L
  127. }
  128. err = inner.Inner()
  129. case *os.PathError:
  130. if inner.Err == nil {
  131. break L
  132. }
  133. err = inner.Err
  134. case *os.SyscallError:
  135. if inner.Err == nil {
  136. break L
  137. }
  138. err = inner.Err
  139. default:
  140. break L
  141. }
  142. }
  143. return err
  144. }
  145. // GetSeverity returns the actual severity of the error, including inner errors.
  146. func GetSeverity(err error) log.Severity {
  147. if s, ok := err.(hasSeverity); ok {
  148. return s.Severity()
  149. }
  150. return log.Severity_Info
  151. }