diff --git a/mysql.go b/mysql.go index 40202e12..6d9baf7d 100644 --- a/mysql.go +++ b/mysql.go @@ -35,7 +35,7 @@ type DBWrapper struct { } func (dbw *DBWrapper) IsConnected() bool { - return *dbw.ConnectedAtomic != 0 + return atomic.LoadUint32(dbw.ConnectedAtomic) != 0 } func (dbw *DBWrapper) CompareAndSetConnected(connected bool) (swapped bool) {