fix: schedulers send invalid direct piece

[jim3ma]

Signed-off-by: Jim Ma [email protected]

Description

Related Issue

Fix #968

Motivation and Context

Screenshots (if appropriate):

Types of changes

• Bug fix (non-breaking change which fixes an issue)
• New feature (non-breaking change which adds functionality)
• Breaking change (fix or feature that would cause existing functionality to change)
• Documentation Update (if none of the other choices apply)

Checklist:

• Code compiles correctly.
• My code follows the code style of this project.
• My change requires a change to the documentation.
• I have updated the documentation accordingly.
• I have read the CONTRIBUTING document.
• I have added tests to cover my changes.
• All new and existing tests passed.

[codecov-commenter]

Codecov Report

Merging #970 (9fc3ed5) into main (35a005e) will increase coverage by 0.07%.
The diff coverage is n/a.

@@            Coverage Diff             @@
##             main     #970      +/-   ##
==========================================
+ Coverage   42.39%   42.47%   +0.07%     
==========================================
  Files         116      116              
  Lines        8796     8796              
==========================================
+ Hits         3729     3736       +7     
+ Misses       4600     4595       -5     
+ Partials      467      465       -2     

Flag	Coverage Δ
Object-compatibility-e2etests	?
e2etests	?
unittests	42.47% <ø> (+0.07%)	⬆️

Flags with carried forward coverage won't be shown. Click here to find out more.

Impacted Files	Coverage Δ
client/daemon/peer/peertask_base.go	45.96% <0.00%> (-0.58%)	⬇️
client/daemon/peer/peertask_stream.go	56.65% <0.00%> (+2.16%)	⬆️
pkg/sync/krwmutex.go	86.36% <0.00%> (+4.54%)	⬆️
pkg/sync/kmutex.go	100.00% <0.00%> (+16.66%)	⬆️

[hyy0322]

LGTM