Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions backend/cmd/config.toml
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@

# Vehicle Configuration
[vehicle]
boards = ["BCU", "BMSL", "HVSCU", "HVSCU-Cabinet", "LCU", "PCU", "VCU", "BLCU"]
boards = ["HVBMS","LCU", "PCU", "VCU", "BLCU"]

# ADJ (Architecture Description JSON) Configuration
[adj]
Expand All @@ -28,7 +28,7 @@ backoff_min_ms = 100 # Minimum backoff duration in milliseconds
backoff_max_ms = 5000 # Maximum backoff duration in milliseconds
backoff_multiplier = 1.5 # Exponential backoff multiplier (e.g., 1.5 means each retry waits 1.5x longer)
max_retries = 0 # Maximum retries before cycling (0 = infinite retries, recommended for persistent reconnection)
connection_timeout_ms = 1000 # Connection timeout in milliseconds
connection_timeout_ms = 3000 # Connection timeout in milliseconds
keep_alive_ms = 1000 # Keep-alive interval in milliseconds

# UDP Configuration
Expand Down
12 changes: 11 additions & 1 deletion backend/cmd/setup_transport.go
Original file line number Diff line number Diff line change
Expand Up @@ -140,6 +140,16 @@ func configureUDPServerTransport(

) {
trace.Info().Msg("Starting UDP server")

onKeepAliveTimeout := func(ip string) {
transp.SendFault()
board, ok := transp.TargetFromIp(ip)
if !ok {
board = "unknown"
}
transp.ReportError(fmt.Errorf("UDP keep-alive timeout: no packets received from board %s (%s) for %dms, fault sent", board, ip, config.UDP.KeepAliveTimeoutMs))
}

udpServer := udp.NewServer(
adj.Info.Addresses[BACKEND],
adj.Info.Ports[UDP],
Expand All @@ -148,7 +158,7 @@ func configureUDPServerTransport(
config.UDP.PacketChanSize,
time.Duration(config.UDP.KeepAliveCheckIntervalMs)*time.Millisecond,
time.Duration(config.UDP.KeepAliveTimeoutMs)*time.Millisecond,
transp.SendFault,
onKeepAliveTimeout,
)
err := udpServer.Start()
if err != nil {
Expand Down
291 changes: 0 additions & 291 deletions backend/pkg/transport/network/tcp/reconnection_test.go

This file was deleted.

Loading
Loading