statusok_error.go 842 B

123456789101112131415161718192021222324252627282930313233343536
  1. package s3
  2. import (
  3. "bytes"
  4. "io/ioutil"
  5. "net/http"
  6. "github.com/aws/aws-sdk-go/aws"
  7. "github.com/aws/aws-sdk-go/aws/awserr"
  8. "github.com/aws/aws-sdk-go/aws/request"
  9. )
  10. func copyMultipartStatusOKUnmarhsalError(r *request.Request) {
  11. b, err := ioutil.ReadAll(r.HTTPResponse.Body)
  12. if err != nil {
  13. r.Error = awserr.New("SerializationError", "unable to read response body", err)
  14. return
  15. }
  16. body := bytes.NewReader(b)
  17. r.HTTPResponse.Body = aws.ReadSeekCloser(body)
  18. defer r.HTTPResponse.Body.(aws.ReaderSeekerCloser).Seek(0, 0)
  19. if body.Len() == 0 {
  20. // If there is no body don't attempt to parse the body.
  21. return
  22. }
  23. unmarshalError(r)
  24. if err, ok := r.Error.(awserr.Error); ok && err != nil {
  25. if err.Code() == "SerializationError" {
  26. r.Error = nil
  27. return
  28. }
  29. r.HTTPResponse.StatusCode = http.StatusServiceUnavailable
  30. }
  31. }