qoherent/ria-toolkit-oss
13
6
Fork 0
Code Issues Pull Requests Workflows Packages Projects Releases 3 Wiki Activity

SDR Package #3

Merged
michael merged 22 commits from sdr into main 2025-10-03 13:34:25 -04:00
Conversation 0 Commits 22 Files Changed 28 +4 -4
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 0f5f36b103 - Show all commits

8
src/ria_toolkit_oss/sdr/pluto.py
View File

@ -102,7 +102,7 @@ class Pluto(SDR):
if channel == 0: if channel == 0:
print(f"Pluto gain = {self.radio.rx_hardwaregain_chan0}") print(f"Pluto gain = {self.radio.rx_hardwaregain_chan0}")
elif channel == 1: elif channel == 1:
self.set_tx_gain(gain=abs_gain, channel=0) self.set_rx_gain(gain=abs_gain, channel=0)
print(f"Pluto gain = {self.radio.rx_hardwaregain_chan0}, {self.radio.rx_hardwaregain_chan1}") print(f"Pluto gain = {self.radio.rx_hardwaregain_chan0}, {self.radio.rx_hardwaregain_chan1}")
self.radio.rx_buffer_size = 1024 # TODO deal with this for zmq self.radio.rx_buffer_size = 1024 # TODO deal with this for zmq
@ -223,7 +223,7 @@ class Pluto(SDR):
print("Pluto Starting RX...") print("Pluto Starting RX...")
samples = self.radio.rx() samples = self.radio.rx()
if self.radio.tx_enabled_channels == [0]: if self.radio.rx_enabled_channels == [0]:
samples = self._convert_rx_samples(samples) samples = self._convert_rx_samples(samples)
samples = [samples] samples = [samples]
else: else:
@ -244,11 +244,11 @@ class Pluto(SDR):
def _format_tx_data(self, recording: Recording | np.ndarray | list): def _format_tx_data(self, recording: Recording | np.ndarray | list):
if isinstance(recording, np.ndarray): if isinstance(recording, np.ndarray):
data = [self._convert_tx_samples(samples=recording)] data = self._convert_tx_samples(samples=recording)
elif isinstance(recording, Recording): elif isinstance(recording, Recording):
if self.radio.tx_enabled_channels == [0]: if self.radio.tx_enabled_channels == [0]:
samples = recording.data[0] samples = recording.data[0]
data = [self._convert_tx_samples(samples=samples)] data = self._convert_tx_samples(samples=samples)
if len(recording.data) > 1: if len(recording.data) > 1:
warnings.warn("Recording object is multichannel, only channel 0 data was used for transmission") warnings.warn("Recording object is multichannel, only channel 0 data was used for transmission")