Fixed bug where failing a chunk or keyframe would crash GameUpdateTask

loldevs · Oct 6, 2014 · 0f4cb84 · 0f4cb84
1 parent f72f8ff
commit 0f4cb84
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/spectator/src/main/java/net/boreeas/riotapi/spectator/GamePool.java b/spectator/src/main/java/net/boreeas/riotapi/spectator/GamePool.java
@@ -39,7 +39,7 @@ public GameUpdateTask submit(InProgressGame game, Consumer<Exception> errorCallb
 
         GameUpdateTask task = new GameUpdateTask(game, errorCallback);
         // Run once to pull all pending chunks, then run on repeat
-        pool.schedule(() -> task.run(), 10, TimeUnit.MILLISECONDS);
+        pool.schedule(() -> task.run(), 0, TimeUnit.MILLISECONDS);
         ScheduledFuture<?> self = pool.scheduleAtFixedRate(task, game.getLastChunkInfo().getNextAvailableChunk(), game.getChunkInterval(), TimeUnit.MILLISECONDS);
         task.setSelf(self);
 

diff --git a/spectator/src/main/java/net/boreeas/riotapi/spectator/GameUpdateTask.java b/spectator/src/main/java/net/boreeas/riotapi/spectator/GameUpdateTask.java
@@ -168,7 +168,7 @@ private void pullNewKeyframes(ChunkInfo chunkInfo) {
     }
 
     private void pullNewChunks(int maxId) {
-        log.debug("[" + game.getGameId() + "] " + (maxId - game.getLastAvailableChunk()) + " new chunks (" + (game.getLastAvailableChunk() + 1) + " to " + maxId + ")");
+        //log.debug("[" + game.getGameId() + "] " + (maxId - game.getLastAvailableChunk()) + " new chunks (" + (game.getLastAvailableChunk() + 1) + " to " + maxId + ")");
 
         // Time between chunks is occasionally less than the chunk time interval
         // So we check for all missed chunks here
@@ -189,7 +189,6 @@ private void doRetriesKeyframes() {
                 retriesKeyframes.remove(i);
                 if (onKeyframePulled != null) { onKeyframeFailed.accept(i); }
             }
-            throw new RequestException("Unreachable keyframe(s): " + retriesExceeded);
         }
 
         if (!retrySuccessful.isEmpty()) {
@@ -209,7 +208,6 @@ private void doRetriesChunk() {
                 retriesChunks.remove(i);
                 if (onChunkFailed != null) { onChunkFailed.accept(i); }
             }
-            throw new RequestException("Unreachable chunk(s): " + retriesExceeded);
         }
 
         if (!retrySuccessful.isEmpty()) {