test/sun/management/jdp/JdpClient.java

rev 8717 : 8014506: Test of Jdp feature
Reviewed-by:
Contributed-by: Alex Schenkman <alex.schenkman@oracle.com>

@@ -34,10 +34,11 @@
 import java.nio.channels.SelectionKey;
 import java.nio.channels.Selector;
 import java.util.Collections;
 import java.util.Enumeration;
 import java.util.Map;
+
 import sun.management.jdp.JdpException;
 import sun.management.jdp.JdpJmxPacket;
 import sun.management.jdp.JdpPacketReader;
 
 public class JdpClient {

@@ -47,11 +48,11 @@
         private static final int BUFFER_LENGTH = 4096;
         private final DatagramChannel channel;
         private static int maxPacketCount = 1;
         private static int maxEmptyPacketCount = 10;
 
-        private void get(Map<?,?> map, String key)
+        private void get(Map<?, ?> map, String key)
             throws JdpException {
 
             if (map.get(key) == null) {
                   throw new JdpException("Test failed, packet field " + key + " missed");
             }

@@ -61,11 +62,11 @@
             throws IOException, JdpException {
 
             byte[] b = p.getPacketData();
 
             JdpPacketReader reader = new JdpPacketReader(b);
-            Map<String,String> pMap = reader.getDiscoveryDataAsMap();
+            Map<String, String> pMap = reader.getDiscoveryDataAsMap();
 
             get(pMap, JdpJmxPacket.UUID_KEY);
             get(pMap, JdpJmxPacket.MAIN_CLASS_KEY);
             get(pMap, JdpJmxPacket.JMX_SERVICE_URL_KEY);
             // get(pMap, JdpJmxPacket.INSTANCE_NAME_KEY);

@@ -100,15 +101,15 @@
                         buf.rewind();
 
                         sel.select(10 * 1000);
                         channel.receive(buf);
 
-                        if (buf.position() == 0 ){
-                            if (JdpDoSomething.getVerbose()){
+                        if (buf.position() == 0) {
+                            if (JdpDoSomething.getVerbose()) {
                                 System.err.println("Empty packet received");
                             }
-                            if (++emptyPacketsCount > maxEmptyPacketCount){
+                            if (++emptyPacketsCount > maxEmptyPacketCount) {
                                 throw new RuntimeException("Test failed, maxEmptyPacketCount reached");
                             }
 
                             continue;
                         }

@@ -118,11 +119,11 @@
                         buf.get(dgramData);
                         try {
                             JdpJmxPacket packet = new JdpJmxPacket(dgramData);
                             JdpDoSomething.printJdpPacket(packet);
                             checkFieldPresence(packet);
-                            if(++count > maxPacketCount){
+                            if (++count > maxPacketCount) {
                                    break;
                             }
                         } catch (JdpException e) {
                             e.printStackTrace();
                             throw new RuntimeException("Test failed");

@@ -177,11 +178,11 @@
             }
 
             PacketListener listener = new PacketListener(channel);
             new Thread(listener, "Jdp Client").start();
 
-        } catch (RuntimeException e){
+        } catch (RuntimeException e) {
             System.out.println("Test failed.");
         } catch (Exception e) {
             e.printStackTrace();
             System.out.println("Test failed. unexpected error " + e);
         }