mirrors/gnss-sdr
1
0
Fork 0
mirror of https://github.com/gnss-sdr/gnss-sdr synced 2025-10-31 15:23:04 +00:00
Code Issues Releases Wiki Activity

added ishort support into custom_udp_signal_source. removed redundant switch block, made overflow events less confusing with number 0 and added explanation to startup

Browse Source
This commit is contained in:
Lenhart
2021-04-17 18:48:47 +02:00
parent de57a26312
commit aaa0e09c1d
1 changed files with 36 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

63
src/algorithms/signal_source/gnuradio_blocks/gr_complex_ip_packet_source.cc
View File

@@ -27,7 +27,7 @@
#include <boost/bind/bind.hpp> #include <boost/bind/bind.hpp>
#endif #endif
const int FIFO_SIZE = 1472000; const int FIFO_SIZE = 1'472'000;
/* 4 bytes IP address */ /* 4 bytes IP address */
@@ -104,6 +104,7 @@ Gr_Complex_Ip_Packet_Source::Gr_Complex_Ip_Packet_Source(std::string src_device,
gr::io_signature::make(1, 4, item_size)) // 1 to 4 baseband complex channels gr::io_signature::make(1, 4, item_size)) // 1 to 4 baseband complex channels
{ {
std::cout << "Start Ethernet packet capture\n"; std::cout << "Start Ethernet packet capture\n";
std::cout << "Overflow events will be indicated by o's\n";
d_n_baseband_channels = n_baseband_channels; d_n_baseband_channels = n_baseband_channels;
if (wire_sample_type == "cbyte") if (wire_sample_type == "cbyte")
@@ -121,6 +122,11 @@ Gr_Complex_Ip_Packet_Source::Gr_Complex_Ip_Packet_Source(std::string src_device,
d_wire_sample_type = 3; d_wire_sample_type = 3;
d_bytes_per_sample = d_n_baseband_channels * 8; d_bytes_per_sample = d_n_baseband_channels * 8;
} }
else if (wire_sample_type == "ishort")
{
d_wire_sample_type = 4;
d_bytes_per_sample = d_n_baseband_channels * 4;
}
else else
{ {
std::cout << "Unknown wire sample type\n"; std::cout << "Unknown wire sample type\n";
@@ -307,7 +313,7 @@ void Gr_Complex_Ip_Packet_Source::pcap_callback(__attribute__((unused)) u_char *
else else
{ {
// notify overflow // notify overflow
std::cout << "O" << std::flush; std::cout << "o" << std::flush;
} }
} }
} }
@@ -397,6 +403,25 @@ void Gr_Complex_Ip_Packet_Source::demux_samples(const gr_vector_void_star &outpu
} }
} }
break; break;
case 4: // interleaved short samples
for (const auto &output_item : output_items)
{
int16_t real;
int16_t imag;
memcpy(&real, &fifo_buff[fifo_read_ptr], sizeof(real));
fifo_read_ptr += 2; // two bytes in short
memcpy(&imag, &fifo_buff[fifo_read_ptr], sizeof(imag));
fifo_read_ptr += 2; // two bytes in short
if (d_IQ_swap)
{
static_cast<gr_complex *>(output_item)[n] = gr_complex(real, imag);
}
else
{
static_cast<gr_complex *>(output_item)[n] = gr_complex(imag, real);
}
}
break;
default: default:
std::cout << "Unknown wire sample type\n"; std::cout << "Unknown wire sample type\n";
exit(0); exit(0);
@@ -422,36 +447,20 @@ int Gr_Complex_Ip_Packet_Source::work(int noutput_items,
if (output_items.size() > static_cast<uint64_t>(d_n_baseband_channels)) if (output_items.size() > static_cast<uint64_t>(d_n_baseband_channels))
{ {
std::cout << "Configuration error: more baseband channels connected than the available in the UDP source\n"; std::cout << "Configuration error: more baseband channels connected than available in the UDP source\n";
exit(0); exit(0);
} }
int num_samples_readed; int num_samples_readed;
int bytes_requested; int bytes_requested;
switch (d_wire_sample_type)
bytes_requested = noutput_items * d_bytes_per_sample;
if (bytes_requested < fifo_items)
{ {
case 1: // complex byte samples num_samples_readed = noutput_items; // read all
case 2: // complex 4 bits samples }
case 3: // complex float samples else
bytes_requested = noutput_items * d_bytes_per_sample; {
if (bytes_requested < fifo_items) num_samples_readed = fifo_items / d_bytes_per_sample; // read what we have
{
num_samples_readed = noutput_items; // read all
}
else
{
num_samples_readed = fifo_items / d_bytes_per_sample; // read what we have
}
break;
default: // complex byte samples
bytes_requested = noutput_items * d_bytes_per_sample;
if (bytes_requested < fifo_items)
{
num_samples_readed = noutput_items; // read all
}
else
{
num_samples_readed = fifo_items / d_bytes_per_sample; // read what we have
}
} }
bytes_requested = num_samples_readed * d_bytes_per_sample; bytes_requested = num_samples_readed * d_bytes_per_sample;