diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-12 21:00:55 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-12 21:00:55 -0700 |
| commit | 7764e0465ce976bb528c27bb9aa25857102570ef (patch) | |
| tree | 7163cf7d7b940ea3ecf7971024f5469cdcd56eee /weed/server | |
| parent | 8e23dc078b6790ace902c09ed71963c9ce49acdb (diff) | |
| download | seaweedfs-7764e0465ce976bb528c27bb9aa25857102570ef.tar.xz seaweedfs-7764e0465ce976bb528c27bb9aa25857102570ef.zip | |
refactoring
Diffstat (limited to 'weed/server')
| -rw-r--r-- | weed/server/filer_grpc_server_listen.go | 4 | ||||
| -rw-r--r-- | weed/server/filer_grpc_server_rename.go | 2 | ||||
| -rw-r--r-- | weed/server/volume_server_handlers_write.go | 6 |
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 } |
