Skip to content

Commit

Permalink
fix(spanner): fix negative values for max_in_use_sessions metrics goo…
Browse files Browse the repository at this point in the history
…gleapis#10449 (googleapis#10508)

* fix(spanner): add debug log to print full stack trace when negative value happens

* skip decrementing num_in_use metric count when session is destroyed from healthchecks.
  • Loading branch information
rahul2393 authored Jul 16, 2024
1 parent 25c5cbe commit 4e180f4
Showing 1 changed file with 7 additions and 2 deletions.
9 changes: 7 additions & 2 deletions spanner/session.go
Original file line number Diff line number Diff line change
Expand Up @@ -1191,6 +1191,11 @@ func (p *sessionPool) incNumInUseLocked(ctx context.Context) {

func (p *sessionPool) decNumInUseLocked(ctx context.Context) {
p.numInUse--
if int64(p.numInUse) < 0 {
// print whole call stack trace
logf(p.sc.logger, "Number of sessions in use is negative, resetting it to currSessionsCheckedOutLocked. Stack trace: %s", string(debug.Stack()))
p.numInUse = p.currSessionsCheckedOutLocked()
}
p.recordStat(ctx, SessionsCount, int64(p.numInUse), tagNumInUseSessions)
p.recordStat(ctx, ReleasedSessionsCount, 1)
if p.otConfig != nil {
Expand Down Expand Up @@ -1459,12 +1464,12 @@ func (hc *healthChecker) healthCheck(s *session) {
defer hc.markDone(s)
if !s.pool.isValid() {
// Session pool is closed, perform a garbage collection.
s.destroy(false, true)
s.destroy(false, false)
return
}
if err := s.ping(); isSessionNotFoundError(err) {
// Ping failed, destroy the session.
s.destroy(false, true)
s.destroy(false, false)
}
}

Expand Down

0 comments on commit 4e180f4

Please sign in to comment.