| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465 |
- package lz4
- import (
- "errors"
- "fmt"
- "io"
- )
- //go:generate go run golang.org/x/tools/cmd/stringer -type=aState -output state_gen.go
- const (
- noState aState = iota // uninitialized reader
- errorState // unrecoverable error encountered
- newState // instantiated object
- headerState // processing header
- readState // reading data
- writeState // writing data
- closedState // all done
- )
- type (
- aState uint8
- _State struct {
- states []aState
- state aState
- err error
- }
- )
- func (s *_State) init(states []aState) *_State {
- s.states = states
- s.state = states[0]
- return s
- }
- // next sets the state to the next one unless it is passed a non nil error.
- // It returns whether or not it is in error.
- func (s *_State) next(err error) bool {
- if err != nil {
- s.err = fmt.Errorf("%s: %w", s.state, err)
- s.state = errorState
- return true
- }
- s.state = s.states[s.state]
- return false
- }
- // check sets s in error if not already in error and if the error is not nil or io.EOF,
- func (s *_State) check(errp *error) {
- if s.state == errorState || errp == nil {
- return
- }
- if err := *errp; err != nil {
- s.err = fmt.Errorf("%s: %w", s.state, err)
- if !errors.Is(err, io.EOF) {
- s.state = errorState
- }
- }
- }
- func (s *_State) fail() error {
- s.state = errorState
- s.err = fmt.Errorf("%w: next state for %q", ErrInternalUnhandledState, s.state)
- return s.err
- }
|