()
| 145 | } |
| 146 | |
| 147 | func (mr *msgReader) close() { |
| 148 | mr.c.readMu.forceLock() |
| 149 | mr.putFlateReader() |
| 150 | if mr.dict != nil { |
| 151 | mr.dict.close() |
| 152 | mr.dict = nil |
| 153 | } |
| 154 | if mr.flateBufio != nil { |
| 155 | putBufioReader(mr.flateBufio) |
| 156 | } |
| 157 | |
| 158 | if mr.c.client { |
| 159 | putBufioReader(mr.c.br) |
| 160 | mr.c.br = nil |
| 161 | } |
| 162 | } |
| 163 | |
| 164 | func (mr *msgReader) flateContextTakeover() bool { |
| 165 | if mr.c.client { |
nothing calls this directly
no test coverage detected