From 8b75cacd46f99dc45bcdfda92828aadaf049bdd1 Mon Sep 17 00:00:00 2001
From: kasemir <kasemirk@ornl.gov>
Date: Thu, 25 May 2017 17:35:21 -0400
Subject: [PATCH] Implement EtherNetIP#readTags()

---
 CHANGE_LOG                    |  3 ++-
 src/etherip/EtherNetIP.java   | 11 +++++++----
 test/etherip/EtherIPDemo.java | 19 +++++++++++++------
 3 files changed, 22 insertions(+), 11 deletions(-)

diff --git a/CHANGE_LOG b/CHANGE_LOG
index b5d1dae..66f4ed2 100644
--- a/CHANGE_LOG
+++ b/CHANGE_LOG
@@ -4,7 +4,8 @@ Changes
 Version number is in EtherNetIP.version
 
 * 1.2 - 2017/05/25
-Fix: Support reading and writing STRING tags (#12)
+Fix: Support reading and writing STRING tags (#12).
+     Implement EtherNetIP#readTags()
 
 * 1.1 - 2016/12/15
 Fix: Handle path tags like "array[2].element" (#8)
diff --git a/src/etherip/EtherNetIP.java b/src/etherip/EtherNetIP.java
index d88d8bc..867a156 100644
--- a/src/etherip/EtherNetIP.java
+++ b/src/etherip/EtherNetIP.java
@@ -179,10 +179,10 @@ public CIPData readTag(final String tag, short count) throws Exception
 
     /** Read multiple scalar tags in one network transaction
      *  @param tags Tag names
-     *  @return Current value of the tag
+     *  @return Current values of the tags
      *  @throws Exception on error
      */
-	public CIPData readTags(final String... tags) throws Exception
+	public CIPData[] readTags(final String... tags) throws Exception
 	{
 	    final MRChipReadProtocol[] reads = new MRChipReadProtocol[tags.length];
 	    for (int i=0; i<reads.length; ++i)
@@ -196,8 +196,11 @@ public CIPData readTags(final String... tags) throws Exception
                             new CIPMultiRequestProtocol(reads)))));
 	    connection.execute(encap);
 
-	    // TODO Nothing decodes the individual responses
-	    throw new Exception("Decoding of response to CIP_MultiRequest has not been implemented");
+	    final CIPData[] results = new CIPData[reads.length];
+        for (int i=0; i<results.length; ++i)
+            results[i] = reads[i].getData();
+
+        return results;
     }
 
 	/** Write a tag
diff --git a/test/etherip/EtherIPDemo.java b/test/etherip/EtherIPDemo.java
index 34d65d6..00859a4 100644
--- a/test/etherip/EtherIPDemo.java
+++ b/test/etherip/EtherIPDemo.java
@@ -16,7 +16,6 @@
 import java.util.logging.Logger;
 
 import org.junit.Before;
-import org.junit.Ignore;
 import org.junit.Test;
 
 import etherip.types.CIPData;
@@ -31,7 +30,7 @@ public void setup()
 	{
 		TestSettings.logAll();
 		Logger.getLogger("").setLevel(Level.ALL);
-        Logger.getLogger("").setLevel(Level.WARNING);
+        //Logger.getLogger("").setLevel(Level.WARNING);
 	}
 
 	@Test
@@ -148,7 +147,6 @@ public void testString() throws Exception
     }
 
     @Test
-    @Ignore
     public void testMultiRead() throws Exception
     {
         try
@@ -159,9 +157,18 @@ public void testMultiRead() throws Exception
             plc.connect();
 
             System.out.println("\n*\n* Multi read:\n*\n");
-            plc.readTags(TestSettings.get("float_tag"),
-                         TestSettings.get("bool_tag"),
-                         TestSettings.get("string_tag"));
+            final String[] tags = new String[]
+            {
+                    TestSettings.get("float_tag"),
+                    TestSettings.get("bool_tag"),
+                    TestSettings.get("string_tag")
+            };
+            final CIPData[] results = plc.readTags(tags);
+            assertThat(results, not(nullValue()));
+            assertThat(results.length, equalTo(tags.length));
+
+            for (int i=0; i<results.length; ++i)
+                System.out.println(tags[i] + " = " + results[i]);
         }
     }
 }