Skip to content

Commit

Permalink
feat: update typo in local_storage.go (#955)
Browse files Browse the repository at this point in the history
  • Loading branch information
guoguodan authored and gaius-qi committed Jun 28, 2023
1 parent 91c15f0 commit 3b6966c
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion client/daemon/storage/local_storage.go
Original file line number Diff line number Diff line change
Expand Up @@ -210,7 +210,7 @@ func (t *localTaskStore) IsInvalid(*PeerTaskMetadata) (bool, error) {
return t.invalid.Load(), nil
}

// ReadPiece get a LimitReadCloser from task data with seeked, caller should read bytes and close it.
// ReadPiece get a LimitReadCloser from task data with sought, caller should read bytes and close it.
func (t *localTaskStore) ReadPiece(ctx context.Context, req *ReadPieceRequest) (io.Reader, io.Closer, error) {
if t.invalid.Load() {
t.Errorf("invalid digest, refuse to get pieces")
Expand Down
2 changes: 1 addition & 1 deletion client/daemon/storage/storage_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ type TaskStorageDriver interface {
WritePiece(ctx context.Context, req *WritePieceRequest) (int64, error)

// ReadPiece get a piece data reader of a task from storage
// return a Reader and a Closer from task data with seeked, caller should read bytes and close it.
// return a Reader and a Closer from task data with sought, caller should read bytes and close it.
// If req.Num is equal to -1, range has a fixed value.
ReadPiece(ctx context.Context, req *ReadPieceRequest) (io.Reader, io.Closer, error)

Expand Down

0 comments on commit 3b6966c

Please sign in to comment.