benjamyn/any-sync
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

increase sendSync timeout

Browse Source
This commit is contained in:
Sergey Cherepanov 2023-05-15 20:30:32 +02:00 committed by Mikhail Iudin
parent b8cb74d2ff
commit 5e1ac84d37
No known key found for this signature in database
GPG Key ID: FAAAA8BAABDFF1C0
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
commonspace/objectsync/msgpool.go
View File

@ -54,7 +54,7 @@ func newMessagePool(peerManager peermanager.PeerManager, messageHandler MessageH
func (s *messagePool) SendSync(ctx context.Context, peerId string, msg *spacesyncproto.ObjectSyncMessage) (reply *spacesyncproto.ObjectSyncMessage, err error) { func (s *messagePool) SendSync(ctx context.Context, peerId string, msg *spacesyncproto.ObjectSyncMessage) (reply *spacesyncproto.ObjectSyncMessage, err error) {
s.updateLastUsage() s.updateLastUsage()
var cancel context.CancelFunc var cancel context.CancelFunc
ctx, cancel = context.WithTimeout(ctx, time.Second*10) ctx, cancel = context.WithTimeout(ctx, time.Minute)
defer cancel() defer cancel()
newCounter := s.counter.Add(1) newCounter := s.counter.Add(1)
msg.RequestId = genReplyKey(peerId, msg.ObjectId, newCounter) msg.RequestId = genReplyKey(peerId, msg.ObjectId, newCounter)