Clear development flag for 4.7.0 release

add JSON support

.readthedocs.yml

@@ -0,0 +1,17 @@
+# .readthedocs.yml
+# Read the Docs configuration file
+# See https://docs.readthedocs.io/en/stable/config-file/v2.html for details
+
+# Required
+version: 2
+
+# Build documentation in the documentation/ directory with Sphinx
+sphinx:
+  configuration: documentation/conf.py
+
+# Build documentation with MkDocs
+#mkdocs:
+#  configuration: mkdocs.yml
+
+# Optionally build your docs in additional formats such as PDF and ePub
+formats: all

.travis.yml

@@ -28,4 +28,3 @@ env:
  - BRBASE=7.0 RTEMS=4.9 TEST=NO
  - BRBASE=3.16
  - BRBASE=3.15
- - BRBASE=3.14

Doxyfile

@@ -38,7 +38,7 @@ PROJECT_NAME           = pvaClientCPP
 # could be handy for archiving the generated documentation or if some version
 # control system is used.
 
-PROJECT_NUMBER         =
+PROJECT_NUMBER         = 4.7.0
 
 # Using the PROJECT_BRIEF tag one can provide an optional one line description
 # for a project that appears at the top of each page and should give viewer a
@@ -152,7 +152,7 @@ FULL_PATH_NAMES        = YES
 # will be relative from the directory where doxygen is started.
 # This tag requires that the tag FULL_PATH_NAMES is set to YES.
 
-STRIP_FROM_PATH        =
+STRIP_FROM_PATH        = src
 
 # The STRIP_FROM_INC_PATH tag can be used to strip a user-defined part of the
 # path mentioned in the documentation of a class, which tells the reader which
@@ -161,7 +161,7 @@ STRIP_FROM_PATH        =
 # specify the list of include paths that are normally passed to the compiler
 # using the -I flag.
 
-STRIP_FROM_INC_PATH    =
+STRIP_FROM_INC_PATH    = src
 
 # If the SHORT_NAMES tag is set to YES, doxygen will generate much shorter (but
 # less readable) file names. This can be useful is your file systems doesn't
@@ -765,7 +765,8 @@ WARN_LOGFILE           =
 # spaces. See also FILE_PATTERNS and EXTENSION_MAPPING
 # Note: If this tag is empty the current directory is searched.
 
-INPUT                  = include
+INPUT                  = src \
+                         src/pv
 
 # This tag can be used to specify the character encoding of the source files
 # that doxygen parses. Internally doxygen uses the UTF-8 encoding. Doxygen uses
@@ -796,7 +797,7 @@ FILE_PATTERNS          =
 # be searched for input files as well.
 # The default value is: NO.
 
-RECURSIVE              = YES
+RECURSIVE              = NO
 
 # The EXCLUDE tag can be used to specify files and/or directories that should be
 # excluded from the INPUT source files. This way you can easily exclude a
@@ -1035,7 +1036,7 @@ GENERATE_HTML          = YES
 # The default directory is: html.
 # This tag requires that the tag GENERATE_HTML is set to YES.
 
-HTML_OUTPUT            = documentation/html
+HTML_OUTPUT            = html/doxygen
 
 # The HTML_FILE_EXTENSION tag can be used to specify the file extension for each
 # generated HTML page (for example: .htm, .php, .asp).

configure/CONFIG_PVACLIENT_VERSION

@@ -0,0 +1,12 @@
+# Version number for the PVA Client API and shared library
+
+EPICS_PVACLIENT_MAJOR_VERSION = 4
+EPICS_PVACLIENT_MINOR_VERSION = 7
+EPICS_PVACLIENT_MAINTENANCE_VERSION = 0
+
+# Development flag, set to zero for release versions
+
+EPICS_PVACLIENT_DEVELOPMENT_FLAG = 0
+
+# Immediately after a release the MAINTENANCE_VERSION
+# will be incremented and the DEVELOPMENT_FLAG set to 1

configure/Makefile

@@ -2,6 +2,8 @@ TOP=..
 
 include $(TOP)/configure/CONFIG
 
+CFG += CONFIG_PVACLIENT_VERSION
+
 TARGETS = $(CONFIG_TARGETS)
 CONFIGS += $(subst ../,,$(wildcard $(CONFIG_INSTALLS)))
 

documentation/RELEASE_NOTES.md

@@ -2,6 +2,45 @@
 
 This document summarizes the changes to the module between releases.
 
+## Release 4.7.0 (EPICS 7.0.3.1, Nov 2019)
+
+* added JSON support for put and putGet
+* Fix for
+  [GitHub issue #62](https://github.com/epics-base/pvaClientCPP/issues/62)
+* Doxygen updates and read-the-docs integration.
+
+
+## Release 4.6.0 (EPICS 7.0.3, Jul 2019)
+
+* pvaClient now handles exceptions from the server properly (issue #54).
+* MultiChannel classes now properly handle PV structures that don't have a top-level `value` field (issue #56), and are more tolerant of other missing fields (issue #57).
+
+
+## Release 4.5.0 (EPICS 7.0.2.2, Apr 2019)
+
+Changes have been made for getDouble, putDouble, getDoubleArray, putDoubleArray, getString, putString, getStringArray, and putStringArray.
+
+1) Previously each only had support for a top level field named value.
+Each now allows access to a single sub field that has the correct type.
+Thus pvRequest must select a single field. For example
+
+    pva->channel("PVRdumbPowerSupply")->putDouble(1.0,"power.value" );
+
+2) PvaChannel now has a method for each of the above.
+For example instead of
+
+    PvaClientChannelPtr channel = pva->channel("PVRdouble");
+    PvaClientPutPtr clientPut = channel->put();
+    PvaClientPutDataPtr putData = clientPut->getData();
+    putData->putDouble(1.0); clientPut->put();
+
+now it can be
+
+    pva->channel("PVRdouble")->putDouble(1.0 );
+
+3) getDoubleArray and putDoubleArray work with any numeric scalar array
+
+4) getStringArray and putStringArray work with any scalar array.
 
 ## Release 4.4 (EPICS 7.0.2, Dec 2018)
 

documentation/_static/css/custom.css

@@ -0,0 +1,7 @@
+.wy-side-nav-search {
+    background-color: #18334B;
+}
+
+.wy-side-nav-search input[type="text"] {
+    border-color: #18334b;
+}

documentation/conf.py

@@ -0,0 +1,80 @@
+# Configuration file for the Sphinx documentation builder.
+#
+# This file only contains a selection of the most common options. For a full
+# list see the documentation:
+# http://www.sphinx-doc.org/en/master/config
+
+# -- Path setup --------------------------------------------------------------
+
+# If extensions (or modules to document with autodoc) are in another directory,
+# add these directories to sys.path here. If the directory is relative to the
+# documentation root, use os.path.abspath to make it absolute, like shown here.
+#
+# import os
+# import sys
+# sys.path.insert(0, os.path.abspath('.'))
+
+
+# -- Project information -----------------------------------------------------
+
+project = 'normativeTypes (C++)'
+copyright = '2019, EPICS Controls.'
+author = 'EPICS'
+
+
+# -- General configuration ---------------------------------------------------
+
+# Add any Sphinx extension module names here, as strings. They can be
+# extensions coming with Sphinx (named 'sphinx.ext.*') or your custom
+# ones.
+extensions = [
+    'sphinx.ext.intersphinx',
+]
+
+# Add any paths that contain templates here, relative to this directory.
+templates_path = ['_templates']
+
+# List of patterns, relative to source directory, that match files and
+# directories to ignore when looking for source files.
+# This pattern also affects html_static_path and html_extra_path.
+exclude_patterns = ['_build', 'Thumbs.db', '.DS_Store']
+
+# Intersphinx links to subprojects
+intersphinx_mapping = {
+}
+
+
+# -- Options for HTML output -------------------------------------------------
+
+# The theme to use for HTML and HTML Help pages.  See the documentation for
+# a list of builtin themes.
+#
+html_theme = 'sphinx_rtd_theme'
+
+
+# Add any paths that contain custom static files (such as style sheets) here,
+# relative to this directory. They are copied after the builtin static files,
+# so a file named "default.css" will overwrite the builtin "default.css".
+html_static_path = ['_static']
+
+html_css_files = [
+    'css/custom.css',
+]
+
+master_doc = 'index'
+
+html_theme_options = {
+    'logo_only': True,
+}
+html_logo = "images/EPICS_white_logo_v02.png"
+
+html_extra_path = [
+    '../html',
+    'pvaClientCPP.html',
+]
+
+
+# -- Run Doxygen ------------------------------------------------------------
+
+import subprocess
+subprocess.call('cd ..; mkdir -p html/doxygen; doxygen', shell=True)

documentation/index.rst

@@ -0,0 +1,17 @@
+pvaClient (C++) Library
+========================
+
+.. toctree::
+   :hidden:
+
+   EPICS Website <https://epics-controls.org>
+   EPICS Documentation Home <https://docs.epics-controls.org>
+
+
+.. toctree::
+   :maxdepth: 1
+   :caption: pvaClientCPP
+
+   Reference Manual <https://docs.epics-controls.org/projects/pvaclient-cpp/en/latest/pvaClientCPP.html>
+   API Documentation <https://docs.epics-controls.org/projects/pvaclient-cpp/en/latest/doxygen>
+   Source Code Repository on GitHub <https://github.com/epics-base/pvaClientCPP>

documentation/pvaClientCPP.html

@@ -26,7 +26,7 @@
 
 <div class="head">
 <h1>EPICS pvaClientCPP</h1>
-<h2 class="nocount">Release 4.4 - December 2018</h2>
+<h2 class="nocount">Release 4.4 - April 2019</h2>
 
 <h2 class="nocount">Abstract</h2>
 
@@ -79,7 +79,7 @@ It is intended for developers that want to use pvaClientCPP.
 <h2>Developer Guide</h2>
 <p>A guide for developers is available at
 <a
-href="http://epics-pvdata.sourceforge.net/informative/developerGuide/developerGuide.html">
+href="https://mrkraimer.github.io/website/developerGuide/developerGuide.html">
 developerGuide
 </a>
 </p>

src/Makefile

@@ -6,12 +6,13 @@ include $(TOP)/configure/CONFIG
 LIBRARY += pvaClient
 
 # shared library ABI version.
-SHRLIB_VERSION ?= 4.4.0
+SHRLIB_VERSION ?= $(EPICS_PVACLIENT_MAJOR_VERSION).$(EPICS_PVACLIENT_MINOR_VERSION).$(EPICS_PVACLIENT_MAINTENANCE_VERSION)
 
 INC += pv/pvaClient.h
 INC += pv/pvaClientMultiChannel.h
 
 LIBSRCS += pvaClient.cpp
+LIBSRCS += pvaClientData.cpp
 LIBSRCS += pvaClientPutData.cpp
 LIBSRCS += pvaClientGetData.cpp
 LIBSRCS += pvaClientMonitorData.cpp

src/pv/pvaClient.h

@@ -17,6 +17,7 @@
 
 #include <list>
 #include <iostream>
+#include <ostream>
 #include <sstream>  
 #include <pv/requester.h>
 #include <pv/status.h>
