UnsafeSetNotIdle instructs the Manager to update its internal state to reflect the reality that the channel is no longer in IDLE mode. N.B. This method is intended only for internal use by the gRPC client when it exits IDLE mode **manually** from `Dial`. The callsite must ensure: - The channel was
()
| 248 | // - There is **no concurrent activity** that could cause the channel to exit |
| 249 | // IDLE mode *naturally* at the same time. |
| 250 | func (m *Manager) UnsafeSetNotIdle() { |
| 251 | m.idleMu.Lock() |
| 252 | defer m.idleMu.Unlock() |
| 253 | |
| 254 | atomic.AddInt32(&m.activeCallsCount, math.MaxInt32) |
| 255 | m.actuallyIdle = false |
| 256 | m.resetIdleTimerLocked(m.timeout) |
| 257 | } |
| 258 | |
| 259 | // OnCallEnd is invoked at the end of every RPC. |
| 260 | func (m *Manager) OnCallEnd() { |
no test coverage detected