=== modified file 'dbus.go' --- dbus.go 2014-11-19 19:24:28 +0000 +++ dbus.go 2015-01-08 15:22:07 +0000 @@ -40,6 +40,7 @@ writeLock sync.Mutex busProxy BusDaemon lastSerial uint32 + connOpen bool handlerMutex sync.Mutex // covers the next three messageFilters []*MessageFilter @@ -120,6 +121,7 @@ if bus.conn, err = trans.Dial(); err != nil { return nil, err } + bus.connOpen = true if err = authenticate(bus.conn, nil); err != nil { bus.conn.Close() @@ -151,7 +153,7 @@ for { msg, err := readMessage(p.conn) if err != nil { - if err != io.EOF { + if err != io.EOF && p.connOpen { log.Println("Failed to read message:", err) } break @@ -245,6 +247,7 @@ } func (p *Connection) Close() error { + p.connOpen = false return p.conn.Close() }