state.go 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. package lz4
  2. import (
  3. "errors"
  4. "fmt"
  5. "io"
  6. "github.com/pierrec/lz4/internal/lz4errors"
  7. )
  8. //go:generate go run golang.org/x/tools/cmd/stringer -type=aState -output state_gen.go
  9. const (
  10. noState aState = iota // uninitialized reader
  11. errorState // unrecoverable error encountered
  12. newState // instantiated object
  13. readState // reading data
  14. writeState // writing data
  15. closedState // all done
  16. )
  17. type (
  18. aState uint8
  19. _State struct {
  20. states []aState
  21. state aState
  22. err error
  23. }
  24. )
  25. func (s *_State) init(states []aState) {
  26. s.states = states
  27. s.state = states[0]
  28. }
  29. // next sets the state to the next one unless it is passed a non nil error.
  30. // It returns whether or not it is in error.
  31. func (s *_State) next(err error) bool {
  32. if err != nil {
  33. s.err = fmt.Errorf("%s: %w", s.state, err)
  34. s.state = errorState
  35. return true
  36. }
  37. s.state = s.states[s.state]
  38. return false
  39. }
  40. func (s *_State) nextd(errp *error) bool {
  41. return s.next(*errp)
  42. }
  43. // check sets s in error if not already in error and if the error is not nil or io.EOF,
  44. func (s *_State) check(errp *error) {
  45. if s.state == errorState || errp == nil {
  46. return
  47. }
  48. if err := *errp; err != nil {
  49. s.err = fmt.Errorf("%w[%s]", err, s.state)
  50. if !errors.Is(err, io.EOF) {
  51. s.state = errorState
  52. }
  53. }
  54. }
  55. func (s *_State) fail() error {
  56. s.state = errorState
  57. s.err = fmt.Errorf("%w[%s]", lz4errors.ErrInternalUnhandledState, s.state)
  58. return s.err
  59. }