aboutsummaryrefslogtreecommitdiffstats
path: root/src/gr-fadingui
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/gr-fadingui/grc/CMakeLists.txt3
-rw-r--r--src/gr-fadingui/grc/fadingui_phasecorrection.block.yml25
-rw-r--r--src/gr-fadingui/python/CMakeLists.txt3
-rw-r--r--src/gr-fadingui/python/__init__.py1
-rw-r--r--src/gr-fadingui/python/phasecorrection.py124
5 files changed, 154 insertions, 2 deletions
diff --git a/src/gr-fadingui/grc/CMakeLists.txt b/src/gr-fadingui/grc/CMakeLists.txt
index 79c1a31..e3422d5 100644
--- a/src/gr-fadingui/grc/CMakeLists.txt
+++ b/src/gr-fadingui/grc/CMakeLists.txt
@@ -23,5 +23,6 @@ install(FILES
fadingui_frame_obj.block.yml
fadingui_multipath_fading.block.yml
fadingui_ber.block.yml
- fadingui_netsink.block.yml DESTINATION share/gnuradio/grc/blocks
+ fadingui_netsink.block.yml
+ fadingui_phasecorrection.block.yml DESTINATION share/gnuradio/grc/blocks
)
diff --git a/src/gr-fadingui/grc/fadingui_phasecorrection.block.yml b/src/gr-fadingui/grc/fadingui_phasecorrection.block.yml
new file mode 100644
index 0000000..d70ea2f
--- /dev/null
+++ b/src/gr-fadingui/grc/fadingui_phasecorrection.block.yml
@@ -0,0 +1,25 @@
+id: fadingui_phasecorrection
+label: Fine Phase and Freq Correction
+category: '[fadingui]'
+
+parameters:
+
+templates:
+ imports: import fadingui
+ make: fadingui.phasecorrection()
+
+inputs:
+- label: in
+ domain: stream
+ dtype: complex
+ vlen: 1
+
+outputs:
+- label: out
+ domain: stream
+ dtype: complex
+ vlen: 1
+
+# 'file_format' specifies the version of the GRC yml format used in the file
+# and should usually not be changed.
+file_format: 1
diff --git a/src/gr-fadingui/python/CMakeLists.txt b/src/gr-fadingui/python/CMakeLists.txt
index bf484cc..ce22d9e 100644
--- a/src/gr-fadingui/python/CMakeLists.txt
+++ b/src/gr-fadingui/python/CMakeLists.txt
@@ -38,7 +38,8 @@ GR_PYTHON_INSTALL(
frame_obj.py
multipath_fading.py
ber.py
- netsink.py DESTINATION ${GR_PYTHON_DIR}/fadingui
+ netsink.py
+ phasecorrection.py DESTINATION ${GR_PYTHON_DIR}/fadingui
)
########################################################################
diff --git a/src/gr-fadingui/python/__init__.py b/src/gr-fadingui/python/__init__.py
index 56dbdd3..c68c7df 100644
--- a/src/gr-fadingui/python/__init__.py
+++ b/src/gr-fadingui/python/__init__.py
@@ -40,5 +40,6 @@ from .frame_obj import frame_obj
from .multipath_fading import multipath_fading
from .ber import ber
from .netsink import netsink
+from .phasecorrection import phasecorrection
#
diff --git a/src/gr-fadingui/python/phasecorrection.py b/src/gr-fadingui/python/phasecorrection.py
new file mode 100644
index 0000000..7d79529
--- /dev/null
+++ b/src/gr-fadingui/python/phasecorrection.py
@@ -0,0 +1,124 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+import pmt
+
+import numpy as np
+from gnuradio import gr
+
+import fadingui.logger
+
+from fadingui.logger import get_logger
+log = get_logger("phasecorrection")
+
+class phasecorrection(gr.sync_block):
+ """
+ Apply phase and frequency correction where there is a correlation peak tag.
+
+ The correlation peak tags are NOT propagated, and instead replaced with a
+ frame_start tag.
+ """
+ def __init__(self):
+ gr.sync_block.__init__(
+ self,
+ name='Phase and Frequency Correction',
+ in_sig=[np.complex64],
+ out_sig=[np.complex64]
+ )
+
+ # tags should not be propagated, we then output our own tags
+ self.set_tag_propagation_policy(gr.TPP_DONT)
+
+ # because we do block processing, we need to keep track of the last tag
+ # of the previous block to correct the first values of the next block
+ self.last = None
+ self.lastfreq = 0
+
+ def block_phase(self, start, end):
+ """
+ Compute a vector for the phase and frequency correction for the samples
+ between two tags (start and end).
+
+ @param start Tag where the samples should start to be corrected
+ @param end Tag where to stop correcting
+
+ @return A vector of phase values for each sample. To correct the samples
+ the data should be multiplied with np.exp(-1j * phase)
+ """
+ # compute number of samples between tags
+ nsamples = end.offset - start.offset
+
+ # unpack pmt values into start and end phase
+ sphase = pmt.to_python(start.value)
+ ephase = pmt.to_python(end.value)
+
+ # compute frequency offset between start and end
+ phasediff = (ephase - sphase) % (2 * np.pi)
+ freq = phasediff / nsamples
+
+ # save this one for the last block (see variable `end' in self.work)
+ self.lastfreq = freq
+
+ # debugging
+ log.debug(f"Correction for chunk of {nsamples:2d} samples is " \
+ f"sphase={sphase: .4f} rad and freq={freq*1e3: .4f}e-3 rad / sample")
+
+ # compute chunk values
+ return sphase * np.ones(nsamples) + freq * np.arange(0, nsamples)
+
+ def work(self, input_items, output_items):
+ counter = self.nitems_written(0)
+
+ # nicer aliases
+ inp = input_items[0]
+ out = output_items[0]
+
+ # read phase tags
+ is_phase = lambda tag: pmt.to_python(tag.key) == "phase_est"
+ tags = list(filter(is_phase, self.get_tags_in_window(0, 0, len(inp))))
+
+ if not tags:
+ log.warning(f"There were no tags in {len(inp)} samples!")
+ out[:] = inp
+ return len(out)
+
+ # debugging
+ log.debug(f"Processing {len(tags)} tags = {tags[-1].offset - tags[0].offset} " \
+ f"samples out of {len(inp)} input samples")
+
+ # compute "the middle"
+ enough_samples = lambda pair: ((pair[1].offset - pair[0].offset) > 0)
+ pairs = list(filter(enough_samples, zip(tags, tags[1:])))
+ chunks = [ self.block_phase(start, end) for (start, end) in pairs ]
+ middle = np.concatenate(chunks) if chunks else []
+
+ # compute values at the end, we do not have informations about the future
+ # but we can use the frequency of the last tag to approximate
+ nback = len(inp) - (tags[-1].offset - counter)
+ log.debug(f"Processing {nback} samples at the back of the buffer")
+ end = np.ones(nback) * pmt.to_python(tags[-1].value) \
+ + self.lastfreq * np.arange(0, nback)
+
+ # compute the "start", using the last tag from the previous call
+ nfront = tags[0].offset - counter
+ log.debug(f"Processing {nfront} samples at the front of the buffer")
+ start = self.block_phase(self.last, tags[0])[-nfront:] \
+ if self.last and nfront else np.zeros(nfront)
+
+ # compute correction
+ correction = np.exp(-1j * np.concatenate([start, middle, end]))
+ length = len(correction)
+
+ # write outputs
+ out[:length] = inp[:length] * correction
+
+ # save last tag for next call
+ self.last = tags[-1]
+
+ # add tags
+ for tag in tags:
+ self.add_item_tag(0, tag.offset, pmt.intern("frame_start"), pmt.PMT_T)
+
+ # FIXME: should return `length' but then the last sample is not
+ # included and self.last does something weird
+ return len(out) \ No newline at end of file