aboutsummaryrefslogtreecommitdiff
path: root/weed/server
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-04-12 21:00:55 -0700
committerChris Lu <chris.lu@gmail.com>2020-04-12 21:00:55 -0700
commit7764e0465ce976bb528c27bb9aa25857102570ef (patch)
tree7163cf7d7b940ea3ecf7971024f5469cdcd56eee /weed/server
parent8e23dc078b6790ace902c09ed71963c9ce49acdb (diff)
downloadseaweedfs-7764e0465ce976bb528c27bb9aa25857102570ef.tar.xz
seaweedfs-7764e0465ce976bb528c27bb9aa25857102570ef.zip
refactoring
Diffstat (limited to 'weed/server')
-rw-r--r--weed/server/filer_grpc_server_listen.go4
-rw-r--r--weed/server/filer_grpc_server_rename.go2
-rw-r--r--weed/server/volume_server_handlers_write.go6
3 files changed, 6 insertions, 6 deletions
diff --git a/weed/server/filer_grpc_server_listen.go b/weed/server/filer_grpc_server_listen.go
index e2d932a99..76bf834ea 100644
--- a/weed/server/filer_grpc_server_listen.go
+++ b/weed/server/filer_grpc_server_listen.go
@@ -10,7 +10,7 @@ import (
"github.com/chrislusf/seaweedfs/weed/util"
)
-func (fs *FilerServer) ListenForEvents(req *filer_pb.ListenForEventsRequest, stream filer_pb.SeaweedFiler_ListenForEventsServer) error {
+func (fs *FilerServer) SubscribeMetadata(req *filer_pb.SubscribeMetadataRequest, stream filer_pb.SeaweedFiler_SubscribeMetadataServer) error {
peerAddress := findClientAddress(stream.Context(), 0)
@@ -46,7 +46,7 @@ func (fs *FilerServer) ListenForEvents(req *filer_pb.ListenForEventsRequest, str
return nil
}
- message := &filer_pb.FullEventNotification{
+ message := &filer_pb.SubscribeMetadataResponse{
Directory: dirPath,
EventNotification: eventNotification,
}
diff --git a/weed/server/filer_grpc_server_rename.go b/weed/server/filer_grpc_server_rename.go
index c18587b45..71e2c7d17 100644
--- a/weed/server/filer_grpc_server_rename.go
+++ b/weed/server/filer_grpc_server_rename.go
@@ -117,7 +117,7 @@ func (fs *FilerServer) moveSelfEntry(ctx context.Context, oldParent util.FullPat
events.newEntries = append(events.newEntries, newEntry)
- if moveFolderSubEntries!=nil {
+ if moveFolderSubEntries != nil {
if moveChildrenErr := moveFolderSubEntries(); moveChildrenErr != nil {
return moveChildrenErr
}
diff --git a/weed/server/volume_server_handlers_write.go b/weed/server/volume_server_handlers_write.go
index 968ece11f..227cb0b28 100644
--- a/weed/server/volume_server_handlers_write.go
+++ b/weed/server/volume_server_handlers_write.go
@@ -167,10 +167,10 @@ func setEtag(w http.ResponseWriter, etag string) {
}
}
-func getEtag(resp *http.Response) (etag string){
+func getEtag(resp *http.Response) (etag string) {
etag = resp.Header.Get("ETag")
- if strings.HasPrefix(etag, "\"") && strings.HasSuffix(etag, "\""){
- return etag[1:len(etag)-1]
+ if strings.HasPrefix(etag, "\"") && strings.HasSuffix(etag, "\"") {
+ return etag[1 : len(etag)-1]
}
return
}