vendor/github.com/aws/aws-sdk-go/service/s3/statusok_error.go

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