diff options
| author | chrislu <chris.lu@gmail.com> | 2022-03-07 02:00:14 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-03-07 02:00:14 -0800 |
| commit | da3d330616663e1c843514bd7a7a2c1833bf42d1 (patch) | |
| tree | 8bb184b6a49b099876f1856f68c21db594ff62cc /weed/s3api/s3api_object_handlers.go | |
| parent | 0cb17b45b108340033de06d71cf2fc1b891c3be8 (diff) | |
| download | seaweedfs-da3d330616663e1c843514bd7a7a2c1833bf42d1.tar.xz seaweedfs-da3d330616663e1c843514bd7a7a2c1833bf42d1.zip | |
s3 and filer transport using unix domain socket instead of tcp
Diffstat (limited to 'weed/s3api/s3api_object_handlers.go')
| -rw-r--r-- | weed/s3api/s3api_object_handlers.go | 15 |
1 files changed, 2 insertions, 13 deletions
diff --git a/weed/s3api/s3api_object_handlers.go b/weed/s3api/s3api_object_handlers.go index fb330b471..6bcf2266f 100644 --- a/weed/s3api/s3api_object_handlers.go +++ b/weed/s3api/s3api_object_handlers.go @@ -27,17 +27,6 @@ import ( "github.com/chrislusf/seaweedfs/weed/util" ) -var ( - client *http.Client -) - -func init() { - client = &http.Client{Transport: &http.Transport{ - MaxIdleConns: 1024, - MaxIdleConnsPerHost: 1024, - }} -} - func mimeDetect(r *http.Request, dataReader io.Reader) io.ReadCloser { mimeBuffer := make([]byte, 512) size, _ := dataReader.Read(mimeBuffer) @@ -335,7 +324,7 @@ func (s3a *S3ApiServer) proxyToFiler(w http.ResponseWriter, r *http.Request, des // ensure that the Authorization header is overriding any previous // Authorization header which might be already present in proxyReq s3a.maybeAddFilerJwtAuthorization(proxyReq, isWrite) - resp, postErr := client.Do(proxyReq) + resp, postErr := s3a.client.Do(proxyReq) if postErr != nil { glog.Errorf("post to filer: %v", postErr) @@ -401,7 +390,7 @@ func (s3a *S3ApiServer) putToFiler(r *http.Request, uploadUrl string, dataReader // ensure that the Authorization header is overriding any previous // Authorization header which might be already present in proxyReq s3a.maybeAddFilerJwtAuthorization(proxyReq, true) - resp, postErr := client.Do(proxyReq) + resp, postErr := s3a.client.Do(proxyReq) if postErr != nil { glog.Errorf("post to filer: %v", postErr) |