( c *gin.Context, machine *relay.PluginResponsesMachine, taskStatus string, )
| 1089 | } |
| 1090 | |
| 1091 | func writeTaskPluginProtocolTimeout( |
| 1092 | c *gin.Context, |
| 1093 | machine *relay.PluginResponsesMachine, |
| 1094 | taskStatus string, |
| 1095 | ) { |
| 1096 | incomplete, err := machine.TimeoutEvent(taskStatus) |
| 1097 | if err != nil { |
| 1098 | logger.LogError(c, "task protocol timeout event failed: "+err.Error()) |
| 1099 | return |
| 1100 | } |
| 1101 | _ = writeTaskPluginProtocolEvent(c, incomplete) |
| 1102 | } |
| 1103 | |
| 1104 | func writeTaskPluginProtocolFailureResponse( |
| 1105 | c *gin.Context, |
no test coverage detected