group_(nullptr),
conversion_type_(NoConversion),
min_value_(0),
- max_value_(0)
+ max_value_(0),
+ error_message_("")
{
if (channel_) {
internal_name_ = QString::fromStdString(channel_->name());
return bgcolor_;
}
+QString SignalBase::get_error_message() const
+{
+ return error_message_;
+}
+
void SignalBase::set_data(shared_ptr<pv::data::SignalData> data)
{
if (data_) {
shared_ptr<data::Analog> SignalBase::analog_data() const
{
+ if (!data_)
+ return nullptr;
+
return dynamic_pointer_cast<Analog>(data_);
}
shared_ptr<data::Logic> SignalBase::logic_data() const
{
+ if (!data_)
+ return nullptr;
+
shared_ptr<Logic> result = dynamic_pointer_cast<Logic>(data_);
if (((conversion_type_ == A2LConversionByThreshold) ||
lsegment->append_payload(logic->data_pointer(), logic->data_length());
samples_added(lsegment->segment_id(), i, i + ConversionBlockSize);
+
i += ConversionBlockSize;
}
// Only advance to next segment if the current input segment is complete
if (asegment->is_complete() &&
analog_data->analog_segments().size() > logic_data->logic_segments().size()) {
+
// There are more segments to process
segment_id++;
logic_data->push_segment(new_segment);
lsegment = logic_data->logic_segments().back();
- } else {
- // No more samples/segments to process, wait for data or interrupt
- if (!conversion_interrupt_) {
- unique_lock<mutex> input_lock(conversion_input_mutex_);
- conversion_input_cond_.wait(input_lock);
- }
+ }
+
+ // No more samples/segments to process, wait for data or interrupt
+ if (!conversion_interrupt_) {
+ unique_lock<mutex> input_lock(conversion_input_mutex_);
+ conversion_input_cond_.wait(input_lock);
}
} while (!conversion_interrupt_);
}
if (converted_data_)
converted_data_->clear();
+
samples_cleared();
conversion_interrupt_ = false;
- conversion_thread_ = std::thread(
- &SignalBase::conversion_thread_proc, this);
+ conversion_thread_ = std::thread(&SignalBase::conversion_thread_proc, this);
+}
+
+void SignalBase::set_error_message(QString msg)
+{
+ error_message_ = msg;
+ // TODO Emulate noquote()
+ qDebug().nospace() << name() << ": " << msg;
+
+ error_message_changed(msg);
}
void SignalBase::stop_conversion()