Browse Source

go fmt

pull/3001/head
chrislu 3 years ago
parent
commit
00c1dfec4f
  1. 2
      weed/s3api/s3api_bucket_handlers.go
  2. 2
      weed/s3api/s3api_object_multipart_handlers.go
  3. 6
      weed/topology/topology.go

2
weed/s3api/s3api_bucket_handlers.go

@ -135,7 +135,7 @@ func (s3a *S3ApiServer) PutBucketHandler(w http.ResponseWriter, r *http.Request)
s3err.WriteErrorResponse(w, r, s3err.ErrInternalError)
return
}
w.Header().Set("Location", "/" + bucket)
w.Header().Set("Location", "/"+bucket)
writeSuccessResponseEmpty(w, r)
}

2
weed/s3api/s3api_object_multipart_handlers.go

@ -1,8 +1,8 @@
package s3api
import (
"encoding/xml"
"crypto/sha1"
"encoding/xml"
"fmt"
"github.com/chrislusf/seaweedfs/weed/glog"
xhttp "github.com/chrislusf/seaweedfs/weed/s3api/http"

6
weed/topology/topology.go

@ -303,8 +303,8 @@ func (t *Topology) IncrementalSyncDataNodeRegistration(newVolumes, deletedVolume
return
}
func (t *Topology) DataNodeRegistration(dcName, rackName string ,dn *DataNode){
if dn.Parent() != nil{
func (t *Topology) DataNodeRegistration(dcName, rackName string, dn *DataNode) {
if dn.Parent() != nil {
return
}
// registration to topo
@ -312,4 +312,4 @@ func (t *Topology) DataNodeRegistration(dcName, rackName string ,dn *DataNode){
rack := dc.GetOrCreateRack(rackName)
rack.LinkChildNode(dn)
glog.Infof("[%s] reLink To topo ", dn.Id())
}
}
Loading…
Cancel
Save