imterah/hermes
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases 1 Packages Wiki Activity Actions

fix: Fixes various crashes.

Browse source
This commit is contained in:
Tera << 8 2025-01-08 11:40:42 -05:00
parent e456de9802
commit 7837334361
Signed by: imterah
GPG key ID: 8FA7DD57BA6CEA37
1 changed files with 8 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

11
backend/api/backendruntime/runtime.go
View file

@ -421,7 +421,12 @@ SchedulingLoop:
} }
// Fetch response and close Channel // Fetch response and close Channel
response := <-commandChannel response, ok := <-commandChannel
if !ok {
return nil, fmt.Errorf("failed to read from command channel: recieved signal that is not OK")
}
close(commandChannel) close(commandChannel)
err, ok := response.(error) err, ok := response.(error)
@ -443,11 +448,11 @@ func (runtime *Runtime) cleanUpPendingCommandProcessingJobs() {
select { select {
case <-timeoutChannel: case <-timeoutChannel:
log.Fatal("Message channel is likely running (timed out reading from it without an error)") log.Warn("Message channel is likely running (timed out reading from it without an error)")
close(message.Channel) close(message.Channel)
case _, ok := <-message.Channel: case _, ok := <-message.Channel:
if ok { if ok {
log.Fatal("Message channel is running, but should be stopped (since message is NOT nil!)") log.Warn("Message channel is running, but should be stopped (since message is NOT nil!)")
close(message.Channel) close(message.Channel)
} }
} }