mirror
/
stratux
kopia lustrzana https://github.com/cyoung/stratux
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

Merge pull request #566 from AvSquirrel/uat-traffic-improvements 

UAT traffic decoding improvements
pull/40/merge
cyoung 2017-03-03 09:56:58 -05:00 zatwierdzone przez GitHub
rodzic acbe7742b2 71a9c06a29
commit 7631543b1a
3 zmienionych plików z 110 dodań i 34 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

6
main/gen_gdl90.go
Wyświetl plik

@ -1092,7 +1092,7 @@ type status struct {
UAT_NOTAM_total uint32
UAT_OTHER_total uint32
Errors []string
Logfile_Size int64
Logfile_Size int64
}
var globalSettings settings
@ -1317,7 +1317,7 @@ func signalWatcher() {
func clearDebugLogFile() {
if logFileHandle != nil {
_, err := logFileHandle.Seek(0,0)
_, err := logFileHandle.Seek(0, 0)
if err != nil {
log.Printf("Could not seek to the beginning of the logfile\n")
return
@ -1421,7 +1421,7 @@ func main() {
// Override after reading in the settings.
if *replayFlag == true {
log.Printf("Replay file %s\n", *replayUATFilename)
globalSettings.ReplayLog = true
globalSettings.ReplayLog = false
}
if globalSettings.DeveloperMode == true {

138
main/traffic.go
Wyświetl plik

@ -97,6 +97,7 @@ type TrafficInfo struct {
Speed_valid bool // set when speed report received.
Vvel int16 // feet per minute
Timestamp time.Time // timestamp of traffic message, UTC
PriorityStatus uint8 // Emergency or priority code as defined in GDL90 spec, DO-260B (Type 28 msg) and DO-282B
// Parameters starting at 'Age' are calculated from last message receipt on each call of sendTrafficUpdates().
// Mode S transmits position and track in separate messages, and altitude can also be
@ -348,9 +349,17 @@ func makeTrafficReportMsg(ti TrafficInfo) []byte {
msg[19+i] = c
}
//msg[27] is priority / emergency status per GDL90 spec (DO260B and DO282B are same codes)
msg[27] = ti.PriorityStatus << 4
return prepareMessage(msg)
}
// parseDownlinkReport decodes a UAT downlink message to extract identity, state vector, and mode status data.
// Decoded data is used to update a TrafficInfo object, keyed to the 24-bit ICAO code contained in the
// downlink message.
// Inputs are a checksum-verified hex string corresponding to the 18 or 34-byte UAT
// message, and an int representing UAT signal amplitude (0-1000).
func parseDownlinkReport(s string, signalLevel int) {
var ti TrafficInfo
@ -385,42 +394,111 @@ func parseDownlinkReport(s string, signalLevel int) {
ti.Addr_type = addr_type
// Parse tail number, if available.
if msg_type == 1 || msg_type == 3 { // Need "MS" portion of message.
base40_alphabet := string("0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ ..")
tail := ""
var uat_version byte // sent as part of MS element, byte 24
v := (uint16(frame[17]) << 8) | uint16(frame[18])
tail += string(base40_alphabet[(v/40)%40])
tail += string(base40_alphabet[v%40])
v = (uint16(frame[19]) << 8) | uint16(frame[20])
tail += string(base40_alphabet[(v/1600)%40])
tail += string(base40_alphabet[(v/40)%40])
tail += string(base40_alphabet[v%40])
v = (uint16(frame[21]) << 8) | uint16(frame[22])
tail += string(base40_alphabet[(v/1600)%40])
tail += string(base40_alphabet[(v/40)%40])
tail += string(base40_alphabet[v%40])
tail = strings.Trim(tail, " ")
ti.Tail = tail
}
// Extract emitter category.
// Extract parameters from Mode Status elements, if available.
if msg_type == 1 || msg_type == 3 {
// Determine UAT message version. This is needed for some capability decoding and is useful for debugging.
uat_version = (frame[23] >> 2) & 0x07
// Extract emitter category.
v := (uint16(frame[17]) << 8) | (uint16(frame[18]))
ti.Emitter_category = uint8((v / 1600) % 40)
}
// OK.
// fmt.Printf("%d, %d, %06X\n", msg_type, ti.Addr_type, ti.Icao_addr)
// Decode callsign or Flight Plan ID (i.e. squawk code)
// If the CSID bit (byte 27, bit 7) is set to 1, all eight characters
// encoded in bytes 18-23 represent callsign.
// If the CSID bit is set to 0, the first four characters encoded in bytes 18-23
// represent the Mode A squawk code.
csid := (frame[26] >> 1) & 0x01
if csid == 1 { // decode as callsign
base40_alphabet := string("0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ ..")
tail := ""
v := (uint16(frame[17]) << 8) | uint16(frame[18])
tail += string(base40_alphabet[(v/40)%40])
tail += string(base40_alphabet[v%40])
v = (uint16(frame[19]) << 8) | uint16(frame[20])
tail += string(base40_alphabet[(v/1600)%40])
tail += string(base40_alphabet[(v/40)%40])
tail += string(base40_alphabet[v%40])
v = (uint16(frame[21]) << 8) | uint16(frame[22])
tail += string(base40_alphabet[(v/1600)%40])
tail += string(base40_alphabet[(v/40)%40])
tail += string(base40_alphabet[v%40])
tail = strings.Trim(tail, " ")
ti.Tail = tail
} else if uat_version >= 2 { // decode as Mode 3/A code, if UAT version is at least 2
v := (uint16(frame[17]) << 8) | uint16(frame[18])
squawk_a := (v / 40) % 40
squawk_b := v % 40
v = (uint16(frame[19]) << 8) | uint16(frame[20])
squawk_c := (v / 1600) % 40
squawk_d := (v / 40) % 40
squawk := 1000*squawk_a + 100*squawk_b + 10*squawk_c + squawk_d
ti.Squawk = int(squawk)
}
ti.NACp = int((frame[25] >> 4) & 0x0F)
ti.PriorityStatus = (frame[23] >> 5) & 0x07
// Following section is future-use for debugging and / or additional status info on UAT traffic. Message parsing needs testing.
if globalSettings.DEBUG {
//declaration for mode status flags -- parse for debug logging
var status_sil byte
//var status_transmit_mso byte
var status_sda byte
var status_nacv byte
//var status_nicbaro byte
//var status_sil_supp byte
//var status_geom_vert_acc byte
//var status_sa_flag byte
var capability_uat_in bool
var capability_1090_in bool
//var capability_tcas bool
//var capability_cdti bool
//var opmode_tcas_active bool
//var opmode_ident_active bool
//var opmode_rec_atc_serv bool
// these are present in v1 and v2 messages
status_sil = frame[23] & 0x03
//status_transmit_mso = frame[24] >> 2
status_nacv = (frame[25] >> 1) & 0x07
//status_nicbaro = frame[25] & 0x01
// other status and capability bits are different between v1 and v2
if uat_version == 2 {
status_sda = frame[24] & 0x03
capability_uat_in = (frame[26] >> 7) != 0
capability_1090_in = ((frame[26] >> 6) & 0x01) != 0
//capability_tcas = ((frame[26] >> 5) & 0x01) != 0
//opmode_tcas_active = ((frame[26] >> 4) & 0x01) != 0
//opmode_ident_active = ((frame[26] >> 3) & 0x01) != 0
//opmode_rec_atc_serv = ((frame[26] >> 2) & 0x01) != 0
//status_sil_supp = frame[26] & 0x01
//status_geom_vert_acc = (frame[27] >> 6) & 0x03
//status_sa_flag = (frame[27] >> 5) & 0x01
} else if uat_version == 1 {
//capability_cdti = (frame[26] >> 7) != 0
//capability_tcas = ((frame[26] >> 6) & 0x01) != 0
//opmode_tcas_active = ((frame[26] >> 5) & 0x01) != 0
//opmode_ident_active = ((frame[26] >> 4) & 0x01) != 0
//opmode_rec_atc_serv = ((frame[26] >> 3) & 0x01) != 0
}
log.Printf("Supplemental UAT Mode Status for %06X: Version = %d; SIL = %d; SDA = %d; NACv = %d; 978 In = %v; 1090 In = %v\n", icao_addr, uat_version, status_sil, status_sda, status_nacv, capability_uat_in, capability_1090_in)
}
}
ti.NIC = int(frame[11] & 0x0F)
if (msg_type == 1) || (msg_type == 3) { // Since NACp is passed with normal UATreports, no need to use our ES hack.
ti.NACp = int((frame[25] >> 4) & 0x0F)
}
var power float64
if signalLevel > 0 {
power = 20 * (math.Log10(float64(signalLevel) / 1000)) // reported amplitude is 0-1000. Normalize to max = 1 and do amplitude dB calculation (20 dB per decade)
@ -549,7 +627,7 @@ func parseDownlinkReport(s string, signalLevel int) {
}
}
if ns_vel_valid && ew_vel_valid {
if ns_vel != 0 && ew_vel != 0 {
if ns_vel != 0 || ew_vel != 0 {
//TODO: Track type
track = uint16((360 + 90 - (int16(math.Atan2(float64(ns_vel), float64(ew_vel)) * 180 / math.Pi))) % 360)
}
@ -590,7 +668,6 @@ func parseDownlinkReport(s string, signalLevel int) {
ti.Last_speed = stratuxClock.Time
}
//OK.
// fmt.Printf("ns_vel %d, ew_vel %d, track %d, speed_valid %t, speed %d, vvel_geo %t, vvel %d\n", ns_vel, ew_vel, track, speed_valid, speed, vvel_geo, vvel)
/*
@ -604,7 +681,6 @@ func parseDownlinkReport(s string, signalLevel int) {
}
*/
//OK.
// fmt.Printf("tisb_site_id %d, utc_coupled %t\n", tisb_site_id, utc_coupled)
ti.Timestamp = time.Now()

BIN
notes/ADS-B_UATv2_data_formats_2017-01-27.xlsx 100644
Wyświetl plik

Plik binarny nie jest wyświetlany.