yangyakun921/MoGoEagleEye
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[6.5.0] fix bug of road count and add trace

Browse Source
This commit is contained in:
EmArrow
2024-07-22 13:56:44 +08:00
parent 81185b9ee9
commit 21457b52df
2 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
core/function-impl/mogo-core-function-datacenter/src/main/java/com/mogo/eagle/core/function/datacenter/v2x/RoadLineEventManager.kt
View File

@@ -21,7 +21,8 @@ class RoadLineEventManager : IMoGoMapRoadListener, IMoGoAutopilotStatusListener
} }
} }
private var record = false @Volatile
private var record = false
fun init() { fun init() {
CallerMapRoadListenerManager.addListener(TAG, this) CallerMapRoadListenerManager.addListener(TAG, this)

12
core/mogo-core-function-call/src/main/java/com/mogo/eagle/core/function/call/autopilot/CallerAutoPilotStatusListenerManager.kt
View File

@@ -26,6 +26,8 @@ import kotlin.properties.Delegates
*/ */
object CallerAutoPilotStatusListenerManager : CallerBase<IMoGoAutopilotStatusListener>() { object CallerAutoPilotStatusListenerManager : CallerBase<IMoGoAutopilotStatusListener>() {
private var atomicCountRoad = AtomicInteger(0)
// 存储最后一次回调的数据，当有新当位置注册了监听将此数据回调过去，防止有些模块注册顺序问题导致无法获取最新状态 // 存储最后一次回调的数据，当有新当位置注册了监听将此数据回调过去，防止有些模块注册顺序问题导致无法获取最新状态
@Volatile @Volatile
private var mAutopilotStatusInfo: AutopilotStatusInfo = AutopilotStatusInfo() private var mAutopilotStatusInfo: AutopilotStatusInfo = AutopilotStatusInfo()
@@ -36,6 +38,7 @@ object CallerAutoPilotStatusListenerManager : CallerBase<IMoGoAutopilotStatusLis
} }
if(newValue == 0L){ if(newValue == 0L){
mAutopilotStatusInfo.isArriveAtStation = false mAutopilotStatusInfo.isArriveAtStation = false
atomicCountRoad.set(0)
} }
M_LISTENERS.forEach { M_LISTENERS.forEach {
val listener = it.value val listener = it.value
@@ -70,8 +73,6 @@ object CallerAutoPilotStatusListenerManager : CallerBase<IMoGoAutopilotStatusLis
private var status: AdasConstants.IpcConnectionStatus? = null private var status: AdasConstants.IpcConnectionStatus? = null
private var atomicCountRoad = AtomicInteger(0)
override fun doSomeAfterAddListener(tag: String, listener: IMoGoAutopilotStatusListener) { override fun doSomeAfterAddListener(tag: String, listener: IMoGoAutopilotStatusListener) {
listener.onAutopilotStatusResponse(autopilotState) listener.onAutopilotStatusResponse(autopilotState)
if(dockerV.isNotEmpty()){ if(dockerV.isNotEmpty()){
@@ -294,11 +295,14 @@ object CallerAutoPilotStatusListenerManager : CallerBase<IMoGoAutopilotStatusLis
} }
fun updateRoadCount(){ fun updateRoadCount(){
atomicCountRoad.addAndGet(1) val roadCount = atomicCountRoad.addAndGet(1)
CallerTrace.write("updateRoadCount", mapOf("roadCount" to roadCount))
} }
fun getRoadCount(): Int { fun getRoadCount(): Int {
return atomicCountRoad.get() val count = atomicCountRoad.get()
CallerTrace.write("getRoadCount", mapOf("roadCount" to count))
return count
} }
} }