blob: 35fa695201b2a611be6a3819160a65991555a926 (
about) (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
package ingest
import "fmt"
// beginEntryCRC starts inline CRC accumulation for one packed entry.
func (scanner *streamScanner) beginEntryCRC() {
scanner.entryCRC = 0
scanner.inEntryCRC = true
}
// endEntryCRC finishes inline CRC accumulation for one packed entry.
func (scanner *streamScanner) endEntryCRC() (uint32, error) {
if !scanner.inEntryCRC {
return 0, fmt.Errorf("format/pack/ingest: entry CRC not started")
}
crc := scanner.entryCRC
scanner.entryCRC = 0
scanner.inEntryCRC = false
return crc, nil
}
|
