pvac::detail::PutBuilder::Exec Struct Reference

Inheritance diagram for pvac::detail::PutBuilder::Exec:

Collaboration diagram for pvac::detail::PutBuilder::Exec:

Public Member Functions
	Exec (detail::PutBuilder &builder)
virtual	~Exec ()
virtual void	putBuild (const epics::pvData::StructureConstPtr &build, Args &args) OVERRIDE FINAL
virtual void	putDone (const PutEvent &evt) OVERRIDE FINAL
	Put operation is complete. More...
Public Member Functions inherited from pvac::ClientChannel::PutCallback
virtual	~PutCallback ()

Public Attributes
detail::PutBuilder &	builder
pvac::PutEvent	result

Detailed Description

Definition at line 141 of file clientSync.cpp.

Constructor & Destructor Documentation

pvac::detail::PutBuilder::Exec::Exec ( detail::PutBuilder &  builder )

inline

Definition at line 147 of file clientSync.cpp.

        :builder(builder)
    {}

virtual pvac::detail::PutBuilder::Exec::~Exec ( )

inlinevirtual

Definition at line 150 of file clientSync.cpp.

{}

Member Function Documentation

virtual void pvac::detail::PutBuilder::Exec::putBuild ( const epics::pvData::StructureConstPtr &  build, Args &  args  )

inlinevirtual

Server provides expected structure.

Implementation must instanciate (or re-use) a PVStructure into args.root, then initialize any necessary fields and set bits in args.tosend as approprate.

If this method throws, then putDone() is called with PutEvent::Fail

Implements pvac::ClientChannel::PutCallback.

Definition at line 152 of file clientSync.cpp.

    {
        pvd::PVDataCreatePtr create(pvd::getPVDataCreate());
        pvd::PVStructurePtr root(create->createPVStructure(build));

        for(PutBuilder::scalars_t::const_iterator it = builder.scalars.begin(), end = builder.scalars.end();
            it!=end; ++it)
        {
            if(it->value.empty())
                continue;

            pvd::PVFieldPtr fld(root->getSubField(it->name));
            if(!fld && it->required)
                throw std::runtime_error(std::string("Server does not have required field ")+it->name);
            else if(!fld)
                continue; // !it->required

            const pvd::FieldConstPtr& ftype(fld->getField());
            if(ftype->getType()==pvd::union_) {
                const pvd::Union *utype = static_cast<const pvd::Union*>(ftype.get());
                pvd::PVUnion *ufld = static_cast<pvd::PVUnion*>(fld.get());

                if(utype->isVariant()) {
                    pvd::PVScalarPtr scalar(create->createPVScalar(it->value.type()));

                    scalar->putFrom(it->value);
                    ufld->set(scalar);

                } else {
                    // attempt automagic assignment to descriminating union
                    pvd::int32 idx = utype->guess(pvd::scalar, it->value.type());

                    if(idx==-1)
                        throw std::runtime_error(std::string("Unable to descriminate union field ")+it->name);

                    ufld->select<pvd::PVScalar>(idx)->putFrom(it->value);
                }

            } else if(ftype->getType()==pvd::scalar) {
                static_cast<pvd::PVScalar*>(fld.get())->putFrom(it->value);

            } else {
                throw std::runtime_error(std::string("Type mis-match assigning scalar to field ")+it->name);

            }

            args.tosend.set(fld->getFieldOffset());
        }

        for(PutBuilder::arrays_t::const_iterator it = builder.arrays.begin(), end = builder.arrays.end();
            it!=end; ++it)
        {
            if(it->value.empty())
                continue;

            pvd::PVFieldPtr fld(root->getSubField(it->name));
            if(!fld && it->required)
                throw std::runtime_error(std::string("Server does not have required field ")+it->name);
            else if(!fld)
                continue; // !it->required

            const pvd::FieldConstPtr& ftype(fld->getField());
            if(ftype->getType()==pvd::union_) {
                const pvd::Union *utype = static_cast<const pvd::Union*>(ftype.get());
                pvd::PVUnion *ufld = static_cast<pvd::PVUnion*>(fld.get());

                if(utype->isVariant()) {
                    pvd::PVScalarArrayPtr scalar(create->createPVScalarArray(it->value.original_type()));

                    scalar->putFrom(it->value);
                    ufld->set(scalar);

                } else {
                    // attempt automagic assignment to descriminating union
                    pvd::int32 idx = utype->guess(pvd::scalarArray, it->value.original_type());

                    if(idx==-1)
                        throw std::runtime_error(std::string("Unable to descriminate union field ")+it->name);

                    ufld->select<pvd::PVScalarArray>(idx)->putFrom(it->value);
                }

            } else if(ftype->getType()==pvd::scalarArray) {
                static_cast<pvd::PVScalarArray*>(fld.get())->putFrom(it->value);

                // TODO
            } else {
                throw std::runtime_error(std::string("Type mis-match assigning scalar to field ")+it->name);

            }

            args.tosend.set(fld->getFieldOffset());
        }

        args.root = root;
    }

virtual void pvac::detail::PutBuilder::Exec::putDone ( const PutEvent &  evt )

inlinevirtual

Put operation is complete.

Implements pvac::ClientChannel::PutCallback.

Definition at line 249 of file clientSync.cpp.

    {
        {
            Guard G(mutex);
            if(done) {
                LOG(pva::logLevelWarn, "oops, double event to PutCallback");
            } else {
                result = evt;
                done = true;
            }
        }
        event.signal();
    }

Member Data Documentation

detail::PutBuilder& pvac::detail::PutBuilder::Exec::builder

Definition at line 144 of file clientSync.cpp.

pvac::PutEvent pvac::detail::PutBuilder::Exec::result

Definition at line 145 of file clientSync.cpp.

---

The documentation for this struct was generated from the following file:

• modules/pvAccess/src/client/clientSync.cpp