(request ziface.IRequest, workerID int)
| 381 | } |
| 382 | |
| 383 | func (mh *MsgHandle) doMsgHandlerSlices(request ziface.IRequest, workerID int) { |
| 384 | defer func() { |
| 385 | if err := recover(); err != nil { |
| 386 | zlog.Ins().ErrorF("workerID: %d doMsgHandler panic: %v", workerID, err) |
| 387 | } |
| 388 | }() |
| 389 | |
| 390 | msgId := request.GetMsgID() |
| 391 | handlers, ok := mh.RouterSlices.GetHandlers(msgId) |
| 392 | if !ok { |
| 393 | zlog.Ins().ErrorF("api msgID = %d is not FOUND!", request.GetMsgID()) |
| 394 | return |
| 395 | } |
| 396 | |
| 397 | request.BindRouterSlices(handlers) |
| 398 | request.RouterSlicesNext() |
| 399 | // 执行完成后回收 Request 对象回对象池 |
| 400 | PutRequest(request) |
| 401 | } |
| 402 | |
| 403 | func (mh *MsgHandle) StopOneWorker(workerID int) { |
| 404 | zlog.Ins().DebugF("stop Worker ID = %d ", workerID) |
no test coverage detected