caspervk/AndroidAPS
1
0
Fork 0
Code Releases Activity

notify -> notifyAll

Browse source
This commit is contained in:
Milos Kozak 2023-08-27 01:42:20 +02:00
parent f2e86ae63c
commit 62462b4f83
6 changed files with 10 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
plugins/sync/src/main/java/info/nightscout/plugins/sync/nsclient/workers/NSClientAddAckWorker.kt
View file

@ -4,7 +4,7 @@ import android.content.Context
import android.os.SystemClock import android.os.SystemClock
import androidx.work.WorkerParameters import androidx.work.WorkerParameters
import androidx.work.workDataOf import androidx.work.workDataOf
import info.nightscout.core.utils.notify import info.nightscout.core.utils.notifyAll
import info.nightscout.core.utils.receivers.DataWorkerStorage import info.nightscout.core.utils.receivers.DataWorkerStorage
import info.nightscout.core.utils.worker.LoggingWorker import info.nightscout.core.utils.worker.LoggingWorker
import info.nightscout.database.impl.AppRepository import info.nightscout.database.impl.AppRepository
@ -180,7 +180,7 @@ class NSClientAddAckWorker(
} }
} }
ack.originalObject?.let { synchronized(it) { it.notify() } } ack.originalObject?.let { synchronized(it) { it.notifyAll() } }
return ret return ret
} }
} }

4
plugins/sync/src/main/java/info/nightscout/plugins/sync/nsclient/workers/NSClientUpdateRemoveAckWorker.kt
View file

@ -3,7 +3,7 @@ package info.nightscout.plugins.sync.nsclient.workers
import android.content.Context import android.content.Context
import androidx.work.WorkerParameters import androidx.work.WorkerParameters
import androidx.work.workDataOf import androidx.work.workDataOf
import info.nightscout.core.utils.notify import info.nightscout.core.utils.notifyAll
import info.nightscout.core.utils.receivers.DataWorkerStorage import info.nightscout.core.utils.receivers.DataWorkerStorage
import info.nightscout.core.utils.worker.LoggingWorker import info.nightscout.core.utils.worker.LoggingWorker
import info.nightscout.database.impl.AppRepository import info.nightscout.database.impl.AppRepository
@ -128,7 +128,7 @@ class NSClientUpdateRemoveAckWorker(
ret = Result.success(workDataOf("ProcessedData" to pair.toString())) ret = Result.success(workDataOf("ProcessedData" to pair.toString()))
} }
} }
ack.originalObject?.let { synchronized(it) { it.notify() } } ack.originalObject?.let { synchronized(it) { it.notifyAll() } }
return ret return ret
} }
} }

2
pump/danar/src/main/java/info/nightscout/androidaps/danar/SerialIOThread.java
View file

@ -81,7 +81,7 @@ public class SerialIOThread extends Thread {
message.setReceived(true); message.setReceived(true);
message.handleMessage(extractedBuff); message.handleMessage(extractedBuff);
synchronized (message) { synchronized (message) {
message.notify(); message.notifyAll();
} }
} }
} }

2
pump/danar/src/main/java/info/nightscout/androidaps/danar/services/DanaRExecutionService.java
View file

@ -343,7 +343,7 @@ public class DanaRExecutionService extends AbstractDanaRExecutionService {
aapsLogger.debug(LTag.PUMP, "Bolus amount in history too old: " + dateUtil.dateAndTimeString(danaPump.getLastBolusTime())); aapsLogger.debug(LTag.PUMP, "Bolus amount in history too old: " + dateUtil.dateAndTimeString(danaPump.getLastBolusTime()));
} }
synchronized (o) { synchronized (o) {
o.notify(); o.notifyAll();
} }
} }
}); });

4
pump/danars/src/main/java/info/nightscout/pump/danars/services/BLEComm.kt
View file

@ -21,7 +21,7 @@ import androidx.core.app.ActivityCompat
import dagger.android.HasAndroidInjector import dagger.android.HasAndroidInjector
import info.nightscout.androidaps.danars.encryption.BleEncryption import info.nightscout.androidaps.danars.encryption.BleEncryption
import info.nightscout.core.ui.toast.ToastUtils import info.nightscout.core.ui.toast.ToastUtils
import info.nightscout.core.utils.notify import info.nightscout.core.utils.notifyAll
import info.nightscout.core.utils.waitMillis import info.nightscout.core.utils.waitMillis
import info.nightscout.interfaces.notifications.Notification import info.nightscout.interfaces.notifications.Notification
import info.nightscout.interfaces.pump.PumpSync import info.nightscout.interfaces.pump.PumpSync
@ -863,7 +863,7 @@ class BLEComm @Inject internal constructor(
message.setReceived() message.setReceived()
synchronized(message) { synchronized(message) {
// notify to sendMessage // notify to sendMessage
message.notify() message.notifyAll()
} }
} else aapsLogger.error("Unknown message received " + DanaRSPacket.toHexString(decryptedBuffer)) } else aapsLogger.error("Unknown message received " + DanaRSPacket.toHexString(decryptedBuffer))
} }

4
pump/diaconn/src/main/java/info/nightscout/pump/diaconn/service/BLECommonService.kt
View file

@ -18,7 +18,7 @@ import android.os.SystemClock
import androidx.core.app.ActivityCompat import androidx.core.app.ActivityCompat
import dagger.android.HasAndroidInjector import dagger.android.HasAndroidInjector
import info.nightscout.core.ui.toast.ToastUtils import info.nightscout.core.ui.toast.ToastUtils
import info.nightscout.core.utils.notify import info.nightscout.core.utils.notifyAll
import info.nightscout.core.utils.waitMillis import info.nightscout.core.utils.waitMillis
import info.nightscout.interfaces.ui.UiInteraction import info.nightscout.interfaces.ui.UiInteraction
import info.nightscout.pump.diaconn.DiaconnG8Pump import info.nightscout.pump.diaconn.DiaconnG8Pump
@ -406,7 +406,7 @@ class BLECommonService @Inject internal constructor(
message!!.setReceived() message!!.setReceived()
synchronized(message!!) { synchronized(message!!) {
// notify to sendMessage // notify to sendMessage
message!!.notify() message!!.notifyAll()
} }
} else aapsLogger.error("Unknown message received " + DiaconnG8Packet.toHex(data)) } else aapsLogger.error("Unknown message received " + DiaconnG8Packet.toHex(data))
} }