(reader io.Reader, expectedSize, maxSize int, compression CompressionType, sp opentracing.Span)
| 180 | } |
| 181 | |
| 182 | func decompressRequest(reader io.Reader, expectedSize, maxSize int, compression CompressionType, sp opentracing.Span) (body []byte, err error) { |
| 183 | defer func() { |
| 184 | if err != nil && len(body) > maxSize { |
| 185 | err = fmt.Errorf(messageSizeLargerErrFmt, len(body), maxSize) |
| 186 | } |
| 187 | }() |
| 188 | if expectedSize > maxSize { |
| 189 | return nil, fmt.Errorf(messageSizeLargerErrFmt, expectedSize, maxSize) |
| 190 | } |
| 191 | buffer, ok := tryBufferFromReader(reader) |
| 192 | if ok { |
| 193 | body, err = decompressFromBuffer(buffer, maxSize, compression, sp) |
| 194 | return |
| 195 | } |
| 196 | body, err = decompressFromReader(reader, expectedSize, maxSize, compression, sp) |
| 197 | return |
| 198 | } |
| 199 | |
| 200 | func decompressFromReader(reader io.Reader, expectedSize, maxSize int, compression CompressionType, sp opentracing.Span) ([]byte, error) { |
| 201 | var ( |
no test coverage detected