X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fsession.cpp;h=eec1a051b5a8838ba3f81b58c0759adbadb024a9;hp=0fef9c91764bc75366bc8db57cfd6880783465b3;hb=de060a86f27bea5d459d4d2d1fc097815cefcd8a;hpb=83b1c8d251386ac1980284c4668cbdd8e425550f diff --git a/pv/session.cpp b/pv/session.cpp index 0fef9c91..eec1a051 100644 --- a/pv/session.cpp +++ b/pv/session.cpp @@ -17,30 +17,25 @@ * along with this program; if not, see . */ -#ifdef _WIN32 -// Windows: Avoid boost/thread namespace pollution (which includes windows.h). -#define NOGDI -#define NORESOURCE -#endif - #include #include +#include #include #include #include -#include "session.hpp" #include "devicemanager.hpp" +#include "session.hpp" #include "data/analog.hpp" #include "data/analogsegment.hpp" +#include "data/decode/decoder.hpp" #include "data/decoderstack.hpp" #include "data/logic.hpp" #include "data/logicsegment.hpp" #include "data/signalbase.hpp" -#include "data/decode/decoder.hpp" #include "devices/hardwaredevice.hpp" #include "devices/inputfile.hpp" @@ -77,6 +72,7 @@ using std::recursive_mutex; using std::runtime_error; using std::shared_ptr; using std::string; +using std::unique_ptr; using std::unordered_set; using std::vector; @@ -810,7 +806,7 @@ void Session::update_signals() } default: - assert(0); + assert(false); break; } } @@ -859,7 +855,7 @@ void Session::sample_thread_proc(function error_handler) // Confirm that SR_DF_END was received if (cur_logic_segment_) { qDebug("SR_DF_END was not received."); - assert(0); + assert(false); } // Optimize memory usage @@ -981,12 +977,15 @@ void Session::feed_in_analog(shared_ptr analog) const vector> channels = analog->channels(); const unsigned int channel_count = channels.size(); const size_t sample_count = analog->num_samples() / channel_count; - const float *data = static_cast(analog->data_pointer()); bool sweep_beginning = false; + unique_ptr data(new float[analog->num_samples()]); + analog->get_data_as_float(data.get()); + if (signalbases_.empty()) update_signals(); + float *channel_data = data.get(); for (auto channel : channels) { shared_ptr segment; @@ -1020,7 +1019,7 @@ void Session::feed_in_analog(shared_ptr analog) assert(segment); // Append the samples in the segment - segment->append_interleaved_samples(data++, sample_count, + segment->append_interleaved_samples(channel_data++, sample_count, channel_count); } @@ -1035,7 +1034,7 @@ void Session::feed_in_analog(shared_ptr analog) void Session::data_feed_in(shared_ptr device, shared_ptr packet) { - static bool frame_began=false; + static bool frame_began = false; (void)device;