This commit is contained in:
Chris Lu 2020-06-11 10:53:25 -07:00
parent 63a1db64c5
commit 00f96d86a1

View File

@ -204,7 +204,7 @@ func (s3a *S3ApiServer) DeleteMultipleObjectsHandler(w http.ResponseWriter, r *h
} }
func (s3a *S3ApiServer) proxyToFiler(w http.ResponseWriter, r *http.Request, destUrl string, responseFn func(proxyResonse *http.Response, w http.ResponseWriter)) { func (s3a *S3ApiServer) proxyToFiler(w http.ResponseWriter, r *http.Request, destUrl string, responseFn func(proxyResponse *http.Response, w http.ResponseWriter)) {
glog.V(2).Infof("s3 proxying %s to %s", r.Method, destUrl) glog.V(2).Infof("s3 proxying %s to %s", r.Method, destUrl)
@ -237,12 +237,12 @@ func (s3a *S3ApiServer) proxyToFiler(w http.ResponseWriter, r *http.Request, des
responseFn(resp, w) responseFn(resp, w)
} }
func passThroughResponse(proxyResonse *http.Response, w http.ResponseWriter) { func passThroughResponse(proxyResponse *http.Response, w http.ResponseWriter) {
for k, v := range proxyResonse.Header { for k, v := range proxyResponse.Header {
w.Header()[k] = v w.Header()[k] = v
} }
w.WriteHeader(proxyResonse.StatusCode) w.WriteHeader(proxyResponse.StatusCode)
io.Copy(w, proxyResonse.Body) io.Copy(w, proxyResponse.Body)
} }
func (s3a *S3ApiServer) putToFiler(r *http.Request, uploadUrl string, dataReader io.Reader) (etag string, code ErrorCode) { func (s3a *S3ApiServer) putToFiler(r *http.Request, uploadUrl string, dataReader io.Reader) (etag string, code ErrorCode) {