Method CloseStream

middleware/grpc_stats.go:160–179

(connID string)

}

func (st *StreamTracker) CloseStream(connID string) {
	st.mu.RLock()
	conn := st.connMap[connID]
	st.mu.RUnlock()
	if conn == nil {
		return
	}
	if res := conn.Dec(); res == 0 {
		// Delete the entry if it's empty.
		st.mu.Lock()

		// Get the entry again to avoid race condition.
		conn = st.connMap[connID]
		if conn == nil || conn.Load() == 0 {
			delete(st.connMap, connID)
		}

		st.mu.Unlock()
	}
}

// MaxStreams returns the number of streams in the connection with the most streams.
func (st *StreamTracker) MaxStreams() int {