Merge remote-tracking branch 'origin/pre-release' into block_alignment

conda.yml

@@ -27,3 +27,4 @@ dependencies:
   - matplotlib
   - pytest
   - pytest-cov
+  - pyqt=5.12

docs/src/installing/petalinux.rst

@@ -18,8 +18,8 @@ You will want to replace the file project-spec/meta-user/recipes-apps/rogue/rogu
 
 .. code::
 
-   ROGUE_VERSION = "6.1.4"
-   ROGUE_MD5SUM  = "659c7f5c894f6915e2bd15f922cdab3b"
+   ROGUE_VERSION = "6.4.0"
+   ROGUE_MD5SUM  = "acbd2b178af84776efbd78cdf3f5db7d"
 
    SUMMARY = "Recipe to build Rogue"
    HOMEPAGE ="https://github.com/slaclab/rogue"
@@ -84,14 +84,14 @@ You will want to replace the file project-spec/meta-user/recipes-apps/rogue/rogu
       install -m 0755 ${S}/python/rogue.so ${D}${PYTHON_SITEPACKAGES_DIR}
    }
 
-Update the ROGUE_VERSION line for an updated version when appropriate (min version is 6.1.3). You will need to first download the tar.gz file and compute the MD5SUM using the following commands if you update the ROGUE_VERSION line:
+Update the ROGUE_VERSION line for an updated version when appropriate. You will need to first download the tar.gz file and compute the MD5SUM using the following commands if you update the ROGUE_VERSION line:
 
 .. code::
 
    > wget https://github.com/slaclab/rogue/archive/vx.x.x.tar.gz
    > md5sum vx.x.x.tar.gz
 
-If your rogue application requires additional python libraries you can add them to the DEPENDS += line in the above text.
+RDEPENDS is the  Runtime Dependencies. If your rogue application requires additional python libraries you can add them to the RDEPENDS += line in the above text. 
 
 To enable compilation and installation of the rogue package in your petalinux project execute the following command:
 

python/pyrogue/_Variable.py

@@ -127,8 +127,8 @@ def varUpdate(self,path,varValue):
 
 class VariableValue(object):
     """ """
-    def __init__(self, var, read=False):
-        self.value     = var.get(read=read)
+    def __init__(self, var, read=False, index=-1):
+        self.value     = var.get(read=read,index=index)
         self.valueDisp = var.genDisp(self.value)
         self.disp      = var.disp
         self.enum      = var.enum
@@ -572,7 +572,7 @@ def write(self, *, verify=True, check=True):
         pass
 
     @pr.expose
-    def getVariableValue(self,read=True):
+    def getVariableValue(self,read=True,index=-1):
         """
         Return the value after performing a read from hardware if applicable.
         Hardware read is blocking. An error will result in a logged exception.
@@ -582,6 +582,8 @@ def getVariableValue(self,read=True):
         ----------
         read : bool
              (Default value = True)
+        index : int
+             (Default value = -1)
 
         Returns
         -------
@@ -590,7 +592,7 @@ def getVariableValue(self,read=True):
             Listeners will be informed of the update.
 
         """
-        return VariableValue(self,read=read)
+        return VariableValue(self,read=read,index=index)
 
     @pr.expose
     def value(self, index=-1):

python/pyrogue/protocols/_Network.py

