Remove cancel with deadline
This commit is contained in:
parent
ac8c8e4a31
commit
fe31afc337
@ -149,9 +149,6 @@ func (s *objectSync) processHandleMessage(msg HandleMessage) {
|
|||||||
err = context.DeadlineExceeded
|
err = context.DeadlineExceeded
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
var cancel context.CancelFunc
|
|
||||||
ctx, cancel = context.WithDeadline(ctx, msg.Deadline)
|
|
||||||
defer cancel()
|
|
||||||
}
|
}
|
||||||
if err = s.handleMessage(ctx, msg.SenderId, msg.Message); err != nil {
|
if err = s.handleMessage(ctx, msg.SenderId, msg.Message); err != nil {
|
||||||
if msg.Message.ObjectId != "" {
|
if msg.Message.ObjectId != "" {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user