diff options
| -rw-r--r-- | nexgb/conn.go | 4 | ||||
| -rw-r--r-- | nexgb/log.go | 85 | ||||
| -rw-r--r-- | nexgb/xgb.go | 28 |
3 files changed, 100 insertions, 17 deletions
diff --git a/nexgb/conn.go b/nexgb/conn.go index 62c31e9..9baf86c 100644 --- a/nexgb/conn.go +++ b/nexgb/conn.go @@ -33,8 +33,8 @@ func (c *Conn) connect(display string) error { authName, authData, err := readAuthority(c.host, c.display) noauth := false if err != nil { - Logger.Printf("Could not get authority info: %v", err) - Logger.Println("Trying connection without authority info...") + logger.Printf("Could not get authority info: %v", err) + logger.Println("Trying connection without authority info...") authName = "" authData = []byte{} noauth = true diff --git a/nexgb/log.go b/nexgb/log.go new file mode 100644 index 0000000..eaaa57e --- /dev/null +++ b/nexgb/log.go @@ -0,0 +1,85 @@ +package xgb + +import ( + "log" + "os" +) + +// Log controls whether XGB emits errors to stderr. By default, it is enabled. +var PrintLog = true + +// log is a wrapper around a log.PrintLogger so we can control whether it should +// output anything. +type xgblog struct { + *log.Logger +} + +func newLogger() xgblog { + return xgblog{log.New(os.Stderr, "XGB: ", log.Lshortfile)} +} + +func (lg xgblog) Print(v ...interface{}) { + if PrintLog { + lg.Logger.Print(v...) + } +} + +func (lg xgblog) Printf(format string, v ...interface{}) { + if PrintLog { + lg.Logger.Printf(format, v...) + } +} + +func (lg xgblog) Println(v ...interface{}) { + if PrintLog { + lg.Logger.Println(v...) + } +} + +func (lg xgblog) Fatal(v ...interface{}) { + if PrintLog { + lg.Logger.Fatal(v...) + } else { + os.Exit(1) + } +} + +func (lg xgblog) Fatalf(format string, v ...interface{}) { + if PrintLog { + lg.Logger.Fatalf(format, v...) + } else { + os.Exit(1) + } +} + +func (lg xgblog) Fatalln(v ...interface{}) { + if PrintLog { + lg.Logger.Fatalln(v...) + } else { + os.Exit(1) + } +} + +func (lg xgblog) Panic(v ...interface{}) { + if PrintLog { + lg.Logger.Panic(v...) + } else { + panic("") + } +} + +func (lg xgblog) Panicf(format string, v ...interface{}) { + if PrintLog { + lg.Logger.Panicf(format, v...) + } else { + panic("") + } +} + +func (lg xgblog) Panicln(v ...interface{}) { + if PrintLog { + lg.Logger.Panicln(v...) + } else { + panic("") + } +} diff --git a/nexgb/xgb.go b/nexgb/xgb.go index dad0ed5..b0a7307 100644 --- a/nexgb/xgb.go +++ b/nexgb/xgb.go @@ -3,14 +3,12 @@ package xgb import ( "errors" "io" - "log" "net" - "os" "sync" ) var ( - Logger = log.New(os.Stderr, "XGB: ", 0) + logger = newLogger() // ExtLock is a lock used whenever new extensions are initialized. // It should not be used. It is exported for use in the extension @@ -304,8 +302,8 @@ func (c *Conn) sendRequests() { // writeBuffer is a convenience function for writing a byte slice to the wire. func (c *Conn) writeBuffer(buf []byte) { if _, err := c.conn.Write(buf); err != nil { - Logger.Printf("Write error: %s", err) - Logger.Fatal("A write error is unrecoverable. Exiting...") + logger.Printf("Write error: %s", err) + logger.Fatal("A write error is unrecoverable. Exiting...") } } @@ -333,8 +331,8 @@ func (c *Conn) readResponses() { err, event, seq = nil, nil, 0 if _, err := io.ReadFull(c.conn, buf); err != nil { - Logger.Printf("Read error: %s", err) - Logger.Fatal("A read error is unrecoverable. Exiting...") + logger.Printf("Read error: %s", err) + logger.Fatal("A read error is unrecoverable. Exiting...") } switch buf[0] { @@ -343,7 +341,7 @@ func (c *Conn) readResponses() { // generated) by looking it up by the error number. newErrFun, ok := NewErrorFuncs[int(buf[1])] if !ok { - Logger.Printf("BUG: Could not find error constructor function "+ + logger.Printf("BUG: Could not find error constructor function "+ "for error with number %d.", buf[1]) continue } @@ -362,8 +360,8 @@ func (c *Conn) readResponses() { biggerBuf := make([]byte, byteCount) copy(biggerBuf[:32], buf) if _, err := io.ReadFull(c.conn, biggerBuf[32:]); err != nil { - Logger.Printf("Read error: %s", err) - Logger.Fatal("A read error is unrecoverable. Exiting...") + logger.Printf("Read error: %s", err) + logger.Fatal("A read error is unrecoverable. Exiting...") } replyBytes = biggerBuf } else { @@ -380,7 +378,7 @@ func (c *Conn) readResponses() { evNum := int(buf[0] & 127) newEventFun, ok := NewEventFuncs[evNum] if !ok { - Logger.Printf("BUG: Could not find event construct function "+ + logger.Printf("BUG: Could not find event construct function "+ "for event with number %d.", evNum) continue } @@ -429,7 +427,7 @@ func (c *Conn) readResponses() { } } else { // this is a reply if cookie.replyChan == nil { - Logger.Printf("Reply with sequence id %d does not "+ + logger.Printf("Reply with sequence id %d does not "+ "have a cookie with a valid reply channel.", seq) continue } else { @@ -442,12 +440,12 @@ func (c *Conn) readResponses() { switch { // Checked requests with replies case cookie.replyChan != nil && cookie.errorChan != nil: - Logger.Printf("Found cookie with sequence id %d that is "+ + logger.Printf("Found cookie with sequence id %d that is "+ "expecting a reply but will never get it. Currently "+ "on sequence number %d", cookie.Sequence, seq) // Unchecked requests with replies case cookie.replyChan != nil && cookie.pingChan != nil: - Logger.Printf("Found cookie with sequence id %d that is "+ + logger.Printf("Found cookie with sequence id %d that is "+ "expecting a reply (and not an error) but will never "+ "get it. Currently on sequence number %d", cookie.Sequence, seq) @@ -470,7 +468,7 @@ func processEventOrError(everr eventOrError) (Event, Error) { case Error: return nil, ee default: - Logger.Printf("Invalid event/error type: %T", everr) + logger.Printf("Invalid event/error type: %T", everr) return nil, nil } panic("unreachable") |