diff options
| author | Aleksey Kosov <rusyak777@list.ru> | 2024-09-13 16:53:04 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-09-13 06:53:04 -0700 |
| commit | 7340c62c474f9224da681c3e742b5e8a008af9f8 (patch) | |
| tree | 5a19aac553236fd0f71f9fdec79c81efc1f1214a | |
| parent | 4f2bdebe4949febd1c3d69f5a01586a482d9cb99 (diff) | |
| download | seaweedfs-7340c62c474f9224da681c3e742b5e8a008af9f8.tar.xz seaweedfs-7340c62c474f9224da681c3e742b5e8a008af9f8.zip | |
changing FindEntry error handling in cassandra store (#6015)
| -rw-r--r-- | weed/filer/cassandra/cassandra_store.go | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/weed/filer/cassandra/cassandra_store.go b/weed/filer/cassandra/cassandra_store.go index b13a50fd3..6ced58776 100644 --- a/weed/filer/cassandra/cassandra_store.go +++ b/weed/filer/cassandra/cassandra_store.go @@ -2,6 +2,7 @@ package cassandra import ( "context" + "errors" "fmt" "github.com/gocql/gocql" "time" @@ -129,13 +130,10 @@ func (store *CassandraStore) FindEntry(ctx context.Context, fullpath util.FullPa if err := store.session.Query( "SELECT meta FROM filemeta WHERE directory=? AND name=?", dir, name).Scan(&data); err != nil { - if err != gocql.ErrNotFound { + if errors.Is(err, gocql.ErrNotFound) { return nil, filer_pb.ErrNotFound } - } - - if len(data) == 0 { - return nil, filer_pb.ErrNotFound + return nil, err } entry = &filer.Entry{ |