@@ -28,10 +28,10 @@ def __init__(self,*, port, host='127.0.0.1', jumbo=False, wait=True, packVer=1,
 
         if server:
             self._udp  = rogue.protocols.udp.Server(port,jumbo)
-            self._rssi = rogue.protocols.rssi.Server(self._udp.maxPayload())
+            self._rssi = rogue.protocols.rssi.Server(self._udp.maxPayload()-8)
         else:
             self._udp  = rogue.protocols.udp.Client(host,port,jumbo)
-            self._rssi = rogue.protocols.rssi.Client(self._udp.maxPayload())
+            self._rssi = rogue.protocols.rssi.Client(self._udp.maxPayload()-8)
 
         if packVer == 2:
             self._pack = rogue.protocols.packetizer.CoreV2(False,True,enSsi) # ibCRC = False, obCRC = True

python/pyrogue/pydm/data_plugins/rogue_plugin.py

@@ -33,10 +33,10 @@
 
 
 def parseAddress(address):
-    # "rogue://index/<path>/<mode>"
+    # "rogue://index/<path>/<mode>/<index>"
     # or
-    # "rogue://host:port/<path>/<mode>"
-    # Mode: 'Value', 'Disp', 'Name' or 'Path'
+    # "rogue://host:port/<path>/<mode>/<index>"
+    # Mode: 'value', 'disp', 'name' or 'path'
     envList = os.getenv('ROGUE_SERVERS')
 
     if envList is None:
@@ -58,12 +58,13 @@ def parseAddress(address):
     port = int(data_server[1])
     path = data[1]
     mode = 'value' if (len(data) < 3) else data[2]
+    index = -1 if (len(data) < 4) else int(data[3])
 
-    return (host,port,path,mode)
+    return (host,port,path,mode,index)
 
 
 def nodeFromAddress(address):
-    host, port, path, mode = parseAddress(address)
+    host, port, path, mode, index = parseAddress(address)
     client = VirtualClient(host, port)
     return client.root.getNode(path)
 
@@ -75,7 +76,7 @@ def __init__(self, channel, address, protocol=None, parent=None):
 
         self.app = QApplication.instance()
 
-        self._host, self._port, self._path, self._mode = parseAddress(channel.address)
+        self._host, self._port, self._path, self._mode, self._index = parseAddress(channel.address)
 
         self._cmd    = False
         self._int    = False
@@ -114,6 +115,10 @@ def linkState(self, state):
 
 
     def _updateVariable(self,path,varValue):
+
+        if self._index != -1:
+            varValue = self._node.getVariableValue(read=False, index=self._index)
+
         if self._mode == 'name':
             self.new_value_signal[str].emit(self._node.name)
         elif self._mode == 'path':
@@ -153,7 +158,7 @@ def put_value(self, new_value):
         if self._cmd:
             self._node.__call__(val)
         else:
-            self._node.setDisp(val)
+            self._node.setDisp(val,index=self._index)
 
 
     def add_listener(self, channel):
@@ -204,7 +209,7 @@ def add_listener(self, channel):
                 self.new_value_signal[str].emit(self._node.path)
             else:
                 self.write_access_signal.emit(self._cmd or self._node.mode!='RO')
-                self._updateVariable(self._node.path,self._node.getVariableValue(read=False))
+                self._updateVariable(self._node.path,self._node.getVariableValue(read=False, index=self._index))
 
         else:
             self.new_value_signal[str].emit(self._node.name)

python/pyrogue/pydm/examples/rogue_plugin_test.ui

@@ -19,7 +19,7 @@
      <item>
       <widget class="QTabWidget" name="tabWidget">
        <property name="currentIndex">
-        <number>4</number>
+        <number>0</number>
        </property>
        <widget class="QWidget" name="tab_6">
         <property name="sizePolicy">
@@ -105,7 +105,7 @@
            </property>
            <property name="yAxes">
             <stringlist>
-             <string>{&quot;name&quot;: &quot;Axis 1&quot;, &quot;orientation&quot;: &quot;left&quot;, &quot;label&quot;: &quot;Test Plot Scatter&quot;, &quot;minRange&quot;: -1.0, &quot;maxRange&quot;: 1.0, &quot;autoRange&quot;: true, &quot;logMode&quot;: false}</string>
+             <string>{&quot;name&quot;: &quot;Axis 1&quot;, &quot;orientation&quot;: &quot;left&quot;, &quot;label&quot;: &quot;Test Plot Scatter&quot;, &quot;minRange&quot;: -1.04, &quot;maxRange&quot;: 1.04, &quot;autoRange&quot;: true, &quot;logMode&quot;: false}</string>
             </stringlist>
            </property>
            <property name="curves">
@@ -125,7 +125,7 @@
            </property>
            <property name="yAxes">
             <stringlist>
-             <string>{&quot;name&quot;: &quot;Axis 1&quot;, &quot;orientation&quot;: &quot;left&quot;, &quot;label&quot;: &quot;Test Plot Time&quot;, &quot;minRange&quot;: -1.0, &quot;maxRange&quot;: 1.0, &quot;autoRange&quot;: true, &quot;logMode&quot;: null}</string>
+             <string>{&quot;name&quot;: &quot;Axis 1&quot;, &quot;orientation&quot;: &quot;left&quot;, &quot;label&quot;: &quot;Test Plot Time&quot;, &quot;minRange&quot;: -1.04, &quot;maxRange&quot;: 1.04, &quot;autoRange&quot;: true, &quot;logMode&quot;: null}</string>
             </stringlist>
            </property>
            <property name="curves">
@@ -151,7 +151,7 @@
            </property>
            <property name="yAxes">
             <stringlist>
-             <string>{&quot;name&quot;: &quot;Axis 1&quot;, &quot;orientation&quot;: &quot;left&quot;, &quot;label&quot;: &quot;Test Array Waveform&quot;, &quot;minRange&quot;: -1.0, &quot;maxRange&quot;: 1.0, &quot;autoRange&quot;: true, &quot;logMode&quot;: false}</string>
+             <string>{&quot;name&quot;: &quot;Axis 1&quot;, &quot;orientation&quot;: &quot;left&quot;, &quot;label&quot;: &quot;Test Array Waveform&quot;, &quot;minRange&quot;: -1.04, &quot;maxRange&quot;: 1.04, &quot;autoRange&quot;: true, &quot;logMode&quot;: false}</string>
             </stringlist>
            </property>
            <property name="curves">

python/pyrogue/pydm/tools/generic_file_tool.py

@@ -41,7 +41,7 @@ def __init__(self,save=False):
         ExternalTool.__init__(self, icon=icon, name=name, group=group, use_with_widgets=use_with_widgets)
 
     def call(self, channels, sender):
-        addr, port, path, mode = parseAddress(channels[0].address)
+        addr, port, path, mode, index = parseAddress(channels[0].address)
         self._client = VirtualClient(addr, port)
         node = self._client.root.getNode(path)
 

python/pyrogue/pydm/tools/node_info_tool.py

@@ -36,7 +36,7 @@ def __init__(self):
         ExternalTool.__init__(self, icon=icon, name=name, group=group, use_with_widgets=use_with_widgets)
 
     def call(self, channels, sender):
-        addr, port, path, mode = parseAddress(channels[0].address)
+        addr, port, path, mode, index = parseAddress(channels[0].address)
         self._client = VirtualClient(addr, port)
         node = self._client.root.getNode(path)
 

python/pyrogue/pydm/tools/read_node_tool.py

@@ -34,7 +34,7 @@ def __init__(self):
         ExternalTool.__init__(self, icon=icon, name=name, group=group, use_with_widgets=use_with_widgets)
 
     def call(self, channels, sender):
-        addr, port, path, mode = parseAddress(channels[0].address)
+        addr, port, path, mode, index = parseAddress(channels[0].address)
         self._client = VirtualClient(addr, port)
         node = self._client.root.getNode(path)
 

python/pyrogue/pydm/tools/read_recursive_tool.py

@@ -34,7 +34,7 @@ def __init__(self):
         ExternalTool.__init__(self, icon=icon, name=name, group=group, use_with_widgets=use_with_widgets)
 
     def call(self, channels, sender):
-        addr, port, path, mode = parseAddress(channels[0].address)
+        addr, port, path, mode, index = parseAddress(channels[0].address)
         self._client = VirtualClient(addr, port)
         node = self._client.root.getNode(path)
 

python/pyrogue/pydm/tools/write_node_tool.py

@@ -34,7 +34,7 @@ def __init__(self):
         ExternalTool.__init__(self, icon=icon, name=name, group=group, use_with_widgets=use_with_widgets)
 
     def call(self, channels, sender):
-        addr, port, path, mode = parseAddress(channels[0].address)
+        addr, port, path, mode, index = parseAddress(channels[0].address)
         self._client = VirtualClient(addr, port)
         node = self._client.root.getNode(path)
 

python/pyrogue/pydm/tools/write_recursive_tool.py

@@ -33,7 +33,7 @@ def __init__(self):
         ExternalTool.__init__(self, icon=icon, name=name, group=group, use_with_widgets=use_with_widgets)
 
     def call(self, channels, sender):
-        addr, port, path, mode = parseAddress(channels[0].address)
+        addr, port, path, mode, index = parseAddress(channels[0].address)
         self._client = VirtualClient(addr, port)
         node = self._client.root.getNode(path)
 

src/rogue/protocols/udp/Client.cpp

@@ -202,7 +202,7 @@ void rpu::Client::runThread(std::weak_ptr<int> lockPtr) {
         if (res > 0) {
             // Message was too big
             if (res > avail) {
-                udpLog_->warning("Receive data was too large. Dropping.");
+                udpLog_->warning("Receive data was too large. Rx=%i, avail=%i Dropping.", res, avail);
             } else {
                 buff->setPayload(res);
                 sendFrame(frame);

templates/RogueConfig.cmake.in

@@ -26,8 +26,9 @@ set(NO_PYTHON   @NO_PYTHON@)
 # Boost + Python
 #####################################
 if ( NOT NO_PYTHON )
-   # Search for newest version of Python3 first
-   set(Python3_FIND_STRATEGY "VERSION")
+
+   # Find newest python interpreter first
+   set(Python3_FIND_STRATEGY "LOCATION")
    find_package(Python3 QUIET REQUIRED COMPONENTS Interpreter Development)
 
    # Find Numpy
@@ -49,10 +50,6 @@ if ( NOT NO_PYTHON )
    # Hint for boost on anaconda
    if (DEFINED ENV{CONDA_PREFIX})
       set(Boost_ROOT $ENV{CONDA_PREFIX})
-
-   # SLAC AFS custom path
-   elseif (DEFINED ENV{BOOST_PATH})
-      set(Boost_ROOT $ENV{BOOST_PATH})
    endif()
 
    # libboost_python3.7 style libraries
@@ -88,6 +85,7 @@ if ( NOT NO_PYTHON )
       message("")
       message(FATAL_ERROR "Failed to find boost libraries!")
    endif()
+
 else()
    add_definitions( -DNO_PYTHON )
 endif()