aboutsummaryrefslogtreecommitdiff
path: root/weed/pb/filer_pb/filer_pb_helper.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/pb/filer_pb/filer_pb_helper.go')
-rw-r--r--weed/pb/filer_pb/filer_pb_helper.go9
1 files changed, 6 insertions, 3 deletions
diff --git a/weed/pb/filer_pb/filer_pb_helper.go b/weed/pb/filer_pb/filer_pb_helper.go
index 349f07320..408caadcd 100644
--- a/weed/pb/filer_pb/filer_pb_helper.go
+++ b/weed/pb/filer_pb/filer_pb_helper.go
@@ -4,6 +4,7 @@ import (
"context"
"fmt"
+ "github.com/chrislusf/seaweedfs/weed/glog"
"github.com/chrislusf/seaweedfs/weed/storage/needle"
)
@@ -71,13 +72,15 @@ func AfterEntryDeserialization(chunks []*FileChunk) {
}
}
-func CreateEntry(ctx context.Context, client SeaweedFilerClient, request *CreateEntryRequest) error {
- resp, err := client.CreateEntry(ctx, request)
+func CreateEntry(client SeaweedFilerClient, request *CreateEntryRequest) error {
+ resp, err := client.CreateEntry(context.Background(), request)
if err != nil {
+ glog.V(1).Infof("create entry %s/%s %v: %v", request.Directory, request.Entry.Name, request.OExcl, err)
return fmt.Errorf("CreateEntry: %v", err)
}
if resp.Error != "" {
+ glog.V(1).Infof("create entry %s/%s %v: %v", request.Directory, request.Entry.Name, request.OExcl, err)
return fmt.Errorf("CreateEntry : %v", resp.Error)
}
- return err
+ return nil
}