aboutsummaryrefslogtreecommitdiffstats
path: root/ethlog/loggers.go
diff options
context:
space:
mode:
Diffstat (limited to 'ethlog/loggers.go')
-rw-r--r--ethlog/loggers.go202
1 files changed, 101 insertions, 101 deletions
diff --git a/ethlog/loggers.go b/ethlog/loggers.go
index be42c9fb7..9ebe59096 100644
--- a/ethlog/loggers.go
+++ b/ethlog/loggers.go
@@ -1,188 +1,188 @@
package ethlog
import (
- "fmt"
- "sync"
- "log"
- "io"
- "os"
+ "fmt"
+ "io"
+ "log"
+ "os"
+ "sync"
)
type LogSystem interface {
- GetLogLevel() LogLevel
- SetLogLevel(i LogLevel)
- Println(v ...interface{})
- Printf(format string, v ...interface{})
+ GetLogLevel() LogLevel
+ SetLogLevel(i LogLevel)
+ Println(v ...interface{})
+ Printf(format string, v ...interface{})
}
type logMessage struct {
- LogLevel LogLevel
- format bool
- msg string
+ LogLevel LogLevel
+ format bool
+ msg string
}
-func newPrintlnLogMessage(level LogLevel, tag string, v...interface{}) *logMessage {
- return &logMessage{level, false, fmt.Sprintf("[%s] %s", tag, fmt.Sprint(v...))}
+func newPrintlnLogMessage(level LogLevel, tag string, v ...interface{}) *logMessage {
+ return &logMessage{level, false, fmt.Sprintf("[%s] %s", tag, fmt.Sprint(v...))}
}
-func newPrintfLogMessage(level LogLevel, tag string, format string, v...interface{}) *logMessage {
- return &logMessage{level, true, fmt.Sprintf("[%s] %s", tag, fmt.Sprintf(format, v...))}
+func newPrintfLogMessage(level LogLevel, tag string, format string, v ...interface{}) *logMessage {
+ return &logMessage{level, true, fmt.Sprintf("[%s] %s", tag, fmt.Sprintf(format, v...))}
}
func (msg *logMessage) send(logger LogSystem) {
- if msg.format {
- logger.Printf(msg.msg)
- } else {
- logger.Println(msg.msg)
- }
+ if msg.format {
+ logger.Printf(msg.msg)
+ } else {
+ logger.Println(msg.msg)
+ }
}
-var logMessages chan(*logMessage)
-var logSystems []LogSystem
+var logMessages chan (*logMessage)
+var logSystems []LogSystem
var drained = true
type LogLevel uint8
const (
- Silence LogLevel = iota
- ErrorLevel
- WarnLevel
- InfoLevel
- DebugLevel
- DebugDetailLevel
+ Silence LogLevel = iota
+ ErrorLevel
+ WarnLevel
+ InfoLevel
+ DebugLevel
+ DebugDetailLevel
)
// log messages are dispatched to log writers
func start() {
- for {
- select {
- case msg := <- logMessages:
- for _, logSystem := range logSystems {
- if logSystem.GetLogLevel() >= msg.LogLevel {
- msg.send(logSystem)
- }
- }
- default:
- drained = true
- }
- }
+ for {
+ select {
+ case msg := <-logMessages:
+ for _, logSystem := range logSystems {
+ if logSystem.GetLogLevel() >= msg.LogLevel {
+ msg.send(logSystem)
+ }
+ }
+ default:
+ drained = true
+ }
+ }
}
// waits until log messages are drained (dispatched to log writers)
func Flush() {
- for !drained {}
+ for !drained {
+ }
}
type Logger struct {
- tag string
+ tag string
}
func NewLogger(tag string) *Logger {
- return &Logger{tag}
+ return &Logger{tag}
}
func AddLogSystem(logSystem LogSystem) {
- var mutex = &sync.Mutex{}
- mutex.Lock()
- defer mutex.Unlock()
- if logSystems == nil {
- logMessages = make(chan *logMessage)
- go start()
- }
- logSystems = append(logSystems, logSystem)
+ var mutex = &sync.Mutex{}
+ mutex.Lock()
+ defer mutex.Unlock()
+ if logSystems == nil {
+ logMessages = make(chan *logMessage)
+ go start()
+ }
+ logSystems = append(logSystems, logSystem)
}
-func (logger *Logger) sendln(level LogLevel, v...interface{}) {
- if logMessages != nil {
- msg := newPrintlnLogMessage(level, logger.tag, v...)
- drained = false
- logMessages <- msg
- }
+func (logger *Logger) sendln(level LogLevel, v ...interface{}) {
+ if logMessages != nil {
+ msg := newPrintlnLogMessage(level, logger.tag, v...)
+ drained = false
+ logMessages <- msg
+ }
}
-func (logger *Logger) sendf(level LogLevel, format string, v...interface{}) {
- if logMessages != nil {
- msg := newPrintfLogMessage(level, logger.tag, format, v...)
- drained = false
- logMessages <- msg
- }
+func (logger *Logger) sendf(level LogLevel, format string, v ...interface{}) {
+ if logMessages != nil {
+ msg := newPrintfLogMessage(level, logger.tag, format, v...)
+ drained = false
+ logMessages <- msg
+ }
}
-func (logger *Logger) Errorln(v...interface{}) {
- logger.sendln(ErrorLevel, v...)
+func (logger *Logger) Errorln(v ...interface{}) {
+ logger.sendln(ErrorLevel, v...)
}
-func (logger *Logger) Warnln(v...interface{}) {
- logger.sendln(WarnLevel, v...)
+func (logger *Logger) Warnln(v ...interface{}) {
+ logger.sendln(WarnLevel, v...)
}
-func (logger *Logger) Infoln(v...interface{}) {
- logger.sendln(InfoLevel, v...)
+func (logger *Logger) Infoln(v ...interface{}) {
+ logger.sendln(InfoLevel, v...)
}
-func (logger *Logger) Debugln(v...interface{}) {
- logger.sendln(DebugLevel, v...)
+func (logger *Logger) Debugln(v ...interface{}) {
+ logger.sendln(DebugLevel, v...)
}
-func (logger *Logger) DebugDetailln(v...interface{}) {
- logger.sendln(DebugDetailLevel, v...)
+func (logger *Logger) DebugDetailln(v ...interface{}) {
+ logger.sendln(DebugDetailLevel, v...)
}
-func (logger *Logger) Errorf(format string, v...interface{}) {
- logger.sendf(ErrorLevel, format, v...)
+func (logger *Logger) Errorf(format string, v ...interface{}) {
+ logger.sendf(ErrorLevel, format, v...)
}
-func (logger *Logger) Warnf(format string, v...interface{}) {
- logger.sendf(WarnLevel, format, v...)
+func (logger *Logger) Warnf(format string, v ...interface{}) {
+ logger.sendf(WarnLevel, format, v...)
}
-func (logger *Logger) Infof(format string, v...interface{}) {
- logger.sendf(InfoLevel, format, v...)
+func (logger *Logger) Infof(format string, v ...interface{}) {
+ logger.sendf(InfoLevel, format, v...)
}
-func (logger *Logger) Debugf(format string, v...interface{}) {
- logger.sendf(DebugLevel, format, v...)
+func (logger *Logger) Debugf(format string, v ...interface{}) {
+ logger.sendf(DebugLevel, format, v...)
}
-func (logger *Logger) DebugDetailf(format string, v...interface{}) {
- logger.sendf(DebugDetailLevel, format, v...)
+func (logger *Logger) DebugDetailf(format string, v ...interface{}) {
+ logger.sendf(DebugDetailLevel, format, v...)
}
-func (logger *Logger) Fatalln (v...interface{}) {
- logger.sendln(ErrorLevel, v...)
- Flush()
- os.Exit(0)
+func (logger *Logger) Fatalln(v ...interface{}) {
+ logger.sendln(ErrorLevel, v...)
+ Flush()
+ os.Exit(0)
}
-func (logger *Logger) Fatalf (format string, v...interface{}) {
- logger.sendf(ErrorLevel, format, v...)
- Flush()
- os.Exit(0)
+func (logger *Logger) Fatalf(format string, v ...interface{}) {
+ logger.sendf(ErrorLevel, format, v...)
+ Flush()
+ os.Exit(0)
}
type StdLogSystem struct {
- logger *log.Logger
- level LogLevel
+ logger *log.Logger
+ level LogLevel
}
func (t *StdLogSystem) Println(v ...interface{}) {
- t.logger.Println(v...)
+ t.logger.Println(v...)
}
func (t *StdLogSystem) Printf(format string, v ...interface{}) {
- t.logger.Printf(format, v...)
+ t.logger.Printf(format, v...)
}
func (t *StdLogSystem) SetLogLevel(i LogLevel) {
- t.level = i
+ t.level = i
}
func (t *StdLogSystem) GetLogLevel() LogLevel {
- return t.level
+ return t.level
}
func NewStdLogSystem(writer io.Writer, flags int, level LogLevel) *StdLogSystem {
- logger := log.New(writer, "", flags)
- return &StdLogSystem{logger, level}
+ logger := log.New(writer, "", flags)
+ return &StdLogSystem{logger, level}
}
-
generated by cgit (git 2.34.1) at 2024-09-28 09:32:17 +0800