summaryrefslogtreecommitdiff
path: root/worker/sync_worker.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-11-25 15:31:24 +0300
committerValery Piashchynski <[email protected]>2021-11-25 15:31:24 +0300
commit6123a45bd77f50b137d46577089b7b43c692b2d1 (patch)
treefb688befd82ada5ee8fa466f3393b9db37b09538 /worker/sync_worker.go
parent6c5e3ab6c01d31caa2d14930c188bae697c5cd48 (diff)
update goridge
print bad header in the error message Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'worker/sync_worker.go')
-rwxr-xr-xworker/sync_worker.go6
1 files changed, 1 insertions, 5 deletions
diff --git a/worker/sync_worker.go b/worker/sync_worker.go
index deea8cb1..12937eac 100755
--- a/worker/sync_worker.go
+++ b/worker/sync_worker.go
@@ -190,11 +190,7 @@ func (tw *SyncWorkerImpl) execPayload(p *payload.Payload) (*payload.Payload, err
return nil, errors.E(op, errors.Network, err)
}
if frameR == nil {
- return nil, errors.E(op, errors.Network, errors.Str("nil fr received"))
- }
-
- if !frameR.VerifyCRC(frameR.Header()) {
- return nil, errors.E(op, errors.Network, errors.Str("failed to verify CRC"))
+ return nil, errors.E(op, errors.Network, errors.Str("nil frame received"))
}
flags := frameR.ReadFlags()