gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 02:00:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

refactor(blobnode): put/get shard eio return error code 613

Browse Source 
. #22358264 of #22357713

Signed-off-by: mawei029 <mawei2@oppo.com>
This commit is contained in:
mawei029 2024-07-05 16:23:38 +08:00 committed by 梁曟風
parent 05155c157d
commit d3575df4d4
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
blobstore/api/blobnode/shard.go
View File

@ -22,6 +22,7 @@ import (
"net/http"
"strconv"
"github.com/cubefs/cubefs/blobstore/blobnode/base"
bloberr "github.com/cubefs/cubefs/blobstore/common/errors"
"github.com/cubefs/cubefs/blobstore/common/proto"
"github.com/cubefs/cubefs/blobstore/common/rpc"
@ -79,6 +80,7 @@ func (c *client) PutShard(ctx context.Context, host string, args *PutShardArgs)
host, args.DiskID, args.Vuid, args.Bid, args.Size, args.Type)
req, err := http.NewRequest(http.MethodPost, urlStr, args.Body)
if err != nil {
err = convertEIO(err)
return
}
req.ContentLength = args.Size
@ -115,6 +117,7 @@ func (c *client) GetShard(ctx context.Context, host string, args *GetShardArgs)
resp, err := c.Get(ctx, urlStr)
if err != nil {
err = convertEIO(err)
return nil, 0, err
}
@ -161,6 +164,7 @@ func (c *client) RangeGetShard(ctx context.Context, host string, args *RangeGetS
req, err := http.NewRequest(http.MethodGet, urlStr, nil)
if err != nil {
err = convertEIO(err)
span.Errorf("Failed new req. urlStr:%s, err:%v", urlStr, err)
return
}
@ -270,3 +274,11 @@ func (c *client) ListShards(ctx context.Context, host string, args *ListShardsAr
return listRet.ShardInfos, listRet.Next, nil
}
func convertEIO(err error) error {
if base.IsEIO(err) {
return bloberr.ErrDiskBroken
}
return err
}