You can not select more than 25 topics
			Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
		
		
		
		
		
			
		
			
				
					
					
						
							113 lines
						
					
					
						
							4.9 KiB
						
					
					
				
			
		
		
	
	
							113 lines
						
					
					
						
							4.9 KiB
						
					
					
				| from cereal import log
 | |
| from common.conversions import Conversions as CV
 | |
| from common.realtime import DT_MDL
 | |
| 
 | |
| LaneChangeState = log.LateralPlan.LaneChangeState
 | |
| LaneChangeDirection = log.LateralPlan.LaneChangeDirection
 | |
| 
 | |
| LANE_CHANGE_SPEED_MIN = 20 * CV.MPH_TO_MS
 | |
| LANE_CHANGE_TIME_MAX = 10.
 | |
| 
 | |
| DESIRES = {
 | |
|   LaneChangeDirection.none: {
 | |
|     LaneChangeState.off: log.LateralPlan.Desire.none,
 | |
|     LaneChangeState.preLaneChange: log.LateralPlan.Desire.none,
 | |
|     LaneChangeState.laneChangeStarting: log.LateralPlan.Desire.none,
 | |
|     LaneChangeState.laneChangeFinishing: log.LateralPlan.Desire.none,
 | |
|   },
 | |
|   LaneChangeDirection.left: {
 | |
|     LaneChangeState.off: log.LateralPlan.Desire.none,
 | |
|     LaneChangeState.preLaneChange: log.LateralPlan.Desire.none,
 | |
|     LaneChangeState.laneChangeStarting: log.LateralPlan.Desire.laneChangeLeft,
 | |
|     LaneChangeState.laneChangeFinishing: log.LateralPlan.Desire.laneChangeLeft,
 | |
|   },
 | |
|   LaneChangeDirection.right: {
 | |
|     LaneChangeState.off: log.LateralPlan.Desire.none,
 | |
|     LaneChangeState.preLaneChange: log.LateralPlan.Desire.none,
 | |
|     LaneChangeState.laneChangeStarting: log.LateralPlan.Desire.laneChangeRight,
 | |
|     LaneChangeState.laneChangeFinishing: log.LateralPlan.Desire.laneChangeRight,
 | |
|   },
 | |
| }
 | |
| 
 | |
| 
 | |
| class DesireHelper:
 | |
|   def __init__(self):
 | |
|     self.lane_change_state = LaneChangeState.off
 | |
|     self.lane_change_direction = LaneChangeDirection.none
 | |
|     self.lane_change_timer = 0.0
 | |
|     self.lane_change_ll_prob = 1.0
 | |
|     self.keep_pulse_timer = 0.0
 | |
|     self.prev_one_blinker = False
 | |
|     self.desire = log.LateralPlan.Desire.none
 | |
| 
 | |
|   def update(self, carstate, lateral_active, lane_change_prob):
 | |
|     v_ego = carstate.vEgo
 | |
|     one_blinker = carstate.leftBlinker != carstate.rightBlinker
 | |
|     below_lane_change_speed = v_ego < LANE_CHANGE_SPEED_MIN
 | |
| 
 | |
|     if not lateral_active or self.lane_change_timer > LANE_CHANGE_TIME_MAX:
 | |
|       self.lane_change_state = LaneChangeState.off
 | |
|       self.lane_change_direction = LaneChangeDirection.none
 | |
|     else:
 | |
|       # LaneChangeState.off
 | |
|       if self.lane_change_state == LaneChangeState.off and one_blinker and not self.prev_one_blinker and not below_lane_change_speed:
 | |
|         self.lane_change_state = LaneChangeState.preLaneChange
 | |
|         self.lane_change_ll_prob = 1.0
 | |
| 
 | |
|       # LaneChangeState.preLaneChange
 | |
|       elif self.lane_change_state == LaneChangeState.preLaneChange:
 | |
|         # Set lane change direction
 | |
|         self.lane_change_direction = LaneChangeDirection.left if \
 | |
|           carstate.leftBlinker else LaneChangeDirection.right
 | |
| 
 | |
|         torque_applied = carstate.steeringPressed and \
 | |
|                          ((carstate.steeringTorque > 0 and self.lane_change_direction == LaneChangeDirection.left) or
 | |
|                           (carstate.steeringTorque < 0 and self.lane_change_direction == LaneChangeDirection.right))
 | |
| 
 | |
|         blindspot_detected = ((carstate.leftBlindspot and self.lane_change_direction == LaneChangeDirection.left) or
 | |
|                               (carstate.rightBlindspot and self.lane_change_direction == LaneChangeDirection.right))
 | |
| 
 | |
|         if not one_blinker or below_lane_change_speed:
 | |
|           self.lane_change_state = LaneChangeState.off
 | |
|         elif torque_applied and not blindspot_detected:
 | |
|           self.lane_change_state = LaneChangeState.laneChangeStarting
 | |
| 
 | |
|       # LaneChangeState.laneChangeStarting
 | |
|       elif self.lane_change_state == LaneChangeState.laneChangeStarting:
 | |
|         # fade out over .5s
 | |
|         self.lane_change_ll_prob = max(self.lane_change_ll_prob - 2 * DT_MDL, 0.0)
 | |
| 
 | |
|         # 98% certainty
 | |
|         if lane_change_prob < 0.02 and self.lane_change_ll_prob < 0.01:
 | |
|           self.lane_change_state = LaneChangeState.laneChangeFinishing
 | |
| 
 | |
|       # LaneChangeState.laneChangeFinishing
 | |
|       elif self.lane_change_state == LaneChangeState.laneChangeFinishing:
 | |
|         # fade in laneline over 1s
 | |
|         self.lane_change_ll_prob = min(self.lane_change_ll_prob + DT_MDL, 1.0)
 | |
| 
 | |
|         if self.lane_change_ll_prob > 0.99:
 | |
|           self.lane_change_direction = LaneChangeDirection.none
 | |
|           if one_blinker:
 | |
|             self.lane_change_state = LaneChangeState.preLaneChange
 | |
|           else:
 | |
|             self.lane_change_state = LaneChangeState.off
 | |
| 
 | |
|     if self.lane_change_state in (LaneChangeState.off, LaneChangeState.preLaneChange):
 | |
|       self.lane_change_timer = 0.0
 | |
|     else:
 | |
|       self.lane_change_timer += DT_MDL
 | |
| 
 | |
|     self.prev_one_blinker = one_blinker
 | |
| 
 | |
|     self.desire = DESIRES[self.lane_change_direction][self.lane_change_state]
 | |
| 
 | |
|     # Send keep pulse once per second during LaneChangeStart.preLaneChange
 | |
|     if self.lane_change_state in (LaneChangeState.off, LaneChangeState.laneChangeStarting):
 | |
|       self.keep_pulse_timer = 0.0
 | |
|     elif self.lane_change_state == LaneChangeState.preLaneChange:
 | |
|       self.keep_pulse_timer += DT_MDL
 | |
|       if self.keep_pulse_timer > 1.0:
 | |
|         self.keep_pulse_timer = 0.0
 | |
|       elif self.desire in (log.LateralPlan.Desire.keepLeft, log.LateralPlan.Desire.keepRight):
 | |
|         self.desire = log.LateralPlan.Desire.none
 | |
| 
 |