-import struct
-import numpy
+"""I provide an AMMOS data header for audio data frames."""
-[docs]class AmmosAudioDemodType():
+import struct
+from ammosreader.AmmosConstants import 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
+[docs]class AmmosAudioDataHeader:
+ """I implement an AMMOS data header for audio data frames."""
- def __str__(self):
- return AmmosAudioDemodType.mapping[self.demod_type]
-
-[docs]class AmmosAudioDataHeader():
+ HEADER_SIZE = 36 # 9 words
[docs] @classmethod
def from_bytes(cls, bytes):
+ """I return an AMMOS data header from given bytes."""
+ assert len(bytes) == cls.HEADER_SIZE
elements = struct.unpack('<IIQIIIII', bytes)
sample_rate = elements[0]
@@ -91,12 +84,14 @@
frequency = elements[2]
demod_bandwidth = elements[3]
- demod_type = elements[4]
- sample_count = elements[5]
- channel_count = elements[6]
+ demod_type = AmmosAudioDemodType(elements[4])
+ number_of_samples = elements[5]
+ number_of_channels = elements[6]
sample_size = elements[7]
return AmmosAudioDataHeader(sample_rate, status, frequency, demod_bandwidth, demod_type,
- sample_count, channel_count, sample_size)
+ number_of_samples, number_of_channels, sample_size)
- def __init__(self, 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, number_of_samples,
+ number_of_channels, sample_size):
+ """I create a new instance of myself using the above parameters."""
self.sample_rate = sample_rate
self.status = status
@@ -104,9 +99,10 @@
self.demod_bandwidth = demod_bandwidth
self.demod_type = AmmosAudioDemodType(demod_type)
- self.sample_count = sample_count
- self.channel_count = channel_count
+ self.number_of_samples = number_of_samples
+ self.number_of_channels = number_of_channels
self.sample_size = sample_size
def __str__(self):
+ """I return the string representation of myself."""
return ("\nAmmosAudioDataHeader\n" +
"Sample rate:" + str(self.sample_rate) + "\n" +
@@ -115,6 +111,6 @@
"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 count:" + str(self.number_of_samples) + "\n" +
+ "Channel count:" + str(self.number_of_channels) + "\n" +
"Sample size:" + str(self.sample_size) + "\n")
-"""I parse an R&S AMMOS recording."""
-
-import os
-
+"""I provide a specialized Ammos Reader for audio data."""
+import logging
+
+from ammosreader.AbstractAmmosReader import AbstractAmmosReader
from ammosreader.AmmosGlobalFrameBody import AmmosGlobalFrameBody
from ammosreader.AmmosAudioDataHeader import AmmosAudioDataHeader
from ammosreader.AmmosExtendedAudioDataHeader import AmmosExtendedAudioDataHeader
-from ammosreader.AmmosGlobalFrameHeader import AmmosGlobalFrameHeader
-from ammosreader.AmmosSingleFrame import AmmosSingleFrame
-from ammosreader.AmmosContainer import AmmosContainer
-
-
-[docs]class AmmosAudioReader():
+from ammosreader.AmmosAudioDataBody import AmmosAudioDataBody
+
+
+[docs]class AmmosAudioReader(AbstractAmmosReader):
"""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):
@@ -90,65 +84,5 @@
: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
+ super().__init__(file_name)
[docs] def read_next_global_frame_body_data_header(self):
@@ -161,10 +95,11 @@
: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")
+ header_size = AmmosAudioDataHeader.HEADER_SIZE
+
+ bytes = self.ammos_file.read(header_size)
+
+ logging.info("\nReading global frame body standard data header\n")
+ if ((not bytes) or (len(bytes) < header_size)):
+ logging.debug("Can not read all %s bytes of global frame body data header", header_size)
return None
return AmmosAudioDataHeader.from_bytes(bytes)
@@ -177,21 +112,22 @@
: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")
+ header_size = AmmosExtendedAudioDataHeader.HEADER_SIZE
+
+ bytes = self.ammos_file.read(header_size)
+
+ if ((not bytes) or (len(bytes) < header_size)):
+ logging.debug("Can not read all %s bytes of global frame extended data header", header_size)
return None
return AmmosExtendedAudioDataHeader.from_bytes(bytes)
-[docs] def read_next_audio_data_body(self, sample_count, channel_count, sample_size):
+[docs] def read_next_audio_data_body(self, number_of_samples, number_of_channels, 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 number_of_samples: the number of samples per channel inside data body
+ :type number_of_samples: int
+
+ :param number_of_channels: number of channels (e.g. mono, stereo or even more)
+ :type number_of_channels: int
:param sample_size: sample size in bytes (1, 2 or 4 bytes)
@@ -201,67 +137,54 @@
:rtype: bytes
"""
- # FIXME: Describe the parameters better
-
- total = sample_count*channel_count*sample_size
-
- byte_string = self.file.read(total)
+ total = number_of_samples*number_of_channels*sample_size
+
+ byte_string = self.ammos_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):
-
+ logging.debug("Can not read all %s bytes of data body", total)
+ return None
+ return AmmosAudioDataBody(byte_string, number_of_channels, number_of_samples, sample_size)
+
+[docs] def read_next_global_frame_body(self, data_header_length):
+ """
+ I return the next global frame body read from current position in file.
+
+ :param 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")
+ if data_header_length == AmmosAudioDataHeader.HEADER_SIZE:
+ logging.info("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")
+ logging.info("Data header length %s", data_header_length)
+ if data_header_length == AmmosExtendedAudioDataHeader.HEADER_SIZE:
+ logging.info("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,
+ logging.debug("Data header missing or format unknown")
+ return None
+
+ audio_data_body = self.read_next_audio_data_body(audio_data_header.number_of_samples,
+ audio_data_header.number_of_channels,
audio_data_header.sample_size)
if audio_data_body is None:
- print("Data body missing")
+ logging.debug("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
+[docs] def pcm_for_channel(self, a_channel):
+ """
+ I return the raw pcm audio data for a given channel.
+
+ :param a_channel: the channel I have to extract
+ :type a_channel: int
+
+ :rtype: bytes
+ """
+ return b"".join([each.global_frame_body.data_body.pcm_for_channel(a_channel) for each in self.container.global_frames])
-import socket
+"""I read a Ammos datastream from a socket."""
+
+import select
+import socket
from collections import deque
-
import numpy as np
from ammosreader.AmmosAudioDataHeader import AmmosAudioDataHeader
@@ -74,5 +76,5 @@
[docs]class AmmosAudioSocketReader:
- def __init__(self, socket:socket.socket):
+ def __init__(self, socket:socket.socket, debug=True):
"""
Initializes the AmmosAudioSocketReader
@@ -80,4 +82,5 @@
Args:
socket (socket.socket): socket to read from
+ debug (bool): if true, prints debug information
"""
@@ -88,26 +91,37 @@
self.__socket = socket
- def __read_next_audio_data_body(self, sample_count:int, channel_count:int, sample_size:int) -> bytearray:
+ #
+ self.DEBUG_MODE = debug
+
+ def __get_next_data(self, byte_count: int) -> bytearray:
"""
- reads the next audio data body
+ Gets the next bytes from the socket, for example headers and body data.
Args:
- sample_count (int): amount of samples
- channel_count (int): amount of channels
- sample_size (int): size of a sample in bytes
+ byte_count (int): number of bytes to read
+
+ Raises:
+ TimeoutError: Raises TimeoutError if the socket does not serve data anymore
Returns:
- bytearray: contains the audio data
- """
-
- total = sample_count*channel_count*sample_size
+ bytearray: data from socket as bytearray
+ """
+
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
+
+ while len(b''.join(byte_array)) < byte_count:
+ if self.DEBUG_MODE:
+ print(f"Remaining Bytes: {byte_count - len(b''.join(byte_array))}")
+ self.__socket.settimeout(5)
+ new_bytes = self.__socket.recv(byte_count - len(b''.join(byte_array)), socket.MSG_WAITALL)
+
+ if not new_bytes:
+ raise TimeoutError("Socket timed out while reading data")
+
+ if self.DEBUG_MODE:
+ print(f"Got {len(new_bytes)} bytes of {byte_count - len(b''.join(byte_array))} ramining")
+
+ byte_array.append(new_bytes)
+
return b''.join(byte_array)
@@ -125,17 +139,26 @@
return np.frombuffer(audio_data_body, dtype=np.int16)
-[docs] def read_next_frame(self) -> tuple[bytearray, int]:
- """
- reads the next ammos audio frame
+[docs] def read_next_frame(self) -> tuple[np.ndarray, int]:
+ """Reads the next ammos audio frame from socket
+
+ Raises:
+ TimeoutError: Raisees TimeoutError if the socket does not serve data anymore
Returns:
- tuple[bytearray, int]: contains the audio data and the sample rate
- """
+ tuple[np.ndarray, int]: Contains the audio data and the sample rate
+ """
+
+ # get first byte of the day
+ self.__socket.settimeout(5)
+
+ new_byte = self.__socket.recv(1, socket.MSG_WAITALL)
+ # raise Exception if socket does not return anything
+ if len(new_byte) < 1:
+ raise TimeoutError
+
#read loop
- byte = self.__socket.recv(1)
-
- while byte:
+ while new_byte:
#
- self.__magic_word_buffer.append(byte)
+ self.__magic_word_buffer.append(new_byte)
byte_array = b''.join(self.__magic_word_buffer)
@@ -144,43 +167,55 @@
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_buffer.append(self.__get_next_data(20))
+ #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 self.DEBUG_MODE:
+ 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)
+ byte_array_header = self.__get_next_data(44)
+ #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(byte_array_header)
+ if self.DEBUG_MODE:
+ 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.__get_next_data(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)
+ if self.DEBUG_MODE:
+ 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)
+ byte_array_header = self.__get_next_data(36)
+ #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(byte_array_header)
+ if self.DEBUG_MODE:
+ print(ammos_audio_data_header.sample_count, ammos_audio_data_header.channel_count, ammos_audio_data_header.sample_size)
+ audio_body = self.__get_next_data(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_audio_data_header.sample_rate)
+ if self.DEBUG_MODE:
+ 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)
+ # get the next byte
+ self.__socket.settimeout(5)
+
+ new_byte = self.__socket.recv(1, socket.MSG_WAITALL)
+ # raise Exception if socket does not return anything
+ if len(new_byte) < 1:
+ raise TimeoutError
return None
@@ -193,5 +228,5 @@
© Copyright 2022, KIDZg.
- Created using Sphinx 4.4.0 ADC Theme .
+ Created using Sphinx 4.5.0 ADC Theme .
(Revision )
Index: doc/html/_modules/ammosreader/AmmosContainer.html
===================================================================
--- doc/html/_modules/ammosreader/AmmosContainer.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_modules/ammosreader/AmmosContainer.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -69,28 +69,43 @@
def __init__(self, name, frames):
- self.name = name
- self.global_frames = frames
- self.tags = []
+ self.__name = name
+ self.__global_frames = frames
+ self.__tags = []
+
+ @property
+ def name(self):
+ return self.__name
+
+ @name.setter
+ def name(self, a_name):
+ self.__name = a_name
+
+ @property
+ def global_frames(self):
+ return self.__global_frames
+ self.__tags.append(tag)
+ self.__global_frames.append(frame)© Copyright 2022, KIDZg. - Created using Sphinx 4.4.0 ADC Theme . + Created using Sphinx 4.5.0 ADC Theme . (Revision )
Index: doc/html/_modules/ammosreader/AmmosExtendedAudioDataHeader.html =================================================================== --- doc/html/_modules/ammosreader/AmmosExtendedAudioDataHeader.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7) +++ doc/html/_modules/ammosreader/AmmosExtendedAudioDataHeader.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5) @@ -64,15 +64,20 @@
-import struct
-import numpy as np
+"""I provide an Ammos extended data header for audio data frames."""
+
+import struct
from ammosreader.AmmosAudioDataHeader import AmmosAudioDataHeader
-[docs]class AmmosExtendedAudioDataHeader():
+[docs]class AmmosExtendedAudioDataHeader:
+
+ HEADER_SIZE = 44 # 11 words
[docs] @classmethod
def from_bytes(cls, bytes):
- standard_header = AmmosAudioDataHeader.from_bytes(bytes[0:36])
- extended_header_elements = struct.unpack('Q', bytes[36:])
+ """I return a new AMMOS extended data header for audio frames built from given bytes."""
+ assert len(bytes) == cls.HEADER_SIZE
+ standard_header = AmmosAudioDataHeader.from_bytes(bytes[0:AmmosAudioDataHeader.HEADER_SIZE])
+ extended_header_elements = struct.unpack('<Q', bytes[AmmosAudioDataHeader.HEADER_SIZE:])
timestamp = extended_header_elements[0]
sample_rate = standard_header.sample_rate
@@ -81,12 +86,13 @@
demod_bandwidth = standard_header.demod_bandwidth
demod_type = standard_header.demod_type
- sample_count = standard_header.sample_count
- channel_count = standard_header.channel_count
+ number_of_samples = standard_header.number_of_samples
+ number_of_channels = standard_header.number_of_channels
sample_size = standard_header.sample_size
return AmmosExtendedAudioDataHeader(sample_rate, status, frequency, demod_bandwidth, demod_type,
- sample_count, channel_count, sample_size, timestamp)
+ number_of_samples, number_of_channels, sample_size, timestamp)
def __init__(self, sample_rate, status, frequency, demod_bandwidth, demod_type,
- sample_count, channel_count, sample_size, timestamp):
+ number_of_samples, number_of_channels, sample_size, timestamp):
+ """I return a new AMMOS extended data header for audio frames built from given parameters."""
self.sample_rate = sample_rate
self.status = status
@@ -94,6 +100,6 @@
self.demod_bandwidth = demod_bandwidth
self.demod_type = demod_type
- self.sample_count = sample_count
- self.channel_count = channel_count
+ self.number_of_samples = number_of_samples
+ self.number_of_channels = number_of_channels
self.sample_size = sample_size
self.timestamp = timestamp
Index: doc/html/_modules/ammosreader/AmmosExtendedIFDataHeader.html
===================================================================
--- doc/html/_modules/ammosreader/AmmosExtendedIFDataHeader.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_modules/ammosreader/AmmosExtendedIFDataHeader.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -70,9 +70,13 @@
[docs]class AmmosExtendedIFDataHeader():
+ """I implement an Ammos extended data header for IF data frames."""
+
+ HEADER_SIZE = 76
[docs] @classmethod
def from_bytes(cls, bytes):
- standard_header = AmmosIFDataHeader.from_bytes(bytes[0:56])
- extended_header_elements = struct.unpack('QQI', bytes[56:76])
+ """I return an AMMOS extended data header from given bytes."""
+ standard_header = AmmosIFDataHeader.from_bytes(bytes[0:AmmosIFDataHeader.HEADER_SIZE])
+ extended_header_elements = struct.unpack('<QQI', bytes[AmmosIFDataHeader.HEADER_SIZE:cls.HEADER_SIZE])
block_count = standard_header.block_count
block_length = standard_header.block_length
@@ -99,5 +103,5 @@
bandwidth, sample_rate, interpolation, decimation, voltage_ref, stream_start, sample_counter,
antenna_correction):
-
+ """I create a new instance of myself using the above parameters."""
self.size = size
self.block_count = block_count
@@ -129,7 +133,5 @@
"Stream start:" + str(self.stream_start) + "\n" +
"Sample counter:" + str(self.sample_counter) + "\n" +
- "Antenna correction:" + str(self.antenna_correction) + "\n"
- )
-
+ "Antenna correction:" + str(self.antenna_correction) + "\n")
return output
Index: doc/html/_modules/ammosreader/AmmosGlobalFrameBody.html
===================================================================
--- doc/html/_modules/ammosreader/AmmosGlobalFrameBody.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_modules/ammosreader/AmmosGlobalFrameBody.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -64,13 +64,37 @@
Source code for ammosreader.AmmosGlobalFrameBody
-[docs]class AmmosGlobalFrameBody():
+"""I provide an AMMOS global frame body."""
+[docs]class AmmosGlobalFrameBody():
+ """
+ I implement an AMMOS global frame body.
+
+ AMMOS frames can store data of various types.
+ The data is described in the data header.
+ The raw data is then stored in the data body.
+ """
def __init__(self, data_header, data_body):
- self.data_header = data_header
- self.data_body = data_body
+ self.__data_header = data_header
+ self.__data_body = data_body
+
+ @property
+ def data_header(self):
+ return self.__data_header
+
+ @data_header.setter
+ def data_header(self, a_data_header):
+ self.__data_header = a_data_header
+
+ @property
+ def data_body(self):
+ return self.__data_body
+
+ @data_body.setter
+ def data_body(self, data_bytes):
+ self.__data_body = data_bytes
[docs] def data_bytes_only(self):
- byte_string = ""
+ byte_string = b""
for each_block in self.data_body:
@@ -78,5 +102,5 @@
print("Block is nil")
- byte_string += each_block.if_data
+ byte_string += each_block.data
return byte_string
Index: doc/html/_modules/ammosreader/AmmosGlobalFrameHeader.html
===================================================================
--- doc/html/_modules/ammosreader/AmmosGlobalFrameHeader.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_modules/ammosreader/AmmosGlobalFrameHeader.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -74,5 +74,5 @@
def from_bytes(cls, bytes):
- elements = struct.unpack('4s4s4s4s4s4s', bytes)
+ elements = struct.unpack('<4s4s4s4s4s4s', bytes)
magic_word = elements[0].hex()
@@ -93,8 +93,7 @@
def __init__(self, magic_word, frame_length, running_frame_number, frame_type, data_header_length, reserved):
- if magic_word != self.MAGIC_WORD:
+ if magic_word != type(self).MAGIC_WORD:
print("Wrong magic word")
self.magic_word = magic_word
- return None
else:
self.magic_word = magic_word
Index: doc/html/_modules/ammosreader/AmmosIFDataBlock.html
===================================================================
--- doc/html/_modules/ammosreader/AmmosIFDataBlock.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_modules/ammosreader/AmmosIFDataBlock.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -64,9 +64,17 @@
Source code for ammosreader.AmmosIFDataBlock
-[docs]class AmmosIFDataBlock():
+[docs]class AmmosIFDataBlock:
- def __init__(self, if_datablock_header, if_data):
- self.if_datablock_header = if_datablock_header
- self.if_data = if_data
+ def __init__(self, header, data):
+ self.__header = header
+ self.__data = data
+
+ @property
+ def header(self):
+ return self.__header
+
+ @property
+ def data(self):
+ return self.__data
Index: doc/html/_modules/ammosreader/AmmosIFDataHeader.html
===================================================================
--- doc/html/_modules/ammosreader/AmmosIFDataHeader.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_modules/ammosreader/AmmosIFDataHeader.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -64,12 +64,19 @@
Source code for ammosreader.AmmosIFDataHeader
-import struct
+"""I provide a Ammos data header for IF data frames."""
+
+import struct
import numpy as np
[docs]class AmmosIFDataHeader():
+ """I implement an Ammos data header for IF data frames."""
+
+ HEADER_SIZE = 56
[docs] @classmethod
def from_bytes(cls, bytes):
+ """I return an AMMOS data header from given bytes."""
+ assert len(bytes) == cls.HEADER_SIZE
elements = struct.unpack('<IIQIIIQIIIIi', bytes)
block_count = elements[0]
@@ -92,4 +99,5 @@
def __init__(self, block_count, block_length, timestamp, status, source_id, source_state, frequency,
bandwidth, sample_rate, interpolation, decimation, voltage_ref):
+ """I create a new instance of myself using the above parameters."""
self.block_count = block_count
self.block_length = block_length
@@ -104,7 +112,4 @@
self.decimation = decimation
self.voltage_ref = voltage_ref
-
-
def __str_(self):
Index: doc/html/_modules/ammosreader/AmmosIFReader.html
===================================================================
--- doc/html/_modules/ammosreader/AmmosIFReader.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_modules/ammosreader/AmmosIFReader.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -64,155 +64,110 @@
Source code for ammosreader.AmmosIFReader
-import math
-import os
+"""I provide a specialized Ammos Reader for IF data."""
+import logging
+from ammosreader.AbstractAmmosReader import AbstractAmmosReader
from ammosreader.AmmosGlobalFrameBody import AmmosGlobalFrameBody
from ammosreader.AmmosIFDataHeader import AmmosIFDataHeader
from ammosreader.AmmosExtendedIFDataHeader import AmmosExtendedIFDataHeader
-from ammosreader.AmmosGlobalFrameHeader import AmmosGlobalFrameHeader
-from ammosreader.AmmosSingleFrame import AmmosSingleFrame
+from ammosreader.AmmosIFDataBody import AmmosIFDataBody
from ammosreader.AmmosIFDataBlock import AmmosIFDataBlock
-from ammosreader.AmmosContainer import AmmosContainer
+from ammosreader.AmmosIFDataBlockHeader import AmmosIFDataBlockHeader
-[docs]class AmmosIFReader():
+[docs]class AmmosIFReader(AbstractAmmosReader):
+ """I read the IF data embedded in an R&S AMMOS recording."""
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 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)
+ super().__init__(file_name)
[docs] def read_next_global_frame_body_data_header(self):
- bytes = self.file.read(56)
+ header_size = AmmosIFDataHeader.HEADER_SIZE
- # 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")
+ bytes = self.ammos_file.read(header_size)
+
+ logging.info("\nReading global frame body standard data header\n")
+ if ((not bytes) or (len(bytes) < header_size)):
+ logging.debug("Can not read all %s bytes of global frame body data header", header_size)
+ return None
+ return AmmosIFDataHeader.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 Extended IF data header or None if incomplete
+ :rtype: AmmosExtendedIFDataHeader
+ """
+ header_size = AmmosExtendedIFDataHeader.HEADER_SIZE
+
+ bytes = self.ammos_file.read(header_size)
+
+ logging.info("\nReading global frame body extended data header\n")
+ if ((not bytes) or (len(bytes) < header_size)):
+ logging.debug("Can not read all %s bytes of global frame extended data header", header_size)
+ return None
+ return AmmosExtendedIFDataHeader.from_bytes(bytes)
+
+[docs] def read_next_if_data_body(self, number_of_data_blocks, data_length):
+ """
+ I return the next data body read from current position in file.
+
+ :param number_of_data_blocks: the number of data blocks inside the body
+ :type number_of_data_blocks: int
+
+ :param data_length: the length of the raw data inside a single block
+ :type data_length: int
+ """
+ header_size = AmmosIFDataBlockHeader.HEADER_SIZE
+
+ data_body = AmmosIFDataBody()
+
+ block_length = header_size + data_length
+
+ total = number_of_data_blocks*block_length
+
+ byte_string = self.ammos_file.read(block_length)
+
+ if len(byte_string) != total:
+ logging.debug("Can not read all %s bytes of data body", total)
return None
- data_header = AmmosIFDataHeader.from_bytes(bytes)
- # print("Data header", data_header)
- return data_header
+ for i in range(0, number_of_data_blocks):
+ result = byte_string[i*block_length:(i*block_length+block_length)]
+ data_body.add_data_block(AmmosIFDataBlock(AmmosIFDataBlockHeader.from_bytes(result[0:header_size]),
+ result[header_size:]))
-
- bytes = self.file.read(76)
- # print("\nReading global frame body extended data header\n")
+[docs] def read_next_global_frame_body(self, data_header_length):
+ """
+ I return the next global frame body read from current position in file.
- 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):
-
+ :param data_header_length: the length of the data header
+ :type data_header_length: int
+ """
if_data_header = None
- if global_frame_header.data_header_length == 56:
+ if data_header_length == AmmosIFDataHeader.HEADER_SIZE:
if_data_header = self.read_next_global_frame_body_data_header()
- else:
+ if data_header_length == AmmosExtendedIFDataHeader.HEADER_SIZE:
if_data_header = self.read_next_global_frame_body_extended_data_header()
if if_data_header is None:
- print("Data header missing")
+ logging.debug("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_data_body = self.read_next_if_data_body(if_data_header.block_count, if_data_header.block_length)
if if_data_body is None:
- print("Data body missing")
+ logging.debug("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)
+[docs] def data(self):
+ return b"".join([each.global_frame_body.data_body.data for each in self.container.global_frames])
Index: doc/html/_modules/ammosreader/AmmosSingleFrame.html
===================================================================
--- doc/html/_modules/ammosreader/AmmosSingleFrame.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_modules/ammosreader/AmmosSingleFrame.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -67,6 +67,14 @@
def __init__(self, global_frame_header, global_frame_body):
- self.global_frame_header = global_frame_header
- self.global_frame_body = global_frame_body
+ self.__global_frame_header = global_frame_header
+ self.__global_frame_body = global_frame_body
+
+ @property
+ def global_frame_header(self):
+ return self.__global_frame_header
+
+ @property
+ def global_frame_body(self):
+ return self.__global_frame_body
[docs] def data(self):
@@ -83,5 +91,5 @@
"Global frame header\n" +
"-------------------\n" +
- "Frame tyoe:" + str(self.global_frame_header.frame_type) + "\n" +
+ "Frame type:" + 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" +
Index: doc/html/_modules/ammosreader/PDW.html
===================================================================
--- doc/html/_modules/ammosreader/PDW.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_modules/ammosreader/PDW.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -64,9 +64,9 @@
Source code for ammosreader.PDW
-import struct
+"""I store the information of a single PDW block."""
+
+import struct
import math
import numpy as np
-
-# TODO: Use BitArray module in future versions
@@ -76,13 +76,10 @@
.. automethod:: __init__
-
"""
[docs] @classmethod
def from_bytes(cls, byte_string):
-
"""
-
- I create an instance of class PDW from data body (8 * 32 bits)
+ 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
@@ -91,12 +88,10 @@
: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)
+ parts = struct.unpack('<Q4s4s4s4s4s4s', byte_string)
nanoseconds = (parts[0])
- time_of_arrival = np.datetime64(nanoseconds, 'ns') #datetime.datetime.utcfromtimestamp(seconds / 1000000000)
+ time_of_arrival = np.datetime64(nanoseconds, 'ns')
third_entry = bin(int.from_bytes(parts[1], byteorder='little'))
@@ -159,6 +154,6 @@
pulse_level_or_pulse_field_strength, region_of_interest, azimuth_confidence, modulation,
sector, polarity, df_quality, elevation, azimuth, channel):
-
- """
+ r"""
+ I return an instance of an Pulse Data word.
:param time_of_arrival: nanoseconds since 1970-01-01 00:00:00
@@ -207,29 +202,32 @@
: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.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.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.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.modulation = modulation #
self.sector = sector
self.polarity = polarity
- self.df_quality = df_quality
- self.elevation = elevation
+ self.df_quality = df_quality #
+ self.elevation = elevation #
self.azimuth = azimuth
- self.channel = channel
+ self.channel = channel #
def __str__(self):
+ """
+ I return the string representation of myself.
+
+ :rtype: str
+ """
output = ("Time of arrival: " + str(self.time_of_arrival) + "\n" +
"PDW Format identifier: " + str(self.pdw_format_identifier) + "\n" +
@@ -287,6 +285,20 @@
output += "Channel: " + str(self.channel) + "\n"
- return output
-
+ return output
+
+[docs] def to_json(self):
+ return {'TIMEOFARRIVAL': self.time_of_arrival.item(),
+ 'CENTERFREQUENCY': self.center_frequency,
+ 'VALID': self.is_valid,
+ 'PULSE': self.is_pulse,
+ 'PULSEWIDTH': self.pulse_width,
+ 'LEVELUNIT': self.level_unit,
+ 'FREQUENCYSHIFTORBANDWIDTH': self.frequency_shift_or_bandwidth,
+ 'PULSELEVELORFIELDSTRENGTH': self.pulse_level_or_pulse_field_strength,
+ 'MODULATION': self.modulation,
+ 'ELEVATION': self.elevation,
+ 'AZIMUTH': self.azimuth,
+ 'CHANNEL': self.channel
+ }
if __name__ == '__main__':
Index: doc/html/_modules/ammosreader/PPDWContainer.html
===================================================================
--- doc/html/_modules/ammosreader/PPDWContainer.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_modules/ammosreader/PPDWContainer.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -64,18 +64,61 @@
Source code for ammosreader.PPDWContainer
-[docs]class PPDWContainer():
+import numpy as np
+from datetime import datetime
+
+[docs]class PPDWContainer():
"""
-
I store multiple signals imported from one or more .ppdw files
-
.. automethod:: __init__
-
"""
-[docs] def __init__(self, signals):
+ def __init__(self, name, signals=None):
- self.signals = signals
+ if signals is None:
+ self.signals = []
+ else:
+ self.signals = signals
+ def __str__(self):
+ return "\n".join(["Number of pulses:" + str(len(self.signals)),
+ "Start time:" + str(self.start_time()),
+ "End time:" + str(self.end_time())])
+
+
+
+[docs] def julian_date_string(self):
+ ts = (self.start_time() - np.datetime64('1970-01-01T00:00:00')) / np.timedelta64(1, 's')
+ time_tuple = datetime.utcfromtimestamp(ts).timetuple()
+ return str(time_tuple.tm_year)[2:] + str(time_tuple.tm_yday).zfill(3)
+
+[docs] def center_frequencies(self):
+ return list({each.center_frequency for each in self.signals})
+
+
+
+
+
+[docs] def bandwidths(self):
+ return list({each.frequency_shift_or_bandwidth for each in self.signals})
+
+
+
+
+
+[docs] def to_json(self):
+ return {'JULIANDATE': self.julian_date_string(),
+ 'STARTTIME': str(self.start_time()),
+ 'ENDTIME': str(self.end_time()),
+ # 'CENTERFREQUENCIES': self.center_frequencies(),
+ 'CHANNELS': self.channels()
+ # 'MODULATIONS': self.modulations(),
+ # 'BANDWIDTHS': self.bandwidths()
+ }
if __name__ == '__main__':
Index: doc/html/_modules/index.html
===================================================================
--- doc/html/_modules/index.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_modules/index.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -86,5 +86,5 @@
© Copyright 2022, KIDZg.
- Created using Sphinx 4.4.0 ADC Theme .
+ Created using Sphinx 4.5.0 ADC Theme .
(Revision )
Index: doc/html/_static/doctools.js
===================================================================
--- doc/html/_static/doctools.js (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_static/doctools.js (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -155,7 +155,5 @@
this.highlightSearchWords();
this.initIndexTable();
- if (DOCUMENTATION_OPTIONS.NAVIGATION_WITH_KEYS) {
- this.initOnKeyListeners();
- }
+ this.initOnKeyListeners();
},
@@ -270,4 +268,11 @@
},
+ /**
+ * helper function to focus on search bar
+ */
+ focusSearchBar : function() {
+ $('input[name=q]').first().focus();
+ },
+
/**
* make the url absolute
@@ -292,25 +297,52 @@
initOnKeyListeners: function() {
+ // only install a listener if it is really needed
+ if (!DOCUMENTATION_OPTIONS.NAVIGATION_WITH_KEYS &&
+ !DOCUMENTATION_OPTIONS.ENABLE_SEARCH_SHORTCUTS)
+ return;
+
$(document).keydown(function(event) {
var activeElementType = document.activeElement.tagName;
// 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
- var prevHref = $('link[rel="prev"]').prop('href');
- if (prevHref) {
- window.location.href = prevHref;
- return false;
- }
- break;
- case 39: // right
- var nextHref = $('link[rel="next"]').prop('href');
- if (nextHref) {
- window.location.href = nextHref;
- return false;
- }
- break;
+ && activeElementType !== 'BUTTON') {
+ if (event.altKey || event.ctrlKey || event.metaKey)
+ return;
+
+ if (!event.shiftKey) {
+ switch (event.key) {
+ case 'ArrowLeft':
+ if (!DOCUMENTATION_OPTIONS.NAVIGATION_WITH_KEYS)
+ break;
+ var prevHref = $('link[rel="prev"]').prop('href');
+ if (prevHref) {
+ window.location.href = prevHref;
+ return false;
+ }
+ break;
+ case 'ArrowRight':
+ if (!DOCUMENTATION_OPTIONS.NAVIGATION_WITH_KEYS)
+ break;
+ var nextHref = $('link[rel="next"]').prop('href');
+ if (nextHref) {
+ window.location.href = nextHref;
+ return false;
+ }
+ break;
+ case 'Escape':
+ if (!DOCUMENTATION_OPTIONS.ENABLE_SEARCH_SHORTCUTS)
+ break;
+ Documentation.hideSearchWords();
+ return false;
+ }
+ }
+
+ // some keyboard layouts may need Shift to get /
+ switch (event.key) {
+ case '/':
+ if (!DOCUMENTATION_OPTIONS.ENABLE_SEARCH_SHORTCUTS)
+ break;
+ Documentation.focusSearchBar();
+ return false;
}
}
Index: doc/html/_static/documentation_options.js
===================================================================
--- doc/html/_static/documentation_options.js (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_static/documentation_options.js (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -9,4 +9,6 @@
HAS_SOURCE: true,
SOURCELINK_SUFFIX: '.txt',
- NAVIGATION_WITH_KEYS: false
+ NAVIGATION_WITH_KEYS: false,
+ SHOW_SEARCH_SUMMARY: true,
+ ENABLE_SEARCH_SHORTCUTS: true,
};
Index: doc/html/_static/searchtools.js
===================================================================
--- doc/html/_static/searchtools.js (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/_static/searchtools.js (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -173,8 +173,4 @@
// stem the word
var word = stemmer.stemWord(tmp[i].toLowerCase());
- // prevent stemmer from cutting word smaller than two chars
- if(word.length < 3 && tmp[i].length >= 3) {
- word = tmp[i];
- }
var toAppend;
// select the correct list
@@ -277,5 +273,5 @@
displayNextItem();
}, 5);
- } else if (DOCUMENTATION_OPTIONS.HAS_SOURCE) {
+ } else if (DOCUMENTATION_OPTIONS.SHOW_SEARCH_SUMMARY) {
$.ajax({url: requestUrl,
dataType: "text",
@@ -294,5 +290,5 @@
}});
} else {
- // no source available, just display title
+ // just display title
Search.output.append(listItem);
setTimeout(function() {
Index: doc/html/ammosreader.html
===================================================================
--- doc/html/ammosreader.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/ammosreader.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -96,37 +96,19 @@
ammosreader.AmmosAudioDataHeader module¶
+I provide an AMMOS data header for audio data frames.
-
-class ammosreader.AmmosAudioDataHeader.AmmosAudioDataHeader(sample_rate, status, frequency, demod_bandwidth, demod_type, sample_count, channel_count, sample_size)[source]¶
-Bases: object
+class ammosreader.AmmosAudioDataHeader.AmmosAudioDataHeader(sample_rate, status, frequency, demod_bandwidth, demod_type, number_of_samples, number_of_channels, sample_size)[source]¶
+Bases: object
+I implement an AMMOS data header for audio data frames.
+
+-
+HEADER_SIZE = 36¶
+
+
-
-
-
-
--
-class ammosreader.AmmosAudioDataHeader.AmmosAudioDemodType(demod_type)[source]¶
-Bases: object
-
--
-class property mapping¶
-dict() -> new empty dictionary
-dict(mapping) -> new dictionary initialized from a mapping object’s
-
-(key, value) pairs
-
-
-- dict(iterable) -> new dictionary initialized as if via:
d = {}
-for k, v in iterable:
-
-d[k] = v
-
-- dict(**kwargs) -> new dictionary initialized with the name=value pairs
in the keyword argument list. For example: dict(one=1, two=2)
-
+I return an AMMOS data header from given bytes.
@@ -136,46 +118,20 @@
ammosreader.AmmosAudioReader module¶
-I parse an R&S AMMOS recording.
+I provide a specialized Ammos Reader for audio data.
-
class ammosreader.AmmosAudioReader.AmmosAudioReader(file_name)[source]¶
-Bases: object
+Bases: ammosreader.AbstractAmmosReader.AbstractAmmosReader
I read the audio data embedded in an R&S AMMOS recording.
-
--
-EXTENDED_AUDIO_DATA_HEADER_SIZE = 44¶
-
-
-
--
-GLOBAL_HEADER_SIZE = 24¶
-
-
-
--
-STANDARD_AUDIO_DATA_HEADER_SIZE = 36¶
-
-
-
--
-add_tag(tag)[source]¶
-I add a tag to my tag list.
-
-- Parameters
-tag (dict) – The tag to add to my tag list
-
-
-
-
--
-read_all_frames_left()[source]¶
-I read all remaining frames into my container until end of file is reached.
-
-- Returns
-a container containing all frames read
+
+-
+pcm_for_channel(a_channel)[source]¶
+I return the raw pcm audio data for a given channel.
+
+- Parameters
+a_channel (int) – the channel I have to extract
- Return type
--
+
bytes
@@ -184,11 +140,11 @@
-
-read_next_audio_data_body(sample_count, channel_count, sample_size)[source]¶
+read_next_audio_data_body(number_of_samples, number_of_channels, sample_size)[source]¶
I return the next audio data read from current position in file.
- Parameters
-sample_count (int) – the number of samples per channel inside data body
channel_count (int) – number of channels (e.g. mono, stereo or even more)
number_of_samples (int) – the number of samples per channel inside data body
number_of_channels (int) – number of channels (e.g. mono, stereo or even more)
sample_size (int) – sample size in bytes (1, 2 or 4 bytes)
@@ -205,6 +161,12 @@
+read_next_global_frame_body(data_header_length)[source]¶
+I return the next global frame body read from current position in file.
+
+- Parameters
+global_frame_header –
+
+
@@ -239,29 +201,4 @@
-
-
-
-
-
-
@@ -269,18 +206,22 @@
ammosreader.AmmosAudioSocketReader module¶
+I read a Ammos datastream from a socket.
-
-class ammosreader.AmmosAudioSocketReader.AmmosAudioSocketReader(socket: socket.socket)[source]¶
+class ammosreader.AmmosAudioSocketReader.AmmosAudioSocketReader(socket: socket.socket, debug=True)[source]¶
Bases: object
-
-read_next_frame() tuple[bytearray, int][source]¶
-reads the next ammos audio frame
-
-- Returns
-contains the audio data and the sample rate
-- Return type
-tuple[bytearray, int]
+read_next_frame() tuple[numpy.ndarray, int][source]¶
+Reads the next ammos audio frame from socket
+
+- Raises
+TimeoutError – Raisees TimeoutError if the socket does not serve data anymore
+- Returns
+Contains the audio data and the sample rate
+- Return type
+tuple[np.ndarray, int]
@@ -308,8 +249,23 @@
+
+
+
+-
+property global_frames¶
+
+
+
+-
+property name¶
+
+
-
@@ -322,12 +278,19 @@
ammosreader.AmmosExtendedAudioDataHeader module¶
+I provide an Ammos extended data header for audio data frames.
-
-class ammosreader.AmmosExtendedAudioDataHeader.AmmosExtendedAudioDataHeader(sample_rate, status, frequency, demod_bandwidth, demod_type, sample_count, channel_count, sample_size, timestamp)[source]¶
-Bases: object
+class ammosreader.AmmosExtendedAudioDataHeader.AmmosExtendedAudioDataHeader(sample_rate, status, frequency, demod_bandwidth, demod_type, number_of_samples, number_of_channels, sample_size, timestamp)[source]¶
+Bases: object
+
+-
+HEADER_SIZE = 44¶
+
+
+I return a new AMMOS extended data header for audio frames built from given bytes.
+
@@ -340,8 +303,15 @@
class ammosreader.AmmosExtendedIFDataHeader.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)[source]¶
Bases: object
+I implement an Ammos extended data header for IF data frames.
+
+-
+HEADER_SIZE = 76¶
+
+
+I return an AMMOS extended data header from given bytes.
+
@@ -350,11 +320,26 @@
ammosreader.AmmosGlobalFrameBody module¶
+I provide an AMMOS global frame body.
-
class ammosreader.AmmosGlobalFrameBody.AmmosGlobalFrameBody(data_header, data_body)[source]¶
Bases: object
+I implement an AMMOS global frame body.
+AMMOS frames can store data of various types.
+The data is described in the data header.
+The raw data is then stored in the data body.
+
+-
+property data_body¶
+
+
+
+
+-
+property data_header¶
@@ -390,6 +375,16 @@
-
-class ammosreader.AmmosIFDataBlock.AmmosIFDataBlock(if_datablock_header, if_data)[source]¶
-Bases: object
+class ammosreader.AmmosIFDataBlock.AmmosIFDataBlock(header, data)[source]¶
+Bases: object
+
+-
+property data¶
+
+
+
+-
+property header¶
+
+
@@ -397,17 +392,20 @@
ammosreader.AmmosIFDataHeader module¶
+I provide a Ammos data header for IF data frames.
-
class ammosreader.AmmosIFDataHeader.AmmosIFDataHeader(block_count, block_length, timestamp, status, source_id, source_state, frequency, bandwidth, sample_rate, interpolation, decimation, voltage_ref)[source]¶
Bases: object
+I implement an Ammos data header for IF data frames.
+
+-
+HEADER_SIZE = 56¶
+
+
-
-
+I return an AMMOS data header from given bytes.
+
@@ -416,22 +414,25 @@
ammosreader.AmmosIFReader module¶
+I provide a specialized Ammos Reader for IF data.
-
class ammosreader.AmmosIFReader.AmmosIFReader(file_name)[source]¶
-Bases: object
-
-
-
--
-read_all_frames_left()[source]¶
+Bases: ammosreader.AbstractAmmosReader.AbstractAmmosReader
+I read the IF data embedded in an R&S AMMOS recording.
+
+read_next_global_frame_body(data_header_length)[source]¶
+I return the next global frame body read from current position in file.
+
+- Parameters
+data_header_length (int) – the length of the data header
+
+
-
-
-
-
-
-
-
-
+I return the next global frame body extended data header from current position in file.
+
+- Returns
+the next Ammos Extended IF data header or None if incomplete
+- Return type
+-
+
+
+
+
+
+-
+read_next_if_data_body(number_of_data_blocks, data_length)[source]¶
+I return the next data body read from current position in file.
+
+- Parameters
+
+number_of_data_blocks (int) – the number of data blocks inside the body
data_length (int) – the length of the raw data inside a single block
+
+
@@ -479,4 +483,14 @@
+
+-
+property global_frame_body¶
+
+
+
+-
+property global_frame_header¶
+
+
-
@@ -503,4 +517,5 @@
ammosreader.PDW module¶
+I store the information of a single PDW block.
-
@@ -511,5 +526,6 @@
-
__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]¶
-
+I return an instance of an Pulse Data word.
+
- Parameters
@@ -524,5 +540,5 @@
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
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
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
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
+
+
+
+-
+classmethod from_bytes(byte_string)[source]¶
+I create an instance of class PDW from data body (8 * 32 bits).
+
+- 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
+an instance of class PDW with attributes set according to the data of a data body
- Return type
@@ -546,19 +579,7 @@
--
-classmethod from_bytes(byte_string)[source]¶
-I create an instance of class PDW from data body (8 * 32 bits)
-
-- 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
--
-
-
-
+-
+to_json()[source]¶
+
@@ -569,10 +590,51 @@
+Bases: object
+I store multiple signals imported from one or more .ppdw files
+.. automethod:: __init__
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
@@ -592,5 +654,5 @@
© Copyright 2022, KIDZg.
- Created using Sphinx 4.4.0 ADC Theme .
+ Created using Sphinx 4.5.0 ADC Theme .
(Revision )
Index: doc/html/genindex.html
===================================================================
--- doc/html/genindex.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/genindex.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -71,4 +71,6 @@
_
| A
+ | B
+ | C
| D
| E
@@ -77,8 +79,11 @@
| H
| I
+ | J
| M
+ | N
| P
| R
| S
+ | T
@@ -87,9 +92,5 @@
+ - add() (ammosreader.PPDWContainer.PPDWContainer method)
+
- add_frame() (ammosreader.AmmosContainer.AmmosContainer method)
- - add_tag() (ammosreader.AmmosAudioReader.AmmosAudioReader method)
-
-
+ - add_tag() (ammosreader.AmmosContainer.AmmosContainer method)
+
- AmmosAudioDataHeader (class in ammosreader.AmmosAudioDataHeader)
- - AmmosAudioDemodType (class in ammosreader.AmmosAudioDataHeader)
-
- AmmosAudioReader (class in ammosreader.AmmosAudioReader)
@@ -160,6 +155,4 @@
-
-
ammosreader.AmmosContainer
@@ -169,4 +162,6 @@
+
-
ammosreader.AmmosExtendedAudioDataHeader
@@ -251,13 +246,45 @@
+B
+
+
+
+C
+
+
+
D
@@ -319,4 +362,12 @@
+J
+
+
+
M
N
+
+
+
P
T
+
+
@@ -460,5 +509,5 @@
© Copyright 2022, KIDZg.
- Created using Sphinx 4.4.0 ADC Theme .
+ Created using Sphinx 4.5.0 ADC Theme .
(Revision )
Index: doc/html/index.html
===================================================================
--- doc/html/index.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/index.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -105,5 +105,5 @@
© Copyright 2022, KIDZg.
- Created using Sphinx 4.4.0 ADC Theme .
+ Created using Sphinx 4.5.0 ADC Theme .
(Revision )
Index: doc/html/modules.html
===================================================================
--- doc/html/modules.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/modules.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -103,5 +103,5 @@
© Copyright 2022, KIDZg.
- Created using Sphinx 4.4.0 ADC Theme .
+ Created using Sphinx 4.5.0 ADC Theme .
(Revision )
Index: doc/html/py-modindex.html
===================================================================
--- doc/html/py-modindex.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/py-modindex.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -166,5 +166,5 @@
© Copyright 2022, KIDZg.
- Created using Sphinx 4.4.0 ADC Theme .
+ Created using Sphinx 4.5.0 ADC Theme .
(Revision )
Index: doc/html/search.html
===================================================================
--- doc/html/search.html (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/search.html (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -93,5 +93,5 @@
© Copyright 2022, KIDZg.
- Created using Sphinx 4.4.0 ADC Theme .
+ Created using Sphinx 4.5.0 ADC Theme .
(Revision )
Index: doc/html/searchindex.js
===================================================================
--- doc/html/searchindex.js (revision eab48d090d8ddff75a2b2b314219c9d19be769f7)
+++ doc/html/searchindex.js (revision 299c79c00241e6f0fbb1e0e96048951cc5b871f5)
@@ -1,1 +1,1 @@
-Search.setIndex({docnames:["ammosreader","index","modules"],envversion:{"sphinx.domains.c":2,"sphinx.domains.changeset":1,"sphinx.domains.citation":1,"sphinx.domains.cpp":4,"sphinx.domains.index":1,"sphinx.domains.javascript":2,"sphinx.domains.math":2,"sphinx.domains.python":3,"sphinx.domains.rst":2,"sphinx.domains.std":2,"sphinx.ext.viewcode":1,sphinx:56},filenames:["ammosreader.rst","index.rst","modules.rst"],objects:{"":[[0,0,0,"-","ammosreader"]],"ammosreader.AmmosAudioDataHeader":[[0,1,1,"","AmmosAudioDataHeader"],[0,1,1,"","AmmosAudioDemodType"]],"ammosreader.AmmosAudioDataHeader.AmmosAudioDataHeader":[[0,2,1,"","from_bytes"]],"ammosreader.AmmosAudioDataHeader.AmmosAudioDemodType":[[0,3,1,"","mapping"]],"ammosreader.AmmosAudioReader":[[0,1,1,"","AmmosAudioReader"]],"ammosreader.AmmosAudioReader.AmmosAudioReader":[[0,4,1,"","EXTENDED_AUDIO_DATA_HEADER_SIZE"],[0,4,1,"","GLOBAL_HEADER_SIZE"],[0,4,1,"","STANDARD_AUDIO_DATA_HEADER_SIZE"],[0,2,1,"","add_tag"],[0,2,1,"","read_all_frames_left"],[0,2,1,"","read_next_audio_data_body"],[0,2,1,"","read_next_global_frame_body"],[0,2,1,"","read_next_global_frame_body_data_header"],[0,2,1,"","read_next_global_frame_body_extended_data_header"],[0,2,1,"","read_next_global_frame_header"],[0,2,1,"","read_next_single_frame"],[0,2,1,"","rewind_to_start"]],"ammosreader.AmmosAudioSocketReader":[[0,1,1,"","AmmosAudioSocketReader"]],"ammosreader.AmmosAudioSocketReader.AmmosAudioSocketReader":[[0,2,1,"","read_next_frame"]],"ammosreader.AmmosContainer":[[0,1,1,"","AmmosContainer"]],"ammosreader.AmmosContainer.AmmosContainer":[[0,2,1,"","add_frame"],[0,2,1,"","add_tag"],[0,2,1,"","frequencies"],[0,2,1,"","size"]],"ammosreader.AmmosExtendedAudioDataHeader":[[0,1,1,"","AmmosExtendedAudioDataHeader"]],"ammosreader.AmmosExtendedAudioDataHeader.AmmosExtendedAudioDataHeader":[[0,2,1,"","from_bytes"]],"ammosreader.AmmosExtendedIFDataHeader":[[0,1,1,"","AmmosExtendedIFDataHeader"]],"ammosreader.AmmosExtendedIFDataHeader.AmmosExtendedIFDataHeader":[[0,2,1,"","from_bytes"]],"ammosreader.AmmosGlobalFrameBody":[[0,1,1,"","AmmosGlobalFrameBody"]],"ammosreader.AmmosGlobalFrameBody.AmmosGlobalFrameBody":[[0,2,1,"","data_bytes_only"]],"ammosreader.AmmosGlobalFrameHeader":[[0,1,1,"","AmmosGlobalFrameHeader"]],"ammosreader.AmmosGlobalFrameHeader.AmmosGlobalFrameHeader":[[0,4,1,"","MAGIC_WORD"],[0,2,1,"","from_bytes"],[0,2,1,"","size"]],"ammosreader.AmmosIFDataBlock":[[0,1,1,"","AmmosIFDataBlock"]],"ammosreader.AmmosIFDataHeader":[[0,1,1,"","AmmosIFDataHeader"]],"ammosreader.AmmosIFDataHeader.AmmosIFDataHeader":[[0,2,1,"","from_bytes"],[0,2,1,"","header_size"]],"ammosreader.AmmosIFReader":[[0,1,1,"","AmmosIFReader"]],"ammosreader.AmmosIFReader.AmmosIFReader":[[0,2,1,"","add_tag"],[0,2,1,"","read_all_frames_left"],[0,2,1,"","read_next_global_frame_body"],[0,2,1,"","read_next_global_frame_body_data_header"],[0,2,1,"","read_next_global_frame_body_extended_data_header"],[0,2,1,"","read_next_global_frame_header"],[0,2,1,"","read_next_if_data_blocks"],[0,2,1,"","read_next_single_frame"],[0,2,1,"","rewind_to_start"]],"ammosreader.AmmosSingleFrame":[[0,1,1,"","AmmosSingleFrame"]],"ammosreader.AmmosSingleFrame.AmmosSingleFrame":[[0,2,1,"","data"],[0,2,1,"","size_correct"]],"ammosreader.IQDWTXBlock":[[0,1,1,"","IQDWTXBLOCK"]],"ammosreader.IQDWTXBlock.IQDWTXBLOCK":[[0,2,1,"","from_bytes"]],"ammosreader.PDW":[[0,1,1,"","PDW"]],"ammosreader.PDW.PDW":[[0,2,1,"","__init__"],[0,2,1,"","from_bytes"]],"ammosreader.PPDWContainer":[[0,1,1,"","PPDWContainer"]],"ammosreader.PPDWContainer.PPDWContainer":[[0,2,1,"","__init__"]],ammosreader:[[0,0,0,"-","AmmosAudioDataHeader"],[0,0,0,"-","AmmosAudioReader"],[0,0,0,"-","AmmosAudioSocketReader"],[0,0,0,"-","AmmosContainer"],[0,0,0,"-","AmmosExtendedAudioDataHeader"],[0,0,0,"-","AmmosExtendedIFDataHeader"],[0,0,0,"-","AmmosGlobalFrameBody"],[0,0,0,"-","AmmosGlobalFrameHeader"],[0,0,0,"-","AmmosIFDataBlock"],[0,0,0,"-","AmmosIFDataHeader"],[0,0,0,"-","AmmosIFReader"],[0,0,0,"-","AmmosSingleFrame"],[0,0,0,"-","IQDWTXBlock"],[0,0,0,"-","PDW"],[0,0,0,"-","PPDWContainer"]]},objnames:{"0":["py","module","Python module"],"1":["py","class","Python class"],"2":["py","method","Python method"],"3":["py","property","Python property"],"4":["py","attribute","Python attribute"]},objtypes:{"0":"py:module","1":"py:class","2":"py:method","3":"py:property","4":"py:attribute"},terms:{"0":0,"00":0,"01":0,"1":0,"100":0,"102":0,"1048575":0,"15":0,"16":0,"1970":0,"2":0,"200":0,"204":0,"24":0,"3":0,"32":0,"359":0,"36":0,"4":0,"409":0,"44":0,"5":0,"6":0,"726574fb":0,"8":0,"9":0,"90":0,"boolean":0,"byte":0,"class":0,"db\u00b5v":0,"float":0,"import":0,"int":0,"new":0,"return":0,For:0,The:0,__init__:0,access:0,accord:0,add:0,add_fram:0,add_tag:0,after:0,all:0,ammo:0,ammosaudiodatahead:[1,2],ammosaudiodemodtyp:0,ammosaudioread:[1,2],ammosaudiosocketread:[1,2],ammoscontain:[1,2],ammosextendedaudiodatahead:[1,2],ammosextendedifdatahead:[1,2],ammosglobalframebodi:[1,2],ammosglobalframehead:[1,2],ammosifdatablock:[1,2],ammosifdatahead:[1,2],ammosifread:[1,2],ammossinglefram:[1,2],an:0,antenna:0,antenna_correct:0,argument:0,arriv:0,attribut:0,audio:0,azimuth:0,azimuth_confid:0,bandwidth:0,base:0,befor:0,begin:0,bit:0,block:0,block_count:0,block_length:0,bodi:0,byte_str:0,bytearrai:0,center:0,center_frequ:0,channel:0,channel_count:0,classmethod:0,clockwis:0,code:0,confid:0,contain:0,content:[1,2],continu:0,counter:0,creat:0,current:0,d:0,data:0,data_bodi:0,data_bytes_onli:0,data_head:0,data_header_length:0,data_header_s:0,decim:0,degre:0,demod_bandwidth:0,demod_typ:0,depend:0,detect:0,df_qualiti:0,dict:0,dictionari:0,direct:0,e:0,elev:0,embed:0,empti:0,end:0,etc:0,even:0,exampl:0,extend:0,extended_audio_data_header_s:0,field:0,file:0,file_nam:0,find:0,flag:0,fm:0,format:0,frame:0,frame_length:0,frame_typ:0,frequenc:0,frequency_shift_or_bandwidth:0,from:0,from_byt:0,g:0,global:0,global_frame_bodi:0,global_frame_head:0,global_header_s:0,header:0,header_s:0,horizont:0,i:0,if_data:0,if_datablock_head:0,incom:0,incomplet:0,inform:0,initi:0,insid:0,instanc:0,integ:0,interest:0,interpol:0,iq:0,iqdwtxblock:[1,2],is_puls:0,is_valid:0,iter:0,k:0,kei:0,keyword:0,khz:0,kwarg:0,length:0,level:0,level_unit:0,list:0,m:0,magic_word:0,map:0,mark:0,mean:0,minu:0,modul:[1,2],mono:0,more:0,multipl:0,my:0,n:0,name:0,nanosecond:0,next:0,none:0,number:0,object:0,one:0,oper:0,packag:[1,2],pair:0,paramet:0,pars:0,pdw:[1,2],pdw_format:0,pdw_format_identifi:0,per:0,percent:0,plu:0,pointer:0,polar:0,posit:0,ppdw:0,ppdwcontain:[1,2],properti:0,psk:0,puls:0,pulse_level_or_pulse_field_strength:0,pulse_width:0,qualiti:0,r:0,rate:0,reach:0,read:0,read_all_frames_left:0,read_next_audio_data_bodi:0,read_next_fram:0,read_next_global_frame_bodi:0,read_next_global_frame_body_data_head:0,read_next_global_frame_body_extended_data_head:0,read_next_global_frame_head:0,read_next_if_data_block:0,read_next_single_fram:0,record:0,refer:0,region:0,region_of_interest:0,remain:0,reserv:0,rewind_to_start:0,running_frame_numb:0,s:0,sampl:0,sample_count:0,sample_r:0,sample_s:0,sector:0,set:0,signal:0,signal_end_miss:0,signal_start_miss:0,sinc:0,singl:0,size:0,size_correct:0,socket:0,sourc:0,source_id:0,source_st:0,standard_audio_data_header_s:0,start:0,statu:0,step:0,stereo:0,stop:0,store:0,stream_start:0,strength:0,string:0,submodul:[1,2],tag:0,time:0,time_of_arriv:0,timestamp:0,tupl:0,two:0,type:0,unknown:0,until:0,v:0,valid:0,valu:0,vertic:0,via:0,voltage_ref:0,wai:0,wave:0,width:0,zero:0},titles:["ammosreader package","ammosreader","ammosreader"],titleterms:{ammosaudiodatahead:0,ammosaudioread:0,ammosaudiosocketread:0,ammoscontain:0,ammosextendedaudiodatahead:0,ammosextendedifdatahead:0,ammosglobalframebodi:0,ammosglobalframehead:0,ammosifdatablock:0,ammosifdatahead:0,ammosifread:0,ammosread:[0,1,2],ammossinglefram:0,content:0,iqdwtxblock:0,modul:0,packag:0,pdw:0,ppdwcontain:0,submodul:0}})
+Search.setIndex({docnames:["ammosreader","index","modules"],envversion:{"sphinx.domains.c":2,"sphinx.domains.changeset":1,"sphinx.domains.citation":1,"sphinx.domains.cpp":5,"sphinx.domains.index":1,"sphinx.domains.javascript":2,"sphinx.domains.math":2,"sphinx.domains.python":3,"sphinx.domains.rst":2,"sphinx.domains.std":2,"sphinx.ext.viewcode":1,sphinx:56},filenames:["ammosreader.rst","index.rst","modules.rst"],objects:{"":[[0,0,0,"-","ammosreader"]],"ammosreader.AmmosAudioDataHeader":[[0,1,1,"","AmmosAudioDataHeader"]],"ammosreader.AmmosAudioDataHeader.AmmosAudioDataHeader":[[0,2,1,"","HEADER_SIZE"],[0,3,1,"","from_bytes"]],"ammosreader.AmmosAudioReader":[[0,1,1,"","AmmosAudioReader"]],"ammosreader.AmmosAudioReader.AmmosAudioReader":[[0,3,1,"","pcm_for_channel"],[0,3,1,"","read_next_audio_data_body"],[0,3,1,"","read_next_global_frame_body"],[0,3,1,"","read_next_global_frame_body_data_header"],[0,3,1,"","read_next_global_frame_body_extended_data_header"]],"ammosreader.AmmosAudioSocketReader":[[0,1,1,"","AmmosAudioSocketReader"]],"ammosreader.AmmosAudioSocketReader.AmmosAudioSocketReader":[[0,3,1,"","read_next_frame"]],"ammosreader.AmmosContainer":[[0,1,1,"","AmmosContainer"]],"ammosreader.AmmosContainer.AmmosContainer":[[0,3,1,"","add_frame"],[0,3,1,"","add_tag"],[0,3,1,"","data_only"],[0,3,1,"","frequencies"],[0,4,1,"","global_frames"],[0,4,1,"","name"],[0,3,1,"","size"]],"ammosreader.AmmosExtendedAudioDataHeader":[[0,1,1,"","AmmosExtendedAudioDataHeader"]],"ammosreader.AmmosExtendedAudioDataHeader.AmmosExtendedAudioDataHeader":[[0,2,1,"","HEADER_SIZE"],[0,3,1,"","from_bytes"]],"ammosreader.AmmosExtendedIFDataHeader":[[0,1,1,"","AmmosExtendedIFDataHeader"]],"ammosreader.AmmosExtendedIFDataHeader.AmmosExtendedIFDataHeader":[[0,2,1,"","HEADER_SIZE"],[0,3,1,"","from_bytes"]],"ammosreader.AmmosGlobalFrameBody":[[0,1,1,"","AmmosGlobalFrameBody"]],"ammosreader.AmmosGlobalFrameBody.AmmosGlobalFrameBody":[[0,4,1,"","data_body"],[0,3,1,"","data_bytes_only"],[0,4,1,"","data_header"]],"ammosreader.AmmosGlobalFrameHeader":[[0,1,1,"","AmmosGlobalFrameHeader"]],"ammosreader.AmmosGlobalFrameHeader.AmmosGlobalFrameHeader":[[0,2,1,"","MAGIC_WORD"],[0,3,1,"","from_bytes"],[0,3,1,"","size"]],"ammosreader.AmmosIFDataBlock":[[0,1,1,"","AmmosIFDataBlock"]],"ammosreader.AmmosIFDataBlock.AmmosIFDataBlock":[[0,4,1,"","data"],[0,4,1,"","header"]],"ammosreader.AmmosIFDataHeader":[[0,1,1,"","AmmosIFDataHeader"]],"ammosreader.AmmosIFDataHeader.AmmosIFDataHeader":[[0,2,1,"","HEADER_SIZE"],[0,3,1,"","from_bytes"]],"ammosreader.AmmosIFReader":[[0,1,1,"","AmmosIFReader"]],"ammosreader.AmmosIFReader.AmmosIFReader":[[0,3,1,"","data"],[0,3,1,"","read_next_global_frame_body"],[0,3,1,"","read_next_global_frame_body_data_header"],[0,3,1,"","read_next_global_frame_body_extended_data_header"],[0,3,1,"","read_next_if_data_body"]],"ammosreader.AmmosSingleFrame":[[0,1,1,"","AmmosSingleFrame"]],"ammosreader.AmmosSingleFrame.AmmosSingleFrame":[[0,3,1,"","data"],[0,4,1,"","global_frame_body"],[0,4,1,"","global_frame_header"],[0,3,1,"","size_correct"]],"ammosreader.IQDWTXBlock":[[0,1,1,"","IQDWTXBLOCK"]],"ammosreader.IQDWTXBlock.IQDWTXBLOCK":[[0,3,1,"","from_bytes"]],"ammosreader.PDW":[[0,1,1,"","PDW"]],"ammosreader.PDW.PDW":[[0,3,1,"","__init__"],[0,3,1,"","from_bytes"],[0,3,1,"","to_json"]],"ammosreader.PPDWContainer":[[0,1,1,"","PPDWContainer"]],"ammosreader.PPDWContainer.PPDWContainer":[[0,3,1,"","add"],[0,3,1,"","bandwidths"],[0,3,1,"","center_frequencies"],[0,3,1,"","channels"],[0,3,1,"","end_time"],[0,3,1,"","julian_date_string"],[0,3,1,"","modulations"],[0,3,1,"","start_time"],[0,3,1,"","to_json"]],ammosreader:[[0,0,0,"-","AmmosAudioDataHeader"],[0,0,0,"-","AmmosAudioReader"],[0,0,0,"-","AmmosAudioSocketReader"],[0,0,0,"-","AmmosContainer"],[0,0,0,"-","AmmosExtendedAudioDataHeader"],[0,0,0,"-","AmmosExtendedIFDataHeader"],[0,0,0,"-","AmmosGlobalFrameBody"],[0,0,0,"-","AmmosGlobalFrameHeader"],[0,0,0,"-","AmmosIFDataBlock"],[0,0,0,"-","AmmosIFDataHeader"],[0,0,0,"-","AmmosIFReader"],[0,0,0,"-","AmmosSingleFrame"],[0,0,0,"-","IQDWTXBlock"],[0,0,0,"-","PDW"],[0,0,0,"-","PPDWContainer"]]},objnames:{"0":["py","module","Python module"],"1":["py","class","Python class"],"2":["py","attribute","Python attribute"],"3":["py","method","Python method"],"4":["py","property","Python property"]},objtypes:{"0":"py:module","1":"py:class","2":"py:attribute","3":"py:method","4":"py:property"},terms:{"0":0,"00":0,"01":0,"1":0,"100":0,"102":0,"1048575":0,"15":0,"16":0,"1970":0,"2":0,"200":0,"204":0,"3":0,"32":0,"359":0,"36":0,"4":0,"409":0,"44":0,"5":0,"56":0,"6":0,"726574fb":0,"76":0,"8":0,"9":0,"90":0,"boolean":0,"byte":0,"class":0,"db\u00b5v":0,"float":0,"import":0,"int":0,"new":0,"return":0,"true":0,IF:0,The:0,__init__:0,a_channel:0,a_pdw:0,abstractammosread:0,access:0,accord:0,add:0,add_fram:0,add_tag:0,after:0,ammo:0,ammosaudiodatahead:[1,2],ammosaudioread:[1,2],ammosaudiosocketread:[1,2],ammoscontain:[1,2],ammosextendedaudiodatahead:[1,2],ammosextendedifdatahead:[1,2],ammosglobalframebodi:[1,2],ammosglobalframehead:[1,2],ammosifdatablock:[1,2],ammosifdatahead:[1,2],ammosifread:[1,2],ammossinglefram:[1,2],an:0,antenna:0,antenna_correct:0,anymor:0,arriv:0,attribut:0,audio:0,automethod:0,azimuth:0,azimuth_confid:0,bandwidth:0,base:0,befor:0,bit:0,block:0,block_count:0,block_length:0,bodi:0,built:0,byte_str:0,can:0,center:0,center_frequ:0,channel:0,classmethod:0,clockwis:0,code:0,confid:0,contain:0,content:[1,2],continu:0,counter:0,creat:0,current:0,data:0,data_bodi:0,data_bytes_onli:0,data_head:0,data_header_length:0,data_header_s:0,data_length:0,data_onli:0,datastream:0,debug:0,decim:0,degre:0,demod_bandwidth:0,demod_typ:0,depend:0,describ:0,detect:0,df_qualiti:0,direct:0,doe:0,e:0,elev:0,embed:0,end_tim:0,etc:0,even:0,extend:0,extract:0,field:0,file:0,file_nam:0,find:0,flag:0,fm:0,format:0,frame:0,frame_length:0,frame_typ:0,frequenc:0,frequency_shift_or_bandwidth:0,from:0,from_byt:0,g:0,given:0,global:0,global_fram:0,global_frame_bodi:0,global_frame_head:0,have:0,header:0,header_s:0,horizont:0,i:0,implement:0,incom:0,incomplet:0,inform:0,insid:0,instanc:0,integ:0,interest:0,interpol:0,iq:0,iqdwtxblock:[1,2],is_puls:0,is_valid:0,julian_date_str:0,khz:0,length:0,level:0,level_unit:0,m:0,magic_word:0,mark:0,mean:0,minu:0,modul:[1,2],mono:0,more:0,multipl:0,name:0,nanosecond:0,ndarrai:0,next:0,none:0,np:0,number:0,number_of_channel:0,number_of_data_block:0,number_of_sampl:0,numpi:0,object:0,one:0,packag:[1,2],param:0,paramet:0,pcm:0,pcm_for_channel:0,pdw:[1,2],pdw_format:0,pdw_format_identifi:0,per:0,percent:0,plu:0,polar:0,posit:0,ppdw:0,ppdwcontain:[1,2],properti:0,provid:0,psk:0,puls:0,pulse_level_or_pulse_field_strength:0,pulse_width:0,qualiti:0,r:0,rais:0,raise:0,rate:0,raw:0,read:0,read_next_audio_data_bodi:0,read_next_fram:0,read_next_global_frame_bodi:0,read_next_global_frame_body_data_head:0,read_next_global_frame_body_extended_data_head:0,read_next_if_data_bodi:0,reader:0,record:0,refer:0,region:0,region_of_interest:0,reserv:0,rtype:0,running_frame_numb:0,s:0,sampl:0,sample_count:0,sample_r:0,sample_s:0,sector:0,serv:0,set:0,signal:0,signal_end_miss:0,signal_start_miss:0,sinc:0,singl:0,size:0,size_correct:0,socket:0,sourc:0,source_id:0,source_st:0,special:0,start:0,start_tim:0,statu:0,step:0,stereo:0,stop:0,store:0,stream_start:0,strength:0,string:0,submodul:[1,2],tag:0,time:0,time_of_arriv:0,timeouterror:0,timestamp:0,to_json:0,tupl:0,type:0,unknown:0,valid:0,valu:0,variou:0,vertic:0,voltage_ref:0,wai:0,wave:0,width:0,word:0,zero:0},titles:["ammosreader package","ammosreader","ammosreader"],titleterms:{ammosaudiodatahead:0,ammosaudioread:0,ammosaudiosocketread:0,ammoscontain:0,ammosextendedaudiodatahead:0,ammosextendedifdatahead:0,ammosglobalframebodi:0,ammosglobalframehead:0,ammosifdatablock:0,ammosifdatahead:0,ammosifread:0,ammosread:[0,1,2],ammossinglefram:0,content:0,iqdwtxblock:0,modul:0,packag:0,pdw:0,ppdwcontain:0,submodul:0}})