add temporary workaround to release all IPs

speed up one failure

ip_manager/throttle.go

@@ -121,6 +121,16 @@ func (i *IPPool) ReleaseIP(ip string) {
 	util.SendErrorToSlack("something went wrong while releasing the IP %s as we reached the end of the function", ip)
 }
 
+func (i *IPPool) ReleaseAll() {
+	i.lock.Lock()
+	defer i.lock.Unlock()
+	for j, _ := range i.ips {
+		localIP := &i.ips[j]
+		localIP.InUse = false
+		localIP.LastUse = time.Now()
+	}
+}
+
 func (i *IPPool) SetThrottled(ip string) {
 	i.lock.Lock()
 	defer i.lock.Unlock()

manager/manager.go

@@ -7,6 +7,7 @@ import (
 	"time"
 
 	"github.com/lbryio/ytsync/blobs_reflector"
+	"github.com/lbryio/ytsync/ip_manager"
 	"github.com/lbryio/ytsync/namer"
 	"github.com/lbryio/ytsync/sdk"
 	logUtils "github.com/lbryio/ytsync/util"
@@ -202,6 +203,12 @@ func (s *SyncManager) Start() error {
 			shouldNotCount := false
 			logUtils.SendInfoToSlack("Syncing %s (%s) to LBRY! total processed channels since startup: %d", sync.LbryChannelName, sync.YoutubeChannelID, syncCount+1)
 			err := sync.FullCycle()
+			//TODO: THIS IS A TEMPORARY WORK AROUND FOR THE STUPID IP LOCKUP BUG
+			ipPool, _ := ip_manager.GetIPPool(sync.grp)
+			if ipPool != nil {
+				ipPool.ReleaseAll()
+			}
+
 			if err != nil {
 				fatalErrors := []string{
 					"default_wallet already exists",

manager/ytsync.go

@@ -895,6 +895,7 @@ func (s *Sync) startWorker(workerNum int) {
 						"requested format not available",
 						"interrupted by user",
 						"Sign in to confirm your age",
+						"This video is unavailable",
 					}
 					if util.SubstringInSlice(err.Error(), errorsNoRetry) {
 						log.Println("This error should not be retried at all")