(ccc *lbCacheClientConn, sccLen, sctaLen int)
| 76 | } |
| 77 | |
| 78 | func checkCacheCC(ccc *lbCacheClientConn, sccLen, sctaLen int) error { |
| 79 | ccc.mu.Lock() |
| 80 | defer ccc.mu.Unlock() |
| 81 | if len(ccc.subConnCache) != sccLen { |
| 82 | return fmt.Errorf("ccc = %+v, want len(ccc.subConnCache) = %v", ccc.subConnCache, sccLen) |
| 83 | } |
| 84 | if len(ccc.subConnToAddr) != sctaLen { |
| 85 | return fmt.Errorf("ccc = %+v, want len(ccc.subConnToAddr) = %v", ccc.subConnToAddr, sctaLen) |
| 86 | } |
| 87 | return nil |
| 88 | } |
| 89 | |
| 90 | // Test that SubConn won't be immediately shut down. |
| 91 | func (s) TestLBCacheClientConnExpire(t *testing.T) { |
no test coverage detected