louis/oktopus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(controller): increase api timeout (1)

Browse Source
This commit is contained in:
Leandro Antônio Farias Machado 2023-06-27 04:05:01 -03:00
parent 29b308987c
commit ef2c20848a
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
backend/services/controller/internal/api/api.go
View File

@ -181,7 +181,7 @@ func (a *Api) deviceFwUpdate(w http.ResponseWriter, r *http.Request) {
delete(a.MsgQueue, msg.Header.MsgId) delete(a.MsgQueue, msg.Header.MsgId)
log.Println("requests queue:", a.MsgQueue) log.Println("requests queue:", a.MsgQueue)
getMsgAnswer = msg.Body.GetResponse().GetGetResp() getMsgAnswer = msg.Body.GetResponse().GetGetResp()
case <-time.After(time.Second * 40): case <-time.After(time.Second * 55):
log.Printf("Request %s Timed Out", msg.Header.MsgId) log.Printf("Request %s Timed Out", msg.Header.MsgId)
w.WriteHeader(http.StatusGatewayTimeout) w.WriteHeader(http.StatusGatewayTimeout)
delete(a.MsgQueue, msg.Header.MsgId) delete(a.MsgQueue, msg.Header.MsgId)
@ -240,7 +240,7 @@ func (a *Api) deviceFwUpdate(w http.ResponseWriter, r *http.Request) {
log.Println("requests queue:", a.MsgQueue) log.Println("requests queue:", a.MsgQueue)
json.NewEncoder(w).Encode(msg.Body.GetResponse().GetSetResp()) json.NewEncoder(w).Encode(msg.Body.GetResponse().GetSetResp())
return return
case <-time.After(time.Second * 28): case <-time.After(time.Second * 55):
log.Printf("Request %s Timed Out", msg.Header.MsgId) log.Printf("Request %s Timed Out", msg.Header.MsgId)
w.WriteHeader(http.StatusGatewayTimeout) w.WriteHeader(http.StatusGatewayTimeout)
delete(a.MsgQueue, msg.Header.MsgId) delete(a.MsgQueue, msg.Header.MsgId)
@ -290,7 +290,7 @@ func (a *Api) deviceGetParameterInstances(w http.ResponseWriter, r *http.Request
log.Println("requests queue:", a.MsgQueue) log.Println("requests queue:", a.MsgQueue)
json.NewEncoder(w).Encode(msg.Body.GetResponse().GetGetInstancesResp()) json.NewEncoder(w).Encode(msg.Body.GetResponse().GetGetInstancesResp())
return return
case <-time.After(time.Second * 28): case <-time.After(time.Second * 55):
log.Printf("Request %s Timed Out", msg.Header.MsgId) log.Printf("Request %s Timed Out", msg.Header.MsgId)
w.WriteHeader(http.StatusGatewayTimeout) w.WriteHeader(http.StatusGatewayTimeout)
delete(a.MsgQueue, msg.Header.MsgId) delete(a.MsgQueue, msg.Header.MsgId)
@ -340,7 +340,7 @@ func (a *Api) deviceGetSupportedParametersMsg(w http.ResponseWriter, r *http.Req
log.Println("requests queue:", a.MsgQueue) log.Println("requests queue:", a.MsgQueue)
json.NewEncoder(w).Encode(msg.Body.GetResponse().GetGetSupportedDmResp()) json.NewEncoder(w).Encode(msg.Body.GetResponse().GetGetSupportedDmResp())
return return
case <-time.After(time.Second * 28): case <-time.After(time.Second * 55):
log.Printf("Request %s Timed Out", msg.Header.MsgId) log.Printf("Request %s Timed Out", msg.Header.MsgId)
w.WriteHeader(http.StatusGatewayTimeout) w.WriteHeader(http.StatusGatewayTimeout)
delete(a.MsgQueue, msg.Header.MsgId) delete(a.MsgQueue, msg.Header.MsgId)
@ -390,7 +390,7 @@ func (a *Api) deviceCreateMsg(w http.ResponseWriter, r *http.Request) {
log.Println("requests queue:", a.MsgQueue) log.Println("requests queue:", a.MsgQueue)
json.NewEncoder(w).Encode(msg.Body.GetResponse().GetAddResp()) json.NewEncoder(w).Encode(msg.Body.GetResponse().GetAddResp())
return return
case <-time.After(time.Second * 28): case <-time.After(time.Second * 55):
log.Printf("Request %s Timed Out", msg.Header.MsgId) log.Printf("Request %s Timed Out", msg.Header.MsgId)
w.WriteHeader(http.StatusGatewayTimeout) w.WriteHeader(http.StatusGatewayTimeout)
delete(a.MsgQueue, msg.Header.MsgId) delete(a.MsgQueue, msg.Header.MsgId)
@ -441,7 +441,7 @@ func (a *Api) deviceGetMsg(w http.ResponseWriter, r *http.Request) {
log.Println("requests queue:", a.MsgQueue) log.Println("requests queue:", a.MsgQueue)
json.NewEncoder(w).Encode(msg.Body.GetResponse().GetGetResp()) json.NewEncoder(w).Encode(msg.Body.GetResponse().GetGetResp())
return return
case <-time.After(time.Second * 40): case <-time.After(time.Second * 55):
log.Printf("Request %s Timed Out", msg.Header.MsgId) log.Printf("Request %s Timed Out", msg.Header.MsgId)
w.WriteHeader(http.StatusGatewayTimeout) w.WriteHeader(http.StatusGatewayTimeout)
delete(a.MsgQueue, msg.Header.MsgId) delete(a.MsgQueue, msg.Header.MsgId)
@ -491,7 +491,7 @@ func (a *Api) deviceDeleteMsg(w http.ResponseWriter, r *http.Request) {
log.Println("requests queue:", a.MsgQueue) log.Println("requests queue:", a.MsgQueue)
json.NewEncoder(w).Encode(msg.Body.GetResponse().GetDeleteResp()) json.NewEncoder(w).Encode(msg.Body.GetResponse().GetDeleteResp())
return return
case <-time.After(time.Second * 28): case <-time.After(time.Second * 55):
log.Printf("Request %s Timed Out", msg.Header.MsgId) log.Printf("Request %s Timed Out", msg.Header.MsgId)
w.WriteHeader(http.StatusGatewayTimeout) w.WriteHeader(http.StatusGatewayTimeout)
delete(a.MsgQueue, msg.Header.MsgId) delete(a.MsgQueue, msg.Header.MsgId)
@ -541,7 +541,7 @@ func (a *Api) deviceUpdateMsg(w http.ResponseWriter, r *http.Request) {
log.Println("requests queue:", a.MsgQueue) log.Println("requests queue:", a.MsgQueue)
json.NewEncoder(w).Encode(msg.Body.GetResponse().GetSetResp()) json.NewEncoder(w).Encode(msg.Body.GetResponse().GetSetResp())
return return
case <-time.After(time.Second * 28): case <-time.After(time.Second * 55):
log.Printf("Request %s Timed Out", msg.Header.MsgId) log.Printf("Request %s Timed Out", msg.Header.MsgId)
w.WriteHeader(http.StatusGatewayTimeout) w.WriteHeader(http.StatusGatewayTimeout)
delete(a.MsgQueue, msg.Header.MsgId) delete(a.MsgQueue, msg.Header.MsgId)