@@ -44,6 +45,8 @@ namespace epics { namespace pvaClient {
 
 class PvaClient;
 typedef std::tr1::shared_ptr<PvaClient> PvaClientPtr;
+class PvaClientData;
+typedef std::tr1::shared_ptr<PvaClientData> PvaClientDataPtr;
 class PvaClientGetData;
 typedef std::tr1::shared_ptr<PvaClientGetData> PvaClientGetDataPtr;
 class PvaClientPutData;
@@ -311,11 +314,42 @@ public:
     PvaClientGetPtr createGet(std::string const & request = "field(value,alarm,timeStamp)");
     /** @brief Creates an PvaClientGet.
      *
-     * @param pvRequest The syntax of pvRequest is defined by the copy facility of pvData.
+     * @param pvRequest The syntax of request is defined by the copy facility of pvData.
+     * @return The interface.
      * @return The interface.
      * @throw runtime_error if failure.
      */
     PvaClientGetPtr createGet(epics::pvData::PVStructurePtr const &  pvRequest);
+    /** @brief Get the value as a double.
+     *
+     * @param request The syntax of request is defined by the copy facility of pvData.
+     * @return The value.
+     * @throw runtime_error if failure.
+     */
+    double getDouble(std::string const & request = "field(value)");
+    /** Get the value as a string.
+     *
+     * @param request The syntax of request is defined by the copy facility of pvData.
+     * @return The value.
+     * @throw runtime_error if failure.
+     */
+    std::string getString(std::string const & request = "field(value)");
+    /** @brief Get the value as a double array.
+     *
+     * @param request The syntax of request is defined by the copy facility of pvData.
+     * @return The value.
+     * @throw runtime_error if failure.
+     */
+    epics::pvData::shared_vector<const double>  getDoubleArray(
+        std::string const & request = "field(value)");
+    /** @brief Get the value as a string array.
+     *
+     * @param request The syntax of request is defined by the copy facility of pvData.
+     * @return The value.
+     * @throw runtime_error if failure.
+     */
+    epics::pvData::shared_vector<const std::string>  getStringArray(
+        std::string const & request = "field(value)");
     /** @brief create a PvaClientPut.
      * 
      * Get a cached PvaClientPut or create and connect to a new PvaClientPut.
@@ -339,6 +373,44 @@ public:
      * @return The interface.
      */
     PvaClientPutPtr createPut(epics::pvData::PVStructurePtr const & pvRequest);
+    /** @brief Put the value as a double.
+     *
+     * @param value The new value.
+     * @param request The syntax of request is defined by the copy facility of pvData.
+     * @throw runtime_error if failure.
+     */
+    void putDouble(double value,std::string const & request = "field(value)");
+    /** @brief Put the value as a string.
+     *
+     * @param value The new value.
+     * @param request The syntax of request is defined by the copy facility of pvData.
+     * @throw runtime_error if failure.
+     */
+    void putString(std::string const & value,std::string const & request = "field(value)");
+    /** @brief Copy the array to the value field.
+     *
+     * @param value The new value.
+     * @param request The syntax of request is defined by the copy facility of pvData.
+     * @throw runtime_error if failure.
+     */
+    void putDoubleArray(
+        epics::pvData::shared_vector<const double> const & value,
+        std::string const & request = "field(value)");
+    /** @brief Copy array to the value field.
+     * 
+     * @param value The new value.
+     * @param request The syntax of request is defined by the copy facility of pvData.
+     * @throw runtime_error if failure.
+     */
+    void putStringArray(
+        epics::pvData::shared_vector<const std::string> const & value,
+        std::string const & request = "field(value)");
+    /** @brief Copy array to the value field.
+     * @param value The data used to update the channel value.
+     * @param request The request as a string to pass to createRequest.
+     * @throw runtime_error if failure.
+     */
+    void putStringArray(std::vector<std::string> const & value,std::string const & request = "field(value)");
     /** @brief create a PvaClientPutGet.
      *
      * First call createRequest as implemented by pvDataJava and then calls the next method.
@@ -490,18 +562,18 @@ public:
 };
 
 /** 
- *  @brief A class that holds data returned by PvaClientGet or PvaClientPutGet
+ *  @brief A base class for PvaClientGetData, PvaClientPutData, and PvaClientMonitorData.
  *
- * <a href = "../htmldoxygen/pvaClientGetData.html">Overview of PvaClientGetData</a>
+ * <a href = "../htmldoxygen/pvaClientData.html">Overview of PvaClientData</a>
  */
-class epicsShareClass PvaClientGetData
+class epicsShareClass PvaClientData
 {
 public:
-    POINTER_DEFINITIONS(PvaClientGetData);
+    POINTER_DEFINITIONS(PvaClientData);
     /**
      * @brief Destructor
      */
-    ~PvaClientGetData() {}
+    ~PvaClientData() {}
     /** @brief Set a prefix for throw messages.
      *
      * This is called by other pvaClient classes.
@@ -542,6 +614,7 @@ public:
     void setData(
         epics::pvData::PVStructurePtr const & pvStructureFrom,
         epics::pvData::BitSetPtr const & bitSetFrom);
+
     /** @brief Is there a top level field named value.
      * @return The answer.
      */
@@ -608,6 +681,74 @@ public:
      * @return The timeStamp.
      */
     epics::pvData::TimeStamp getTimeStamp();
+    /** @brief parse from args
+     *
+     * Accepts arguments of the form json or field='value' where value is json syntax.
+     * field is name.name...
+     * @param args The arguments
+     * @throw runtime_error if failure.
+     */
+    void parse(const std::vector<std::string> &args);
+    /** @brief generate JSON output from the current PVStructure
+     *
+     * @param strm output stream
+     * @param ignoreUnprintable false or true; default is true.
+     * @param multiline false or true; default is false
+     *
+     * @throw runtime_error if failure.
+     */
+    void streamJSON(
+               std::ostream& strm,
+               bool ignoreUnprintable = true,
+               bool multiLine = false);
+     /** @brief set length of all array fields to 0
+     */
+    void zeroArrayLength();
+    /** @brief Factory method for creating an instance of PvaClientData.
+     *
+     * NOTE: Not normally called by clients
+     * @param structure Introspection interface
+     * @throw runtime_error if failure.
+     */
+    static PvaClientDataPtr create(epics::pvData::StructureConstPtr const & structure);
+protected:
+    PvaClientData(epics::pvData::StructureConstPtr const & structure);
+    void checkValue();
+    std::string messagePrefix;
+private:
+    void parse(
+        const std::string &arg,
+        const epics::pvData::PVFieldPtr &dest,
+        epics::pvData::BitSetPtr &bitSet);
+    void parse(
+        const std::string &arg,
+        const epics::pvData::PVUnionPtr &dest);
+    void zeroArrayLength(const epics::pvData::PVStructurePtr &pvStructure);
+
+    epics::pvData::StructureConstPtr structure;
+    epics::pvData::PVStructurePtr pvStructure;
+    epics::pvData::BitSetPtr bitSet;
+
+    epics::pvData::PVFieldPtr pvValue;
+    epics::pvData::PVAlarm pvAlarm;
+    epics::pvData::PVTimeStamp pvTimeStamp;
+    friend class PvaClientGet;
+    friend class PvaClientPutGet;
+};
+
+/** 
+ *  @brief A class that holds data returned by PvaClientGet or PvaClientPutGet
+ *
+ * <a href = "../htmldoxygen/pvaClientGetData.html">Overview of PvaClientGetData</a>
+ */
+class epicsShareClass PvaClientGetData : public PvaClientData
+{
+public:
+    POINTER_DEFINITIONS(PvaClientGetData);
+    /**
+     * @brief Destructor
+     */
+    ~PvaClientGetData() {}
     /** @brief Factory method for creating an instance of PvaClientGetData.
      *
      * NOTE: Not normally called by clients
@@ -617,15 +758,6 @@ public:
     static PvaClientGetDataPtr create(epics::pvData::StructureConstPtr const & structure);
 private:
     PvaClientGetData(epics::pvData::StructureConstPtr const & structure);
-    void checkValue();
-    epics::pvData::StructureConstPtr structure;
-    epics::pvData::PVStructurePtr pvStructure;
-    epics::pvData::BitSetPtr bitSet;
-
-    std::string messagePrefix;
-    epics::pvData::PVFieldPtr pvValue;
-    epics::pvData::PVAlarm pvAlarm;
-    epics::pvData::PVTimeStamp pvTimeStamp;
     friend class PvaClientGet;
     friend class PvaClientPutGet;
 };
@@ -636,7 +768,7 @@ class PvaClientPostHandlerPvt; // private to PvaClientPutData
  *
  * <a href = "../htmldoxygen/pvaClientPutData.html">Overview of PvaClientPutData</a>
  */
-class epicsShareClass PvaClientPutData 
+class epicsShareClass PvaClientPutData : public PvaClientData
 {
 public:
     POINTER_DEFINITIONS(PvaClientPutData);
@@ -644,93 +776,6 @@ public:
      * @brief Destructor
      */    
     ~PvaClientPutData() {}
-    /** @brief Set a prefix for throw messages.
-     *
-     * @param value The prefix.
-     */
-    void setMessagePrefix(std::string const & value);
-    /** @brief Get the structure.
-     *
-     * @return The Structure
-     * @throw runtime_error if failure.
-     */
-    epics::pvData::StructureConstPtr getStructure();
-   /** @brief Get the pvStructure.
-    *
-    * @return the pvStructure.
-    * @throw runtime_error if failure.
-    */
-   epics::pvData::PVStructurePtr getPVStructure();
-    /**  @brief Get the changed BitSet for the pvStructure
-     *
-     * This shows which fields have changed values.
-     * @return The bitSet
-     * @throw runtime_error if failure.
-     */
-    epics::pvData::BitSetPtr getChangedBitSet();
-    /**  @brief Show the fields that have changed values.
-     *
-     * @param out The stream that shows the changed fields.
-     * @return The stream that was passed as out.
-     */
-    std::ostream & showChanged(std::ostream & out);
-    /**
-     * @brief Is there a top level field named value.
-     *
-     * @return The answer.
-     */
-    bool hasValue();
-    /** @brief Is the value field a scalar?
-     *
-     * @return The answer.
-     */
-    bool isValueScalar();
-    /** @brief Is the value field a scalar array?
-     * @return The answer.
-     */
-    bool isValueScalarArray();
-    /** Get the interface to the value field.
-     *
-     * @return The interface. an excetion is thrown if a value field does not exist.
-     */
-    epics::pvData::PVFieldPtr getValue();
-    /** @brief Get the interface to a scalar value field.
-     *
-     * @return The interface for a scalar value field.
-     * @throw runtime_error if failure.
-     */
-    epics::pvData::PVScalarPtr getScalarValue();
-    /** @brief Get the interface to an array value field.
-     * @return The interface.
-     * An exception is thown if no array value field.
-     */
-    std::tr1::shared_ptr<epics::pvData::PVArray> getArrayValue();
-    /** @brief Get the interface to a scalar array value field.
-     * @return Return the interface.
-     * @throw runtime_error if failure.
-     */
-    std::tr1::shared_ptr<epics::pvData::PVScalarArray> getScalarArrayValue();
-    /** @brief Get the value as a double.
-     *
-     * If value is not a numeric scalar an exception is thrown.
-     * @return The value.
-     */
-    double getDouble();
-    /** @brief Get the value as a string.
-     * @return The value.
-     * @throw runtime_error if failure.
-     */
-    std::string getString();
-    /** @brief Get the value as a double array.
-     * If the value is not a numeric array an exception is thrown.
-     * @return The value.
-     */
-    epics::pvData::shared_vector<const double>  getDoubleArray();
-    /** @brief Get the value as a string array.
-     * @return The value.
-     * @throw runtime_error if failure.
-     */
-    epics::pvData::shared_vector<const std::string>  getStringArray();
     /** @brief Put the value as a double.
      * @param value The new value.
      * An exception is also thrown if the actualy type can cause an overflow.
@@ -764,17 +809,9 @@ public:
      static PvaClientPutDataPtr create(epics::pvData::StructureConstPtr const & structure);
 private:
     PvaClientPutData(epics::pvData::StructureConstPtr const &structure);
-    void checkValue();
     void postPut(size_t fieldNumber);
-
     std::vector<epics::pvData::PostHandlerPtr> postHandler;
-    epics::pvData::StructureConstPtr structure;
-    epics::pvData::PVStructurePtr pvStructure;
-    epics::pvData::BitSetPtr bitSet;
     friend class PvaClientPostHandlerPvt;
-
-    std::string messagePrefix;
-    epics::pvData::PVFieldPtr pvValue;
     friend class PvaClientPut;
     friend class PvaClientPutGet;
 };
@@ -784,7 +821,7 @@ private:
  *
  * <a href = "../htmldoxygen/pvaClientMonitorData.html">Overview of PvaClientMonitorData</a>
  */
-class epicsShareClass PvaClientMonitorData
+class epicsShareClass PvaClientMonitorData : public PvaClientData
 {
 public:
     POINTER_DEFINITIONS(PvaClientMonitorData);
@@ -792,27 +829,6 @@ public:
      * @brief Destructor
      */    
     ~PvaClientMonitorData() {}
-    /** @brief Set a prefix for throw messages.
-     * @param value The prefix.
-     */
-    void setMessagePrefix(std::string const & value);
-    /** @brief Get the structure.
-     * @return The Structure
-     * @throw runtime_error if failure.
-     */
-    epics::pvData::StructureConstPtr getStructure();
-    /** @brief Get the pvStructure.
-     * @return the pvStructure.
-     * @throw runtime_error if failure.
-     */
-    epics::pvData::PVStructurePtr getPVStructure();
-    /**  @brief Get the changed BitSet for the pvStructure,
-     *
-     * This shows which fields have changed value.
-     * @return The bitSet
-     * @throw runtime_error if failure.
-     */
-    epics::pvData::BitSetPtr getChangedBitSet();
     /** @brief Get the overrun BitSet for the pvStructure
      * This shows which fields have had more than one change.
      * @return The bitSet
@@ -823,111 +839,21 @@ public:
      * @param out The stream that shows the changed fields.
      * @return The stream that was passed as out.
      */
-    std::ostream & showChanged(std::ostream & out);
-    /** @brief Show the fields that have overrun.
-     * @param out The stream that shows the overrun fields.
-     * @return The stream that was  passed as out
-     */
     std::ostream & showOverrun(std::ostream & out);
-    /** @brief Is there a top level field named value.
-     * @return The answer.
-     */
-    bool hasValue();
-    /** @brief Is the value field a scalar?
-     * @return The answer.
-     */
-    bool isValueScalar();
-    /** @brief Is the value field a scalar array?
-     * @return The answer.
-     */
-    bool isValueScalarArray();
-    /** @brief Get the interface to the value field.
-     * @return The interface. an excetion is thrown if a value field does not exist.
-     */
-    epics::pvData::PVFieldPtr getValue();
-    /** @brief Get the interface to a scalar value field.
-     * @return The interface for a scalar value field.
-     * @throw runtime_error if failure.
-     * An exception is thown if no scalar value field.
-     */
-    epics::pvData::PVScalarPtr getScalarValue();
-    /** @brief Get the interface to an array value field.
-     * @return The interface.
-     * @throw runtime_error if failure.
-     * An exception is thown if no array value field.
-     */
-    std::tr1::shared_ptr<epics::pvData::PVArray> getArrayValue();
-    /** @brief Get the interface to a scalar array value field.
-     * @return Return the interface.
-     * @throw runtime_error if failure.
-     * An exception is thown if no scalar array value field.
-     */
-    std::tr1::shared_ptr<epics::pvData::PVScalarArray> getScalarArrayValue();
-    /** @brief Get the value as a double.
-     *
-     * If value is not a numeric scalar an exception is thrown.
-     * @return The value.
-     */
-    double getDouble();
-    /** @brief Get the value as a string.
-     *
-     * If value is not a scalar an exception is thrown
-     * @return The value.
-     * @throw runtime_error if failure.
-     */
-    std::string getString();
-    /** @brief Get the value as a double array.
-     *
-     * If the value is not a numeric array an exception is thrown.
-     * @return The value.
-     * @throw runtime_error if failure.
-     */
-    epics::pvData::shared_vector<const double>  getDoubleArray();
-    /** @brief Get the value as a string array.
-     *
-     * If the value is not a string array an exception is thrown.
-     * @return The value.
-     * @throw runtime_error if failure.
-     */
-    epics::pvData::shared_vector<const std::string>  getStringArray();
-    /** @brief Get the alarm.
-     *
-     * If the pvStructure as an alarm field it's values are returned.
-     * If no then alarm shows that not alarm defined.
-     * @return The alarm.
-     * @throw runtime_error if failure.
-     */
-    epics::pvData::Alarm getAlarm();
-    /** @brief Get the timeStamp.
-     *
-     * If the pvStructure has a timeStamp field, it's values are returned.
-     * If no then all fields are 0.
-     * @return The timeStamp.
-     */
-    epics::pvData::TimeStamp getTimeStamp();
-    /** Factory method for creating an instance of PvaClientGetData.
-     * NOTE: Not normally called by clients
-     * @param structure Introspection interface
-     */
-     static PvaClientMonitorDataPtr create(epics::pvData::StructureConstPtr const & structure);
      /** Put data into PVStructure from monitorElement
       *  NOTE: Not normally called by clients
       * @param monitorElement the monitorElement that has new data.
       */
      void setData(epics::pvData::MonitorElementPtr const & monitorElement);
+    /** Factory method for creating an instance of PvaClientGetData.
+     * NOTE: Not normally called by clients
+     * @param structure Introspection interface
+     */
+     static PvaClientMonitorDataPtr create(epics::pvData::StructureConstPtr const & structure);
 private:
     PvaClientMonitorData(epics::pvData::StructureConstPtr const & structure);
-    void checkValue();
-    
-    epics::pvData::StructureConstPtr structure;
-    epics::pvData::PVStructurePtr pvStructure;
-    epics::pvData::BitSetPtr changedBitSet;
     epics::pvData::BitSetPtr overrunBitSet;
 
-    std::string messagePrefix;
-    epics::pvData::PVFieldPtr pvValue;
-    epics::pvData::PVAlarm pvAlarm;
-    epics::pvData::PVTimeStamp pvTimeStamp;
     friend class PvaClientMonitor;
 };
 
@@ -1919,6 +1845,7 @@ private:
 
     enum RPCState {rpcIdle,rpcActive,rpcComplete};
     RPCState rpcState;
+    epics::pvData::Status requestStatus;
     double responseTimeout;
     friend class RPCRequesterImpl;
 };

src/pv/pvaClientMultiChannel.h

@@ -360,8 +360,10 @@ public:
     void connect();
     /**
      * @brief Get each channel.
+     *
+     * @param valueOnly use only value for union.
      */
-    void get();
+    void get(bool valueOnly = true);
     /**
      * @brief Get the data from the last get.
      * @return the pvaClientNTMultiData.
@@ -476,10 +478,11 @@ public:
      /**
      * @brief Poll each channel.
      *
+     * @param valueOnly use only value for union.
      * If any has new data it is used to update the double[].
      * @return (false,true) if (no, at least one) value was updated.
      */
-    bool poll();
+    bool poll(bool valueOnly = true);
     /**
      * @brief Wait until poll returns true.
      * @param secondsToWait The time to keep trying.
@@ -551,11 +554,12 @@ public:
      * @brief Set the timeStamp base for computing deltaTimes. 
      */
     void startDeltaTime();
-   
     /**
      * @brief Update NTMultiChannel fields.
+     *
+     * @param valueOnly use only value for union.
      */
-    void endDeltaTime();
+    void endDeltaTime(bool valueOnly = true);
     /**
      * @brief Get the time when the last get was made.
      * @return The timeStamp.
@@ -579,7 +583,6 @@ private:
          PvaClientMultiChannelPtr const &pvaNTMultiChannel,
          PvaClientChannelArray const &pvaClientChannelArray,
          epics::pvData::PVStructurePtr const &  pvRequest);
-    void setStructure(epics::pvData::StructureConstPtr const & structure,size_t index);
     void setPVStructure(
         epics::pvData::PVStructurePtr const &pvStructure,size_t index);
 

src/pvaClient.cpp

@@ -18,7 +18,6 @@
 
 #include <pv/pvaClient.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace epics::pvAccess::ca;

src/pvaClientChannel.cpp

@@ -18,7 +18,6 @@
 
 #include <pv/pvaClient.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace std;
@@ -381,6 +380,26 @@ PvaClientGetPtr PvaClientChannel::createGet(PVStructurePtr const &  pvRequest)
     return PvaClientGet::create(yyy,shared_from_this(),pvRequest);
 }
 
+double PvaClientChannel::getDouble(string const & request)
+{
+     return get(request)->getData()->getDouble();
+}
+
+string PvaClientChannel::getString(string const & request)
+{
+    return get(request)->getData()->getString();
+}
+
+shared_vector<const double>  PvaClientChannel::getDoubleArray(string const & request)
+{
+    return get(request)->getData()->getDoubleArray();
+}
+
+shared_vector<const std::string>  PvaClientChannel::getStringArray(string const & request)
+{
+    return get(request)->getData()->getStringArray();
+}
+
 
 PvaClientPutPtr PvaClientChannel::put(string const & request)
 {
@@ -416,6 +435,44 @@ PvaClientPutPtr PvaClientChannel::createPut(PVStructurePtr const & pvRequest)
     return PvaClientPut::create(yyy,shared_from_this(),pvRequest);
 }
 
+void PvaClientChannel::putDouble(double value,string const & request)
+{
+    PvaClientPutPtr clientPut = put(request);
+    PvaClientPutDataPtr putData = clientPut->getData();
+    putData->putDouble(value); clientPut->put();
+}
+
+void PvaClientChannel::putString(std::string const & value,string const & request)
+{
+    PvaClientPutPtr clientPut = put(request);
+    PvaClientPutDataPtr putData = clientPut->getData();
+    putData->putString(value); clientPut->put();
+}
+
+void PvaClientChannel::putDoubleArray(
+    shared_vector<const double> const & value,
+    string const & request)
+{
+    PvaClientPutPtr clientPut = put(request);
+    PvaClientPutDataPtr putData = clientPut->getData();
+    size_t n = value.size();
+    shared_vector<double> valueArray(n);
+    for(size_t i=0; i<n; ++i) valueArray[i] = value[i];
+    putData->putDoubleArray(freeze(valueArray)); clientPut->put();
+}
+
+void PvaClientChannel::putStringArray(
+    shared_vector<const string> const & value,
+    string const & request)
+{
+    PvaClientPutPtr clientPut = put(request);
+    PvaClientPutDataPtr putData = clientPut->getData();
+    size_t n = value.size();
+    shared_vector<string> valueArray(n);
+    for(size_t i=0; i<n; ++i) valueArray[i] = value[i];
+    putData->putStringArray(freeze(valueArray)); clientPut->put();
+}
+
 PvaClientPutGetPtr PvaClientChannel::createPutGet(string const & request)
 {
     PVStructurePtr pvRequest = createRequest->createRequest(request);

src/pvaClientData.cpp

@@ -0,0 +1,508 @@
+/* pvaClientData.cpp */
+/**
+ * Copyright - See the COPYRIGHT that is included with this distribution.
+ * EPICS pvData is distributed subject to a Software License Agreement found
+ * in file LICENSE that is included with this distribution.
+ */
+/**
+ * @author mrk
+ * @date 2019.04
+ */
+
+#include <typeinfo>
+#include <sstream>
+#include <istream>
+#include <ostream>
+
+#include <pv/createRequest.h>
+#include <pv/convert.h>
+#include <pv/pvEnumerated.h>
+
+#if EPICS_VERSION_INT>=VERSION_INT(3,15,0,1)
+#  include <pv/json.h>
+#  define USE_JSON
+#endif
+
+#define epicsExportSharedSymbols
+
+#include <pv/pvaClient.h>
+
+using std::tr1::static_pointer_cast;
+using namespace epics::pvData;
+using namespace epics::pvAccess;
+using namespace std;
+
+namespace epics { namespace pvaClient {
+
+
+typedef std::tr1::shared_ptr<PVArray> PVArrayPtr;
+static ConvertPtr convert = getConvert();
+static string noStructure("no pvStructure ");
+static string noValue("no value field");
+static string noScalar("value is not a scalar");
+static string noArray("value is not an array");
+static string noScalarArray("value is not a scalarArray");
+static string noAlarm("no alarm");
+static string noTimeStamp("no timeStamp");
+
+PvaClientDataPtr PvaClientData::create(StructureConstPtr const & structure)
+{
+    if(PvaClient::getDebug()) cout << "PvaClientData::create\n";
+    PvaClientDataPtr epv(new PvaClientData(structure));
+    return epv;
+}
+
+PvaClientData::PvaClientData(StructureConstPtr const & structure)
+: structure(structure)
+{
+}
+
+void PvaClientData::checkValue()
+{
+    if(PvaClient::getDebug()) cout << "PvaClientData::checkValue\n";
+    if(pvValue) return;
+    throw std::runtime_error(messagePrefix + noValue);
+}
+
+void PvaClientData::setMessagePrefix(std::string const & value)
+{
+    messagePrefix = value + " ";
+}
+
+StructureConstPtr PvaClientData::getStructure()
+{
+    return structure;
+}
+
+PVStructurePtr PvaClientData::getPVStructure()
+{
+    if(pvStructure) return pvStructure;
+    throw std::runtime_error(messagePrefix + noStructure);
+}
+
+BitSetPtr PvaClientData::getChangedBitSet()
+{
+    if(bitSet)return bitSet;
+    throw std::runtime_error(messagePrefix + noStructure);
+}
+
+std::ostream & PvaClientData::showChanged(std::ostream & out)
+{
+    if(!bitSet) throw std::runtime_error(messagePrefix + noStructure);
+    size_t nextSet = bitSet->nextSetBit(0);
+    PVFieldPtr pvField;
+    while(nextSet!=string::npos) {
+        if(nextSet==0) {
+             pvField = pvStructure;
+        } else {
+              pvField = pvStructure->getSubField(nextSet);
+        }
+        string name = pvField->getFullName();
+        out << name << " = " << pvField << endl;
+        nextSet = bitSet->nextSetBit(nextSet+1);
+    }
+    return out;
+}
+
+void PvaClientData::setData(
+    PVStructurePtr const & pvStructureFrom,
+    BitSetPtr const & bitSetFrom)
+{
+   if(PvaClient::getDebug()) cout << "PvaClientData::setData\n";
+   pvStructure = pvStructureFrom;
+   bitSet = bitSetFrom;
+   pvValue = pvStructure->getSubField("value");
+}
+
+
+bool PvaClientData::hasValue()
+{
+    if(PvaClient::getDebug()) cout << "PvaClientData::hasValue\n";
+    if(!pvValue) return false;
+    return true;
+}
+
+bool PvaClientData::isValueScalar()
+{
+    if(PvaClient::getDebug()) cout << "PvaClientData::isValueScalar\n";
+    if(!pvValue) return false;
+    if(pvValue->getField()->getType()==scalar) return true;
+    return false;
+}
+
+bool PvaClientData::isValueScalarArray()
+{
+    if(PvaClient::getDebug()) cout << "PvaClientData::isValueScalarArray\n";
+    if(!pvValue) return false;
+    if(pvValue->getField()->getType()==scalarArray) return true;
+    return false;
+}
+
+PVFieldPtr  PvaClientData::getValue()
+{
+   if(PvaClient::getDebug()) cout << "PvaClientData::getValue\n";
+   checkValue();
+   return pvValue;
+}
+
+PVScalarPtr  PvaClientData::getScalarValue()
+{
+    if(PvaClient::getDebug()) cout << "PvaClientData::getScalarValue\n";
+    checkValue();
+    if(pvValue->getField()->getType()!=scalar) {
+       throw std::runtime_error(messagePrefix + noScalar);
+    }
+    return pvStructure->getSubField<PVScalar>("value");
+}
+
+PVArrayPtr  PvaClientData::getArrayValue()
+{
+    if(PvaClient::getDebug()) cout << "PvaClientData::getArrayValue\n";
+    checkValue();
+    Type type = pvValue->getField()->getType();
+    if(type!=scalarArray && type!=structureArray && type!=unionArray) {
+        throw std::runtime_error(messagePrefix + noArray);
+    }
+    return pvStructure->getSubField<PVArray>("value");
+}
+
+PVScalarArrayPtr  PvaClientData::getScalarArrayValue()
+{
+    if(PvaClient::getDebug()) cout << "PvaClientData::getScalarArrayValue\n";
+    checkValue();
+    Type type = pvValue->getField()->getType();
+    if(type!=scalarArray) {
+        throw std::runtime_error(messagePrefix + noScalarArray);
+    }
+    return pvStructure->getSubField<PVScalarArray>("value");
+}
+
+double PvaClientData::getDouble()
+{
+    if(PvaClient::getDebug()) cout << "PvaClientData::getDouble\n";
+    PVScalarPtr pvScalar;
+    PVStructurePtr pvStructure = getPVStructure();
+    PVFieldPtr pvValue  = pvStructure->getSubField("value");
+    if(pvValue) {
+        Type type = pvValue->getField()->getType();
+        if(type==scalar) pvScalar = static_pointer_cast<PVScalar>(pvValue);
+    }
+    if(!pvScalar) {
+        while(true) {
+             const PVFieldPtrArray fieldPtrArray(pvStructure->getPVFields());
+             if(fieldPtrArray.size()!=1) {
+                  throw std::logic_error(
+                      "PvaClientData::getDouble() pvRequest for multiple fields");
+             }
+             PVFieldPtr pvField(fieldPtrArray[0]);
+             Type type = pvField->getField()->getType();
+             if(type==scalar) {
+                 pvScalar = static_pointer_cast<PVScalar>(pvField);
+                 break;
+             }
+             if(pvField->getField()->getType()!=epics::pvData::structure) break;
+             pvStructure = static_pointer_cast<PVStructure>(pvField);
+        }
+    }
+    if(!pvScalar) {
+        throw std::logic_error(
+            "PvaClientData::getDouble() did not find a scalar field");
+    }
+    ScalarType scalarType = pvScalar->getScalar()->getScalarType();
+    if(scalarType==pvDouble) {
+        PVDoublePtr pvDouble = static_pointer_cast<PVDouble>(pvScalar);
+        return pvDouble->get();
+    }
+    if(!ScalarTypeFunc::isNumeric(scalarType)) {
+        throw std::logic_error(
+            "PvaClientData::getDouble() did not find a numeric scalar field");
+    }
+    return convert->toDouble(pvScalar);
+}
+
+string PvaClientData::getString()
+{
+    if(PvaClient::getDebug()) cout << "PvaClientData::getString\n";
+    PVScalarPtr pvScalar;
+    PVStructurePtr pvStructure = getPVStructure();
+    PVFieldPtr pvValue  = pvStructure->getSubField("value");
+    if(pvValue) {
+        Type type = pvValue->getField()->getType();
+        if(type==scalar) pvScalar = static_pointer_cast<PVScalar>(pvValue);
+    }
+    if(!pvScalar) {
+        while(true) {
+             const PVFieldPtrArray fieldPtrArray(pvStructure->getPVFields());
+             if(fieldPtrArray.size()!=1) {
+                  throw std::logic_error(
+                      "PvaClientData::getString() pvRequest for multiple fields");
+             }
+             PVFieldPtr pvField(fieldPtrArray[0]);
+             Type type = pvField->getField()->getType();
+             if(type==scalar) {
+                 pvScalar = static_pointer_cast<PVScalar>(pvField);
+                 break;
+             }
+             if(pvField->getField()->getType()!=epics::pvData::structure) break;
+             pvStructure = static_pointer_cast<PVStructure>(pvField);
+        }
+    }
+    if(!pvScalar) {
+        throw std::logic_error(
+            "PvaClientData::getString() did not find a scalar field");
+    }
+    return convert->toString(pvScalar);
+}
+
+shared_vector<const double> PvaClientData::getDoubleArray()
+{
+    if(PvaClient::getDebug()) cout << "PvaClientData::getDoubleArray\n";
+    PVScalarArrayPtr pvScalarArray;
+    PVStructurePtr pvStructure = getPVStructure();
+    PVFieldPtr pvValue  = pvStructure->getSubField("value");
+    if(pvValue) {
+        Type type = pvValue->getField()->getType();
+        if(type==scalarArray) {
+            pvScalarArray = static_pointer_cast<PVScalarArray>(pvValue);
+        }
+    }
+    if(!pvScalarArray) {
+        while(true) {
+             const PVFieldPtrArray fieldPtrArray(pvStructure->getPVFields());
+             if(fieldPtrArray.size()!=1) {
+                  throw std::logic_error(
+                      "PvaClientData::getDoubleArray() pvRequest for multiple fields");
+             }
+             PVFieldPtr pvField(fieldPtrArray[0]);
+             Type type = pvField->getField()->getType();
+             if(type==scalarArray) {
+                 pvScalarArray = static_pointer_cast<PVScalarArray>(pvField);
+                 break;
+             }
+             if(pvField->getField()->getType()!=epics::pvData::structure) break;
+             pvStructure = static_pointer_cast<PVStructure>(pvField);
+        }
+    }
+    if(!pvScalarArray) {
+        throw std::logic_error(
+            "PvaClientData::getDoubleArray() did not find a scalarArray field");
+    }
+    ScalarType scalarType = pvScalarArray->getScalarArray()->getElementType();
+    if(!ScalarTypeFunc::isNumeric(scalarType)) {
+        throw std::logic_error(
+            "PvaClientData::getDoubleArray() did not find a numeric scalarArray field");
+    }
+    shared_vector<const double> retValue;
+    pvScalarArray->getAs<const double>(retValue);
+    return retValue;
+}
+
+shared_vector<const string> PvaClientData::getStringArray()
+{
+    if(PvaClient::getDebug()) cout << "PvaClientData::getStringArray\n";
+    PVScalarArrayPtr pvScalarArray;
+    PVStructurePtr pvStructure = getPVStructure();
+    PVFieldPtr pvValue  = pvStructure->getSubField("value");
+    if(pvValue) {
+       Type type = pvValue->getField()->getType();
+        if(type==scalarArray) {
+             pvScalarArray = static_pointer_cast<PVScalarArray>(pvValue);
+        }
+    }
+    if(!pvScalarArray) {
+        while(true) {
+             const PVFieldPtrArray fieldPtrArray(pvStructure->getPVFields());
+             if(fieldPtrArray.size()!=1) {
+                  throw std::logic_error(
+                      "PvaClientData::getStringArray() pvRequest for multiple fields");
+             }
+             PVFieldPtr pvField(fieldPtrArray[0]);
+             Type type = pvField->getField()->getType();
+             if(type==scalarArray) {
+                 pvScalarArray = static_pointer_cast<PVScalarArray>(pvField);
+                 break;
+             }
+             if(pvField->getField()->getType()!=epics::pvData::structure) break;
+             pvStructure = static_pointer_cast<PVStructure>(pvField);
+        }
+    }
+    if(!pvScalarArray) {
+        throw std::logic_error(
+            "PvaClientData::getStringArray() did not find a scalarArray field");
+    }
+    shared_vector<const string> retValue;
+    pvScalarArray->getAs<const string>(retValue);
+    return retValue;
+}
+
+Alarm PvaClientData::getAlarm()
+{
+   if(PvaClient::getDebug()) cout << "PvaClientData::getAlarm\n";
+   if(!pvStructure) throw new std::runtime_error(messagePrefix + noStructure);
+   PVStructurePtr pvs = pvStructure->getSubField<PVStructure>("alarm");
+   if(!pvs) throw std::runtime_error(messagePrefix + noAlarm);
+   pvAlarm.attach(pvs);
+   if(pvAlarm.isAttached()) {
+       Alarm alarm;
+       pvAlarm.get(alarm);
+       pvAlarm.detach();
+       return alarm;
+   }
+   throw std::runtime_error(messagePrefix + noAlarm);
+}
+
+TimeStamp PvaClientData::getTimeStamp()
+{
+   if(PvaClient::getDebug()) cout << "PvaClientData::getTimeStamp\n";
+   if(!pvStructure) throw new std::runtime_error(messagePrefix + noStructure);
+   PVStructurePtr pvs = pvStructure->getSubField<PVStructure>("timeStamp");
+   if(!pvs) throw std::runtime_error(messagePrefix + noTimeStamp);
+   pvTimeStamp.attach(pvs);
+   if(pvTimeStamp.isAttached()) {
+       TimeStamp timeStamp;
+       pvTimeStamp.get(timeStamp);
+       pvTimeStamp.detach();
+       return timeStamp;
+   }
+   throw std::runtime_error(messagePrefix + noTimeStamp);
+}
+
+void PvaClientData::zeroArrayLength()
+{
+    if(!pvStructure) throw new std::runtime_error(messagePrefix + noStructure);
+    zeroArrayLength(pvStructure);
+}
+void PvaClientData::parse(
+    const std::string &arg,const PVFieldPtr &dest,BitSetPtr & bitSet)
+{
+#ifdef USE_JSON
+    std::istringstream strm(arg);
+    parseJSON(strm, dest,&(*bitSet));
+#else
+    throw std::runtime_error("JSON support not built");
+#endif
+}
+
+void PvaClientData::parse(
+    const std::string &arg,const PVUnionPtr &pvUnion)
+{
+    if(pvUnion->getUnion()->isVariant()) {
+          throw std::runtime_error(messagePrefix + "varient union not implemented");
+    }
+    size_t iequals = arg.find_first_of('=');
+    string field;
+    string rest;
+    if(iequals==std::string::npos) {
+        string mess(arg);
+        mess += " was expected to start with field=";
+          throw std::runtime_error(messagePrefix + mess);
+    }
+    field = arg.substr(0,iequals);
+    rest = arg.substr(iequals+1);
+    PVFieldPtr pvField(pvUnion->select(field));
+    if(pvField->getField()->getType()==epics::pvData::union_) {
+        PVUnionPtr pvu = static_pointer_cast<PVUnion>(pvField);
+        parse(rest,pvu);
+        return;
+    }
+    BitSetPtr bs;
+    parse(rest,pvField,bs);
+    return;
+}
+
+void PvaClientData::parse(const std::vector<std::string> &args)
+{
+    if(!pvStructure) throw std::runtime_error(messagePrefix + noStructure);
+    if(!bitSet) throw std::runtime_error(messagePrefix + noStructure);
+    size_t num = args.size();
+    if(num<1) throw std::runtime_error(messagePrefix + " no arguments");
+    for(size_t i=0; i<num; ++i)
+    {
+        string val = args[i];
+        size_t iequals = val.find_first_of('=');
+        string field;
+        string rest(val);
+        if(iequals==std::string::npos) {
+           parse(rest,pvStructure,bitSet);
+           continue;
+        }
+        field = val.substr(0,iequals);
+        rest = val.substr(iequals+1);
+        if(field.size()==std::string::npos) {
+           parse(rest,pvStructure,bitSet);
+           continue;
+        } 
+        PVFieldPtr pvField(pvStructure->getSubField(field));
+        if(!pvField) throw std::runtime_error(messagePrefix + field +" does not exist");
+        // look for enumerated structure
+        PVEnumerated pvEnumerated;
+        bool result = pvEnumerated.attach(pvField);
+        if(result) {
+             PVStringArray::const_svector choices(pvEnumerated.getChoices());
+             for(size_t i=0; i<choices.size(); ++i) {
+                  if(choices[i]==rest) {
+                     pvEnumerated.setIndex(i);
+                     return;
+                  }
+             }
+        }
+        // look for union
+        PVUnionPtr pvUnion(pvStructure->getSubField<PVUnion>(field));
+        if(pvUnion) {
+            parse(rest,pvUnion);
+            bitSet->set(pvUnion->getFieldOffset());
+            return;
+        }
+        parse(rest,pvField,bitSet);
+    }
+}
+
+void PvaClientData::streamJSON(
+               std::ostream& strm,
+               bool ignoreUnprintable,
+               bool multiLine)
+{
+#ifdef USE_JSON
+    JSONPrintOptions opts;
+    opts.ignoreUnprintable = ignoreUnprintable;
+    opts.multiLine = multiLine;
+    printJSON(strm,*pvStructure,*bitSet,opts);
+#else
+    throw std::runtime_error("JSON support not built");
+#endif
+}
+
+
+void PvaClientData::zeroArrayLength(const epics::pvData::PVStructurePtr &pvStructure)
+{
+const PVFieldPtrArray pvFields(pvStructure->getPVFields());
+    for(size_t i=0; i<pvFields.size(); ++i) {
+        PVFieldPtr pvField = pvFields[i];
+        Type type(pvField->getField()->getType());
+        switch(type) {
+        case epics::pvData::scalarArray:
+            {
+                PVScalarArrayPtr pvScalarArray = static_pointer_cast<PVScalarArray>(pvField);
+                pvScalarArray->setLength(0);
+            }
+            break;
+        case epics::pvData::structureArray:
+            {
+                PVStructureArrayPtr pvStructureArray = static_pointer_cast<PVStructureArray>(pvField);
+                pvStructureArray->setLength(0);
+            }
+            break;
+        case epics::pvData::structure:
+            {
+                PVStructurePtr pvStructure = static_pointer_cast<PVStructure>(pvField);
+                zeroArrayLength(pvStructure);
+            } 
+            break;
+        default:
+               break;
+        }
+    }
+}
+
+
+}}

src/pvaClientGet.cpp

@@ -15,7 +15,6 @@
 
 #include <pv/pvaClient.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace std;
@@ -99,18 +98,16 @@ PvaClientGet::PvaClientGet(
   getState(getIdle)
 {
      if(PvaClient::getDebug()) {
-        cout << "PvaClientGet::PvaClientGet::PvaClientGet"
-           << " channelName " << pvaClientChannel->getChannel()->getChannelName()
-           << endl;
+        cout << "PvaClientGet::PvaClientGet channelName "
+             << pvaClientChannel->getChannel()->getChannelName() << "\n";
     }
 }
 
 PvaClientGet::~PvaClientGet()
 {
     if(PvaClient::getDebug()) {
-        cout<< "PvaClientGet::~PvaClientGet"
-           << " channelName " << pvaClientChannel->getChannel()->getChannelName()
-           << endl;
+        cout<< "PvaClientGet::~PvaClientGet channelName "
+           << pvaClientChannel->getChannel()->getChannelName() << "\n";
     }
 }
 
@@ -118,9 +115,8 @@ PvaClientGet::~PvaClientGet()
 void PvaClientGet::checkConnectState()
 {
     if(PvaClient::getDebug()) {
-        cout << "PvaClientGet::checkConnectState"
-           << " channelName " << pvaClientChannel->getChannel()->getChannelName()
-           << endl;
+        cout << "PvaClientGet::checkConnectState channelName "
+           << pvaClientChannel->getChannel()->getChannelName() << "\n";
     }
     if(!pvaClientChannel->getChannel()->isConnected()) {
         string message = string("channel ") + pvaClientChannel->getChannel()->getChannelName()
@@ -159,10 +155,10 @@ void PvaClientGet::channelGetConnect(
     StructureConstPtr const & structure)
 {
     if(PvaClient::getDebug()) {
-        cout << "PvaClientGet::channelGetConnect"
-           << " channelName " << pvaClientChannel->getChannel()->getChannelName()
+        cout << "PvaClientGet::channelGetConnect channelName "
+           << pvaClientChannel->getChannel()->getChannelName()
            << " status.isOK " << (status.isOK() ? "true" : "false")
-           << endl;
+           << "\n";
     }
     {
         Lock xx(mutex);
@@ -196,10 +192,10 @@ void PvaClientGet::getDone(
     BitSetPtr const & bitSet)
 {
     if(PvaClient::getDebug()) {
-        cout << "PvaClientGet::getDone"
-           << " channelName " << pvaClientChannel->getChannel()->getChannelName()
+        cout << "PvaClientGet::getDone channelName "
+           << pvaClientChannel->getChannel()->getChannelName()
            << " status.isOK " << (status.isOK() ? "true" : "false")
-           << endl;
+           << "\n";
     }
     {
         Lock xx(mutex);
@@ -219,9 +215,8 @@ void PvaClientGet::getDone(
 void PvaClientGet::connect()
 {
     if(PvaClient::getDebug()) {
-        cout << "PvaClientGet::connect"
-           << " channelName " << pvaClientChannel->getChannel()->getChannelName()
-           << endl;
+        cout << "PvaClientGet::connect channelName "
+           << pvaClientChannel->getChannel()->getChannelName() << "\n";
     }
     issueConnect();
     Status status = waitConnect();
@@ -234,9 +229,8 @@ void PvaClientGet::connect()
 void PvaClientGet::issueConnect()
 {
     if(PvaClient::getDebug()) {
-        cout << "PvaClientGet::issueConnect"
-           << " channelName " << pvaClientChannel->getChannel()->getChannelName()
-           << endl;
+        cout << "PvaClientGet::issueConnect channelName "
+           << pvaClientChannel->getChannel()->getChannelName() << "\n";
     }
     if(connectState!=connectIdle) {
         string message = string("channel ")  + pvaClientChannel->getChannel()->getChannelName()
@@ -251,9 +245,8 @@ void PvaClientGet::issueConnect()
 Status PvaClientGet::waitConnect()
 {
     if(PvaClient::getDebug()) {
-        cout << "PvaClientGet::waitConnect"
-           << " channelName " << pvaClientChannel->getChannel()->getChannelName()
-           << endl;
+        cout << "PvaClientGet::waitConnect channelName "
+           << pvaClientChannel->getChannel()->getChannelName() << "\n";
     }
     {
         Lock xx(mutex);
@@ -275,9 +268,8 @@ Status PvaClientGet::waitConnect()
 void PvaClientGet::get()
 {
     if(PvaClient::getDebug()) {
-        cout << "PvaClientGet::get"
-           << " channelName " << pvaClientChannel->getChannel()->getChannelName()
-           << endl;
+        cout << "PvaClientGet::get channelName "
+          << pvaClientChannel->getChannel()->getChannelName() << "\n";
     }
     issueGet();
     Status status = waitGet();
@@ -290,9 +282,8 @@ void PvaClientGet::get()
 void PvaClientGet::issueGet()
 {
     if(PvaClient::getDebug()) {
-        cout << "PvaClientGet::issueGet"
-           << " channelName " << pvaClientChannel->getChannel()->getChannelName()
-           << endl;
+        cout << "PvaClientGet::issueGet channelName "
+           << pvaClientChannel->getChannel()->getChannelName() << "\n";
     }
     if(connectState==connectIdle) connect();
     if(getState==getActive) {
@@ -307,9 +298,8 @@ void PvaClientGet::issueGet()
 Status PvaClientGet::waitGet()
 {
     if(PvaClient::getDebug()) {
-        cout << "PvaClientGet::waitGet"
-           << " channelName " << pvaClientChannel->getChannel()->getChannelName()
-           << endl;
+        cout << "PvaClientGet::waitGet channelName "
+           << pvaClientChannel->getChannel()->getChannelName() << "\n";
     }
     {
         Lock xx(mutex);
@@ -330,9 +320,8 @@ Status PvaClientGet::waitGet()
 PvaClientGetDataPtr PvaClientGet::getData()
 {
     if(PvaClient::getDebug()) {
-           cout<< "PvaClientGet::getData"
-               << " channelName " << pvaClientChannel->getChannel()->getChannelName()
-               << endl;
+           cout<< "PvaClientGet::getData  channelName "
+               << pvaClientChannel->getChannel()->getChannelName() << "\n";
     }
     checkConnectState();
     if(getState==getIdle) get();
@@ -342,9 +331,8 @@ PvaClientGetDataPtr PvaClientGet::getData()
 void PvaClientGet::setRequester(PvaClientGetRequesterPtr const & pvaClientGetRequester)
 {
     if(PvaClient::getDebug()) {
-        cout << "PvaClientGet::setRequester"
-           << " channelName " << pvaClientChannel->getChannel()->getChannelName()
-           << endl;
+        cout << "PvaClientGet::setRequester channelName "
+           << pvaClientChannel->getChannel()->getChannelName() << "\n";
     }
     this->pvaClientGetRequester = pvaClientGetRequester;
 }

src/pvaClientGetData.cpp

@@ -19,7 +19,6 @@
 
 #include <pv/pvaClient.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace std;
@@ -27,214 +26,15 @@ using namespace std;
 namespace epics { namespace pvaClient {
 
 
-typedef std::tr1::shared_ptr<PVArray> PVArrayPtr;
-static ConvertPtr convert = getConvert();
-static string noStructure("no pvStructure ");
-static string noValue("no value field");
-static string noScalar("value is not a scalar");
-static string notCompatibleScalar("value is not a compatible scalar");
-static string noArray("value is not an array");
-static string noScalarArray("value is not a scalarArray");
-static string notDoubleArray("value is not a doubleArray");
-static string notStringArray("value is not a stringArray");
-static string noAlarm("no alarm");
-static string noTimeStamp("no timeStamp");
-
 PvaClientGetDataPtr PvaClientGetData::create(StructureConstPtr const & structure)
 {
-    if(PvaClient::getDebug()) {
-        cout << "PvaClientGetData::create"
-           << endl;
-    }
+    if(PvaClient::getDebug()) cout << "PvaClientGetData::create\n";
     PvaClientGetDataPtr epv(new PvaClientGetData(structure));
     return epv;
 }
 
 PvaClientGetData::PvaClientGetData(StructureConstPtr const & structure)
-: structure(structure),
-  pvStructure(getPVDataCreate()->createPVStructure(structure)),
-  bitSet(BitSetPtr(new BitSet(pvStructure->getNumberFields())))
-{
-    messagePrefix = "";
-    pvValue = pvStructure->getSubField("value");
-}
-
-void PvaClientGetData::checkValue()
-{
-    if(PvaClient::getDebug()) {
-        cout << "PvaClientGetData::checkValue"
-           << endl;
-    }
-    if(pvValue) return;
-    throw std::runtime_error(messagePrefix + noValue);
-}
-
-void PvaClientGetData::setMessagePrefix(std::string const & value)
-{
-    messagePrefix = value + " ";
-}
-
-StructureConstPtr PvaClientGetData::getStructure()
-{return structure;}
-
-PVStructurePtr PvaClientGetData::getPVStructure()
-{
-    if(pvStructure) return pvStructure;
-    throw std::runtime_error(messagePrefix + noStructure);
-}
-
-BitSetPtr PvaClientGetData::getChangedBitSet()
-{
-    if(bitSet)return bitSet;
-    throw std::runtime_error(messagePrefix + noStructure);
-}
-
-std::ostream & PvaClientGetData::showChanged(std::ostream & out)
-{
-    if(!bitSet) throw std::runtime_error(messagePrefix + noStructure);
-    size_t nextSet = bitSet->nextSetBit(0);
-    PVFieldPtr pvField;
-    while(nextSet!=string::npos) {
-        if(nextSet==0) {
-             pvField = pvStructure;
-        } else {
-              pvField = pvStructure->getSubField(nextSet);
-        }
-        string name = pvField->getFullName();
-        out << name << " = " << pvField << endl;
-        nextSet = bitSet->nextSetBit(nextSet+1);
-    }
-    return out;
-}
-
-void PvaClientGetData::setData(
-    PVStructurePtr const & pvStructureFrom,
-    BitSetPtr const & bitSetFrom)
-{
-    if(PvaClient::getDebug()) {
-        cout << "PvaClientGetData::setData"
-           << endl;
-    }
-   pvStructure = pvStructureFrom;
-   bitSet = bitSetFrom;
-   pvValue = pvStructure->getSubField("value");
-}
-
-bool PvaClientGetData::hasValue()
-{
-    if(!pvValue) return false;
-    return true;
-}
-
-bool PvaClientGetData::isValueScalar()
-{
-    if(!pvValue) return false;
-    if(pvValue->getField()->getType()==scalar) return true;
-    return false;
-}
-
-bool PvaClientGetData::isValueScalarArray()
-{
-    if(!pvValue) return false;
-    if(pvValue->getField()->getType()==scalarArray) return true;
-    return false;
-}
-
-PVFieldPtr  PvaClientGetData::getValue()
-{
-   checkValue();
-   return pvValue;
-}
-
-PVScalarPtr  PvaClientGetData::getScalarValue()
-{
-    checkValue();
-    PVScalarPtr pv = pvStructure->getSubField<PVScalar>("value");
-    if(!pv) throw std::runtime_error(messagePrefix + noScalar);
-    return pv;
-}
-
-PVArrayPtr  PvaClientGetData::getArrayValue()
-{
-    checkValue();
-    PVArrayPtr pv = pvStructure->getSubField<PVArray>("value");
-    if(!pv) throw std::runtime_error(messagePrefix + noArray);
-    return pv;
-}
-
-PVScalarArrayPtr  PvaClientGetData::getScalarArrayValue()
-{
-    checkValue();
-    PVScalarArrayPtr pv = pvStructure->getSubField<PVScalarArray>("value");
-    if(!pv) throw std::runtime_error(messagePrefix + noScalarArray);
-    return pv;
-}
-
-double PvaClientGetData::getDouble()
-{
-    PVScalarPtr pvScalar = getScalarValue();
-    ScalarType scalarType = pvScalar->getScalar()->getScalarType();
-    if(scalarType==pvDouble) {
-        PVDoublePtr pvDouble = static_pointer_cast<PVDouble>(pvScalar);
-        return pvDouble->get();
-    }
-    if(!ScalarTypeFunc::isNumeric(scalarType)) {
-        throw std::runtime_error(messagePrefix + notCompatibleScalar);
-    }
-    return convert->toDouble(pvScalar);
-}
-
-string PvaClientGetData::getString()
-{
-    PVScalarPtr pvScalar = getScalarValue();
-    return convert->toString(pvScalar);
-}
-
-shared_vector<const double> PvaClientGetData::getDoubleArray()
-{
-    checkValue();
-    PVDoubleArrayPtr pv = pvStructure->getSubField<PVDoubleArray>("value");
-    if(!pv) throw std::runtime_error(messagePrefix + notDoubleArray);
-    return pv->view();   
-}
-
-shared_vector<const string> PvaClientGetData::getStringArray()
-{
-    checkValue();
-    PVStringArrayPtr pv = pvStructure->getSubField<PVStringArray>("value");
-    if(!pv) throw std::runtime_error(messagePrefix + notStringArray);
-    return pv->view();   
-}
-
-
-Alarm PvaClientGetData::getAlarm()
-{
-   if(!pvStructure) throw new std::runtime_error(messagePrefix + noStructure);
-   PVStructurePtr pvs = pvStructure->getSubField<PVStructure>("alarm");
-   if(!pvs) throw std::runtime_error(messagePrefix + noAlarm);
-   pvAlarm.attach(pvs);
-   if(pvAlarm.isAttached()) {
-       Alarm alarm;
-       pvAlarm.get(alarm);
-       pvAlarm.detach();
-       return alarm;
-   }
-   throw std::runtime_error(messagePrefix + noAlarm);
-}
-
-TimeStamp PvaClientGetData::getTimeStamp()
-{
-   if(!pvStructure) throw new std::runtime_error(messagePrefix + noStructure);
-   PVStructurePtr pvs = pvStructure->getSubField<PVStructure>("timeStamp");
-   if(!pvs) throw std::runtime_error(messagePrefix + noTimeStamp);
-   pvTimeStamp.attach(pvs);
-   if(pvTimeStamp.isAttached()) {
-       TimeStamp timeStamp;
-       pvTimeStamp.get(timeStamp);
-       pvTimeStamp.detach();
-       return timeStamp;
-   }
-   throw std::runtime_error(messagePrefix + noTimeStamp);
-}
+: PvaClientData(structure)
+{}
 
 }}

src/pvaClientMonitor.cpp

@@ -17,8 +17,6 @@
 
 #include <pv/pvaClient.h>
 
-using std::tr1::static_pointer_cast;
-using std::tr1::dynamic_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace std;

src/pvaClientMonitorData.cpp

@@ -19,7 +19,6 @@
 
 #include <pv/pvaClient.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace std;
@@ -53,43 +52,16 @@ PvaClientMonitorDataPtr PvaClientMonitorData::create(StructureConstPtr const & s
 }
 
 PvaClientMonitorData::PvaClientMonitorData(StructureConstPtr const & structure)
-: structure(structure)
+: PvaClientData(structure)
 {
-    messagePrefix = "";
 }
 
 void PvaClientMonitorData::setData(MonitorElementPtr const & monitorElement)
 {
-   pvStructure = monitorElement->pvStructurePtr;
-   changedBitSet = monitorElement->changedBitSet;
+   PVStructurePtr pvStructure = monitorElement->pvStructurePtr;
+   BitSetPtr changedBitSet = monitorElement->changedBitSet;
+   PvaClientData::setData(pvStructure,changedBitSet);
    overrunBitSet = monitorElement->overrunBitSet;
-   pvValue = pvStructure->getSubField("value");
-}
-
-void PvaClientMonitorData::checkValue()
-{
-    if(pvValue) return;
-    throw std::runtime_error(messagePrefix + noValue);
-}
-
-void PvaClientMonitorData::setMessagePrefix(std::string const & value)
-{
-    messagePrefix = value + " ";
-}
-
-StructureConstPtr PvaClientMonitorData::getStructure()
-{return structure;}
-
-PVStructurePtr PvaClientMonitorData::getPVStructure()
-{
-    if(pvStructure) return pvStructure;
-    throw std::runtime_error(messagePrefix + noStructure);
-}
-
-BitSetPtr PvaClientMonitorData::getChangedBitSet()
-{
-    if(!changedBitSet) throw std::runtime_error(messagePrefix + noStructure);
-    return changedBitSet;
 }
 
 BitSetPtr PvaClientMonitorData::getOverrunBitSet()
@@ -98,24 +70,6 @@ BitSetPtr PvaClientMonitorData::getOverrunBitSet()
     return overrunBitSet;
 }
 
-std::ostream & PvaClientMonitorData::showChanged(std::ostream & out)
-{
-    if(!changedBitSet) throw std::runtime_error(messagePrefix + noStructure);
-    size_t nextSet = changedBitSet->nextSetBit(0);
-    PVFieldPtr pvField;
-    while(nextSet!=string::npos) {
-        if(nextSet==0) {
-             pvField = pvStructure;
-        } else {
-              pvField = pvStructure->getSubField(nextSet);
-        }
-        string name = pvField->getFullName();
-        out << name << " = " << pvField << endl;
-        nextSet = changedBitSet->nextSetBit(nextSet+1);
-    }
-    return out;
-}
-
 std::ostream & PvaClientMonitorData::showOverrun(std::ostream & out)
 {
     if(!overrunBitSet) throw std::runtime_error(messagePrefix + noStructure);
@@ -123,9 +77,9 @@ std::ostream & PvaClientMonitorData::showOverrun(std::ostream & out)
     PVFieldPtr pvField;
     while(nextSet!=string::npos) {
         if(nextSet==0) {
-             pvField = pvStructure;
+             pvField = getPVStructure();
         } else {
-              pvField = pvStructure->getSubField(nextSet);
+              pvField = getPVStructure()->getSubField(nextSet);
         }
         string name = pvField->getFullName();
         out << name << " = " << pvField << endl;
@@ -134,135 +88,4 @@ std::ostream & PvaClientMonitorData::showOverrun(std::ostream & out)
     return out;
 }
 
-bool PvaClientMonitorData::hasValue()
-{
-    if(!pvValue) return false;
-    return true;
-}
-
-bool PvaClientMonitorData::isValueScalar()
-{
-    if(!pvValue) return false;
-    if(pvValue->getField()->getType()==scalar) return true;
-    return false;
-}
-
-bool PvaClientMonitorData::isValueScalarArray()
-{
-    if(!pvValue) return false;
-    if(pvValue->getField()->getType()==scalarArray) return true;
-    return false;
-}
-
-PVFieldPtr  PvaClientMonitorData::getValue()
-{
-   checkValue();
-   return pvValue;
-}
-
-PVScalarPtr  PvaClientMonitorData::getScalarValue()
-{
-    checkValue();
-    PVScalarPtr pv = pvStructure->getSubField<PVScalar>("value");
-    if(!pv) {
-        throw std::runtime_error(messagePrefix + noScalar);
-    }
-    return pv;
-}
-
-PVArrayPtr  PvaClientMonitorData::getArrayValue()
-{
-    checkValue();
-    PVArrayPtr pv = pvStructure->getSubField<PVArray>("value");
-    if(!pv) {
-        throw std::runtime_error(messagePrefix + noArray);
-    }
-    return pv;
-}
-
-PVScalarArrayPtr  PvaClientMonitorData::getScalarArrayValue()
-{
-    checkValue();
-    PVScalarArrayPtr pv = pvStructure->getSubField<PVScalarArray>("value");
-    if(!pv) {
-        throw std::runtime_error(messagePrefix + noScalarArray);
-    }
-    return pv;
-}
-
-double PvaClientMonitorData::getDouble()
-{
-    PVScalarPtr pvScalar = getScalarValue();
-    ScalarType scalarType = pvScalar->getScalar()->getScalarType();
-    if(scalarType==pvDouble) {
-        PVDoublePtr pvDouble = static_pointer_cast<PVDouble>(pvScalar);
-        return pvDouble->get();
-    }
-    if(!ScalarTypeFunc::isNumeric(scalarType)) {
-        throw std::runtime_error(messagePrefix + notCompatibleScalar);
-    }
-    return convert->toDouble(pvScalar);
-}
-
-string PvaClientMonitorData::getString()
-{
-    PVScalarPtr pvScalar = getScalarValue();
-    return convert->toString(pvScalar);
-}
-
-shared_vector<const double> PvaClientMonitorData::getDoubleArray()
-{
-    checkValue();
-    PVDoubleArrayPtr pv = pvStructure->getSubField<PVDoubleArray>("value");
-    if(!pv) {
-        throw std::runtime_error(messagePrefix + notDoubleArray);
-    }
-    return pv->view();   
-}
-
-shared_vector<const string> PvaClientMonitorData::getStringArray()
-{
-    checkValue();
-    PVStringArrayPtr pv = pvStructure->getSubField<PVStringArray>("value");
-    if(!pv) {
-        throw std::runtime_error(messagePrefix + notStringArray);
-    }
-    return pv->view();   
-
-}
-
-Alarm PvaClientMonitorData::getAlarm()
-{
-   if(!pvStructure) {
-        throw std::runtime_error(messagePrefix + noAlarm);
-   }
-   PVStructurePtr pvs = pvStructure->getSubField<PVStructure>("alarm");
-   if(!pvs) throw std::runtime_error(messagePrefix + noAlarm);
-   pvAlarm.attach(pvs);
-   if(pvAlarm.isAttached()) {
-       Alarm alarm;
-       pvAlarm.get(alarm);
-       pvAlarm.detach();
-       return alarm;
-   }
-   throw std::runtime_error(messagePrefix + noAlarm);
-}
-
-TimeStamp PvaClientMonitorData::getTimeStamp()
-{
-   if(!pvStructure) {
-        throw std::runtime_error(messagePrefix + noTimeStamp);
-   }
-   PVStructurePtr pvs = pvStructure->getSubField<PVStructure>("timeStamp");
-   if(!pvs) throw std::runtime_error(messagePrefix + noTimeStamp);
-   pvTimeStamp.attach(pvs);
-   if(pvTimeStamp.isAttached()) {
-       TimeStamp timeStamp;
-       pvTimeStamp.get(timeStamp);
-       pvTimeStamp.detach();
-       return timeStamp;
-   }
-   throw std::runtime_error(messagePrefix + noTimeStamp);
-}
-
 }}

src/pvaClientMultiChannel.cpp

@@ -17,9 +17,6 @@
 
 #include <pv/pvaClientMultiChannel.h>
 
-
-
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace std;

src/pvaClientMultiGetDouble.cpp

@@ -16,7 +16,6 @@
 
 #include <pv/pvaClientMultiChannel.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace epics::nt;

src/pvaClientMultiMonitorDouble.cpp

@@ -16,7 +16,6 @@
 
 #include <pv/pvaClientMultiChannel.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace epics::nt;

src/pvaClientMultiPutDouble.cpp

@@ -16,7 +16,6 @@
 
 #include <pv/pvaClientMultiChannel.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace epics::nt;

src/pvaClientNTMultiData.cpp

@@ -15,7 +15,6 @@
 
 #include <pv/pvaClientMultiChannel.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace epics::nt;
@@ -45,10 +44,6 @@ PvaClientNTMultiData::PvaClientNTMultiData(
   gotTimeStamp(false)
 {
     if(PvaClient::getDebug()) cout<< "PvaClientNTMultiData::PvaClientNTMultiData()\n";
-    PVFieldPtr pvValue = pvRequest->getSubField("field.value");
-    if(!pvValue) {
-        throw std::runtime_error("pvRequest did not specify value");
-    }
     topPVStructure.resize(nchannel);
     unionValue.resize(nchannel);
     PVDataCreatePtr pvDataCreate = getPVDataCreate();
@@ -89,18 +84,6 @@ PvaClientNTMultiData::~PvaClientNTMultiData()
     if(PvaClient::getDebug()) cout<< "PvaClientNTMultiData::~PvaClientNTMultiData()\n";
 }
 
-
-void PvaClientNTMultiData::setStructure(StructureConstPtr const & structure,size_t index)
-{
-    FieldConstPtr field = structure->getField("value");
-    if(!field) {
-        string message = "channel "
-           + pvaClientChannelArray[index]->getChannel()->getChannelName()
-           + " does not have top level value field";
-        throw std::runtime_error(message);
-    }
-}
-
 void PvaClientNTMultiData::setPVStructure(
         PVStructurePtr const &pvStructure,size_t index)
 {
@@ -138,7 +121,7 @@ void PvaClientNTMultiData::startDeltaTime()
 }
 
 
-void PvaClientNTMultiData::endDeltaTime()
+void PvaClientNTMultiData::endDeltaTime(bool valueOnly)
 {
     for(size_t i=0; i<nchannel; ++i)
     {
@@ -146,18 +129,41 @@ void PvaClientNTMultiData::endDeltaTime()
         if(!pvst) {
             unionValue[i] = PVUnionPtr();
         } else if(unionValue[i]) {
-            unionValue[i]->set(pvst->getSubField("value"));
+            if(valueOnly) {
+                PVFieldPtr pvValue = pvst->getSubField("value");
+                if(pvValue) {
+                    unionValue[i]->set(pvst->getSubField("value"));
+                } else {
+                    unionValue[i] = PVUnionPtr();
+                }
+            } else {
+                unionValue[i]->set(pvst);
+            }
             if(gotAlarm)
             {
-                severity[i] = pvst->getSubField<PVInt>("alarm.severity")->get();
-                status[i] = pvst->getSubField<PVInt>("alarm.status")->get();
-                message[i] = pvst->getSubField<PVString>("alarm.message")->get();
+                PVIntPtr pvSeverity = pvst->getSubField<PVInt>("alarm.severity");
+                PVIntPtr pvStatus = pvst->getSubField<PVInt>("alarm.status");
+                PVStringPtr pvMessage = pvst->getSubField<PVString>("alarm.message");
+                if(pvSeverity&&pvStatus&&pvMessage) {
+                    severity[i] = pvSeverity->get();
+                    status[i] = pvStatus->get();
+                    message[i] = pvMessage->get();
+                } else {
+                    severity[i] = undefinedAlarm;
+                    status[i] = undefinedStatus;
+                    message[i] = "no alarm field";
+                }
             }
             if(gotTimeStamp)
             {
-                secondsPastEpoch[i] = pvst->getSubField<PVLong>("timeStamp.secondsPastEpoch")->get();
-                nanoseconds[i] = pvst->getSubField<PVInt>("timeStamp.nanoseconds")->get();
-                userTag[i] = pvst->getSubField<PVInt>("timeStamp.userTag")->get();
+                PVLongPtr pvEpoch = pvst->getSubField<PVLong>("timeStamp.secondsPastEpoch");
+                PVIntPtr pvNano = pvst->getSubField<PVInt>("timeStamp.nanoseconds");
+                PVIntPtr pvTag = pvst->getSubField<PVInt>("timeStamp.userTag");
+                if(pvEpoch&&pvNano&&pvTag) {
+                    secondsPastEpoch[i] = pvEpoch->get();
+                    nanoseconds[i] = pvNano->get();
+                    userTag[i] = pvTag->get();
+                }
             }
         } 
     }

src/pvaClientNTMultiGet.cpp

@@ -15,7 +15,6 @@
 
 #include <pv/pvaClientMultiChannel.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace epics::nt;
@@ -64,13 +63,10 @@ void PvaClientNTMultiGet::connect()
 {
     pvaClientGet.resize(nchannel);
     shared_vector<epics::pvData::boolean> isConnected = pvaClientMultiChannel->getIsConnected();
-    string request = "value";
-    if(pvRequest->getSubField("field.alarm")) request += ",alarm";
-    if(pvRequest->getSubField("field.timeStamp")) request += ",timeStamp";
     for(size_t i=0; i<nchannel; ++i)
     {
          if(isConnected[i]) {
-               pvaClientGet[i] = pvaClientChannelArray[i]->createGet(request);
+               pvaClientGet[i] = pvaClientChannelArray[i]->createGet(pvRequest);
                pvaClientGet[i]->issueConnect();
          }
     }
@@ -87,7 +83,7 @@ void PvaClientNTMultiGet::connect()
     this->isConnected = true;
 }
 
-void PvaClientNTMultiGet::get()
+void PvaClientNTMultiGet::get(bool valueOnly)
 {
     if(!isConnected) connect();
     shared_vector<epics::pvData::boolean> isConnected = pvaClientMultiChannel->getIsConnected();
@@ -115,7 +111,7 @@ void PvaClientNTMultiGet::get()
               pvaClientNTMultiData->setPVStructure(pvaClientGet[i]->getData()->getPVStructure(),i);
          }
     }
-    pvaClientNTMultiData->endDeltaTime();
+    pvaClientNTMultiData->endDeltaTime(valueOnly);
 }
 
 PvaClientNTMultiDataPtr PvaClientNTMultiGet::getData()

src/pvaClientNTMultiMonitor.cpp

@@ -18,7 +18,6 @@
 
 #include <pv/pvaClientMultiChannel.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace epics::nt;
@@ -68,13 +67,10 @@ void PvaClientNTMultiMonitor::connect()
 {
     pvaClientMonitor.resize(nchannel);
     shared_vector<epics::pvData::boolean> isConnected = pvaClientMultiChannel->getIsConnected();
-    string request = "value";
-    if(pvRequest->getSubField("field.alarm")) request += ",alarm";
-    if(pvRequest->getSubField("field.timeStamp")) request += ",timeStamp";
     for(size_t i=0; i<nchannel; ++i)
     {
          if(isConnected[i]) {
-               pvaClientMonitor[i] = pvaClientChannelArray[i]->createMonitor(request);
+               pvaClientMonitor[i] = pvaClientChannelArray[i]->createMonitor(pvRequest);
                pvaClientMonitor[i]->issueConnect();
          }
     }
@@ -95,7 +91,7 @@ void PvaClientNTMultiMonitor::connect()
     this->isConnected = true;
 }
 
-bool PvaClientNTMultiMonitor::poll()
+bool PvaClientNTMultiMonitor::poll(bool valueOnly)
 {
     if(!isConnected) connect();
     bool result = false;
@@ -112,7 +108,7 @@ bool PvaClientNTMultiMonitor::poll()
               }
          }
     }
-    if(result) pvaClientNTMultiData->endDeltaTime();
+    if(result) pvaClientNTMultiData->endDeltaTime(valueOnly);
     return result;
 }
 

src/pvaClientNTMultiPut.cpp

@@ -17,7 +17,6 @@
 
 #include <pv/pvaClientMultiChannel.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace epics::nt;

src/pvaClientProcess.cpp

@@ -15,7 +15,6 @@
 
 #include <pv/pvaClient.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace std;

src/pvaClientPut.cpp

@@ -15,7 +15,6 @@
 
 #include <pv/pvaClient.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace std;

src/pvaClientPutData.cpp

@@ -25,6 +25,10 @@ using namespace epics::pvAccess;
 using namespace std;
 
 namespace epics { namespace pvaClient {
+static ConvertPtr convert = getConvert();
+static string notCompatibleScalar("value is not a compatible scalar");
+static string notDoubleArray("value is not a doubleArray");
+static string notStringArray("value is not a stringArray");
 
 class PvaClientPostHandlerPvt: public PostHandler
 {
@@ -36,28 +40,21 @@ public:
     void postPut() { putData->postPut(fieldNumber);}
 };
 
-typedef std::tr1::shared_ptr<PVArray> PVArrayPtr;
-static ConvertPtr convert = getConvert();
-static string noValue("no value field");
-static string notScalar("value is not a scalar");
-static string notCompatibleScalar("value is not a compatible scalar");
-static string notArray("value is not an array");
-static string notScalarArray("value is not a scalarArray");
-static string notDoubleArray("value is not a doubleArray");
-static string notStringArray("value is not a stringArray");
 
 PvaClientPutDataPtr PvaClientPutData::create(StructureConstPtr const & structure)
 {
+    if(PvaClient::getDebug()) cout << "PvaClientPutData::create\n";
     PvaClientPutDataPtr epv(new PvaClientPutData(structure));
     return epv;
 }
 
 PvaClientPutData::PvaClientPutData(StructureConstPtr const & structure)
-: structure(structure),
-  pvStructure(getPVDataCreate()->createPVStructure(structure)),
-  bitSet(BitSetPtr(new BitSet(pvStructure->getNumberFields())))
+: PvaClientData(structure)
 {
-    messagePrefix = "";
+    if(PvaClient::getDebug()) cout << "PvaClientPutData::PvaClientPutData\n";
+    PVStructurePtr pvStructure(getPVDataCreate()->createPVStructure(structure));
+    BitSetPtr bitSet(BitSetPtr(new BitSet(pvStructure->getNumberFields())));
+    setData(pvStructure,bitSet);
     size_t nfields = pvStructure->getNumberFields();
     postHandler.resize(nfields);
     PVFieldPtr pvField;
@@ -71,145 +68,40 @@ PvaClientPutData::PvaClientPutData(StructureConstPtr const & structure)
         }
         pvField->setPostHandler(postHandler[i]);
     }
-    pvValue = pvStructure->getSubField("value");
 }
 
-void PvaClientPutData::checkValue()
-{
-    if(pvValue) return;
-    throw std::runtime_error(messagePrefix + noValue);
-}
-
-void PvaClientPutData::postPut(size_t fieldNumber)
-{
-    bitSet->set(fieldNumber);
-}
-
-void PvaClientPutData::setMessagePrefix(std::string const & value)
-{
-    messagePrefix = value + " ";
-}
-
-StructureConstPtr PvaClientPutData::getStructure()
-{return structure;}
-
-PVStructurePtr PvaClientPutData::getPVStructure()
-{return pvStructure;}
-
-BitSetPtr PvaClientPutData::getChangedBitSet()
-{return bitSet;}
-
-std::ostream & PvaClientPutData::showChanged(std::ostream & out)
-{
-    size_t nextSet = bitSet->nextSetBit(0);
-    PVFieldPtr pvField;
-    while(nextSet!=string::npos) {
-        if(nextSet==0) {
-             pvField = pvStructure;
-        } else {
-              pvField = pvStructure->getSubField(nextSet);
-        }
-        string name = pvField->getFullName();
-        out << name << " = " << pvField << endl;
-        nextSet = bitSet->nextSetBit(nextSet+1);
-    }
-    return out;
-}
-
-bool PvaClientPutData::hasValue()
-{
-    if(!pvValue) return false;
-    return true;
-}
-
-bool PvaClientPutData::isValueScalar()
-{
-    if(!pvValue) return false;
-    if(pvValue->getField()->getType()==scalar) return true;
-    return false;
-}
-
-bool PvaClientPutData::isValueScalarArray()
-{
-    if(!pvValue) return false;
-    if(pvValue->getField()->getType()==scalarArray) return true;
-    return false;
-}
-
-PVFieldPtr  PvaClientPutData::getValue()
-{
-   checkValue();
-   return pvValue;
-}
-
-PVScalarPtr  PvaClientPutData::getScalarValue()
-{
-    checkValue();
-    PVScalarPtr pv = pvStructure->getSubField<PVScalar>("value");
-    if(!pv) throw std::runtime_error(messagePrefix + notScalar);
-    return pv;
-}
-
-PVArrayPtr  PvaClientPutData::getArrayValue()
-{
-    checkValue();
-    PVArrayPtr pv = pvStructure->getSubField<PVArray>("value");
-    if(!pv) throw std::runtime_error(messagePrefix + notArray);
-    return pv;
-}
-
-PVScalarArrayPtr  PvaClientPutData::getScalarArrayValue()
-{
-    checkValue();
-    PVScalarArrayPtr pv = pvStructure->getSubField<PVScalarArray>("value");
-    if(!pv) throw std::runtime_error(messagePrefix + notScalarArray);
-    return pv;
-}
-
-double PvaClientPutData::getDouble()
-{
-    PVScalarPtr pvScalar = getScalarValue();
-    ScalarType scalarType = pvScalar->getScalar()->getScalarType();
-    if(scalarType==pvDouble) {
-        PVDoublePtr pvDouble = static_pointer_cast<PVDouble>(pvScalar);
-        return pvDouble->get();
-    }
-    if(!ScalarTypeFunc::isNumeric(scalarType)) {
-        throw std::runtime_error(messagePrefix  + notCompatibleScalar);
-    }
-    return convert->toDouble(pvScalar);
-}
-
-string PvaClientPutData::getString()
-{
-    PVScalarPtr pvScalar = getScalarValue();
-    return convert->toString(pvScalar);
-}
-
-shared_vector<const double> PvaClientPutData::getDoubleArray()
-{
-    checkValue();
-    PVDoubleArrayPtr pv = pvStructure->getSubField<PVDoubleArray>("value");
-    if(!pv) {
-        throw std::runtime_error(messagePrefix + notDoubleArray);
-    }
-    return pv->view();   
-}
-
-shared_vector<const string> PvaClientPutData::getStringArray()
-{
-    checkValue();
-    PVStringArrayPtr pv = pvStructure->getSubField<PVStringArray>("value");
-    if(!pv) {
-        throw std::runtime_error(messagePrefix + notStringArray);
-    }
-    return pv->view();   
-
-}
 
 void PvaClientPutData::putDouble(double value)
 {
-    PVScalarPtr pvScalar = getScalarValue();
+    if(PvaClient::getDebug()) cout << "PvaClientPutData::putDouble\n";
+    PVScalarPtr pvScalar;
+    PVStructurePtr pvStructure = getPVStructure();
+    PVFieldPtr pvValue  = pvStructure->getSubField("value");
+    if(pvValue) {
+        Type type = pvValue->getField()->getType();
+        if(type==scalar) pvScalar = static_pointer_cast<PVScalar>(pvValue);
+    }
+    if(!pvScalar) {
+        while(true) {
+             const PVFieldPtrArray fieldPtrArray(pvStructure->getPVFields());
+             if(fieldPtrArray.size()!=1) {
+                  throw std::logic_error(
+                      "PvaClientData::putDouble() pvRequest for multiple fields");
+             }
+             PVFieldPtr pvField(fieldPtrArray[0]);
+             Type type = pvField->getField()->getType();
+             if(type==scalar) {
+                 pvScalar = static_pointer_cast<PVScalar>(pvField);
+                 break;
+             }
+             if(pvField->getField()->getType()!=epics::pvData::structure) break;
+             pvStructure = static_pointer_cast<PVStructure>(pvField);
+        }
+    }
+    if(!pvScalar) {
+        throw std::logic_error(
+            "PvaClientData::putDouble() did not find a scalar field");
+    }
     ScalarType scalarType = pvScalar->getScalar()->getScalarType();
     if(scalarType==pvDouble) {
         PVDoublePtr pvDouble = static_pointer_cast<PVDouble>(pvScalar);
@@ -217,47 +109,138 @@ void PvaClientPutData::putDouble(double value)
          return;
     }
     if(!ScalarTypeFunc::isNumeric(scalarType)) {
-        throw std::runtime_error(messagePrefix + notCompatibleScalar);
+        throw std::logic_error(
+            "PvaClientData::putDouble() did not find a numeric scalar field");
     }
     convert->fromDouble(pvScalar,value);
 }
 
 void PvaClientPutData::putString(std::string const & value)
 {
-    PVScalarPtr pvScalar = getScalarValue();
+    if(PvaClient::getDebug()) cout << "PvaClientPutData::putString\n";
+    PVScalarPtr pvScalar;
+    PVStructurePtr pvStructure = getPVStructure();
+    PVFieldPtr pvValue  = pvStructure->getSubField("value");
+    if(pvValue) {
+        Type type = pvValue->getField()->getType();
+        if(type==scalar) pvScalar = static_pointer_cast<PVScalar>(pvValue);
+    }
+    if(!pvScalar) {
+        while(true) {
+             const PVFieldPtrArray fieldPtrArray(pvStructure->getPVFields());
+             if(fieldPtrArray.size()!=1) {
+                  throw std::logic_error(
+                      "PvaClientData::putString() pvRequest for multiple fields");
+             }
+             PVFieldPtr pvField(fieldPtrArray[0]);
+             Type type = pvField->getField()->getType();
+             if(type==scalar) {
+                 pvScalar = static_pointer_cast<PVScalar>(pvField);
+                 break;
+             }
+             if(pvField->getField()->getType()!=epics::pvData::structure) break;
+             pvStructure = static_pointer_cast<PVStructure>(pvField);
+        }
+    }
+    if(!pvScalar) {
+        throw std::logic_error(
+            "PvaClientData::putString() did not find a scalar field");
+    }
     convert->fromString(pvScalar,value);
 }
 
-
-
 void PvaClientPutData::putDoubleArray(shared_vector<const double> const & value)
 {
-    checkValue();
-    PVDoubleArrayPtr pv = pvStructure->getSubField<PVDoubleArray>("value");
-    if(!pv) {
-        throw std::runtime_error(messagePrefix + notDoubleArray);
+    if(PvaClient::getDebug()) cout << "PvaClientPutData::putDoubleArray\n";
+    PVScalarArrayPtr pvScalarArray;
+    PVStructurePtr pvStructure = getPVStructure();
+    PVFieldPtr pvValue  = pvStructure->getSubField("value");
+    if(pvValue) {
+        Type type = pvValue->getField()->getType();
+        if(type==scalarArray) {
+             pvScalarArray = static_pointer_cast<PVScalarArray>(pvValue);
+        }
     }
-    pv->replace(value);
+    if(!pvScalarArray) {
+        while(true) {
+             const PVFieldPtrArray fieldPtrArray(pvStructure->getPVFields());
+             if(fieldPtrArray.size()!=1) {
+                  throw std::logic_error(
+                      "PvaClientData::putDoubleArray() pvRequest for multiple fields");
+             }
+             PVFieldPtr pvField(fieldPtrArray[0]);
+             Type type = pvField->getField()->getType();
+             if(type==scalarArray) {
+                 PVScalarArrayPtr pvScalarArray = static_pointer_cast<PVScalarArray>(pvField);
+                 break;
+             }
+             if(pvField->getField()->getType()!=epics::pvData::structure) break;
+             pvStructure = static_pointer_cast<PVStructure>(pvField);
+        }
+    }
+    if(!pvScalarArray) {
+        throw std::logic_error(
+            "PvaClientData::putDoubleArray() did not find a scalarArray field");
+    }
+    ScalarType scalarType = pvScalarArray->getScalarArray()->getElementType();
+    if(!ScalarTypeFunc::isNumeric(scalarType)) {
+        throw std::logic_error(
+            "PvaClientData::putDoubleArray() did not find a numeric scalarArray field");
+    }
+    pvScalarArray->putFrom<const double>(value);
 }
 
 void PvaClientPutData::putStringArray(shared_vector<const std::string> const & value)
 {
-    checkValue();
-    PVStringArrayPtr pv = pvStructure->getSubField<PVStringArray>("value");
-    if(!pv) {
-        throw std::runtime_error(messagePrefix + notStringArray);
+    if(PvaClient::getDebug()) cout << "PvaClientPutData::putStringArray\n";
+    PVScalarArrayPtr pvScalarArray;
+    PVStructurePtr pvStructure = getPVStructure();
+    PVFieldPtr pvValue  = pvStructure->getSubField("value");
+    if(pvValue) {
+       Type type = pvValue->getField()->getType();
+        if(type==scalarArray) {
+             pvScalarArray = static_pointer_cast<PVScalarArray>(pvValue);
+        }
     }
-    pv->replace(value);
+    if(!pvScalarArray) {
+        while(true) {
+             const PVFieldPtrArray fieldPtrArray(pvStructure->getPVFields());
+             if(fieldPtrArray.size()!=1) {
+                  throw std::logic_error(
+                      "PvaClientData::putStringArray() pvRequest for multiple fields");
+             }
+             PVFieldPtr pvField(fieldPtrArray[0]);
+             Type type = pvField->getField()->getType();
+             if(type==scalarArray) {
+                 pvScalarArray = static_pointer_cast<PVScalarArray>(pvField);
+                 break;
+             }
+             if(pvField->getField()->getType()!=epics::pvData::structure) break;
+             pvStructure = static_pointer_cast<PVStructure>(pvField);
+        }
+    }
+    if(!pvScalarArray) {
+        throw std::logic_error(
+            "PvaClientData::putStringArray() did not find a scalarArray field");
+    }
+    pvScalarArray->putFrom<const string>(value);
+    return;
 }
 
-void PvaClientPutData::putStringArray(std::vector<std::string> const & value)
+void PvaClientPutData::putStringArray(std::vector<string> const & value)
 {
-    checkValue();
-    PVScalarArrayPtr pv = pvStructure->getSubField<PVScalarArray>("value");
-    if(!pv) {
-        throw std::runtime_error(messagePrefix + notScalarArray);
-    }
-    convert->fromStringArray(pv,0,value.size(),value,0);
+    size_t length = value.size();
+    shared_vector<string> val(length);
+    for(size_t i=0; i < length; ++i) val[i] = value[i];
+    putStringArray(freeze(val));
+    return;
 }
 
+void PvaClientPutData::postPut(size_t fieldNumber)
+{
+    if(PvaClient::getDebug()) cout << "PvaClientPutData::postPut\n";
+    getChangedBitSet()->set(fieldNumber);
+}
+
+
 }}

src/pvaClientPutGet.cpp

@@ -14,7 +14,6 @@
 
 #include <pv/pvaClient.h>
 
-using std::tr1::static_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace std;
@@ -174,7 +173,7 @@ void PvaClientPutGet::channelPutGetConnect(
            << " channelName " << pvaClientChannel->getChannel()->getChannelName()
            << " status.isOK " << (status.isOK() ? "true" : "false")
            << endl;
-    }
+    } 
     {
         Lock xx(mutex);
         this->channelPutGet = channelPutGet;
@@ -215,14 +214,13 @@ void PvaClientPutGet::putGetDone(
            << " status.isOK " << (status.isOK() ? "true" : "false")
            << endl;
     }
-    channelPutGetStatus = status;
-    putGetState = putGetComplete;
-    if(status.isOK()) {
-        PVStructurePtr pvs = pvaClientGetData->getPVStructure();
-        pvs->copyUnchecked(*getPVStructure,*getChangedBitSet);
-        BitSetPtr bs = pvaClientGetData->getChangedBitSet();
-        bs->clear();
-        *bs |= *getChangedBitSet;
+    {
+        Lock xx(mutex);
+        channelPutGetStatus = status;
+        putGetState = putGetComplete;
+        if(status.isOK()) {
+            pvaClientGetData->setData(getPVStructure,getChangedBitSet);
+        }
     }
     PvaClientPutGetRequesterPtr  req(pvaClientPutGetRequester.lock());
     if(req) {
@@ -243,14 +241,17 @@ void PvaClientPutGet::getPutDone(
            << " status.isOK " << (status.isOK() ? "true" : "false")
            << endl;
     }
-    channelPutGetStatus = status;
-    putGetState = putGetComplete;
-    if(status.isOK()) {
-        PVStructurePtr pvs = pvaClientPutData->getPVStructure();
-        pvs->copyUnchecked(*putPVStructure,*putBitSet);
-        BitSetPtr bs = pvaClientPutData->getChangedBitSet();
-        bs->clear();
-        *bs |= *putBitSet;
+    {
+        Lock xx(mutex);
+        channelPutGetStatus = status;
+        putGetState = putGetComplete;
+        if(status.isOK()) {
+            PVStructurePtr pvs = pvaClientPutData->getPVStructure();
+            pvs->copyUnchecked(*putPVStructure,*putBitSet);
+            BitSetPtr bs = pvaClientPutData->getChangedBitSet();
+            bs->clear();
+            *bs |= *putBitSet;
+        }
     }
     PvaClientPutGetRequesterPtr  req(pvaClientPutGetRequester.lock());
     if(req) {
@@ -271,14 +272,13 @@ void PvaClientPutGet::getGetDone(
            << " status.isOK " << (status.isOK() ? "true" : "false")
            << endl;
     }
-    channelPutGetStatus = status;
-    putGetState = putGetComplete;
-    if(status.isOK()) {
-        PVStructurePtr pvs = pvaClientGetData->getPVStructure();
-        pvs->copyUnchecked(*getPVStructure,*getChangedBitSet);
-        BitSetPtr bs = pvaClientGetData->getChangedBitSet();
-        bs->clear();
-        *bs |= *getChangedBitSet;
+    {
+        Lock xx(mutex);
+        channelPutGetStatus = status;
+        putGetState = putGetComplete;
+        if(status.isOK()) {
+            pvaClientGetData->setData(getPVStructure,getChangedBitSet);
+        }
     }
     PvaClientPutGetRequesterPtr  req(pvaClientPutGetRequester.lock());
     if(req) {
@@ -555,6 +555,4 @@ PvaClientChannelPtr PvaClientPutGet::getPvaClientChannel()
     return pvaClientChannel;
 }
 
-
-
 }}

src/pvaClientRPC.cpp

@@ -12,13 +12,12 @@
 #include <sstream>
 #include <pv/event.h>
 #include <pv/bitSetUtil.h>
+#include <pv/rpcService.h>
 
 #define epicsExportSharedSymbols
 
 #include <pv/pvaClient.h>
 
-using std::tr1::static_pointer_cast;
-using std::tr1::dynamic_pointer_cast;
 using namespace epics::pvData;
 using namespace epics::pvAccess;
 using namespace std;
@@ -182,6 +181,7 @@ void PvaClientRPC::requestDone(
     PvaClientRPCRequesterPtr req = pvaClientRPCRequester.lock();
     {
         Lock xx(mutex);
+        requestStatus = status;
         if(PvaClient::getDebug()) {
              string channelName("disconnected");
              Channel::shared_pointer chan(channel.lock());
@@ -226,7 +226,7 @@ void PvaClientRPC::connect()
         + channelName
         + " PvaClientRPC::connect "
         + status.getMessage();
-    throw std::runtime_error(message);
+    throw RPCRequestException(Status::STATUSTYPE_ERROR,message);
 }
 
 void PvaClientRPC::issueConnect()
@@ -307,10 +307,18 @@ PVStructure::shared_pointer PvaClientRPC::request(PVStructure::shared_pointer co
         string message = "channel "
             + channelName
             + " PvaClientRPC::request request timeout ";
-        throw std::runtime_error(message);
+        throw RPCRequestException(Status::STATUSTYPE_ERROR,message);
     }
     rpcState = rpcIdle;
-    return pvResponse;
+    if(requestStatus.isOK()) return pvResponse;
+    Channel::shared_pointer chan(channel.lock());
+    string channelName("disconnected");
+    if(chan) channelName = chan->getChannelName();
+    string message = "channel "
+            + channelName
+            + " PvaClientRPC::request status ";
+    message += requestStatus.getMessage();
+    throw RPCRequestException(Status::STATUSTYPE_ERROR,message);
 }