forked from j62/ctbrec
Revert "Remove online check for currently running recordings"
This reverts commit e4ab0873bc
.
This commit is contained in:
parent
8d3f2da18b
commit
6c9bff56fc
|
@ -2,14 +2,10 @@ package ctbrec.recorder;
|
|||
|
||||
import static ctbrec.Model.State.*;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InterruptedIOException;
|
||||
import java.net.SocketTimeoutException;
|
||||
import java.security.InvalidKeyException;
|
||||
import java.security.NoSuchAlgorithmException;
|
||||
import java.time.Duration;
|
||||
import java.time.Instant;
|
||||
import java.util.Collections;
|
||||
import java.util.HashMap;
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
||||
|
@ -56,21 +52,8 @@ public class OnlineMonitor extends Thread {
|
|||
}
|
||||
}
|
||||
|
||||
List<Model> activeRecordings = null;
|
||||
try {
|
||||
activeRecordings = recorder.getCurrentlyRecording();
|
||||
} catch (InvalidKeyException | NoSuchAlgorithmException | IllegalStateException | IOException e1) {
|
||||
activeRecordings = Collections.emptyList();
|
||||
}
|
||||
|
||||
// update the currently recorded models
|
||||
for (Model model : models) {
|
||||
if(activeRecordings.contains(model)) {
|
||||
// ctbrec is recording this model, no need to check the online state
|
||||
EventBusHolder.BUS.post(new ModelIsOnlineEvent(model));
|
||||
continue;
|
||||
}
|
||||
|
||||
try {
|
||||
if(model.isOnline(IGNORE_CACHE)) {
|
||||
EventBusHolder.BUS.post(new ModelIsOnlineEvent(model));
|
||||
|
|
Loading…
Reference in New Issue