| 706 | } |
| 707 | |
| 708 | void RedisConnection::DecreasePendingQueries(int count) |
| 709 | { |
| 710 | if (m_Parent) { |
| 711 | m_Parent->DecreasePendingQueries(count); |
| 712 | } |
| 713 | |
| 714 | // Same as in IncreasePendingQueries(). |
| 715 | if (!m_Parent || m_TrackOwnPendingQueries) { |
| 716 | m_PendingQueries.fetch_sub(count); |
| 717 | m_OutputQueries.InsertValue(Utility::GetTime(), count); |
| 718 | } |
| 719 | } |
| 720 | |
| 721 | void RedisConnection::RecordAffected(RedisConnection::QueryAffects affected, double when) |
| 722 | { |
nothing calls this directly
no test coverage detected