fusen/fusenapi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
laodaming 2023-09-12 10:52:47 +08:00
parent f9a53b9e36
commit a63a473641
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/websocket/internal/logic/ws_render_image.go
View File

@ -57,7 +57,7 @@ type renderTask struct {
// 处理分发到这里的数据 // 处理分发到这里的数据
func (r *renderProcessor) allocationMessage(w *wsConnectItem, data []byte) { func (r *renderProcessor) allocationMessage(w *wsConnectItem, data []byte) {
logx.Info("收到渲染任务消息:", string(data)) //logx.Info("收到渲染任务消息:", string(data))
select { select {
case <-w.closeChan: //已经关闭 case <-w.closeChan: //已经关闭
return return
@ -88,7 +88,7 @@ func (w *wsConnectItem) consumeRenderImageData() {
// 执行渲染任务 // 执行渲染任务
func (w *wsConnectItem) renderImage(data []byte) { func (w *wsConnectItem) renderImage(data []byte) {
logx.Info("消费渲染数据:", string(data)) //logx.Info("消费渲染数据:", string(data))
var renderImageData websocket_data.RenderImageReqMsg var renderImageData websocket_data.RenderImageReqMsg
if err := json.Unmarshal(data, &renderImageData); err != nil { if err := json.Unmarshal(data, &renderImageData); err != nil {
w.incomeDataFormatErrResponse("invalid format of render data:" + string(data)) w.incomeDataFormatErrResponse("invalid format of render data:" + string(data))