Index: doc/html/.buildinfo =================================================================== --- doc/html/.buildinfo (revision 184608777df5dc9cf0895d39bc592a07dbc23746) +++ doc/html/.buildinfo (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -1,4 +1,4 @@ # Sphinx build info version 1 # This file hashes the configuration used when building these files. When it is not found, a full rebuild will be done. -config: b8c0c727f124f1ffa85da00ef3757336 +config: 9183d4fef97c4097ad1bd368cc52b887 tags: 645f666f9bcd5a90fca523b33c5a78b7 Index: doc/html/PDW.html =================================================================== --- doc/html/PDW.html (revision 184608777df5dc9cf0895d39bc592a07dbc23746) +++ doc/html/PDW.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -1,23 +1,22 @@ - + - + - - - PDW module — RadarDex 0.314 documentation - - - - - - - + + + + PDW module — AmmosReader 0.314 documentation + + + + + + - + @@ -29,83 +28,81 @@

+ +

PDW module¶

-class PDW.PDW(time_of_arrival, pdw_format_identifier, center_frequency, is_valid, is_pulse, level_unit, signal_start_missing, signal_end_missing, pulse_width, frequency_shift_or_bandwidth, pulse_level_or_pulse_field_strength, region_of_interest, azimuth_confidence, modulation, sector, polarity, df_quality, elevation, azimuth, channel)[source]¶

Parameters:	- time_of_arrival (Integer) – nanoseconds since 1970-01-01 00:00:00 - pdw_format (Integer) – format code - center_frequency (Integer) – center frequency in KHz - is_valid (Boolean) – flag to mark if pdw data body is valid - is_pulse (Boolean) – flag to mark if pdw data body contains a pulse or a continuous wave signal - level_unit (Integer) – 0 means dBµV - 1 means dBµV/m - signal_start_missing (Boolean) – signal started before time of arrival - signal_end_missing (Boolean) – signal stops after time of arrival - pulse_width (Integer) – pulse width in nanoseconds - Zero if no valid pulse detected - frequency_shift_or_bandwidth (Integer) – Value in KHz - Value set to 1048575 means Unknown - pulse_level_or_pulse_field_strength (Float) – Pulse level or Pulse Field Strength depending on level_unit (-200.0…200.0) in 0.1 steps / minus 204.8 means no valid level detected - region_of_interest (Boolean) – Marks if signal is from region of interest - azimuth_confidence (Float) – degree in steps of 0.1 (0.0-6.2) / 6.3 means confidence unknown - modulation (String) – type of modulation (e.g. PSK-2, PSK-4, FM etc.) - sector (Integer) – reference antenna sector (0-15) - polarity (String) – Horizontal, Vertical, Clockwise, Counter clockwise - df_quality (Integer) – Direction finding quality in percent (0-100) - Zero means unknown - elevation (Float) – elevation of incoming signal (from -90 to 90 degree) in steps of 0.1 degree minus 102.4 means unknown - azimuth (Float) – azimuth of incoming signal (from 0 to 359.9 degree) in steps of 0.1 degree plus 409.5 means unknown - channel (Integer) – detecting channel (0-16) - Zero means unknown + I store information from a single ppdw data block. + + +__init__(time_of_arrival, pdw_format_identifier, center_frequency, is_valid, is_pulse, level_unit, signal_start_missing, signal_end_missing, pulse_width, frequency_shift_or_bandwidth, pulse_level_or_pulse_field_strength, region_of_interest, azimuth_confidence, modulation, sector, polarity, df_quality, elevation, azimuth, channel)[source]¶ + + Parameters + + time_of_arrival (Integer) – nanoseconds since 1970-01-01 00:00:00 + pdw_format (Integer) – format code + center_frequency (Integer) – center frequency in KHz + is_valid (Boolean) – flag to mark if pdw data body is valid + is_pulse (Boolean) – flag to mark if pdw data body contains a pulse or a continuous wave signal + level_unit (Integer) – 0 means dBµV - 1 means dBµV/m + signal_start_missing (Boolean) – signal started before time of arrival + signal_end_missing (Boolean) – signal stops after time of arrival + pulse_width (Integer) – pulse width in nanoseconds - Zero if no valid pulse detected + frequency_shift_or_bandwidth (Integer) – Value in KHz - Value set to 1048575 means Unknown + pulse_level_or_pulse_field_strength (Float) – Pulse level or Pulse Field Strength depending on level_unit (-200.0…200.0) in 0.1 steps / minus 204.8 means no valid level detected + region_of_interest (Boolean) – Marks if signal is from region of interest + azimuth_confidence (Float) – degree in steps of 0.1 (0.0-6.2) / 6.3 means confidence unknown + modulation (String) – type of modulation (e.g. PSK-2, PSK-4, FM etc.) + sector (Integer) – reference antenna sector (0-15) + polarity (String) – Horizontal, Vertical, Clockwise, Counter clockwise + df_quality (Integer) – Direction finding quality in percent (0-100) - Zero means unknown + elevation (Float) – elevation of incoming signal (from -90 to 90 degree) in steps of 0.1 degree minus 102.4 means unknown + azimuth (Float) – azimuth of incoming signal (from 0 to 359.9 degree) in steps of 0.1 degree plus 409.5 means unknown + channel (Integer) – detecting channel (0-16) - Zero means unknown -
Returns:	An instance of class PDW with attributes set according to the data of a data body -
Return type:	PDW -

Parameters:	byte_string (byte string) – a byte string containing a single data body read from a ppdw file
Returns:	an instance of class PDW with attributes set according to the data of a data body
Return type:	PDW

@@ -146,9 +148,9 @@

- ©2020, Enrico Schwass. + ©2022, Enrico Schwass. | - Powered by Sphinx 1.8.5 - & Alabaster 0.7.8 + Powered by Sphinx 4.2.0 + & Alabaster 0.7.12 | Index: c/html/_modules/PDW.html =================================================================== --- doc/html/_modules/PDW.html (revision 184608777df5dc9cf0895d39bc592a07dbc23746) +++ (revision ) @@ -1,322 +1,0 @@ - - - - - - - - PDW — RadarDex 0.314 documentation - - - - - - - - - - - - - - - - - -

- -

Source code for PDW

-import struct
-import math
-import datetime
-
-# TODO: Use BitArray module in future versions
-
-
-[docs]class PDW():
-
-    """
-
-    I store information from a single ppdw data block
-
-    .. automethod:: __init__
-
-    """
-
-[docs]    @classmethod
-    def from_bytes(cls, byte_string):
-
-        """
-
-        I create an instance of class PDW from data body (8 * 32 bits)
-
-        :param byte_string: a byte string containing a single data body read from a ppdw file
-        :type byte_string: byte string
-
-        :return: an instance of class PDW with attributes set according to the data of a data body
-        :rtype: PDW
-
-        """
-
-        assert(len(byte_string) == 32)
-
-        parts = struct.unpack('Q4s4s4s4s4s4s', byte_string)
-        seconds = (parts[0])
-        time_of_arrival = datetime.datetime.utcfromtimestamp(seconds / 1000000000)
-
-        third_entry = bin(int.from_bytes(parts[1], byteorder='little'))
-        padding = 32-len(str(third_entry)[2:])
-        third_entry_bit_string = "0" * padding + str(third_entry)[2:]
-        pdw_format_identifier = int(third_entry_bit_string[0:6], 2)
-        center_frequency = int(third_entry_bit_string[5:32], 2)
-
-        fourth_entry = bin(int.from_bytes(parts[2], byteorder='little'))
-        padding = 32-len(str(fourth_entry)[2:])
-        fourth_entry_bit_string = "0" * padding + str(fourth_entry)[2:]
-        is_valid = bool(int(fourth_entry_bit_string[0]))
-        is_pulse = bool(int(fourth_entry_bit_string[1]))
-        level_unit = int(fourth_entry_bit_string[2])
-        signal_start_missing = bool(int(fourth_entry_bit_string[3]))
-        signal_end_missing = bool(int(fourth_entry_bit_string[4]))
-        pulse_width = int(fourth_entry_bit_string[7:33], 2)
-
-        fifth_entry = bin(int.from_bytes(parts[3], byteorder='little'))
-        padding = 32-len(str(fifth_entry)[2:])
-        fifth_entry_bit_string = "0" * padding + str(fifth_entry)[2:]
-        frequency_shift_or_bandwidth = int(fifth_entry_bit_string[0:20], 2)
-        # FIXME: You have to scale me to the range from -200.0 to 200.0 in 0.1 steps
-        pulse_level_or_pulse_field_strength = math.ceil(int(fifth_entry_bit_string[20:32], 2)) / 10
-
-        sixth_entry = bin(int.from_bytes(parts[4], byteorder='little'))
-        padding = 32-len(str(sixth_entry)[2:])
-        sixth_entry_bit_string = "0" * padding + str(sixth_entry)[2:]
-        region_of_interest = bool(int(sixth_entry_bit_string[0]))
-        # FIXME: You have to scale me to a range from 0.0 to 6.2 in steps of 0.1 - 6.3 means unknown
-        azimuth_confidence = math.ceil(int(sixth_entry_bit_string[1:7], 2)) / 10
-        modulations = {0: 'Unknown', 1: 'Unmodulated', 2: 'FM', 3: 'LFM', 4: 'PSK-2', 5: 'PSK-3', 6: 'PSK-4',
-                       7: 'PSK-m', 8: 'NLFM', 9: 'SFM', 10: 'TFM', 11: 'Pulse too short'}
-        modulation = modulations[int(sixth_entry_bit_string[7:12], 2)]
-        sector = int(sixth_entry_bit_string[28:32], 2)
-
-        seventh_entry = bin(int.from_bytes(parts[5], byteorder='little'))
-        padding = 32-len(str(seventh_entry)[2:])
-        seventh_entry_bit_string = "0" * padding + str(seventh_entry)[2:]
-        polarities = {0: 'Horizontal/Unknown', 1: 'Vertical', 2: 'Counter clockwise', 3: 'Clockwise'}
-        polarity = polarities[int(seventh_entry_bit_string[0:2], 2)]
-        df_quality = int(seventh_entry_bit_string[2:9], 2)
-        # FIXME: You have to scale me from -90 to 90 in 0.1 degree steps
-        elevation = int(seventh_entry_bit_string[9:20], 2)
-        # FIXME: You have to check me for a range from 0.0 to 359.9 in steps of 0.1
-        azimuth = 0.1 * (int(seventh_entry_bit_string[20:32], 2))
-
-        eighth_entry = bin(int.from_bytes(parts[5], byteorder='little'))
-        padding = 32-len(str(eighth_entry)[2:])
-        eighth_entry_bit_string = "0" * padding + str(eighth_entry)[2:]
-        channel = int(eighth_entry_bit_string[0:4], 2)
-
-        return PDW(time_of_arrival, pdw_format_identifier, center_frequency, is_valid, is_pulse, level_unit,
-                   signal_start_missing, signal_end_missing, pulse_width, frequency_shift_or_bandwidth,
-                   pulse_level_or_pulse_field_strength, region_of_interest, azimuth_confidence, modulation,
-                   sector, polarity, df_quality, elevation, azimuth, channel)
-
-[docs]    def __init__(self, time_of_arrival, pdw_format_identifier, center_frequency, is_valid, is_pulse,
-                 level_unit, signal_start_missing, signal_end_missing, pulse_width, frequency_shift_or_bandwidth,
-                 pulse_level_or_pulse_field_strength, region_of_interest, azimuth_confidence, modulation,
-                 sector, polarity, df_quality, elevation, azimuth, channel):
-
-        """
-
-        :param time_of_arrival: nanoseconds since 1970-01-01 00:00:00
-        :type time_of_arrival: Integer
-        :param pdw_format: format code
-        :type pdw_format: Integer
-        :param center_frequency: center frequency in KHz
-        :type center_frequency: Integer
-        :param is_valid: flag to mark if pdw data body is valid
-        :type is_valid: Boolean
-        :param is_pulse: flag to mark if pdw data body contains a pulse or a continuous wave signal
-        :type is_pulse: Boolean
-        :param level_unit: 0 means dBµV - 1 means dBµV/m
-        :type level_unit: Integer
-        :param signal_start_missing: signal started before time of arrival
-        :type signal_start_missing: Boolean
-        :param signal_end_missing: signal stops after time of arrival
-        :type signal_end_missing: Boolean
-        :param pulse_width: pulse width in nanoseconds - Zero if no valid pulse detected
-        :type pulse_width: Integer
-        :param frequency_shift_or_bandwidth: Value in KHz - Value set to 1048575 means Unknown
-        :type frequency_shift_or_bandwidth: Integer
-        :param pulse_level_or_pulse_field_strength: Pulse level or Pulse Field Strength depending on level_unit \
-         (-200.0...200.0) in 0.1 steps / minus 204.8 means no valid level detected
-        :type pulse_level_or_pulse_field_strength: Float
-        :param region_of_interest: Marks if signal is from region of interest
-        :type region_of_interest: Boolean
-        :param azimuth_confidence: degree in steps of 0.1 (0.0-6.2) / 6.3 means confidence unknown
-        :type azimuth_confidence: Float
-        :param modulation: type of modulation (e.g. PSK-2, PSK-4, FM etc.)
-        :type modulation: String
-        :param sector: reference antenna sector (0-15)
-        :type sector: Integer
-        :param polarity: Horizontal, Vertical, Clockwise, Counter clockwise
-        :type polarity: String
-        :param df_quality: Direction finding quality in percent (0-100) - Zero means unknown
-        :type df_quality: Integer
-        :param elevation: elevation of incoming signal (from -90 to 90 degree) in steps of 0.1 degree \
-        minus 102.4 means unknown
-        :type elevation: Float
-        :param azimuth: azimuth of incoming signal (from 0 to 359.9 degree) in steps of 0.1 degree \
-        plus 409.5 means unknown
-        :type azimuth: Float
-        :param channel: detecting channel (0-16) - Zero means unknown
-        :type channel: Integer
-        :return: An instance of class PDW with attributes set according to the data of a data body
-        :rtype: PDW
-
-        """
-
-        self.time_of_arrival = time_of_arrival
-        self.pdw_format_identifier = pdw_format_identifier
-        self.center_frequency = center_frequency
-        self.is_valid = is_valid
-        self.is_pulse = is_pulse
-        self.level_unit = level_unit
-        self.signal_start_missing = signal_start_missing
-        self.signal_end_missing = signal_end_missing
-        self.pulse_width = pulse_width
-        self.frequency_shift_or_bandwidth = frequency_shift_or_bandwidth
-        self.pulse_level_or_pulse_field_strength = pulse_level_or_pulse_field_strength
-        self.region_of_interest = region_of_interest
-        self.azimuth_confidence = azimuth_confidence
-        self.modulation = modulation
-        self.sector = sector
-        self.polarity = polarity
-        self.df_quality = df_quality
-        self.elevation = elevation
-        self.azimuth = azimuth
-        self.channel = channel
-
-    def __str__(self):
-        output = ("Time of arrival: " + str(self.time_of_arrival) + "\n" +
-                  "PDW Format identifier: " + str(self.pdw_format_identifier) + "\n" +
-                  "Center frequency: " + str(self.center_frequency) + " KHz\n")
-
-        if self.is_valid:
-            output += "Signal: Valid\n"
-        else:
-            output += "Signal: Invalid\n"
-
-        if self.is_pulse:
-            output += "Signal type: Pulse\n"
-        else:
-            output += "Signal type: Continuous wave\n"
-
-        if self.level_unit == 1:
-            output += "Pulse level: " + str(self.pulse_level_or_pulse_field_strength) + " dbµV\n"
-        else:
-            output += "Pulse field strength: " + str(self.pulse_level_or_pulse_field_strength) + " dbµV/meter\n"
-
-        output += ("Pulse width: " + str(self.pulse_width) + " nanoseconds\n" +
-                   "Frequency shift or bandwidth: " + str(self.frequency_shift_or_bandwidth) + " KHz\n")
-
-        if self.region_of_interest:
-            output += "Region of interest: Yes\n"
-        else:
-            output += "Region of interest: No\n"
-
-        if self.azimuth_confidence == 6.3:
-            output += "Azimuth confidence: Invalid\n"
-        else:
-            output += "Azimuth confidence: " + str(self.azimuth_confidence) + " degree\n"
-
-        output += "Modulation: " + str(self.modulation) + "\n"
-
-        if self.sector == 0:
-            output += "Sector: Unknown\n"
-        else:
-            output += "Sector:" + str(self.sector) + "\n"
-
-        output += "Polarity: " + str(self.polarity) + "\n"
-
-        output += "DF quality: " + str(self.df_quality) + " %\n"
-
-        if self.elevation == 1024:
-            output += "Elevation: Unknown\n"
-        else:
-            output += "Elevation: " + str(self.elevation) + " degree\n"
-
-        if self.azimuth == 409.5:
-            output += "Azimuth: Unknown\n"
-        else:
-            output += "Azimuth: " + str(self.azimuth) + " degree\n"
-
-        output += "Channel: " + str(self.channel) + "\n"
-
-        return output
-
-
-if __name__ == '__main__':
-    pass
-

- -

- - - - - - - Index: doc/html/_modules/ammosreader/AmmosAudioDataHeader.html =================================================================== --- doc/html/_modules/ammosreader/AmmosAudioDataHeader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/AmmosAudioDataHeader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,154 @@ + + + + + + + + ammosreader.AmmosAudioDataHeader — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.AmmosAudioDataHeader

+import struct
+import numpy
+
+[docs]class AmmosAudioDemodType():
+
+    @classmethod
+    @property
+    def mapping(cls):
+        return {0: 'FM', 1: 'AM', 5: 'ISB', 6: 'CW',
+                7: 'USB', 8: 'LSB', 256: 'DIGITAL',
+                0xFFFFFFFF: 'UNKNOWN'}
+
+    def __init__(self, demod_type):
+        self.demod_type = demod_type
+
+    def __str__(self):
+        return AmmosAudioDemodType.mapping[self.demod_type]
+
+[docs]class AmmosAudioDataHeader():
+
+[docs]    @classmethod
+    def from_bytes(cls, bytes):
+        elements = struct.unpack('<IIQIIIII', bytes)
+        sample_rate = elements[0]
+        status = elements[1]
+        frequency = elements[2]
+        demod_bandwidth = elements[3]
+        demod_type = elements[4]
+        sample_count = elements[5]
+        channel_count = elements[6]
+        sample_size = elements[7]
+        return AmmosAudioDataHeader(sample_rate, status, frequency, demod_bandwidth, demod_type,
+                                    sample_count, channel_count, sample_size)
+
+    def __init__(self, sample_rate, status, frequency, demod_bandwidth, demod_type, sample_count, channel_count, sample_size):
+        self.sample_rate = sample_rate
+        self.status = status
+        self.frequency = frequency
+        self.demod_bandwidth = demod_bandwidth
+        self.demod_type = AmmosAudioDemodType(demod_type)
+        self.sample_count = sample_count
+        self.channel_count = channel_count
+        self.sample_size = sample_size
+
+    def __str__(self):
+        return ("\nAmmosAudioDataHeader\n" +
+                "Sample rate:" + str(self.sample_rate) + "\n" +
+                "Status:" + str(self.status) + "\n" +
+                "Frequency:" + str(self.frequency) + "\n" +
+                "Demodulation bandwidth:" + str(self.demod_bandwidth) + "\n" +
+                "Demodulation type:" + str(self.demod_type) + "\n" +
+                "Sample count:" + str(self.sample_count) + "\n" +
+                "Channel count:" + str(self.channel_count) + "\n" +
+                "Sample size:" + str(self.sample_size) + "\n")
+

+ +

+ + + + + + + Index: doc/html/_modules/ammosreader/AmmosAudioReader.html =================================================================== --- doc/html/_modules/ammosreader/AmmosAudioReader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/AmmosAudioReader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,300 @@ + + + + + + + + ammosreader.AmmosAudioReader — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.AmmosAudioReader

+"""I parse an R&S AMMOS recording."""
+
+import os
+
+from .AmmosGlobalFrameBody import AmmosGlobalFrameBody
+from .AmmosAudioDataHeader import AmmosAudioDataHeader
+from .AmmosExtendedAudioDataHeader import AmmosExtendedAudioDataHeader
+from .AmmosGlobalFrameHeader import AmmosGlobalFrameHeader
+from .AmmosSingleFrame import AmmosSingleFrame
+from .AmmosContainer import AmmosContainer
+
+
+[docs]class AmmosAudioReader():
+    """I read the audio data embedded in an R&S AMMOS recording."""
+
+    GLOBAL_HEADER_SIZE = 24  # 8 words
+    STANDARD_AUDIO_DATA_HEADER_SIZE = 36  # 9 words
+    EXTENDED_AUDIO_DATA_HEADER_SIZE = 44  # 11 words
+
+    def __init__(self, file_name):
+        """
+        I return an instance of AmmosAudioReader initialized with a given file name.
+
+        :param file_name: the file to read from
+        :type file_name: str
+        """
+        self.file_name = file_name
+        self.file = open(self.file_name, "rb")
+        self.file_size = os.path.getsize(self.file_name)
+
+        self.container = AmmosContainer(self.file_name, [])
+
+        self.tags = {}
+
+[docs]    def rewind_to_start(self):
+        """I set the file pointer to the beginning of the file for the next operation."""
+        self.file.seek(0)
+
+[docs]    def add_tag(self, tag):
+        """
+        I add a tag to my tag list.
+
+        :param tag: The tag to add to my tag list
+        :type tag: dict
+        """
+        self.tags[tag.key] = tag.value
+
+[docs]    def read_all_frames_left(self):
+        """
+        I read all remaining frames into my container until end of file is reached.
+
+        :return: a container containing all frames read
+        :rtype: AmmosContainer
+        """
+        frames_read = 0
+        while True:
+            print("Reading single frame", frames_read, '...')
+            current_frame = self.read_next_single_frame()
+            if current_frame is not None:
+                frames_read += 1
+                self.container.add_frame(current_frame)
+                if frames_read % 10000 == 0:
+                    print("#", end="")
+            else:
+                print("Frame:", frames_read+1, " incomplete")
+                break
+
+        print(len(self.container.global_frames), "frames read")
+        return self.container
+
+[docs]    def read_next_global_frame_header(self):
+        """
+        I return the next global frame header read from current position in file.
+
+        :return: the next global frame header or None if incomplete
+        :rtype: AmmosGlobalFrameHeader
+        """
+        bytes = self.file.read(AmmosAudioReader.GLOBAL_HEADER_SIZE)
+        print("Reading next global frame header")
+        if ((not bytes) or (len(bytes) < AmmosAudioReader.GLOBAL_HEADER_SIZE)):
+            print("Can not read all", AmmosAudioReader.GLOBAL_HEADER_SIZE, "bytes of global frame header")
+            return None
+
+        # FIXME: Catch exceptions and add some asserts
+        current_global_frame_header = AmmosGlobalFrameHeader.from_bytes(bytes)
+        # print("Current global frame header", current_global_frame_header)
+        return current_global_frame_header
+
+[docs]    def read_next_global_frame_body_data_header(self):
+        """
+        I return the next global frame body data header from current position in file.
+
+        :param data_header_size: the number of bytes to read
+        :type data_header_size: int
+        :return: the next Ammos Audio Data header or None if incomplete
+        :rtype: AmmosAudioDataHeader
+        """
+        bytes = self.file.read(AmmosAudioReader.STANDARD_AUDIO_DATA_HEADER_SIZE)
+
+        # print("\nReading global frame body standard data header\n")
+        if ((not bytes) or (len(bytes) < AmmosAudioReader.STANDARD_AUDIO_DATA_HEADER_SIZE)):
+            print("Can not read all", AmmosAudioReader.STANDARD_AUDIO_DATA_HEADER_SIZE,
+                  "bytes of global frame body data header")
+            return None
+        return AmmosAudioDataHeader.from_bytes(bytes)
+
+[docs]    def read_next_global_frame_body_extended_data_header(self):
+        """
+        I return the next global frame body extended data header from current position in file.
+
+        :return: the next Ammos Audio Extended Data header or None if incomplete
+        :rtype: AmmosExtendedAudioDataHeader
+        """
+        bytes = self.file.read(AmmosAudioReader.EXTENDED_AUDIO_DATA_HEADER_SIZE)
+
+        if ((not bytes) or (len(bytes) < AmmosAudioReader.EXTENDED_AUDIO_DATA_HEADER_SIZE)):
+            print("Can not read all ", AmmosAudioReader.EXTENDED_AUDIO_DATA_HEADER_SIZE,
+                  " bytes of global frame extended data header")
+            return None
+        return AmmosExtendedAudioDataHeader.from_bytes(bytes)
+
+[docs]    def read_next_audio_data_body(self, sample_count, channel_count, sample_size):
+        """
+        I return the next audio data read from current position in file.
+
+        :param sample_count: the number of samples per channel inside data body
+        :type sample_count: int
+
+        :param channel_count: number of channels (e.g. mono, stereo or even more)
+        :type channel_count: int
+
+        :param sample_size: sample size in bytes (1, 2 or 4 bytes)
+        :type sample_size: int
+
+        :return: the next audio data or None if incomplete
+        :rtype: bytes
+        """
+        # FIXME: Describe the parameters better
+
+        total = sample_count*channel_count*sample_size
+
+        byte_string = self.file.read(total)
+
+        if len(byte_string) != total:
+            print("Can not read all", total, "bytes of data body")
+            return None
+        print([hex(c) for c in byte_string])
+        return byte_string
+
+[docs]    def read_next_global_frame_body(self, global_frame_header):
+
+        audio_data_header = None
+
+        if global_frame_header.data_header_length == AmmosAudioReader.STANDARD_AUDIO_DATA_HEADER_SIZE:
+            print("Read standard data header")
+            audio_data_header = self.read_next_global_frame_body_data_header()
+
+        if global_frame_header.data_header_length == AmmosAudioReader.EXTENDED_AUDIO_DATA_HEADER_SIZE:
+            print("Read extended data header")
+            audio_data_header = self.read_next_global_frame_body_extended_data_header()
+
+        if audio_data_header is None:
+            print("Data header missing or format unknown")
+            return None
+
+        audio_data_body = self.read_next_audio_data_body(audio_data_header.sample_count,
+                                                         audio_data_header.channel_count,
+                                                         audio_data_header.sample_size)
+
+        if audio_data_body is None:
+            print("Data body missing")
+            return None
+
+        return AmmosGlobalFrameBody(audio_data_header, audio_data_body)
+
+[docs]    def read_next_single_frame(self):
+
+        global_frame_header = self.read_next_global_frame_header()
+
+        print(global_frame_header)
+
+        if global_frame_header is None:
+            print("Global frame header missing")
+            return None
+
+        if global_frame_header.data_header_length is None:
+            print("Data header length empty")
+            return None
+
+        if global_frame_header.frame_type == 256:
+            print("Audio Datastream found")
+            global_frame_body = self.read_next_global_frame_body(global_frame_header)
+            if global_frame_body is None:
+                return None
+        else:
+            print("Unsupported frame type", global_frame_header.frame_type, "found")
+            return None
+
+        ammos_single_frame = AmmosSingleFrame(global_frame_header, global_frame_body)
+        return ammos_single_frame
+

+ +

+ + + + + + + Index: doc/html/_modules/ammosreader/AmmosAudioSocketReader.html =================================================================== --- doc/html/_modules/ammosreader/AmmosAudioSocketReader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/AmmosAudioSocketReader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,223 @@ + + + + + + + + ammosreader.AmmosAudioSocketReader — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.AmmosAudioSocketReader

+import socket
+from collections import deque
+
+import numpy as np
+from .AmmosAudioDataHeader import AmmosAudioDataHeader
+from .AmmosExtendedAudioDataHeader import AmmosExtendedAudioDataHeader
+from .AmmosGlobalFrameHeader import AmmosGlobalFrameHeader
+
+
+[docs]class AmmosAudioSocketReader:
+    def __init__(self, socket:socket.socket):
+        """
+        Initializes the AmmosAudioSocketReader
+
+        Args:
+            socket (socket.socket): socket to read from
+        """
+        
+        self.__socket = socket
+
+        #buffer for reading socket bytewise und check for the magic word
+        self.__magic_word_buffer = deque(maxlen=4)
+
+        #input socket to read from
+        self.__socket = socket
+
+    def __read_next_audio_data_body(self, sample_count:int, channel_count:int, sample_size:int) -> bytearray:
+        """
+        reads the next audio data body
+
+        Args:
+            sample_count (int): amount of samples
+            channel_count (int): amount of channels
+            sample_size (int): size of a sample in bytes
+
+        Returns:
+            bytearray: contains the audio data
+        """
+
+        total = sample_count*channel_count*sample_size
+        byte_array = []
+
+        while len(b''.join(byte_array)) < total:
+            byte_array.append(self.__socket.recv(total - len(b''.join(byte_array))))
+
+        if len(b''.join(byte_array)) != total:
+            print("Can not read all", total, "bytes of data body")
+            return None
+        return b''.join(byte_array)
+
+    def __audio_data_body_to_numpy(self, audio_data_body:bytearray) -> np.ndarray:
+        """
+        converts the audio data body to a numpy array
+
+        Args:
+            audio_data_body (bytearray): audio data from audio data body
+
+        Returns:
+            np.ndarray: audio data as numpy array
+        """
+
+        return np.frombuffer(audio_data_body, dtype=np.int16)
+
+[docs]    def read_next_frame(self) -> tuple[bytearray, int]:
+        """
+        reads the next ammos audio frame
+
+        Returns:
+            tuple[bytearray, int]: contains the audio data and the sample rate
+        """
+        #read loop
+        byte = self.__socket.recv(1)
+
+        while byte:
+            #
+            self.__magic_word_buffer.append(byte)
+            byte_array = b''.join(self.__magic_word_buffer)
+
+            if byte_array.hex() == '726574fb':
+                #print(byte_array.hex())
+
+                ammos_global_header_buffer = list(self.__magic_word_buffer)
+                while len(b''.join(ammos_global_header_buffer)) < 24:
+                    ammos_global_header_buffer.append(self.__socket.recv(24 - len(b''.join(ammos_global_header_buffer))))
+                    
+                ammos_global_header = AmmosGlobalFrameHeader.from_bytes(b''.join(ammos_global_header_buffer))
+                print(ammos_global_header)
+
+                if ammos_global_header.data_header_length == 44 and ammos_global_header.frame_type == 256:
+                    byte_array_header = []
+                    while len(b''.join(byte_array_header)) < 44:
+                        byte_array_header.append(self.__socket.recv(44 - len(b''.join(byte_array_header))))
+
+                    ammos_extended_audio_data_header = AmmosExtendedAudioDataHeader.from_bytes(b''.join(byte_array_header))
+                    print(ammos_extended_audio_data_header.sample_count, ammos_extended_audio_data_header.channel_count, ammos_extended_audio_data_header.sample_size)
+                    audio_body = self.__read_next_audio_data_body(ammos_extended_audio_data_header.sample_count, 
+                                                                  ammos_extended_audio_data_header.channel_count, 
+                                                                  ammos_extended_audio_data_header.sample_size)
+
+                    audio_array = self.__audio_data_body_to_numpy(audio_body)
+                    print(len(audio_array), len(audio_array)/ammos_extended_audio_data_header.sample_rate)
+
+                    return [audio_array, ammos_extended_audio_data_header.sample_rate]
+
+                elif ammos_global_header.data_header_length == 36 and ammos_global_header.frame_type == 256:
+                    byte_array_header = []
+                    while len(b''.join(byte_array_header)) < 36:
+                        byte_array_header.append(self.__socket.recv(36 - len(b''.join(byte_array_header))))
+
+                    ammos_audio_data_header = AmmosAudioDataHeader.from_bytes(b''.join(byte_array_header))
+                    print(ammos_audio_data_header.sample_count, ammos_audio_data_header.channel_count, ammos_audio_data_header.sample_size)
+                    audio_body = self.__read_next_audio_data_body(ammos_audio_data_header.sample_count, 
+                                                                  ammos_audio_data_header.channel_count, 
+                                                                  ammos_audio_data_header.sample_size)
+
+                    audio_array = self.__audio_data_body_to_numpy(audio_body)
+                    print(len(audio_array), len(audio_array)/ammos_audio_data_header.sample_rate)
+
+                    return [audio_array, ammos_audio_data_header.sample_rate]
+
+            byte = self.__socket.recv(1)
+
+        return None
+

+ +

+ + + + + + + Index: doc/html/_modules/ammosreader/AmmosContainer.html =================================================================== --- doc/html/_modules/ammosreader/AmmosContainer.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/AmmosContainer.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,129 @@ + + + + + + + + ammosreader.AmmosContainer — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.AmmosContainer

+from datetime import datetime
+
+[docs]class AmmosContainer():
+
+    def __init__(self, name, frames):
+        self.name = name
+        self.global_frames = frames
+        self.tags = []
+
+[docs]    def add_tag(self, tag):
+        self.tags.append(tag)
+
+[docs]    def add_frame(self, frame):
+        self.global_frames.append(frame)
+
+[docs]    def size(self):
+        len(self.global_frames)
+
+[docs]    def frequencies(self):
+        return set(list(filter(lambda frame: frame.global_frame_body.data_header.frequency, self.global_frames)))
+
+    def __str__(self):
+        start_time = self.global_frames[0].global_frame_body.data_header.timestamp
+        end_time = self.global_frames[-1].global_frame_body.data_header.timestamp
+
+        frq = str(self.global_frames[0].global_frame_body.data_header.frequency)
+
+        return ("Start time: " + str(datetime.utcfromtimestamp(start_time/1000000)) +
+                "\nEnd time  : " + str(datetime.utcfromtimestamp(end_time/1000000)) + "\nFrequencies: " + frq)
+

+ +

+ + + + + + + Index: doc/html/_modules/ammosreader/AmmosExtendedAudioDataHeader.html =================================================================== --- doc/html/_modules/ammosreader/AmmosExtendedAudioDataHeader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/AmmosExtendedAudioDataHeader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,134 @@ + + + + + + + + ammosreader.AmmosExtendedAudioDataHeader — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.AmmosExtendedAudioDataHeader

+import struct
+import numpy as np
+from .AmmosAudioDataHeader import AmmosAudioDataHeader
+
+
+[docs]class AmmosExtendedAudioDataHeader():
+
+[docs]    @classmethod
+    def from_bytes(cls, bytes):
+        standard_header = AmmosAudioDataHeader.from_bytes(bytes[0:36])
+        extended_header_elements = struct.unpack('Q', bytes[36:])
+        timestamp = extended_header_elements[0]
+        sample_rate = standard_header.sample_rate
+        status = standard_header.status
+        frequency = standard_header.frequency
+        demod_bandwidth = standard_header.demod_bandwidth
+        demod_type = standard_header.demod_type
+        sample_count = standard_header.sample_count
+        channel_count = standard_header.channel_count
+        sample_size = standard_header.sample_size
+        return AmmosExtendedAudioDataHeader(sample_rate, status, frequency, demod_bandwidth, demod_type,
+                                            sample_count, channel_count, sample_size, timestamp)
+
+    def __init__(self, sample_rate, status, frequency, demod_bandwidth, demod_type,
+                 sample_count, channel_count, sample_size, timestamp):
+        self.sample_rate = sample_rate
+        self.status = status
+        self.frequency = frequency
+        self.demod_bandwidth = demod_bandwidth
+        self.demod_type = demod_type
+        self.sample_count = sample_count
+        self.channel_count = channel_count
+        self.sample_size = sample_size
+        self.timestamp = timestamp
+

+ +

+ + + + + + + Index: doc/html/_modules/ammosreader/AmmosExtendedIFDataHeader.html =================================================================== --- doc/html/_modules/ammosreader/AmmosExtendedIFDataHeader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/AmmosExtendedIFDataHeader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,169 @@ + + + + + + + + ammosreader.AmmosExtendedIFDataHeader — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.AmmosExtendedIFDataHeader

+import struct
+import numpy as np
+from .AmmosIFDataHeader import AmmosIFDataHeader
+
+
+[docs]class AmmosExtendedIFDataHeader():
+
+[docs]    @classmethod
+    def from_bytes(cls, bytes):
+        standard_header = AmmosIFDataHeader.from_bytes(bytes[0:56])
+        extended_header_elements = struct.unpack('QQI', bytes[56:76])
+        block_count = standard_header.block_count
+        block_length = standard_header.block_length
+        timestamp = standard_header.timestamp
+        status = standard_header.status
+        source_id = standard_header.source_id
+        source_state = standard_header.source_state
+        frequency = standard_header.frequency
+        bandwidth = standard_header.bandwidth
+        sample_rate = standard_header.sample_rate
+        interpolation = standard_header.interpolation
+        decimation = standard_header.decimation
+        voltage_ref = standard_header.voltage_ref
+        stream_start = np.datetime64(int(extended_header_elements[0]), 'ns')
+        sample_counter = extended_header_elements[1]
+        antenna_correction = extended_header_elements[2]
+        size = len(bytes)
+        return AmmosExtendedIFDataHeader(size, block_count, block_length, timestamp, status, source_id,
+                                         source_state, frequency, bandwidth, sample_rate, interpolation,
+                                         decimation, voltage_ref, stream_start, sample_counter,
+                                         antenna_correction)
+
+    def __init__(self, size, block_count, block_length, timestamp, status, source_id, source_state, frequency,
+                 bandwidth, sample_rate, interpolation, decimation, voltage_ref, stream_start, sample_counter,
+                 antenna_correction):
+
+        self.size = size
+        self.block_count = block_count
+        self.block_length = block_length
+        self.timestamp = timestamp
+        self.status = status
+        self.source_id = source_id
+        self.source_state = source_state
+        self.frequency = frequency
+        self.bandwidth = bandwidth
+        self.sample_rate = sample_rate
+        self.interpolation = interpolation
+        self.decimation = decimation
+        self.voltage_ref = voltage_ref
+        self.stream_start = stream_start
+        self.sample_counter = sample_counter
+        self.antenna_correction = antenna_correction
+
+    def __str__(self):
+        output = (
+            "\nGlobal frame body data header\n" +
+            "-----------------------------\n" +
+            "Block count:" + str(self.block_count) + "\n" +
+            "Block length:" + str(self.block_length) + "\n" +
+            "Time stamp:" + str(self.timestamp) + "\n" +
+            "Frequency:" + str(self.frequency) + "\n" +
+            "Bandwidth:" + str(self.bandwidth) + "\n" +
+            "Sample rate:" + str(self.sample_rate) + "\n" +
+            "Stream start:" + str(self.stream_start) + "\n" +
+            "Sample counter:" + str(self.sample_counter) + "\n" +
+            "Antenna correction:" + str(self.antenna_correction) + "\n"
+        )
+
+        return output
+

+ +

+ + + + + + + Index: doc/html/_modules/ammosreader/AmmosGlobalFrameBody.html =================================================================== --- doc/html/_modules/ammosreader/AmmosGlobalFrameBody.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/AmmosGlobalFrameBody.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,117 @@ + + + + + + + + ammosreader.AmmosGlobalFrameBody — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.AmmosGlobalFrameBody

+[docs]class AmmosGlobalFrameBody():
+
+    def __init__(self, data_header, data_body):
+        self.data_header = data_header
+        self.data_body = data_body
+
+[docs]    def data_bytes_only(self):
+
+        byte_string = ""
+
+        for each_block in self.data_body:
+            if not each_block:
+                print("Block is nil")
+
+            byte_string += each_block.if_data
+
+        return byte_string
+

+ +

+ + + + + + + Index: doc/html/_modules/ammosreader/AmmosGlobalFrameHeader.html =================================================================== --- doc/html/_modules/ammosreader/AmmosGlobalFrameHeader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/AmmosGlobalFrameHeader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,153 @@ + + + + + + + + ammosreader.AmmosGlobalFrameHeader — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.AmmosGlobalFrameHeader

+import struct
+
+
+[docs]class AmmosGlobalFrameHeader():
+
+    MAGIC_WORD = "726574fb"
+
+[docs]    @classmethod
+    def from_bytes(cls, bytes):
+
+        elements = struct.unpack('4s4s4s4s4s4s', bytes)
+
+        magic_word = elements[0].hex()
+
+        frame_length = (int.from_bytes(elements[1], byteorder='little')*4)
+
+        running_frame_number = (int.from_bytes(elements[2], byteorder='little'))
+
+        frame_type = (int.from_bytes(elements[3], byteorder='little'))
+
+        data_header_length = 4 * int.from_bytes(elements[4], byteorder='little')
+
+        reserved = elements[5]
+
+        return AmmosGlobalFrameHeader(magic_word, frame_length, running_frame_number,
+                                      frame_type, data_header_length, reserved)
+
+    def __init__(self, magic_word, frame_length, running_frame_number, frame_type, data_header_length, reserved):
+
+        if magic_word != self.MAGIC_WORD:
+            print("Wrong magic word")
+            self.magic_word = magic_word
+            return None
+        else:
+            self.magic_word = magic_word
+            self.frame_length = frame_length
+            self.running_frame_number = running_frame_number
+            self.frame_type = frame_type
+            self.data_header_length = data_header_length
+            self.reserved = reserved
+
+    def __str__(self):
+        output = ("Global frame header info\n" +
+                  "------------------------\n" +
+                  "Magic word:" + str(self.magic_word) + "\n" +
+                  "Frame length:" + str(self.frame_length) + "\n" +
+                  "Running frame:" + str(self.running_frame_number) + "\n" +
+                  "Frame Type:" + str(self.frame_type) + "\n" +
+                  "Data header length:" + str(self.data_header_length) + "\n")
+        return output
+
+[docs]    def size(self):
+        return 24
+

+ +

+ + + + + + + Index: doc/html/_modules/ammosreader/AmmosIFDataBlock.html =================================================================== --- doc/html/_modules/ammosreader/AmmosIFDataBlock.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/AmmosIFDataBlock.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,105 @@ + + + + + + + + ammosreader.AmmosIFDataBlock — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.AmmosIFDataBlock

+[docs]class AmmosIFDataBlock():
+
+    def __init__(self, if_datablock_header, if_data):
+        self.if_datablock_header = if_datablock_header
+        self.if_data = if_data
+

+ +

+ + + + + + + Index: doc/html/_modules/ammosreader/AmmosIFDataHeader.html =================================================================== --- doc/html/_modules/ammosreader/AmmosIFDataHeader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/AmmosIFDataHeader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,154 @@ + + + + + + + + ammosreader.AmmosIFDataHeader — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.AmmosIFDataHeader

+import struct
+import numpy as np
+
+
+[docs]class AmmosIFDataHeader():
+
+[docs]    @classmethod
+    def from_bytes(cls, bytes):
+        elements = struct.unpack('<IIQIIIQIIIIi', bytes)
+        block_count = elements[0]
+        block_length = int(elements[1])*4
+        timestamp = np.datetime64(int(elements[2])*1000, 'ns')
+        status = elements[3]
+        source_id = elements[4]
+        source_state = elements[5]
+        frequency = elements[6]
+        bandwidth = elements[7]
+        sample_rate = elements[8]
+        interpolation = elements[9]
+        decimation = elements[10]
+        voltage_ref = elements[11]
+
+        return AmmosIFDataHeader(block_count, block_length, timestamp, status, source_id,
+                                 source_state, frequency, bandwidth, sample_rate,
+                                 interpolation, decimation, voltage_ref)
+
+    def __init__(self, block_count, block_length, timestamp, status, source_id, source_state, frequency,
+                 bandwidth, sample_rate, interpolation, decimation, voltage_ref):
+        self.block_count = block_count
+        self.block_length = block_length
+        self.timestamp = timestamp
+        self.status = status
+        self.source_id = source_id
+        self.source_state = source_state
+        self.frequency = frequency
+        self.bandwidth = bandwidth
+        self.sample_rate = sample_rate
+        self.interpolation = interpolation
+        self.decimation = decimation
+        self.voltage_ref = voltage_ref
+
+[docs]    def header_size(self):
+        return 56
+
+    def __str_(self):
+        output = ("\nGlobal frame body data header\n" +
+                  "-----------------------------\n" +
+                  "Block count:" + str(self.block_count) + "\n" +
+                  "Block length:" + str(self.block_length) + "\n" +
+                  "Time stamp:" + str(self.timestamp) + "\n" +
+                  "Frequency:" + str(self.frequency) + "\n" +
+                  "Bandwidth:" + str(self.bandwidth) + "\n" +
+                  "Sample rate:" + str(self.sample_rate) + "\n")
+        return output
+

+ +

+ + + + + + + Index: doc/html/_modules/ammosreader/AmmosIFReader.html =================================================================== --- doc/html/_modules/ammosreader/AmmosIFReader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/AmmosIFReader.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,251 @@ + + + + + + + + ammosreader.AmmosIFReader — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.AmmosIFReader

+import math
+import os
+
+from .AmmosGlobalFrameBody import AmmosGlobalFrameBody
+from .AmmosIFDataHeader import AmmosIFDataHeader
+from .AmmosExtendedIFDataHeader import AmmosExtendedIFDataHeader
+from .AmmosGlobalFrameHeader import AmmosGlobalFrameHeader
+from .AmmosSingleFrame import AmmosSingleFrame
+from .AmmosIFDataBlock import AmmosIFDataBlock
+from .AmmosContainer import AmmosContainer
+
+
+[docs]class AmmosIFReader():
+
+    def __init__(self, file_name):
+
+        self.file_name = file_name
+        self.file = open(self.file_name, "rb")
+        self.file_size = os.path.getsize(self.file_name)
+
+        self.container = AmmosContainer(self.file_name, [])
+
+        self.tags = []
+
+[docs]    def rewind_to_start(self):
+        self.file.seek(0)
+
+[docs]    def add_tag(self, tag):
+        self.tags.append(tag)
+
+[docs]    def read_all_frames_left(self):
+
+        frames_read = 0
+
+        while True:
+            print("Reading single frame", frames_read, '...')
+            current_frame = self.read_next_single_frame()
+            if current_frame is not None:
+                frames_read += 1
+                self.container.add_frame(current_frame)
+                if frames_read % 10000 == 0:
+                    print("#", end="")
+            else:
+                print("Frame:", frames_read+1, " incomplete")
+                break
+
+        print(len(self.container.global_frames), "frames read")
+
+[docs]    def read_next_global_frame_header(self):
+        bytes = self.file.read(24)
+        print("Reading next global frame header")
+        if ((not bytes) or (len(bytes) < 24)):
+            print("Can not read all 24 bytes of global frame header")
+            return None
+
+        return AmmosGlobalFrameHeader.from_bytes(bytes)
+
+[docs]    def read_next_global_frame_body_data_header(self):
+
+        bytes = self.file.read(56)
+
+        # print("\nReading global frame body standard data header\n")
+        if ((not bytes) or (len(bytes) < 56)):
+            print("Can not read all 56 bytes of global frame body data header")
+            return None
+
+        data_header = AmmosIFDataHeader.from_bytes(bytes)
+        # print("Data header", data_header)
+        return data_header
+
+[docs]    def read_next_global_frame_body_extended_data_header(self):
+
+        bytes = self.file.read(76)
+        # print("\nReading global frame body extended data header\n")
+
+        if ((not bytes) or (len(bytes) < 76)):
+            print("Can not read all ", 76, "bytes of global frame extended data header")
+            return None
+        extended_data_header = AmmosExtendedIFDataHeader.from_bytes(bytes)
+        # print("Extended data header", extended_data_header)
+        return extended_data_header
+
+[docs]    def read_next_if_data_blocks(self, n, length):
+
+        # FIXME: Describe the parameters better
+
+        data_blocks = []
+
+        block_length = 4 + length
+
+        total = n*block_length
+
+        byte_string = self.file.read(block_length)
+
+        if len(byte_string) != total:
+            print("Can not read all", total, "bytes of data body")
+            return None
+
+        for i in range(0, n):
+            result = byte_string[i*block_length:(i*block_length+block_length)]
+            data_blocks.append(AmmosIFDataBlock(result[0:4], result[4:]))
+
+        return data_blocks
+
+[docs]    def read_next_global_frame_body(self, global_frame_header):
+
+        if_data_header = None
+
+        if global_frame_header.data_header_length == 56:
+            if_data_header = self.read_next_global_frame_body_data_header()
+        else:
+            if_data_header = self.read_next_global_frame_body_extended_data_header()
+
+        if if_data_header is None:
+            print("Data header missing")
+            return None
+
+        if_data_body = self.read_next_if_data_blocks(if_data_header.block_count, if_data_header.block_length)
+
+        if if_data_body is None:
+            print("Data body missing")
+            return None
+
+        return AmmosGlobalFrameBody(if_data_header, if_data_body)
+
+[docs]    def read_next_single_frame(self):
+
+        global_frame_header = self.read_next_global_frame_header()
+
+        print("\nReading next global frame header\n", global_frame_header)
+        # print("File pointer", self.file.tell())
+
+        if global_frame_header is None:
+            print("Global frame header missing")
+            return None
+
+        if global_frame_header.data_header_length is None:
+            print("Data header length empty")
+            return None
+
+        if global_frame_header.frame_type == 2:
+
+            global_frame_body = self.read_next_global_frame_body(global_frame_header)
+            if global_frame_body is None:
+                return None
+
+        else:
+            print("Unsupported frame type", global_frame_header.frame_type, "found")
+            return None
+
+        return AmmosSingleFrame(global_frame_header, global_frame_body)
+

+ +

+ + + + + + + Index: doc/html/_modules/ammosreader/AmmosSingleFrame.html =================================================================== --- doc/html/_modules/ammosreader/AmmosSingleFrame.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/AmmosSingleFrame.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,125 @@ + + + + + + + + ammosreader.AmmosSingleFrame — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.AmmosSingleFrame

+[docs]class AmmosSingleFrame():
+
+    def __init__(self, global_frame_header, global_frame_body):
+        self.global_frame_header = global_frame_header
+        self.global_frame_body = global_frame_body
+
+[docs]    def data(self):
+        return self.global_frame_body.data_bytes_only()
+
+[docs]    def size_correct(self):
+        return (self.global_frame_header.frame_length == (24 + self.global_frame_header.data_header_length +
+                                                          (self.global_frame_body.data_header.block_count *
+                                                           (self.global_frame_body.data_header.block_length + 4))))
+    # FIXME: Use str method instead
+
+    def __str__(self):
+        output = (
+            "Global frame header\n" +
+            "-------------------\n" +
+            "Frame tyoe:" + str(self.global_frame_header.frame_type) + "\n" +
+            "Frame count:" + str(self.global_frame_header.running_frame_number) + "\n" +
+            "Data header length:" + str(self.global_frame_header.data_header_length) + " bytes\n" +
+            "Frame length:" + str(self.global_frame_header.frame_length) + " bytes\n"
+        )
+        return output
+

+ +

+ + + + + + + Index: doc/html/_modules/ammosreader/PDW.html =================================================================== --- doc/html/_modules/ammosreader/PDW.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/PDW.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,328 @@ + + + + + + + + ammosreader.PDW — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.PDW

+import struct
+import math
+import numpy as np
+
+# TODO: Use BitArray module in future versions
+
+
+[docs]class PDW():
+    """
+    I store information from a single ppdw data block.
+
+    .. automethod:: __init__
+
+    """
+
+[docs]    @classmethod
+    def from_bytes(cls, byte_string):
+
+        """
+
+        I create an instance of class PDW from data body (8 * 32 bits)
+
+        :param byte_string: a byte string containing a single data body read from a ppdw file
+        :type byte_string: byte string
+
+        :return: an instance of class PDW with attributes set according to the data of a data body
+        :rtype: PDW
+
+        """
+
+        assert(len(byte_string) == 32)
+
+        parts = struct.unpack('Q4s4s4s4s4s4s', byte_string)
+        nanoseconds = (parts[0])
+        time_of_arrival = np.datetime64(nanoseconds, 'ns')  #datetime.datetime.utcfromtimestamp(seconds / 1000000000)
+
+        third_entry = bin(int.from_bytes(parts[1], byteorder='little'))
+        padding = 32-len(str(third_entry)[2:])
+        third_entry_bit_string = "0" * padding + str(third_entry)[2:]
+        pdw_format_identifier = int(third_entry_bit_string[0:6], 2)
+        center_frequency = int(third_entry_bit_string[5:32], 2)
+
+        fourth_entry = bin(int.from_bytes(parts[2], byteorder='little'))
+        padding = 32-len(str(fourth_entry)[2:])
+        fourth_entry_bit_string = "0" * padding + str(fourth_entry)[2:]
+        is_valid = bool(int(fourth_entry_bit_string[0]))
+        is_pulse = bool(int(fourth_entry_bit_string[1]))
+        level_unit = int(fourth_entry_bit_string[2])
+        signal_start_missing = bool(int(fourth_entry_bit_string[3]))
+        signal_end_missing = bool(int(fourth_entry_bit_string[4]))
+        pulse_width = int(fourth_entry_bit_string[7:33], 2)
+
+        fifth_entry = bin(int.from_bytes(parts[3], byteorder='little'))
+        padding = 32-len(str(fifth_entry)[2:])
+        fifth_entry_bit_string = "0" * padding + str(fifth_entry)[2:]
+        frequency_shift_or_bandwidth = int(fifth_entry_bit_string[0:20], 2)
+        # FIXME: You have to scale me to the range from -200.0 to 200.0 in 0.1 steps
+        pulse_level_or_pulse_field_strength = math.ceil(int(fifth_entry_bit_string[20:32], 2)) / 10
+
+        sixth_entry = bin(int.from_bytes(parts[4], byteorder='little'))
+        padding = 32-len(str(sixth_entry)[2:])
+        sixth_entry_bit_string = "0" * padding + str(sixth_entry)[2:]
+        region_of_interest = bool(int(sixth_entry_bit_string[0]))
+        # FIXME: You have to scale me to a range from 0.0 to 6.2 in steps of 0.1 - 6.3 means unknown
+        azimuth_confidence = math.ceil(int(sixth_entry_bit_string[1:7], 2)) / 10
+        modulations = {0: 'Unknown', 1: 'Unmodulated', 2: 'FM', 3: 'LFM', 4: 'PSK-2', 5: 'PSK-3', 6: 'PSK-4',
+                       7: 'PSK-m', 8: 'NLFM', 9: 'SFM', 10: 'TFM', 11: 'Pulse too short'}
+        modulation = modulations[int(sixth_entry_bit_string[7:12], 2)]
+        sector = int(sixth_entry_bit_string[28:32], 2)
+
+        seventh_entry = bin(int.from_bytes(parts[5], byteorder='little'))
+        padding = 32-len(str(seventh_entry)[2:])
+        seventh_entry_bit_string = "0" * padding + str(seventh_entry)[2:]
+        polarities = {0: 'Horizontal/Unknown', 1: 'Vertical', 2: 'Counter clockwise', 3: 'Clockwise'}
+        polarity = polarities[int(seventh_entry_bit_string[0:2], 2)]
+        df_quality = int(seventh_entry_bit_string[2:9], 2)
+        # FIXME: You have to scale me from -90 to 90 in 0.1 degree steps
+        elevation = int(seventh_entry_bit_string[9:20], 2)
+        # FIXME: You have to check me for a range from 0.0 to 359.9 in steps of 0.1
+        azimuth = 0.1 * (int(seventh_entry_bit_string[20:32], 2))
+
+        eighth_entry = bin(int.from_bytes(parts[5], byteorder='little'))
+        padding = 32-len(str(eighth_entry)[2:])
+        eighth_entry_bit_string = "0" * padding + str(eighth_entry)[2:]
+        channel = int(eighth_entry_bit_string[0:4], 2)
+
+        return PDW(time_of_arrival, pdw_format_identifier, center_frequency, is_valid, is_pulse, level_unit,
+                   signal_start_missing, signal_end_missing, pulse_width, frequency_shift_or_bandwidth,
+                   pulse_level_or_pulse_field_strength, region_of_interest, azimuth_confidence, modulation,
+                   sector, polarity, df_quality, elevation, azimuth, channel)
+
+[docs]    def __init__(self, time_of_arrival, pdw_format_identifier, center_frequency, is_valid, is_pulse,
+                 level_unit, signal_start_missing, signal_end_missing, pulse_width, frequency_shift_or_bandwidth,
+                 pulse_level_or_pulse_field_strength, region_of_interest, azimuth_confidence, modulation,
+                 sector, polarity, df_quality, elevation, azimuth, channel):
+
+        """
+
+        :param time_of_arrival: nanoseconds since 1970-01-01 00:00:00
+        :type time_of_arrival: Integer
+        :param pdw_format: format code
+        :type pdw_format: Integer
+        :param center_frequency: center frequency in KHz
+        :type center_frequency: Integer
+        :param is_valid: flag to mark if pdw data body is valid
+        :type is_valid: Boolean
+        :param is_pulse: flag to mark if pdw data body contains a pulse or a continuous wave signal
+        :type is_pulse: Boolean
+        :param level_unit: 0 means dBµV - 1 means dBµV/m
+        :type level_unit: Integer
+        :param signal_start_missing: signal started before time of arrival
+        :type signal_start_missing: Boolean
+        :param signal_end_missing: signal stops after time of arrival
+        :type signal_end_missing: Boolean
+        :param pulse_width: pulse width in nanoseconds - Zero if no valid pulse detected
+        :type pulse_width: Integer
+        :param frequency_shift_or_bandwidth: Value in KHz - Value set to 1048575 means Unknown
+        :type frequency_shift_or_bandwidth: Integer
+        :param pulse_level_or_pulse_field_strength: Pulse level or Pulse Field Strength depending on level_unit \
+         (-200.0...200.0) in 0.1 steps / minus 204.8 means no valid level detected
+        :type pulse_level_or_pulse_field_strength: Float
+        :param region_of_interest: Marks if signal is from region of interest
+        :type region_of_interest: Boolean
+        :param azimuth_confidence: degree in steps of 0.1 (0.0-6.2) / 6.3 means confidence unknown
+        :type azimuth_confidence: Float
+        :param modulation: type of modulation (e.g. PSK-2, PSK-4, FM etc.)
+        :type modulation: String
+        :param sector: reference antenna sector (0-15)
+        :type sector: Integer
+        :param polarity: Horizontal, Vertical, Clockwise, Counter clockwise
+        :type polarity: String
+        :param df_quality: Direction finding quality in percent (0-100) - Zero means unknown
+        :type df_quality: Integer
+        :param elevation: elevation of incoming signal (from -90 to 90 degree) in steps of 0.1 degree \
+        minus 102.4 means unknown
+        :type elevation: Float
+        :param azimuth: azimuth of incoming signal (from 0 to 359.9 degree) in steps of 0.1 degree \
+        plus 409.5 means unknown
+        :type azimuth: Float
+        :param channel: detecting channel (0-16) - Zero means unknown
+        :type channel: Integer
+        :return: An instance of class PDW with attributes set according to the data of a data body
+        :rtype: PDW
+
+        """
+
+        self.time_of_arrival = time_of_arrival
+        self.pdw_format_identifier = pdw_format_identifier
+        self.center_frequency = center_frequency
+        self.is_valid = is_valid
+        self.is_pulse = is_pulse
+        self.level_unit = level_unit
+        self.signal_start_missing = signal_start_missing
+        self.signal_end_missing = signal_end_missing
+        self.pulse_width = pulse_width
+        self.frequency_shift_or_bandwidth = frequency_shift_or_bandwidth
+        self.pulse_level_or_pulse_field_strength = pulse_level_or_pulse_field_strength
+        self.region_of_interest = region_of_interest
+        self.azimuth_confidence = azimuth_confidence
+        self.modulation = modulation
+        self.sector = sector
+        self.polarity = polarity
+        self.df_quality = df_quality
+        self.elevation = elevation
+        self.azimuth = azimuth
+        self.channel = channel
+
+    def __str__(self):
+        output = ("Time of arrival: " + str(self.time_of_arrival) + "\n" +
+                  "PDW Format identifier: " + str(self.pdw_format_identifier) + "\n" +
+                  "Center frequency: " + str(self.center_frequency) + " KHz\n")
+
+        if self.is_valid:
+            output += "Signal: Valid\n"
+        else:
+            output += "Signal: Invalid\n"
+
+        if self.is_pulse:
+            output += "Signal type: Pulse\n"
+        else:
+            output += "Signal type: Continuous wave\n"
+
+        if self.level_unit == 1:
+            output += "Pulse level: " + str(self.pulse_level_or_pulse_field_strength) + " dbµV\n"
+        else:
+            output += "Pulse field strength: " + str(self.pulse_level_or_pulse_field_strength) + " dbµV/meter\n"
+
+        output += ("Pulse width: " + str(self.pulse_width) + " nanoseconds\n" +
+                   "Frequency shift or bandwidth: " + str(self.frequency_shift_or_bandwidth) + " KHz\n")
+
+        if self.region_of_interest:
+            output += "Region of interest: Yes\n"
+        else:
+            output += "Region of interest: No\n"
+
+        if self.azimuth_confidence == 6.3:
+            output += "Azimuth confidence: Invalid\n"
+        else:
+            output += "Azimuth confidence: " + str(self.azimuth_confidence) + " degree\n"
+
+        output += "Modulation: " + str(self.modulation) + "\n"
+
+        if self.sector == 0:
+            output += "Sector: Unknown\n"
+        else:
+            output += "Sector:" + str(self.sector) + "\n"
+
+        output += "Polarity: " + str(self.polarity) + "\n"
+
+        output += "DF quality: " + str(self.df_quality) + " %\n"
+
+        if self.elevation == 1024:
+            output += "Elevation: Unknown\n"
+        else:
+            output += "Elevation: " + str(self.elevation) + " degree\n"
+
+        if self.azimuth == 409.5:
+            output += "Azimuth: Unknown\n"
+        else:
+            output += "Azimuth: " + str(self.azimuth) + " degree\n"
+
+        output += "Channel: " + str(self.channel) + "\n"
+
+        return output
+
+
+if __name__ == '__main__':
+    pass
+

+ +

+ + + + + + + Index: doc/html/_modules/ammosreader/PPDWContainer.html =================================================================== --- doc/html/_modules/ammosreader/PPDWContainer.html (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_modules/ammosreader/PPDWContainer.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,117 @@ + + + + + + + + ammosreader.PPDWContainer — AmmosReader 0.314 documentation + + + + + + + + + + + + + + + + + +

+ + +

+ +

Source code for ammosreader.PPDWContainer

+[docs]class PPDWContainer():
+
+    """
+
+    I store multiple signals imported from one or more .ppdw files
+
+    .. automethod:: __init__
+
+    """
+
+[docs]    def __init__(self, signals):
+
+        self.signals = signals
+
+
+if __name__ == '__main__':
+    pass
+

+ +

+ + + + + + + Index: doc/html/_modules/index.html =================================================================== --- doc/html/_modules/index.html (revision 184608777df5dc9cf0895d39bc592a07dbc23746) +++ doc/html/_modules/index.html (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -1,22 +1,21 @@ - + - + - - - Overview: module code — RadarDex 0.314 documentation - - - - - - - + + + Overview: module code — AmmosReader 0.314 documentation + + + + + + + @@ -28,16 +27,32 @@

+ +

All modules for which code is available

@@ -77,9 +98,9 @@ Index: doc/html/_sources/PDW.rst.txt =================================================================== --- doc/html/_sources/PDW.rst.txt (revision 184608777df5dc9cf0895d39bc592a07dbc23746) +++ doc/html/_sources/PDW.rst.txt (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -2,5 +2,5 @@ ========== -.. automodule:: PDW +.. automodule:: ammosreader.PDW :members: :undoc-members: Index: doc/html/_sources/ammosreader.rst.txt =================================================================== --- doc/html/_sources/ammosreader.rst.txt (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_sources/ammosreader.rst.txt (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,133 @@ +ammosreader package +=================== + +Submodules +---------- + +ammosreader.AmmosAudioDataHeader module +--------------------------------------- + +.. automodule:: ammosreader.AmmosAudioDataHeader + :members: + :undoc-members: + :show-inheritance: + +ammosreader.AmmosAudioReader module +----------------------------------- + +.. automodule:: ammosreader.AmmosAudioReader + :members: + :undoc-members: + :show-inheritance: + +ammosreader.AmmosAudioSocketReader module +----------------------------------------- + +.. automodule:: ammosreader.AmmosAudioSocketReader + :members: + :undoc-members: + :show-inheritance: + +ammosreader.AmmosContainer module +--------------------------------- + +.. automodule:: ammosreader.AmmosContainer + :members: + :undoc-members: + :show-inheritance: + +ammosreader.AmmosExtendedAudioDataHeader module +----------------------------------------------- + +.. automodule:: ammosreader.AmmosExtendedAudioDataHeader + :members: + :undoc-members: + :show-inheritance: + +ammosreader.AmmosExtendedIFDataHeader module +-------------------------------------------- + +.. automodule:: ammosreader.AmmosExtendedIFDataHeader + :members: + :undoc-members: + :show-inheritance: + +ammosreader.AmmosGlobalFrameBody module +--------------------------------------- + +.. automodule:: ammosreader.AmmosGlobalFrameBody + :members: + :undoc-members: + :show-inheritance: + +ammosreader.AmmosGlobalFrameHeader module +----------------------------------------- + +.. automodule:: ammosreader.AmmosGlobalFrameHeader + :members: + :undoc-members: + :show-inheritance: + +ammosreader.AmmosIFDataBlock module +----------------------------------- + +.. automodule:: ammosreader.AmmosIFDataBlock + :members: + :undoc-members: + :show-inheritance: + +ammosreader.AmmosIFDataHeader module +------------------------------------ + +.. automodule:: ammosreader.AmmosIFDataHeader + :members: + :undoc-members: + :show-inheritance: + +ammosreader.AmmosIFReader module +-------------------------------- + +.. automodule:: ammosreader.AmmosIFReader + :members: + :undoc-members: + :show-inheritance: + +ammosreader.AmmosSingleFrame module +----------------------------------- + +.. automodule:: ammosreader.AmmosSingleFrame + :members: + :undoc-members: + :show-inheritance: + +ammosreader.IQDWTXBlock module +------------------------------ + +.. automodule:: ammosreader.IQDWTXBlock + :members: + :undoc-members: + :show-inheritance: + +ammosreader.PDW module +---------------------- + +.. automodule:: ammosreader.PDW + :members: + :undoc-members: + :show-inheritance: + +ammosreader.PPDWContainer module +-------------------------------- + +.. automodule:: ammosreader.PPDWContainer + :members: + :undoc-members: + :show-inheritance: + +Module contents +--------------- + +.. automodule:: ammosreader + :members: + :undoc-members: + :show-inheritance: Index: doc/html/_sources/index.rst.txt =================================================================== --- doc/html/_sources/index.rst.txt (revision 184608777df5dc9cf0895d39bc592a07dbc23746) +++ doc/html/_sources/index.rst.txt (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -1,7 +1,7 @@ -radardex -======== +ammosreader +=========== .. toctree:: :maxdepth: 4 - PDW + ammosreader Index: doc/html/_sources/modules.rst.txt =================================================================== --- doc/html/_sources/modules.rst.txt (revision 184608777df5dc9cf0895d39bc592a07dbc23746) +++ doc/html/_sources/modules.rst.txt (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -1,7 +1,7 @@ -radardex -======== +ammosreader +=========== .. toctree:: :maxdepth: 4 - PDW + ammosreader Index: c/html/_sources/pdw_reader.rst.txt =================================================================== --- doc/html/_sources/pdw_reader.rst.txt (revision 184608777df5dc9cf0895d39bc592a07dbc23746) +++ (revision ) @@ -1,7 +1,0 @@ -pdw\_reader module -================== - -.. automodule:: pdw_reader - :members: - :undoc-members: - :show-inheritance: Index: doc/html/_static/alabaster.css =================================================================== --- doc/html/_static/alabaster.css (revision 184608777df5dc9cf0895d39bc592a07dbc23746) +++ doc/html/_static/alabaster.css (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -1,19 +1,2 @@ - - - - - - - - - - - - - - - - - @import url("basic.css"); @@ -21,7 +4,7 @@ body { - font-family: 'goudy old style', 'minion pro', 'bell mt', Georgia, 'Hiragino Mincho Pro', serif; + font-family: Georgia, serif; font-size: 17px; - background-color: white; + background-color: #fff; color: #000; margin: 0; @@ -55,5 +38,5 @@ div.body { - background-color: #ffffff; + background-color: #fff; color: #3E4349; padding: 0 30px 0 30px; @@ -77,5 +60,5 @@ p.caption { - font-family: ; + font-family: inherit; font-size: inherit; } @@ -125,5 +108,5 @@ div.sphinxsidebar h3, div.sphinxsidebar h4 { - font-family: 'Garamond', 'Georgia', serif; + font-family: Georgia, serif; color: #444; font-size: 24px; @@ -169,5 +152,5 @@ div.sphinxsidebar input { border: 1px solid #CCC; - font-family: 'goudy old style', 'minion pro', 'bell mt', Georgia, 'Hiragino Mincho Pro', serif; + font-family: Georgia, serif; font-size: 1em; } @@ -182,4 +165,17 @@ margin-left: 0; width: 50%; +} + +div.sphinxsidebar .badge { + border-bottom: none; +} + +div.sphinxsidebar .badge:hover { + border-bottom: none; +} + +/* To address an issue with donation coming after search */ +div.sphinxsidebar h3.donation { + margin-top: 10px; } @@ -202,5 +198,5 @@ div.body h5, div.body h6 { - font-family: 'Garamond', 'Georgia', serif; + font-family: Georgia, serif; font-weight: normal; margin: 30px 0px 10px 0px; @@ -233,19 +229,15 @@ margin: 20px 0px; padding: 10px 30px; - background-color: #FCC; - border: 1px solid #FAA; -} - -div.admonition tt.xref, div.admonition a tt { + background-color: #EEE; + border: 1px solid #CCC; +} + +div.admonition tt.xref, div.admonition code.xref, div.admonition a tt { + background-color: #FBFBFB; border-bottom: 1px solid #fafafa; } -dd div.admonition { - margin-left: -60px; - padding-left: 60px; -} - div.admonition p.admonition-title { - font-family: 'Garamond', 'Georgia', serif; + font-family: Georgia, serif; font-weight: normal; font-size: 24px; @@ -260,9 +252,45 @@ div.highlight { - background-color: white; + background-color: #fff; } dt:target, .highlight { background: #FAF3E8; +} + +div.warning { + background-color: #FCC; + border: 1px solid #FAA; +} + +div.danger { + background-color: #FCC; + border: 1px solid #FAA; + -moz-box-shadow: 2px 2px 4px #D52C2C; + -webkit-box-shadow: 2px 2px 4px #D52C2C; + box-shadow: 2px 2px 4px #D52C2C; +} + +div.error { + background-color: #FCC; + border: 1px solid #FAA; + -moz-box-shadow: 2px 2px 4px #D52C2C; + -webkit-box-shadow: 2px 2px 4px #D52C2C; + box-shadow: 2px 2px 4px #D52C2C; +} + +div.caution { + background-color: #FCC; + border: 1px solid #FAA; +} + +div.attention { + background-color: #FCC; + border: 1px solid #FAA; +} + +div.important { + background-color: #EEE; + border: 1px solid #CCC; } @@ -272,4 +300,14 @@ } +div.tip { + background-color: #EEE; + border: 1px solid #CCC; +} + +div.hint { + background-color: #EEE; + border: 1px solid #CCC; +} + div.seealso { background-color: #EEE; @@ -278,5 +316,5 @@ div.topic { - background-color: #eee; + background-color: #EEE; } @@ -290,5 +328,5 @@ pre, tt, code { - font-family: 'Consolas', 'Menlo', 'Deja Vu Sans Mono', 'Bitstream Vera Sans Mono', monospace; + font-family: 'Consolas', 'Menlo', 'DejaVu Sans Mono', 'Bitstream Vera Sans Mono', monospace; font-size: 0.9em; } @@ -313,14 +351,14 @@ img.screenshot { - -moz-box-shadow: 2px 2px 4px #eee; - -webkit-box-shadow: 2px 2px 4px #eee; - box-shadow: 2px 2px 4px #eee; + -moz-box-shadow: 2px 2px 4px #EEE; + -webkit-box-shadow: 2px 2px 4px #EEE; + box-shadow: 2px 2px 4px #EEE; } table.docutils { border: 1px solid #888; - -moz-box-shadow: 2px 2px 4px #eee; - -webkit-box-shadow: 2px 2px 4px #eee; - box-shadow: 2px 2px 4px #eee; + -moz-box-shadow: 2px 2px 4px #EEE; + -webkit-box-shadow: 2px 2px 4px #EEE; + box-shadow: 2px 2px 4px #EEE; } @@ -362,4 +400,14 @@ } +/* Cloned from + * https://github.com/sphinx-doc/sphinx/commit/ef60dbfce09286b20b7385333d63a60321784e68 + */ +.field-name { + -moz-hyphens: manual; + -ms-hyphens: manual; + -webkit-hyphens: manual; + hyphens: manual; +} + table.footnote td.label { width: .1px; @@ -398,12 +446,11 @@ } +div.viewcode-block:target { + background: #ffd; +} + dl pre, blockquote pre, li pre { margin-left: 0; padding-left: 30px; -} - -dl dl pre { - margin-left: -90px; - padding-left: 90px; } @@ -416,5 +463,5 @@ tt.xref, code.xref, a tt { background-color: #FBFBFB; - border-bottom: 1px solid white; + border-bottom: 1px solid #fff; } @@ -518,5 +565,5 @@ div.documentwrapper { float: none; - background: white; + background: #fff; } @@ -533,5 +580,5 @@ div.sphinxsidebar h3, div.sphinxsidebar h4, div.sphinxsidebar p, div.sphinxsidebar h3 a { - color: white; + color: #fff; } @@ -606,2 +653,49 @@ box-shadow: none; } + + +/* relbar */ + +.related { + line-height: 30px; + width: 100%; + font-size: 0.9rem; +} + +.related.top { + border-bottom: 1px solid #EEE; + margin-bottom: 20px; +} + +.related.bottom { + border-top: 1px solid #EEE; +} + +.related ul { + padding: 0; + margin: 0; + list-style: none; +} + +.related li { + display: inline; +} + +nav#rellinks { + float: right; +} + +nav#rellinks li+li:before { + content: "|"; +} + +nav#breadcrumbs li+li:before { + content: "\00BB"; +} + +/* Hide certain items when printing */ +@media print { + div.related { + display: none; + } +} Index: doc/html/_static/basic.css =================================================================== --- doc/html/_static/basic.css (revision 184608777df5dc9cf0895d39bc592a07dbc23746) +++ doc/html/_static/basic.css (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -5,5 +5,5 @@ * Sphinx stylesheet -- basic theme. * - * :copyright: Copyright 2007-2019 by the Sphinx team, see AUTHORS. + * :copyright: Copyright 2007-2021 by the Sphinx team, see AUTHORS. * :license: BSD, see LICENSE for details. * @@ -14,4 +14,10 @@ div.clearer { clear: both; +} + +div.section::after { + display: block; + content: ''; + clear: left; } @@ -125,5 +131,5 @@ } -ul.search li div.context { +ul.search li p.context { color: #888; margin: 2px 0 0 30px; @@ -230,4 +236,14 @@ a.headerlink { visibility: hidden; +} + +a.brackets:before, +span.brackets > a:before{ + content: "["; +} + +a.brackets:after, +span.brackets > a:after { + content: "]"; } @@ -262,5 +278,5 @@ } -img.align-left, .figure.align-left, object.align-left { +img.align-left, figure.align-left, .figure.align-left, object.align-left { clear: left; float: left; @@ -268,5 +284,5 @@ } -img.align-right, .figure.align-right, object.align-right { +img.align-right, figure.align-right, .figure.align-right, object.align-right { clear: right; float: right; @@ -274,5 +290,5 @@ } -img.align-center, .figure.align-center, object.align-center { +img.align-center, figure.align-center, .figure.align-center, object.align-center { display: block; margin-left: auto; @@ -280,4 +296,10 @@ } +img.align-default, figure.align-default, .figure.align-default { + display: block; + margin-left: auto; + margin-right: auto; +} + .align-left { text-align: left; @@ -288,4 +310,8 @@ } +.align-default { + text-align: center; +} + .align-right { text-align: right; @@ -294,15 +320,22 @@ /* -- sidebars -------------------------------------------------------------- */ -div.sidebar { +div.sidebar, +aside.sidebar { margin: 0 0 0.5em 1em; border: 1px solid #ddb; - padding: 7px 7px 0 7px; + padding: 7px; background-color: #ffe; width: 40%; float: right; + clear: right; + overflow-x: auto; } p.sidebar-title { font-weight: bold; +} + +div.admonition, div.topic, blockquote { + clear: left; } @@ -311,5 +344,5 @@ div.topic { border: 1px solid #ccc; - padding: 7px 7px 0 7px; + padding: 7px; margin: 10px 0 10px 0; } @@ -333,8 +366,4 @@ } -div.admonition dl { - margin-bottom: 0; -} - p.admonition-title { margin: 0px 10px 5px 0px; @@ -347,7 +376,28 @@ } +/* -- content of sidebars/topics/admonitions -------------------------------- */ + +div.sidebar > :last-child, +aside.sidebar > :last-child, +div.topic > :last-child, +div.admonition > :last-child { + margin-bottom: 0; +} + +div.sidebar::after, +aside.sidebar::after, +div.topic::after, +div.admonition::after, +blockquote::after { + display: block; + content: ''; + clear: both; +} + /* -- tables ---------------------------------------------------------------- */ table.docutils { + margin-top: 10px; + margin-bottom: 10px; border: 0; border-collapse: collapse; @@ -355,4 +405,9 @@ table.align-center { + margin-left: auto; + margin-right: auto; +} + +table.align-default { margin-left: auto; margin-right: auto; @@ -392,20 +447,32 @@ } +th > :first-child, +td > :first-child { + margin-top: 0px; +} + +th > :last-child, +td > :last-child { + margin-bottom: 0px; +} + /* -- figures --------------------------------------------------------------- */ -div.figure { +div.figure, figure { margin: 0.5em; padding: 0.5em; } -div.figure p.caption { +div.figure p.caption, figcaption { padding: 0.3em; } -div.figure p.caption span.caption-number { +div.figure p.caption span.caption-number, +figcaption span.caption-number { font-style: italic; } -div.figure p.caption span.caption-text { +div.figure p.caption span.caption-text, +figcaption span.caption-text { } @@ -434,8 +501,69 @@ /* -- hlist styles ---------------------------------------------------------- */ +table.hlist { + margin: 1em 0; +} + table.hlist td { vertical-align: top; } +/* -- object description styles --------------------------------------------- */ + +.sig { + font-family: 'Consolas', 'Menlo', 'DejaVu Sans Mono', 'Bitstream Vera Sans Mono', monospace; +} + +.sig-name, code.descname { + background-color: transparent; + font-weight: bold; +} + +.sig-name { + font-size: 1.1em; +} + +code.descname { + font-size: 1.2em; +} + +.sig-prename, code.descclassname { + background-color: transparent; +} + +.optional { + font-size: 1.3em; +} + +.sig-paren { + font-size: larger; +} + +.sig-param.n { + font-style: italic; +} + +/* C++ specific styling */ + +.sig-inline.c-texpr, +.sig-inline.cpp-texpr { + font-family: unset; +} + +.sig.c .k, .sig.c .kt, +.sig.cpp .k, .sig.cpp .kt { + color: #0033B3; +} + +.sig.c .m, +.sig.cpp .m { + color: #1750EB; +} + +.sig.c .s, .sig.c .sc, +.sig.cpp .s, .sig.cpp .sc { + color: #067D17; +} + /* -- other body styles ----------------------------------------------------- */ @@ -461,9 +589,76 @@ } +:not(li) > ol > li:first-child > :first-child, +:not(li) > ul > li:first-child > :first-child { + margin-top: 0px; +} + +:not(li) > ol > li:last-child > :last-child, +:not(li) > ul > li:last-child > :last-child { + margin-bottom: 0px; +} + +ol.simple ol p, +ol.simple ul p, +ul.simple ol p, +ul.simple ul p { + margin-top: 0; +} + +ol.simple > li:not(:first-child) > p, +ul.simple > li:not(:first-child) > p { + margin-top: 0; +} + +ol.simple p, +ul.simple p { + margin-bottom: 0; +} + +dl.footnote > dt, +dl.citation > dt { + float: left; + margin-right: 0.5em; +} + +dl.footnote > dd, +dl.citation > dd { + margin-bottom: 0em; +} + +dl.footnote > dd:after, +dl.citation > dd:after { + content: ""; + clear: both; +} + +dl.field-list { + display: grid; + grid-template-columns: fit-content(30%) auto; +} + +dl.field-list > dt { + font-weight: bold; + word-break: break-word; + padding-left: 0.5em; + padding-right: 5px; +} + +dl.field-list > dt:after { + content: ":"; +} + +dl.field-list > dd { + padding-left: 0.5em; + margin-top: 0em; + margin-left: 0em; + margin-bottom: 0em; +} + dl { margin-bottom: 15px; } -dd p { +dd > :first-child { margin-top: 0px; } @@ -479,4 +674,9 @@ } +dl > dd:last-child, +dl > dd:last-child > :last-child { + margin-bottom: 0; +} + dt:target, span.highlighted { background-color: #fbe54e; @@ -490,12 +690,4 @@ font-weight: bold; font-size: 1.1em; -} - -.optional { - font-size: 1.3em; -} - -.sig-paren { - font-size: larger; } @@ -538,4 +730,10 @@ } +.classifier:before { + font-style: normal; + margin: 0.5em; + content: ":"; +} + abbr, acronym { border-bottom: dotted 1px; @@ -548,4 +746,8 @@ overflow: auto; overflow-y: hidden; /* fixes display issues on Chrome browsers */ +} + +pre, div[class*="highlight-"] { + clear: both; } @@ -557,6 +759,9 @@ } +div[class*="highlight-"] { + margin: 1em 0; +} + td.linenos pre { - padding: 5px 0px; border: 0; background-color: transparent; @@ -565,12 +770,44 @@ table.highlighttable { - margin-left: 0.5em; + display: block; +} + +table.highlighttable tbody { + display: block; +} + +table.highlighttable tr { + display: flex; } table.highlighttable td { - padding: 0 0.5em 0 0.5em; + margin: 0; + padding: 0; +} + +table.highlighttable td.linenos { + padding-right: 0.5em; +} + +table.highlighttable td.code { + flex: 1; + overflow: hidden; +} + +.highlight .hll { + display: block; +} + +div.highlight pre, +table.highlighttable pre { + margin: 0; +} + +div.code-block-caption + div { + margin-top: 0; } div.code-block-caption { + margin-top: 1em; padding: 2px 5px; font-size: small; @@ -581,6 +818,12 @@ } -div.code-block-caption + div > div.highlight > pre { - margin-top: 0; +table.highlighttable td.linenos, +span.linenos, +div.highlight span.gp { /* gp: Generic.Prompt */ + user-select: none; + -webkit-user-select: text; /* Safari fallback only */ + -webkit-user-select: none; /* Chrome/Safari */ + -moz-user-select: none; /* Firefox */ + -ms-user-select: none; /* IE10+ */ } @@ -594,19 +837,5 @@ div.literal-block-wrapper { - padding: 1em 1em 0; -} - -div.literal-block-wrapper div.highlight { - margin: 0; -} - -code.descname { - background-color: transparent; - font-weight: bold; - font-size: 1.2em; -} - -code.descclassname { - background-color: transparent; + margin: 1em 0; } @@ -649,6 +878,5 @@ span.eqno a.headerlink { - position: relative; - left: 0px; + position: absolute; z-index: 1; } Index: doc/html/_static/doctools.js =================================================================== --- doc/html/_static/doctools.js (revision 184608777df5dc9cf0895d39bc592a07dbc23746) +++ doc/html/_static/doctools.js (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -5,5 +5,5 @@ * Sphinx JavaScript utilities for all documentation. * - * :copyright: Copyright 2007-2019 by the Sphinx team, see AUTHORS. + * :copyright: Copyright 2007-2021 by the Sphinx team, see AUTHORS. * :license: BSD, see LICENSE for details. * @@ -30,7 +30,12 @@ /** * small helper function to urldecode strings + * + * See https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/decodeURIComponent#Decoding_query_parameters_from_a_URL */ jQuery.urldecode = function(x) { - return decodeURIComponent(x).replace(/\+/g, ' '); + if (!x) { + return x + } + return decodeURIComponent(x.replace(/\+/g, ' ')); }; @@ -88,12 +93,11 @@ node.nodeValue = val.substr(0, pos); if (isInSVG) { - var bbox = span.getBBox(); var rect = document.createElementNS("http://www.w3.org/2000/svg", "rect"); - rect.x.baseVal.value = bbox.x; + var bbox = node.parentElement.getBBox(); + rect.x.baseVal.value = bbox.x; rect.y.baseVal.value = bbox.y; rect.width.baseVal.value = bbox.width; rect.height.baseVal.value = bbox.height; rect.setAttribute('class', className); - var parentOfText = node.parentNode.parentNode; addItems.push({ "parent": node.parentNode, @@ -285,8 +289,10 @@ initOnKeyListeners: function() { - $(document).keyup(function(event) { + $(document).keydown(function(event) { var activeElementType = document.activeElement.tagName; - // don't navigate when in search box or textarea - if (activeElementType !== 'TEXTAREA' && activeElementType !== 'INPUT' && activeElementType !== 'SELECT') { + // don't navigate when in search box, textarea, dropdown or button + if (activeElementType !== 'TEXTAREA' && activeElementType !== 'INPUT' && activeElementType !== 'SELECT' + && activeElementType !== 'BUTTON' && !event.altKey && !event.ctrlKey && !event.metaKey + && !event.shiftKey) { switch (event.keyCode) { case 37: // left @@ -296,4 +302,5 @@ return false; } + break; case 39: // right var nextHref = $('link[rel="next"]').prop('href'); @@ -302,4 +309,5 @@ return false; } + break; } } Index: doc/html/_static/documentation_options.js =================================================================== --- doc/html/_static/documentation_options.js (revision 184608777df5dc9cf0895d39bc592a07dbc23746) +++ doc/html/_static/documentation_options.js (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -4,7 +4,9 @@ LANGUAGE: 'None', COLLAPSE_INDEX: false, + BUILDER: 'html', FILE_SUFFIX: '.html', + LINK_SUFFIX: '.html', HAS_SOURCE: true, SOURCELINK_SUFFIX: '.txt', - NAVIGATION_WITH_KEYS: false, + NAVIGATION_WITH_KEYS: false }; Index: doc/html/_static/jquery-3.5.1.js =================================================================== --- doc/html/_static/jquery-3.5.1.js (revision ada37fa89b30f532d9c00236dfc011d131449841) +++ doc/html/_static/jquery-3.5.1.js (revision ada37fa89b30f532d9c00236dfc011d131449841) @@ -0,0 +1,10872 @@ +/*! + * jQuery JavaScript Library v3.5.1 + * https://jquery.com/ + * + * Includes Sizzle.js + * https://sizzlejs.com/ + * + * Copyright JS Foundation and other contributors + * Released under the MIT license + * https://jquery.org/license + * + * Date: 2020-05-04T22:49Z + */ +( function( global, factory ) { + + "use strict"; + + if ( typeof module === "object" && typeof module.exports === "object" ) { + + // For CommonJS and CommonJS-like environments where a proper `window` + // is present, execute the factory and get jQuery. + // For environments that do not have a `window` with a `document` + // (such as Node.js), expose a factory as module.exports. + // This accentuates the need for the creation of a real `window`. + // e.g. var jQuery = require("jquery")(window); + // See ticket #14549 for more info. + module.exports = global.document ? + factory( global, true ) : + function( w ) { + if ( !w.document ) { + throw new Error( "jQuery requires a window with a document" ); + } + return factory( w ); + }; + } else { + factory( global ); + } + +// Pass this if window is not defined yet +} )( typeof window !== "undefined" ? window : this, function( window, noGlobal ) { + +// Edge <= 12 - 13+, Firefox <=18 - 45+, IE 10 - 11, Safari 5.1 - 9+, iOS 6 - 9.1 +// throw exceptions when non-strict code (e.g., ASP.NET 4.5) accesses strict mode +// arguments.callee.caller (trac-13335). But as of jQuery 3.0 (2016), strict mode should be common +// enough that all such attempts are guarded in a try block. +"use strict"; + +var arr = []; + +var getProto = Object.getPrototypeOf; + +var slice = arr.slice; + +var flat = arr.flat ? function( array ) { + return arr.flat.call( array ); +} : function( array ) { + return arr.concat.apply( [], array ); +}; + + +var push = arr.push; + +var indexOf = arr.indexOf; + +var class2type = {}; + +var toString = class2type.toString; + +var hasOwn = class2type.hasOwnProperty; + +var fnToString = hasOwn.toString; + +var ObjectFunctionString = fnToString.call( Object ); + +var support = {}; + +var isFunction = function isFunction( obj ) { + + // Support: Chrome <=57, Firefox <=52 + // In some browsers, typeof returns "function" for HTML


- p
+ a
+ `ammosreader`	+
- `PDW`	+	+ `ammosreader.AmmosAudioDataHeader`	+
+ `ammosreader.AmmosAudioReader`	+
+ `ammosreader.AmmosAudioSocketReader`	+
+ `ammosreader.AmmosContainer`	+
+ `ammosreader.AmmosExtendedAudioDataHeader`	+
+ `ammosreader.AmmosExtendedIFDataHeader`	+
+ `ammosreader.AmmosGlobalFrameBody`	+
+ `ammosreader.AmmosGlobalFrameHeader`	+
+ `ammosreader.AmmosIFDataBlock`	+
+ `ammosreader.AmmosIFDataHeader`	+
+ `ammosreader.AmmosIFReader`	+
+ `ammosreader.AmmosSingleFrame`	+
+ `ammosreader.PDW`	+
+ `ammosreader.PPDWContainer`

PDW module¶

PDW module¶

Source code for PDW

Source code for ammosreader.AmmosAudioDataHeader

Source code for ammosreader.AmmosAudioReader

Source code for ammosreader.AmmosAudioSocketReader

Source code for ammosreader.AmmosContainer

Source code for ammosreader.AmmosExtendedAudioDataHeader

Source code for ammosreader.AmmosExtendedIFDataHeader

Source code for ammosreader.AmmosGlobalFrameBody

Source code for ammosreader.AmmosGlobalFrameHeader

Source code for ammosreader.AmmosIFDataBlock

Source code for ammosreader.AmmosIFDataHeader

Source code for ammosreader.AmmosIFReader

Source code for ammosreader.AmmosSingleFrame

Source code for ammosreader.PDW

Source code for ammosreader.PPDWContainer

All modules for which code is available

ammosreader package¶

Submodules¶

ammosreader.AmmosAudioDataHeader module¶

ammosreader.AmmosAudioReader module¶

ammosreader.AmmosAudioSocketReader module¶

ammosreader.AmmosContainer module¶

ammosreader.AmmosExtendedAudioDataHeader module¶

ammosreader.AmmosExtendedIFDataHeader module¶

ammosreader.AmmosGlobalFrameBody module¶

ammosreader.AmmosGlobalFrameHeader module¶

ammosreader.AmmosIFDataBlock module¶

ammosreader.AmmosIFDataHeader module¶

ammosreader.AmmosIFReader module¶

ammosreader.AmmosSingleFrame module¶

ammosreader.IQDWTXBlock module¶

ammosreader.PDW module¶

ammosreader.PPDWContainer module¶

Module contents¶

A

D

E

G

H

M

R

S

radardex¶

ammosreader¶

radardex¶

ammosreader¶

pdw_reader module¶

Search