github-mirrors/blah2
1
0
Fork 0
mirror of https://github.com/30hours/blah2.git synced 2024-11-18 12:33:58 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Running on single channel

Browse source
This commit is contained in:
30hours 2024-01-13 22:36:53 +00:00
parent 27d8994914
commit 758b495716
2 changed files with 8 additions and 39 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
CMakeLists.txt
View file

@ -63,6 +63,7 @@ target_link_libraries(blah2 PRIVATE
ryml::ryml ryml::ryml
httplib::httplib httplib::httplib
armadillo armadillo
${UHD_LIBRARIES}
fftw3 fftw3
fftw3_threads fftw3_threads
sdrplay sdrplay

46
src/capture/usrp/Usrp.cpp
View file

@ -23,10 +23,8 @@ Usrp::Usrp(uint32_t _fc, std::string _path)
std::string Usrp::set_file(std::string path) std::string Usrp::set_file(std::string path)
{ {
char buffer[15]; // todo: deprecate
gettimeofday(&start_tm, NULL); return "/blah2/tmp.iq";
strftime(buffer, 16, "%Y%m%d-%H%M%S", localtime(&start_tm.tv_sec));
return path + buffer + ".usrp";
} }
void Usrp::start() void Usrp::start()
@ -92,21 +90,19 @@ void Usrp::process(IqData *buffer1, IqData *buffer2)
buffer2->lock(); buffer2->lock();
for (size_t i = 0; i < buffer.size(); i++) for (size_t i = 0; i < buffer.size(); i++)
{ {
buffer1->push_back({(double)buffer[i][0], (double)buffer[i][1]}) buffer1->push_back({(double)buffer[i].real(), (double)buffer[i].imag()});
buffer2->push_back({(double)buffer[i].real(), (double)buffer[i].imag()});
} }
buffer1->unlock(); buffer1->unlock();
buffer2->unlock(); buffer2->unlock();
} }
} }
void Usrp::replay(IqData *_buffer1, IqData *_buffer2, std::string _file, bool _loop) void Usrp::replay(IqData *buffer1, IqData *buffer2, std::string _file, bool _loop)
{ {
buffer1 = _buffer1;
buffer2 = _buffer2;
short i1, q1, i2, q2; short i1, q1, i2, q2;
int rv; int rv;
file_replay = fopen(_file.c_str(), "rb"); FILE *file_replay = fopen(_file.c_str(), "rb");
while (true) while (true)
{ {
@ -133,40 +129,12 @@ void Usrp::replay(IqData *_buffer1, IqData *_buffer2, std::string _file, bool _l
void Usrp::open_file() void Usrp::open_file()
{ {
file = set_file(path);
char time_tx[BUFFER_SIZE_NR];
// get start date and time
gettimeofday(&start_tm, NULL);
strftime(time_tx, sizeof(time_tx), "%d %b %Y %H:%M:%S", localtime(&start_tm.tv_sec));
fprintf(stderr, "Info - start - start_tm: %s.%03ld\n", time_tx, start_tm.tv_usec / 1000);
//validate();
// open files
if (chunk_time_nr == 0)
{
out_file_fp = fopen(file.c_str(), "wb");
if (out_file_fp == NULL)
{
fprintf(stderr, "Error - start - opening output file %s\n", file.c_str());
exit(1);
}
fprintf(stderr, "Info - start - output file %s\n", file.c_str());
}
return; return;
} }
void Usrp::close_file() void Usrp::close_file()
{ {
if (out_file_fp != NULL) return;
{
fclose(out_file_fp);
}
} }