Mastodon
/
nextpush-android
mirror of https://codeberg.org/NextPush/nextpush-android.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Restart only if the fail comes from current source

This commit is contained in:
sim 2023-08-31 08:10:30 +02:00
parent 5484ff6d59
commit 747beb7620
2 changed files with 34 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
app/src/main/java/org/unifiedpush/distributor/nextpush/api/SSEListener.kt
View File

@ -101,9 +101,10 @@ class SSEListener(val context: Context) : EventSourceListener() {
Log.d(TAG, "onClosed: $eventSource")
eventSource.cancel()
if (!shouldRestart()) return
FailureHandler.newFail(context, eventSource)
clearVars()
RestartWorker.run(context, delay = 0)
if (FailureHandler.newFail(context, eventSource)) {
clearVars()
RestartWorker.run(context, delay = 0)
}
}
override fun onFailure(eventSource: EventSource, t: Throwable?, response: Response?) {
@ -118,23 +119,25 @@ class SSEListener(val context: Context) : EventSourceListener() {
}
if (!AppCompanion.hasInternet.get()) {
Log.d(TAG, "No Internet: do not restart")
FailureHandler.once(eventSource)
clearVars()
if (FailureHandler.once(eventSource)) {
clearVars()
}
return
}
FailureHandler.newFail(context, eventSource)
clearVars()
val delay = when (FailureHandler.nFails()) {
1 -> 2 // 2sec
2 -> 5 // 5sec
3 -> 20 // 20sec
4 -> 60 // 1min
5 -> 300 // 5min
6 -> 600 // 10min
else -> return // else keep the worker with its 16min
}.toLong()
Log.d(TAG, "Retrying in $delay s")
RestartWorker.run(context, delay = delay)
if (FailureHandler.newFail(context, eventSource)) {
clearVars()
val delay = when (FailureHandler.nFails()) {
1 -> 2 // 2sec
2 -> 5 // 5sec
3 -> 20 // 20sec
4 -> 60 // 1min
5 -> 300 // 5min
6 -> 600 // 10min
else -> return // else keep the worker with its 16min
}.toLong()
Log.d(TAG, "Retrying in $delay s")
RestartWorker.run(context, delay = delay)
}
}
private fun shouldRestart(): Boolean {

18
app/src/main/java/org/unifiedpush/distributor/nextpush/services/FailureHandler.kt
View File

@ -18,7 +18,7 @@ object FailureHandler {
// This is the last eventSource opened
private val eventSource: AtomicReference<EventSource?> = AtomicReference(null)
private fun isRightEventSource(eventSource: EventSource?): Boolean {
private fun isCurrentEventSource(eventSource: EventSource?): Boolean {
return this.eventSource.get()?.let {
it == eventSource
} ?: true
@ -39,11 +39,12 @@ object FailureHandler {
return nFails.get()
}
fun newFail(context: Context, eventSource: EventSource?) {
// Returns true if the fail is from the current eventSource
fun newFail(context: Context, eventSource: EventSource?): Boolean {
Log.d(TAG, "newFail/Eventsource: $eventSource")
// ignore fails from a possible old eventSource
// if we are already reconnected
if (isRightEventSource(eventSource)) {
return if (isCurrentEventSource(eventSource)) {
Log.d(TAG, "EventSource is known or null")
ttlFails.getAndIncrement()
if (nFails.incrementAndGet() == 2) {
@ -56,21 +57,28 @@ object FailureHandler {
}
}
this.eventSource.getAndSet(null)?.cancel()
true
} else {
Log.d(TAG, "This is an old EventSource.")
eventSource?.cancel()
false
}
}
fun once(eventSource: EventSource?) {
// Returns true if the fail is from the current eventSource
fun once(eventSource: EventSource?): Boolean {
Log.d(TAG, "once/Eventsource: $eventSource")
// ignore fails from a possible old eventSource
// if we are already reconnected
if (isRightEventSource(eventSource)) {
return if (isCurrentEventSource(eventSource)) {
Log.d(TAG, "EventSource is known or null")
nFails.set(1)
this.eventSource.getAndSet(null)?.cancel()
true
} else {
Log.d(TAG, "This is an old EventSource.")
eventSource?.cancel()
false
}
}