| src/main/java/com/zy/core/thread/impl/v5/StationV5StatusReader.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
src/main/java/com/zy/core/thread/impl/v5/StationV5StatusReader.java
@@ -94,6 +94,7 @@ stationProtocol.setWeight(statusEntity.getWeight()); stationProtocol.setTaskWriteIdx(statusEntity.getTaskWriteIdx()); stationProtocol.setTaskBufferItems(statusEntity.getTaskBufferItems()); stationProtocol.setIoMode(statusEntity.getIoMode()); recentArrivalTracker.observe(statusEntity.getStationId(), statusEntity.getTaskNo(), statusEntity.isLoading()); }