fix ProgressiveDownloader infinite loop doe to priority

library/core/src/main/java/com/google/android/exoplayer2/offline/ProgressiveDownloader.java

@@ -88,19 +88,7 @@ public final class ProgressiveDownloader implements Downloader {
   public void download(@Nullable ProgressListener progressListener)
   public void download(@Nullable ProgressListener progressListener)
       throws IOException, InterruptedException {
       throws IOException, InterruptedException {
     this.progressListener = progressListener;
     this.progressListener = progressListener;
-    downloadRunnable =
-        new RunnableFutureTask<Void, IOException>() {
-          @Override
-          protected Void doWork() throws IOException {
-            cacheWriter.cache();
-            return null;
-          }
-
-          @Override
-          protected void cancelWork() {
-            cacheWriter.cancel();
-          }
-        };
+    downloadRunnable = createDownloadTask();
 
 
     if (priorityTaskManager != null) {
     if (priorityTaskManager != null) {
       priorityTaskManager.add(C.PRIORITY_DOWNLOAD);
       priorityTaskManager.add(C.PRIORITY_DOWNLOAD);
@@ -119,6 +107,8 @@ public final class ProgressiveDownloader implements Downloader {
           Throwable cause = Assertions.checkNotNull(e.getCause());
           Throwable cause = Assertions.checkNotNull(e.getCause());
           if (cause instanceof PriorityTooLowException) {
           if (cause instanceof PriorityTooLowException) {
             // The next loop iteration will block until the task is able to proceed.
             // The next loop iteration will block until the task is able to proceed.
+            // recreate downloadRunnable in order to prevent error state caching
+            downloadRunnable = createDownloadTask();
           } else if (cause instanceof IOException) {
           } else if (cause instanceof IOException) {
             throw (IOException) cause;
             throw (IOException) cause;
           } else {
           } else {
@@ -161,4 +151,19 @@ public final class ProgressiveDownloader implements Downloader {
             : ((bytesCached * 100f) / contentLength);
             : ((bytesCached * 100f) / contentLength);
     progressListener.onProgress(contentLength, bytesCached, percentDownloaded);
     progressListener.onProgress(contentLength, bytesCached, percentDownloaded);
   }
   }
+
+  private RunnableFutureTask<Void, IOException> createDownloadTask() {
+    return new RunnableFutureTask<Void, IOException>() {
+      @Override
+      protected Void doWork() throws IOException {
+        cacheWriter.cache();
+        return null;
+      }
+
+      @Override
+      protected void cancelWork() {
+        cacheWriter.cancel();
+      }
+    };
+  }
 }
 }