TinyWeatherForecastGermanyGroup/TinyWeatherForecastGermany
2
2
Fork 0
mirror of https://codeberg.org/Starfish/TinyWeatherForecastGermany.git synced 2025-10-06 01:32:39 +02:00
Code Releases Wiki Activity

improve fetching of rain radar

Browse Source
This commit is contained in:
Starfish
2025-08-04 18:48:56 +02:00
parent ce08de70e2
commit a8ad009eb3
1 changed files with 17 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
app/src/main/java/de/kaffeemitkoffein/tinyweatherforecastgermany/APIReaders.java
View File

@@ -941,9 +941,9 @@ public class APIReaders {
long startTime = 0;
private boolean forceUpdate = false;
public boolean ssl_exception = false;
private boolean fetchIsReady = false;
int progress = 0;
int errors = 0;
int threadsDone = 0;
public RadarMNSetGeoserverRunnable(Context context){
this.context = context;
@@ -1119,24 +1119,20 @@ public class APIReaders {
public void fetchRadarSet(int start, int stop){
// data available for 2h with 5 min steps => 24 data sets at max
for (int i=start; i<=stop; i++){
if (!fetchIsReady) {
try {
putRadarMapToCache(getRadarInputStream(startTime+i*TIMESTEP_5MINUTES),i);
incrementProgress();
} catch (IOException e){
incrementErrors();
incrementProgress();
}
} else {
break;
try {
putRadarMapToCache(getRadarInputStream(startTime+i*TIMESTEP_5MINUTES),i);
incrementProgress();
} catch (IOException e){
incrementErrors();
incrementProgress();
}
}
threadsDone++;
checkThreadsDone();
}
public void incrementProgress(){
progress++;
if ((progress>=24) && (!fetchIsReady)){
fetchIsReady = true;
private void checkThreadsDone(){
if (threadsDone>=4){
if (errors>3){
startTime = WeatherSettings.getPrefRadarLastdatapoll(context);
onFinished(startTime,false);
@@ -1144,18 +1140,21 @@ public class APIReaders {
WeatherSettings.setPrefRadarLastdatapoll(context,startTime);
onFinished(startTime,true);
}
} else {
onProgress(startTime,progress);
}
}
public void incrementProgress(){
progress++;
onProgress(startTime,progress);
}
public void incrementErrors(){
errors++;
}
private void multiFetchRadarSet(){
progress = 0;
fetchIsReady = false;
threadsDone = 0;
// use 0 to 24 for full set
startTime = roundUTCUpToNextFiveMinutes(Calendar.getInstance().getTimeInMillis());
// need to delete if read is incomplete