CL-Softwares
/
modelRT
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: CL-Softwares:feature/bay-realtime-data-calc
Branches Tags
CL-Softwares:develop
CL-Softwares:feature/bay-realtime-data-calc
CL-Softwares:feature-jointDebuggingDemo
CL-Softwares:feature-attrsKey
CL-Softwares:feature-cgo
CL-Softwares:feature-demo
CL-Softwares:feature-panelDataCommunication
CL-Softwares:feature-circuitUpdate
CL-Softwares:feature-realTimeData
CL-Softwares:feature-loadCircuitDiagram
..
compare: CL-Softwares:develop
Branches Tags
CL-Softwares:feature/bay-realtime-data-calc
CL-Softwares:develop
CL-Softwares:feature-jointDebuggingDemo
CL-Softwares:feature-attrsKey
CL-Softwares:feature-cgo
CL-Softwares:feature-demo
CL-Softwares:feature-panelDataCommunication
CL-Softwares:feature-circuitUpdate
CL-Softwares:feature-realTimeData
CL-Softwares:feature-loadCircuitDiagram

No commits in common. "feature/bay-realtime-data-calc" and "develop" have entirely different histories.
feature/ba ... develop

1 changed files with 0 additions and 9 deletions
Show Stats Expand all files Collapse all files

9
handler/real_time_data_pull.go
View File

@ -60,15 +60,6 @@ func PullRealTimeDataHandler(c *gin.Context) {
ctx, cancel := context.WithCancel(c.Request.Context()) ctx, cancel := context.WithCancel(c.Request.Context())
defer cancel() defer cancel()
conn.SetCloseHandler(func(code int, text string) error {
logger.Info(c.Request.Context(), "websocket processor shutdown trigger",
"clientID", clientID, "code", code, "reason", text)
// call cancel to notify other goroutines to stop working
cancel()
return nil
})
// TODO[BACKPRESSURE-ISSUE] 先期使用固定大容量对扇入模型进行定义 #1 // TODO[BACKPRESSURE-ISSUE] 先期使用固定大容量对扇入模型进行定义 #1
fanInChan := make(chan network.RealTimePullTarget, constants.FanInChanMaxSize) fanInChan := make(chan network.RealTimePullTarget, constants.FanInChanMaxSize)
sendChan := make(chan []network.RealTimePullTarget, constants.SendChanBufferSize) sendChan := make(chan []network.RealTimePullTarget, constants.SendChanBufferSize)