14 #include "NetworkAnalogOut.pb.h"
15 #include "NetworkAnalogOut.grpc.pb.h"
19 template <
typename BaseInstr,
typename std::enable_if_t<std::is_base_of_v<AnalogOut, BaseInstr>,
int>,
typename... gRPCStubs>
20 class NetworkAnalogOutT;
22 namespace NetworkAnalogOutTasks
24 template <
typename BaseInstr,
typename std::enable_if_t<std::is_base_of_v<AnalogOut, BaseInstr>,
int>,
typename... gRPCStubs>
38 virtual bool ApplyLimits() const noexcept
override {
return false; }
41 template <
typename BaseInstr,
typename std::enable_if_t<std::is_base_of_v<AnalogOut, BaseInstr>,
int>,
typename... gRPCStubs>
52 template <
typename BaseInstr,
typename std::enable_if_t<std::is_base_of_v<AnalogOut, BaseInstr>,
int>,
typename... gRPCStubs>
63 template <
typename BaseInstr,
typename std::enable_if_t<std::is_base_of_v<AnalogOut, BaseInstr>,
int>,
typename... gRPCStubs>
72 DynExpProto::NetworkAnalogOut::SampleMessage SampleMsg;
73 SampleMsg.set_value(
Sample);
78 StubPtr = InstrData->template GetStub<DynExpProto::NetworkAnalogOut::NetworkAnalogOut>();
81 InvokeStubFunc(StubPtr, &DynExpProto::NetworkAnalogOut::NetworkAnalogOut::Stub::SetAsync, SampleMsg);
89 template <
typename BaseInstr,
typename std::enable_if_t<std::is_base_of_v<AnalogOut, BaseInstr>,
int>,
typename... gRPCStubs>
101 StubPtr = InstrData->template GetStub<DynExpProto::NetworkAnalogOut::NetworkAnalogOut>();
104 InvokeStubFunc(StubPtr, &DynExpProto::NetworkAnalogOut::NetworkAnalogOut::Stub::SetDefault, {});
111 template <
typename BaseInstr,
typename std::enable_if_t<std::is_base_of_v<AnalogOut, BaseInstr>,
int>,
typename... gRPCStubs>
130 template <
typename BaseInstr,
typename std::enable_if_t<std::is_base_of_v<AnalogOut, BaseInstr>,
int>,
typename... gRPCStubs>
137 virtual const char*
GetParamClassTag() const noexcept
override {
return "NetworkAnalogOutParams"; }
153 template <
typename BaseInstr,
typename std::enable_if_t<std::is_base_of_v<AnalogOut, BaseInstr>,
int>,
typename... gRPCStubs>
167 template <
typename BaseInstr,
typename std::enable_if_t<std::is_base_of_v<AnalogOut, BaseInstr>,
int>,
typename... gRPCStubs>
176 constexpr
static auto Name() noexcept {
return "Network Analog Out"; }
188 auto InstrData = dynamic_InstrumentData_cast<NetworkAnalogOutT>(this->GetInstrumentData());
189 StubPtr = InstrData->template GetStub<StubType>();
192 auto Response =
InvokeStubFunc(StubPtr, &StubType::Stub::GetHardwareLimits, {});
194 return Response.lowerlimit();
201 auto InstrData = dynamic_InstrumentData_cast<NetworkAnalogOutT>(this->GetInstrumentData());
202 StubPtr = InstrData->template GetStub<StubType>();
205 auto Response =
InvokeStubFunc(StubPtr, &StubType::Stub::GetHardwareLimits, {});
207 return Response.upperlimit();
214 auto InstrData = dynamic_InstrumentData_cast<NetworkAnalogOutT>(this->GetInstrumentData());
215 StubPtr = InstrData->template GetStub<StubType>();
218 auto Response =
InvokeStubFunc(StubPtr, &StubType::Stub::GetHardwareResolution, {});
220 return Response.resolution();
227 auto InstrData = dynamic_InstrumentData_cast<NetworkAnalogOutT>(this->GetInstrumentData());
228 StubPtr = InstrData->template GetStub<StubType>();
231 auto Response =
InvokeStubFunc(StubPtr, &StubType::Stub::GetValueUnit, {});
240 auto InstrData = dynamic_InstrumentData_cast<NetworkAnalogOutT>(this->GetInstrumentData());
241 StubPtr = InstrData->template GetStub<StubType>();
244 auto Response =
InvokeStubFunc(StubPtr, &StubType::Stub::GetUserLimits, {});
246 return Response.lowerlimit();
253 auto InstrData = dynamic_InstrumentData_cast<NetworkAnalogOutT>(this->GetInstrumentData());
254 StubPtr = InstrData->template GetStub<StubType>();
257 auto Response =
InvokeStubFunc(StubPtr, &StubType::Stub::GetUserLimits, {});
259 return Response.upperlimit();
270 DynExpProto::NetworkAnalogOut::SampleMessage SampleMsg;
271 SampleMsg.set_value(Sample);
275 auto InstrData = dynamic_InstrumentData_cast<NetworkAnalogOutT>(this->GetInstrumentData());
276 StubPtr = InstrData->template GetStub<StubType>();
Defines a meta instrument for a single analog output port to write a data stream consisting of analog...
Implementation of a gRPC client instrument to access a remote data stream meta instrument.
void DisableUserEditable()
Calls DynExp::ParamsBase::DisableUserEditable() on all bundled parameters.
SampleT SampleType
Alias for SampleT.
UnitType
Units which can be used for data stream instruments.
double ValueType
Data type to represent hardware limits on the sample values to write to the hardware adapter assigned...
@ UserDefined
Arbitrary waveform.
NetworkAnalogOutConfigurator()=default
virtual DynExp::ParamsBasePtrType MakeParams(DynExp::ItemIDType ID, const DynExp::DynExpCore &Core) const override
Override to make derived classes call DynExp::MakeParams with the correct configurator type derived f...
virtual ~NetworkAnalogOutConfigurator()=default
NetworkAnalogOutData(size_t BufferSizeInSamples=1)
virtual ~NetworkAnalogOutData()=default
virtual void ResetImpl(DynExp::InstrumentDataBase::dispatch_tag< NetworkAnalogOutData >)
void ResetImpl(DynExp::InstrumentDataBase::dispatch_tag< NetworkDataStreamInstrumentData< BaseInstr, 0, gRPCStubs... >>) override final
virtual void ConfigureParamsImpl(DynExp::ParamsBase::dispatch_tag< NetworkAnalogOutParams >)
virtual ~NetworkAnalogOutParams()=default
DynExp::ParamsBase::DummyParam Dummy
void ConfigureParamsImpl(DynExp::ParamsBase::dispatch_tag< NetworkDataStreamInstrumentParams< BaseInstr, 0, gRPCStubs... >>) override final
virtual const char * GetParamClassTag() const noexcept override
This function is intended to be overridden once in each derived class returning the name of the respe...
NetworkAnalogOutParams(DynExp::ItemIDType ID, const DynExp::DynExpCore &Core)
virtual DataStreamInstrumentData::ValueType GetHardwareMinValue() const override
void ResetImpl(DynExp::Object::dispatch_tag< NetworkDataStreamInstrumentT< BaseInstr, 0, gRPCStubs... >>) override final
virtual DataStreamInstrumentData::ValueType GetHardwareResolution() const override final
constexpr static auto Name() noexcept
virtual void ReadData(DynExp::TaskBase::CallbackType CallbackFunc=nullptr) const override
virtual void SetSync(AnalogOutData::SampleStreamType::SampleType Sample) const override
virtual void ResetImpl(DynExp::Object::dispatch_tag< NetworkAnalogOutT >)
virtual std::unique_ptr< DynExp::InitTaskBase > MakeInitTask() const override
Factory function for an init task (InitTaskBase). Override to define the desired initialization task ...
virtual void Set(AnalogOutData::SampleStreamType::SampleType Sample, DynExp::TaskBase::CallbackType CallbackFunc=nullptr) const override
virtual DataStreamInstrumentData::ValueType GetUserMaxValue() const override
NetworkAnalogOutT(const std::thread::id OwnerThreadID, DynExp::ParamsBasePtrType &&Params)
virtual DataStreamInstrumentData::ValueType GetUserMinValue() const override
virtual void SetDefault(DynExp::TaskBase::CallbackType CallbackFunc=nullptr) const override
virtual DataStreamInstrumentData::ValueType GetHardwareMaxValue() const override
virtual ~NetworkAnalogOutT()
virtual std::string GetName() const override
Returns the name of this Object type.
virtual std::unique_ptr< DynExp::ExitTaskBase > MakeExitTask() const override
Factory function for an exit task (ExitTaskBase). Override to define the desired deinitialization tas...
virtual Util::FeatureTester< FunctionGenerator::WaveformCapsType > GetWaveformCapsChild() const override
DynExpProto::NetworkAnalogOut::NetworkAnalogOut StubType
virtual std::unique_ptr< DynExp::UpdateTaskBase > MakeUpdateTask() const override
Factory function for an update task (UpdateTaskBase). Override to define the desired update task in d...
virtual DataStreamInstrumentData::UnitType GetValueUnit() const override
void ExitFuncImpl(DynExp::ExitTaskBase::dispatch_tag< NetworkDataStreamInstrumentTasks::ExitTask< BaseInstr, 0, gRPCStubs... >>, DynExp::InstrumentInstance &Instance) override final
virtual void ExitFuncImpl(DynExp::ExitTaskBase::dispatch_tag< ExitTask >, DynExp::InstrumentInstance &Instance)
void InitFuncImpl(DynExp::InitTaskBase::dispatch_tag< NetworkDataStreamInstrumentTasks::InitTask< BaseInstr, 0, gRPCStubs... >>, DynExp::InstrumentInstance &Instance) override final
virtual bool ApplyLimits() const noexcept override
Disable setting data stream limits in AnalogOutTasks::InitTask::InitFuncImpl() since limits are manag...
virtual void InitFuncImpl(DynExp::InitTaskBase::dispatch_tag< InitTask >, DynExp::InstrumentInstance &Instance)
virtual DynExp::TaskResultType RunChild(DynExp::InstrumentInstance &Instance) override
Runs the task. Override RunChild() to define a derived task's action(s). Any exception leaving RunChi...
SetDefaultTask(CallbackType CallbackFunc) noexcept
const AnalogOutData::SampleStreamType::SampleType Sample
virtual DynExp::TaskResultType RunChild(DynExp::InstrumentInstance &Instance) override
Runs the task. Override RunChild() to define a derived task's action(s). Any exception leaving RunChi...
SetTask(AnalogOutData::SampleStreamType::SampleType Sample, CallbackType CallbackFunc) noexcept
virtual void UpdateFuncImpl(DynExp::UpdateTaskBase::dispatch_tag< UpdateTask >, DynExp::InstrumentInstance &Instance)
void UpdateFuncImpl(DynExp::UpdateTaskBase::dispatch_tag< NetworkDataStreamInstrumentTasks::UpdateTask< BaseInstr, 0, gRPCStubs... >>, DynExp::InstrumentInstance &Instance) override final
Data stream instrument for bidirectional gRPC communication.
void DisableUserEditable()
Calls DynExp::ParamsBase::DisableUserEditable() on all bundled parameters.
DynExp's core class acts as the interface between the user interface and DynExp's internal data like ...
Refer to DynExp::ParamsBase::dispatch_tag.
Refer to DynExp::ParamsBase::dispatch_tag.
void MakeAndEnqueueTask(ArgTs &&...Args) const
Calls MakeTask() to construct a new task and subsequently enqueues the task into the instrument's tas...
Refer to ParamsBase::dispatch_tag.
Defines data for a thread belonging to a InstrumentBase instance. Refer to RunnableInstance.
const InstrumentBase::InstrumentDataGetterType InstrumentDataGetter
Getter for instrument's data. Refer to InstrumentBase::InstrumentDataGetterType.
Refer to ParamsBase::dispatch_tag.
Dummy parameter which is to be owned once by parameter classes that do not contain any other paramete...
Tag for function dispatching mechanism within this class used when derived classes are not intended t...
Base class for all tasks being processed by instruments. The class must not contain public virtual fu...
std::function< void(const TaskBase &, ExceptionContainer &)> CallbackType
Type of a callback function which is invoked when a task has finished, failed or has been aborted....
TaskBase(CallbackType CallbackFunc=nullptr) noexcept
Constructs an instrument task.
const CallbackType CallbackFunc
This callback function is called after the task has finished (either successfully or not) with a refe...
Defines the return type of task functions.
Refer to DynExp::ParamsBase::dispatch_tag.
Holds a bitset containing flags to indicate which features a certain instrument/ module etc....
DynExp's instrument namespace contains the implementation of DynExp instruments which extend DynExp's...
ResponseMsgType InvokeStubFunc(StubPtrType< gRPCStub > StubPtr, StubFuncPtrType< gRPCStub, RequestMsgType, ResponseMsgType > StubFunc, const RequestMsgType &RequestMsg)
Invokes a gRPC stub function as a remote procedure call. Waits for a fixed amount of time (2 seconds)...
std::shared_ptr< typename gRPCStub::Stub > StubPtrType
Alias for a pointer to a gRPC stub.
constexpr DataStreamInstrumentData::UnitType ToDataStreamInstrumentUnitType(DynExpProto::Common::UnitType Unit)
NetworkAnalogOutT< AnalogOut, 0, typename NetworkDataStreamInstrument::StubType, DynExpProto::NetworkAnalogOut::NetworkAnalogOut > NetworkAnalogOut
Explicit instantiation of derivable class NetworkAnalogOutT to create the network analog out instrume...
std::unique_ptr< TaskT > MakeTask(ArgTs &&...Args)
Factory function to create a task to be enqueued in an instrument's task queue.
auto dynamic_InstrumentData_cast(Util::SynchronizedPointer< From > &&InstrumentDataPtr)
Casts the data base class From into a derived InstrumentBase's (To) data class keeping the data locke...
std::unique_ptr< ParamsBase > ParamsBasePtrType
Alias for a pointer to the parameter system base class ParamsBase.
size_t ItemIDType
ID type of objects/items managed by DynExp.
Accumulates include statements to provide a precompiled header.