LBRYCommunity/ytsync
1
0
Fork 0
Code Issues 39 Pull requests 8 Projects Releases 197 Packages Wiki Activity

change timeouts to avoid long wait times

Browse source
This commit is contained in:
Niko Storni 2020-05-20 04:28:29 +02:00
parent 1ae32d638b
commit 47e467057d
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
manager/transfer.go
View file

@ -95,8 +95,8 @@ func abandonSupports(s *Sync) (float64, error) {
}() }()
consumerWG := &stop.Group{} consumerWG := &stop.Group{}
//TODO: remove this once the SDK team fixes their RPC bugs.... //TODO: remove this once the SDK team fixes their RPC bugs....
s.daemon.SetRPCTimeout(30 * time.Second) s.daemon.SetRPCTimeout(60 * time.Second)
defer s.daemon.SetRPCTimeout(20 * time.Minute) defer s.daemon.SetRPCTimeout(5 * time.Minute)
for i := 0; i < s.ConcurrentVideos; i++ { for i := 0; i < s.ConcurrentVideos; i++ {
consumerWG.Add(1) consumerWG.Add(1)
go func() { go func() {

2
manager/ytsync.go
View file

@ -307,7 +307,7 @@ func (s *Sync) FullCycle() (e error) {
log.Infoln("Waiting for daemon to finish starting...") log.Infoln("Waiting for daemon to finish starting...")
s.daemon = jsonrpc.NewClient(os.Getenv("LBRYNET_ADDRESS")) s.daemon = jsonrpc.NewClient(os.Getenv("LBRYNET_ADDRESS"))
s.daemon.SetRPCTimeout(20 * time.Minute) s.daemon.SetRPCTimeout(5 * time.Minute)
err = s.waitForDaemonStart() err = s.waitForDaemonStart()
if err != nil { if err != nil {