public/openhab-addons
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[rustpotterks] Remove unnecessary thread sleep call (#14664)

Browse Source 
* [rustpotterks] Remove unnecessary thread sleep call

Signed-off-by: Miguel Álvarez <miguelwork92@gmail.com>
This commit is contained in:
GiviMAD 2023-03-25 00:20:34 +01:00 committed by GitHub
parent b9751dced3
commit c30893281c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
bundles/org.openhab.voice.rustpotterks/src/main/java/org/openhab/voice/rustpotterks/internal/RustpotterKSService.java
View File

@ -191,12 +191,11 @@ public class RustpotterKSService implements KSService {
while (!aborted.get()) { while (!aborted.get()) {
try { try {
numBytesRead = audioStream.read(audioBuffer, bufferSize - remaining, remaining); numBytesRead = audioStream.read(audioBuffer, bufferSize - remaining, remaining);
if (aborted.get()) { if (aborted.get() || numBytesRead == -1) {
break; break;
} }
if (numBytesRead != remaining) { if (numBytesRead != remaining) {
remaining = remaining - numBytesRead; remaining = remaining - numBytesRead;
Thread.sleep(100);
continue; continue;
} }
remaining = bufferSize; remaining = bufferSize;
@ -217,7 +216,7 @@ public class RustpotterKSService implements KSService {
detection.delete(); detection.delete();
ksListener.ksEventReceived(new KSpottedEvent()); ksListener.ksEventReceived(new KSpottedEvent());
} }
} catch (IOException | InterruptedException e) { } catch (IOException e) {
String errorMessage = e.getMessage(); String errorMessage = e.getMessage();
ksListener.ksEventReceived(new KSErrorEvent(errorMessage != null ? errorMessage : "Unexpected error")); ksListener.ksEventReceived(new KSErrorEvent(errorMessage != null ? errorMessage : "Unexpected error"));
} }