Stefan/evcc-io
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Revert "OCPP: fix flaky test deadlock between trigger handler and WS … (#30110)

Browse source
This commit is contained in:
andig 2026-05-22 15:09:08 +02:00 • committed by GitHub
parent b41dc59531
commit d72cd4e653
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 2 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

8
charger/ocpp_test_handler.go
View file

@ -14,10 +14,7 @@ type ChargePointHandler struct {
// core
func (handler *ChargePointHandler) OnChangeAvailability(request *core.ChangeAvailabilityRequest) (confirmation *core.ChangeAvailabilityConfirmation, err error) {
// dispatch asynchronously: the trigger handler issues synchronous CP→CS
// requests whose responses are read by this same goroutine, so a blocking
// send would deadlock the WebSocket read loop
go func() { handler.triggerC <- core.ChangeAvailabilityFeatureName }()
defer func() { handler.triggerC <- core.ChangeAvailabilityFeatureName }()
return core.NewChangeAvailabilityConfirmation(core.AvailabilityStatusAccepted), nil
}
@ -64,8 +61,7 @@ func (handler *ChargePointHandler) OnUnlockConnector(request *core.UnlockConnect
}
func (handler *ChargePointHandler) OnTriggerMessage(request *remotetrigger.TriggerMessageRequest) (confirmation *remotetrigger.TriggerMessageConfirmation, err error) {
// see OnChangeAvailability for why this is async
go func() { handler.triggerC <- request.RequestedMessage }()
defer func() { handler.triggerC <- request.RequestedMessage }()
return remotetrigger.NewTriggerMessageConfirmation(remotetrigger.TriggerMessageStatusAccepted), nil
}