Changeset e204013 for apps


Ignore:
Timestamp:
Nov 13, 2018 5:08:56 PM (20 months ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
71d8f0e
Parents:
6f7881c
Message:

NDT changes adapted from Vuze/BiglyBT, and changes for I2P.
Vuze/Bigly? is based on NDT 3.6.2b, so their changes are
manually merged here.
This rev does not compile, requires swingemu package to follow.
Changes:

  • Add external start hook to Tcpbw100 from BiglyBT
  • Replace all Swing/AWT classes with emulations from BiglyBT (included in next checkin)
  • Leave classes in edu.internet2.ndt package rather than moving to com.vuze.plugins.mlab heirarchy as Vuze/BiglyBT did
  • Change IPv6 support setting to use I2P class for detection
  • Change in-progress field to an AtomicBoolean?
  • Change from System to I2P logging
  • Change JSON library package
  • Comment out some applet code
  • Javadoc fixes
Location:
apps/routerconsole/java/src/edu/internet2/ndt
Files:
7 edited

Legend:

Unmodified
Added
Removed
  • apps/routerconsole/java/src/edu/internet2/ndt/JSONUtils.java

    r6f7881c re204013  
    11package edu.internet2.ndt;
    22
    3 import org.json.simple.JSONObject;
    4 import org.json.simple.JSONValue;
     3import net.minidev.json.JSONObject;
     4import net.minidev.json.JSONValue;
    55import java.util.Iterator;
    66import java.util.Map;
     
    1414         * Function that return value from json object represented by jsontext containing a single message
    1515         * which is assigned to "msg" key.
    16          * @param {String} JSON object
     16         * @param jsonTxt {String} JSON object
    1717         * @return {int} obtained value from JSON object
    1818         */
     
    2323        /**
    2424         * Function that return value for given key from json object represented by jsontext
    25          * @param {String} JSON object
    26          * @param {int} key by which value should be obtained from JSON map
     25         * @param jsonTxt {String} JSON object
     26         * @param key {int} key by which value should be obtained from JSON map
    2727         * @return {int} obtained value from JSON map
    2828         */
     
    4242        /**
    4343         * Function that add new value to JSON map
    44          * @param {String} JSON object
    45          * @param {String} key by which value should be assigned to JSON map
    46          * @param {String} value for given key
     44         * @param jsonTxt {String} JSON object
     45         * @param key {String} key by which value should be assigned to JSON map
     46         * @param value {String} value for given key
    4747         * @return {String} json object with added value.
    4848         */
     
    5858         * Function that return json object represented by jsontext and included
    5959         * single message assigned to "msg" key
    60          * @param {byte[]} message which should be assigned to json object
     60         * @param msg {byte[]} message which should be assigned to json object
    6161         * @return {byte[]} json object represented by jsontext and encodes into a sequence of bytes
    6262         */
  • apps/routerconsole/java/src/edu/internet2/ndt/NDTConstants.java

    r6f7881c re204013  
    44import java.util.ResourceBundle;
    55
    6 import javax.swing.JOptionPane;
     6import com.vuze.plugins.mlab.tools.ndt.swingemu.JOptionPane;
    77
    88/**
  • apps/routerconsole/java/src/edu/internet2/ndt/NewFrame.java

    r6f7881c re204013  
    11package edu.internet2.ndt;
    22
    3 import javax.swing.*;
    4 import java.awt.*;
    5 import java.awt.event.WindowAdapter;
    6 import java.awt.event.WindowEvent;
     3import com.vuze.plugins.mlab.tools.ndt.swingemu.*;
    74
    85/**
     
    1613 */
    1714public class NewFrame extends JFrame {
    18         /**
    19          * Auto-generated compiler constant that does not contribute to classes'
    20          * functionality
    21          */
    22         private static final long serialVersionUID = 8990839319520684317L;
    2315
    2416    /**
    2517     * Constructor
    2618     **/
    27     public NewFrame(final JApplet parent) throws HeadlessException {
    28                 addWindowListener(new WindowAdapter() {
    29                         public void windowClosing(WindowEvent event) {
    30                 parent.requestFocus();
    31                                 dispose();
    32                         }
    33                 });
     19    public NewFrame(final JApplet parent) {
    3420        }
    35 
    3621} // class: NewFrame
  • apps/routerconsole/java/src/edu/internet2/ndt/OsfwWorker.java

    r6f7881c re204013  
    3131         * Constructor
    3232         *
    33          * @param Socket
    34          *            srvSocketParam Socket used to transmit protocol messages
     33         * @param srvSocketParam
     34         *            Socket used to transmit protocol messages
    3535         *
    3636         * @param iParamTestTime
     
    4545         * Constructor accepting Tcpbw100 parameter
    4646         *
    47          * @param ServerSocket
     47         * @param srvSocketParam
    4848         *            Socket on which to accept connections
    4949         * @param iParamTestTime
  • apps/routerconsole/java/src/edu/internet2/ndt/ResultsTextPane.java

    r6f7881c re204013  
    11package edu.internet2.ndt;
    22
    3 import javax.swing.*;
    4 import javax.swing.text.BadLocationException;
    5 import java.awt.*;
     3import com.vuze.plugins.mlab.tools.ndt.swingemu.*;
    64
    75/*
     
    2826         **/
    2927        public void append(String paramTextStr) {
     28/****
    3029                try {
    3130                        getStyledDocument().insertString(getStyledDocument().getLength(),
     
    3635                                                        + paramTextStr + "]");
    3736                }
     37****/
    3838        }
    3939
     
    4747         * */
    4848        public void insertComponent(Component paramCompObj) {
     49/****
    4950                setSelectionStart(this.getStyledDocument().getLength());
    5051                setSelectionEnd(this.getStyledDocument().getLength());
    5152                super.insertComponent(paramCompObj);
     53****/
    5254        }
    5355
  • apps/routerconsole/java/src/edu/internet2/ndt/StatusPanel.java

    r6f7881c re204013  
    11package edu.internet2.ndt;
    22
    3 import java.awt.event.ActionEvent;
    4 import java.awt.event.ActionListener;
    5 
    6 import javax.swing.JButton;
    7 import javax.swing.JLabel;
    8 import javax.swing.JPanel;
    9 import javax.swing.JProgressBar;
     3import com.vuze.plugins.mlab.tools.ndt.swingemu.*;
    104
    115/**
     
    2721        private boolean _bStop = false;
    2822
     23/****
    2924        private JLabel _labelTestNum = new JLabel();
    3025        private JButton _buttonStop;
    3126        private JProgressBar _progressBarObj = new JProgressBar();
     27****/
    3228
    3329        /*
     
    4036         */
    4137        public StatusPanel(int iParamTestsNum, String sParamEnableMultiple) {
     38/****
    4239                this._iTestsCompleted = 1;
    4340                this._iTestsNum = iParamTestsNum;
     
    8077                        add(_buttonStop);
    8178                }
     79****/
    8280        }
    8381
     
    8684         * */
    8785        private void setTestNoLabelText() {
     86/****
    8887                _labelTestNum.setText(NDTConstants.getMessageString("test") + " "
    8988                                + _iTestsCompleted + " " + NDTConstants.getMessageString("of")
    9089                                + " " + _iTestsNum);
    9190
     91****/
    9292        }
    9393
     
    105105         * */
    106106        public void endTest() {
     107/****
    107108                _progressBarObj.setValue(_iTestsCompleted);
    108109                _iTestsCompleted++;
    109110                setTestNoLabelText();
     111****/
    110112        }
    111113
     
    117119         * */
    118120        public void setText(String sParamText) {
     121/****
    119122                if (!_progressBarObj.isIndeterminate()) {
    120123                        _progressBarObj.setString(sParamText);
    121124                }
     125****/
    122126        }
    123127} // end class StatusPanel
  • apps/routerconsole/java/src/edu/internet2/ndt/Tcpbw100.java

    r6f7881c re204013  
    6363 */
    6464
     65/*
    6566import java.awt.BorderLayout;
    6667import java.awt.Color;
     
    7677import java.awt.event.WindowAdapter;
    7778import java.awt.event.WindowEvent;
     79*/
     80
    7881import java.io.IOException;
    7982import java.io.InputStream;
     
    9598import java.util.Timer;
    9699import java.util.TimerTask;
    97 
     100import java.util.concurrent.atomic.AtomicBoolean;
     101
     102/*
    98103import javax.swing.BorderFactory;
    99104import javax.swing.BoxLayout;
     
    110115import javax.swing.JTextArea;
    111116import javax.swing.SpinnerNumberModel;
     117*/
     118import com.vuze.plugins.mlab.tools.ndt.swingemu.*;
     119
     120// Workaround for remote JavaScript start method
     121import java.security.AccessController;
     122import java.security.PrivilegedAction;
     123
     124import net.i2p.util.Addresses;
     125import net.i2p.util.Log;
    112126
    113127/*
     
    216230
    217231        boolean _bIsApplication = false;
    218         boolean _bTestInProgress = false;
     232        private final AtomicBoolean _bTestInProgress = new AtomicBoolean();
    219233        String sHostName = null;
    220234        InetAddress hostAddress = null;
     
    283297        private boolean retry = false;
    284298
     299        // I2P
     300        private final Log _log = new Log(Tcpbw100.class);
     301
    285302        /**
    286303         * public static void main for invoking as an Application
     
    288305         * */
    289306        public static void main(String[] args) {
     307                Tcpbw100 test = mainSupport( args );
     308                test.runIt();
     309        }
     310
     311        /** bigly */
     312        public static Tcpbw100 mainSupport(String[] args) {
    290313                JFrame frame = new JFrame("ANL/Internet2 NDT (applet)");
    291314                if (args.length < 1 || args.length > 2) {
     
    310333                applet.start();
    311334                frame.setVisible(true);
    312         }
     335                return applet;
     336        }
     337
     338
     339
     340
    313341
    314342        //
     
    558586        //
    559587
     588        /** I2P */
     589        public boolean isTestInProgress() {
     590                return _bTestInProgress.get();
     591        }
     592
    560593        /**
    561594         * Class to start tests in a thread. Starts by disabling all buttons, and
     
    566599         * */
    567600        class TestWorker implements Runnable {
     601                // I2P
    568602                public void run() {
    569                         if (!_bTestInProgress) {
     603                        if (_bTestInProgress.compareAndSet(false, true)) {
     604                                try {
     605                                        run2();
     606                                } finally {
     607                                        _bTestInProgress.set(false);
     608                                }
     609                        }
     610                }
     611
     612                private void run2() {
    570613                                int testNo = 1;
    571614                                int testsNum = ((Integer) _spinnerTestCount.getValue())
    572615                                                .intValue();
    573                                 _bTestInProgress = true;
    574616                                _buttonStartTest.setEnabled(false);
    575617                                _buttonDetails.setEnabled(false);
     
    702744                                                } catch (InterruptedException e) {
    703745                                                        // do nothing.
    704                                                         System.err.println("INFO: Thread interrupted while sleeping before starting the next test.");
     746                                                        _log.warn("INFO: Thread interrupted while sleeping before starting the next test.");
    705747                                                }
    706748                                        }
     
    737779                                                + _resBundDisplayMsgs.getString("clickStart2") + "\n");
    738780                                _buttonStartTest.setEnabled(true);
    739                                 _bTestInProgress = false;
    740781                                getContentPane().remove(sPanel);
    741782                                getContentPane().validate();
    742783                                getContentPane().repaint();
    743                         }
    744784                }
    745785        } // end inner class
     
    801841                        });
    802842                } catch (Exception e) {
    803                         System.err.println("createGUI didn't successfully complete");
     843                        _log.warn("createGUI didn't successfully complete", e);
    804844                }
    805845
     
    898938                _chkboxPreferIPv6 = new JCheckBox(
    899939                                _resBundDisplayMsgs.getString("preferIPv6"));
    900                 _chkboxPreferIPv6.setSelected(true);
     940                // I2P
     941                _chkboxPreferIPv6.setSelected(Addresses.isConnectedIPv6());
    901942                _chkboxPreferIPv6.addActionListener(this);
    902943                // 2. Conduct default tests?
     
    12411282                        // some data, and is acted on by disabling the
    12421283                        // copy button.
    1243                         System.err.println(" You may not have some security Permissions. Please confirm");
     1284                        _log.warn(" You may not have some security Permissions. Please confirm", e);
    12441285                }
    12451286        }
     
    13231364                                midSrvrSockObj = new Socket(hostAddress, midport);
    13241365                        } catch (UnknownHostException e) {
    1325                                 System.err.println("Don't know about host: " + sHostName);
     1366                                _log.warn("Don't know about host: " + sHostName, e);
    13261367                                _sErrMsg = _resBundDisplayMsgs.getString("unknownServer")
    13271368                                                + "\n";
    13281369                                return true;
    13291370                        } catch (IOException e) {
    1330                                 System.err.println("Couldn't perform middlebox testing to: "
    1331                                                 + sHostName);
     1371                                _log.warn("Couldn't perform middlebox testing to: "
     1372                                                + sHostName, e);
    13321373                                _sErrMsg = _resBundDisplayMsgs.getString("middleboxFail")
    13331374                                                + "\n";
     
    13621403                                }
    13631404                        } catch (IOException e) {
    1364                                 System.err.println("Couldn't complete middlebox testing to: "
     1405                                _log.warn("Couldn't complete middlebox testing to: "
    13651406                                                + sHostName
    1366                                                 + " since the socket read was not succesful");
     1407                                                + " since the socket read was not succesful", e);
    13671408                                _sErrMsg = _resBundDisplayMsgs.getString("middleboxFail")
    13681409                                                + "\n";
     
    13731414                        double tempSpeedInBits = (NDTConstants.EIGHT * bytes) / _dTime;
    13741415                        double tempTimeInSecs = _dTime / NDTConstants.KILO;
    1375                         System.out.println(bytes + " bytes " + tempSpeedInBits + " kb/s "
     1416                        _log.warn(bytes + " bytes " + tempSpeedInBits + " kb/s "
    13761417                                        + tempTimeInSecs + " secs");
    13771418                        // Calculate throughput in Kbps
     
    14101451                                                                                                                                                        // Double.toString(_dS2cspd*
    14111452                                                                                                                                                        // 1000);
    1412                         System.out.println("Sending '" + tmpstr4 + "' back to server");
     1453                        _log.warn("Sending '" + tmpstr4 + "' back to server");
    14131454                        paramProtoObj.send_json_msg(MessageType.TEST_MSG, tmpstr4.getBytes());
    14141455
     
    14351476
    14361477                                // Append local address to the Test results obtained from server
    1437                                 System.err.println("calling in2Socket.getLocalAddress()");
     1478                                _log.warn("calling in2Socket.getLocalAddress()");
    14381479                                String sClientSideClientIp;
    14391480                                try {
     
    14641505
    14651506                                // Append local address to the Test results obtained from server
    1466                                 System.err.println("calling in2Socket.getLocalAddress()");
     1507                                _log.warn("calling in2Socket.getLocalAddress()");
    14671508                                try {
    14681509                                        _sMidBoxTestResult += midSrvrSockObj.getLocalAddress() + ";";
     
    15931634                        }
    15941635
    1595                         System.out.println("SFW: port=" + iSrvPort);
    1596                         System.out.println("SFW: testTime=" + iTestTime);
     1636                        _log.warn("SFW: port=" + iSrvPort);
     1637                        _log.warn("SFW: testTime=" + iTestTime);
    15971638
    15981639                        // Client creates a server socket to send TEST_MSG
     
    16151656                        }
    16161657
    1617                         System.out.println("SFW: oport=" + srvSocket.getLocalPort());
     1658                        _log.warn("SFW: oport=" + srvSocket.getLocalPort());
    16181659                        // Send TEST_MSG
    16191660                        protocolObj.send_json_msg(MessageType.TEST_MSG,
     
    17891830                                outSocket = new Socket(hostAddress, iC2sport);
    17901831                        } catch (UnknownHostException e) {
    1791                                 System.err.println("Don't know about host: " + sHostName);
     1832                                _log.warn("Don't know about host: " + sHostName, e);
    17921833                                _sErrMsg = _resBundDisplayMsgs.getString("unknownServer")
    17931834                                                + "\n";
    17941835                                return true;
    17951836                        } catch (IOException e) {
    1796                                 System.err.println("Couldn't get 2nd connection to: "
    1797                                                 + sHostName);
     1837                                _log.warn("Couldn't get 2nd connection to: "
     1838                                                + sHostName, e);
    17981839                                _sErrMsg = _resBundDisplayMsgs.getString("serverBusy15s")
    17991840                                                + "\n";
     
    18391880                                _yabuff2Write[i] = c++;
    18401881                        }
    1841                         System.err.println("******Send buffer size =" + i);
     1882                        if (_log.shouldWarn())
     1883                            _log.warn("******Send buffer size =" + i);
    18421884
    18431885                        _iPkts = 0;
     
    18521894                                                Thread.sleep(10000);
    18531895                                        } catch (InterruptedException e) {
    1854                                                 System.err.println("Thread interrupted : " + e);
     1896                                                _log.warn("Thread interrupted", e);
    18551897                                                // Thread was interrupted while timing 10 seconds
    18561898                                                // of the C->S test. So, streaming 10 seconds of data may not be complete.
     
    18631905                                                outSocket.close();
    18641906                                        } catch (IOException e) {
    1865                                                 System.err.println("Caught IOException while closing stream after thread interrupted : " + e);
     1907                                                _log.warn("Caught IOException while closing stream after thread interrupted", e);
    18661908                                        }
    18671909                                }
     
    18791921                        // While the 10 s timer ticks, write buffer data into server socket
    18801922                        while (true) {
    1881                                 // System.err.println("Send pkt = " + pkts + "; at " +
     1923                                // _log.error("Send pkt = " + pkts + "; at " +
    18821924                                // System.currentTimeMillis());
    18831925                                try {
    18841926                                        outStream.write(_yabuff2Write, 0, _yabuff2Write.length);
    18851927                                } catch (SocketException e) {
    1886                                         System.out.println("SocketException while writing to server" + e);
     1928                                        _log.warn("SocketException while writing to server", e);
    18871929                                        break;
    18881930                                }
    18891931                                // catch (InterruptedIOException iioe) {
    18901932                                catch (IOException ioe) {
    1891                                         System.out.println("Client socket timed out");
     1933                                        _log.warn("Client socket timed out");
    18921934                                        break;
    18931935                                }
     
    19041946                        c2sspdUpdateTimer.cancel();
    19051947                        _dTime = System.currentTimeMillis() - _dTime;
    1906                         System.err.println(_dTime + " millisec test completed" + ","
     1948                        _log.warn(_dTime + " millisec test completed" + ","
    19071949                                        + _yabuff2Write.length + ","+ _iPkts);
    19081950                        if (_dTime == 0) {
     
    19111953
    19121954                        // Calculate C2S throughput in kbps
    1913                         System.out.println((NDTConstants.EIGHT * _iPkts * _yabuff2Write.length) / _dTime
     1955                        _log.warn((NDTConstants.EIGHT * _iPkts * _yabuff2Write.length) / _dTime
    19141956                                        + " kb/s outbound"); //*8 for calculating bits
    19151957
     
    20532095                                inSocket = new Socket(hostAddress, iS2cport);
    20542096                        } catch (UnknownHostException e) {
    2055                                 System.err.println("Don't know about host: " + sHostName);
     2097                                _log.warn("Don't know about host: " + sHostName, e);
    20562098                                _sErrMsg = "unknown server\n";
    20572099                                return true;
    20582100                        } catch (IOException e) {
    2059                                 System.err.println("Couldn't get 3rd connection to: "
    2060                                                 + sHostName);
     2101                                _log.warn("Couldn't get 3rd connection to: "
     2102                                                + sHostName, e);
    20612103                                _sErrMsg = "Server Failed while receiving data\n";
    20622104                                return true;
     
    21152157                        } catch (IOException ioExcep) {
    21162158                                // new addition to handle Exception
    2117                                 System.err.println("Couldn't perform s2c testing to: "
    2118                                                 + sHostName + ":" + ioExcep);
     2159                                _log.warn("Couldn't perform s2c testing to: "
     2160                                                + sHostName, ioExcep);
    21192161                                _sErrMsg = "Server Failed while reading socket data\n";
    21202162                                return true;
     
    21252167                        // get time duration during which bytes were received
    21262168                        _dTime = System.currentTimeMillis() - _dTime;
    2127                         System.out.println(iBitCount + " bytes "
     2169                        _log.warn(iBitCount + " bytes "
    21282170                                        + (NDTConstants.EIGHT * iBitCount) / _dTime + " kb/s "
    21292171                                        + _dTime / NDTConstants.KILO + " secs");
     
    22202262                        buff = Double.toString(_dS2cspd * NDTConstants.KILO).getBytes();
    22212263                        String tmpstr4 = new String(buff, 0, buff.length);
    2222                         System.out.println("Sending '" + tmpstr4 + "' back to server");
     2264                        _log.warn("Sending '" + tmpstr4 + "' back to server");
    22232265                        paramProtoObj.send_json_msg(MessageType.TEST_MSG, buff);
    22242266
     
    22742316                                _sErrMsg = _resBundDisplayMsgs.getString("s2cThroughputFailed")
    22752317                                                + "\n";
    2276                                 System.err.println("Couldn't perform s2c testing to: "
    2277                                                 + sHostName + ":" + ioExcep);
     2318                                _log.warn("Couldn't perform s2c testing to: "
     2319                                                + sHostName, ioExcep);
    22782320                                _sErrMsg += "Server Failed while reading socket data\n";
    22792321                                return true;
     
    23662408                        // Note that there are length constraints to keys- values: 64/256
    23672409                        // characters respectively
    2368                         System.err.println("USERAGENT " + getUserAgent());
     2410                        _log.warn("USERAGENT " + getUserAgent());
    23692411                        paramProtoObj.send_json_msg(MessageType.TEST_MSG,
    23702412                                        (NDTConstants.META_CLIENT_OS + ":" + System
     
    24902532                        ctlSocket = new Socket(hostAddress, ctlport);
    24912533                } catch (UnknownHostException e) {
    2492                         System.err.println("Don't know about host: " + sHostName);
     2534                        _log.warn("Don't know about host: " + sHostName, e);
    24932535                        _sErrMsg = _resBundDisplayMsgs.getString("unknownServer") + "\n";
    24942536                        _bFailed = true;
    24952537                        return;
    24962538                } catch (IOException e) {
    2497                         System.err.println("Couldn't get the connection to: " + sHostName
    2498                                         + " " + ctlport);
     2539                        _log.warn("Couldn't get the connection to: " + sHostName
     2540                                        + " " + ctlport, e);
    24992541                        _sErrMsg = _resBundDisplayMsgs.getString("serverNotRunning") + " ("
    25002542                                        + sHostName + ":" + ctlport + ")\n";
     
    25662608                                                ctlSocket = new Socket(hostAddress, ctlport);
    25672609                                        } catch (UnknownHostException e) {
    2568                                                 System.err.println("Don't know about host: " + sHostName);
     2610                                                _log.warn("Don't know about host: " + sHostName, e);
    25692611                                                _sErrMsg = _resBundDisplayMsgs.getString("unknownServer") + "\n";
    25702612                                                _bFailed = true;
    25712613                                                return;
    25722614                                        } catch (IOException e) {
    2573                                                 System.err.println("Couldn't get the connection to: " + sHostName
    2574                                                                 + " " + ctlport);
     2615                                                _log.warn("Couldn't get the connection to: " + sHostName
     2616                                                                + " " + ctlport, e);
    25752617                                                _sErrMsg = _resBundDisplayMsgs.getString("serverNotRunning") + " ("
    25762618                                                                + sHostName + ":" + ctlport + ")\n";
     
    26152657                        String tmpstr3 = new String(msg.getBody());
    26162658                        wait = parseMsgBodyToInt(tmpstr3);
    2617                         System.out.println("wait flag received = " + wait);
     2659                        _log.warn("wait flag received = " + wait);
    26182660
    26192661                        if (wait == NDTConstants.SRV_QUEUE_TEST_STARTS_NOW) { // SRV_QUEUE message received indicating
     
    27172759                        return;
    27182760                }
    2719                 System.out.println("Server version: " + vVersion.substring(1));
     2761                _log.warn("Server version: " + vVersion.substring(1));
    27202762
    27212763                if (vVersion.endsWith("Web10G") || vVersion.endsWith("Web100")) {
     
    27232765                                _resultsTxtPane.append(_resBundDisplayMsgs
    27242766                                                .getString("diffrentVersion") + " (" + vVersion.substring(1, vVersion.lastIndexOf('-')) + ")\n");
    2725                                 System.out.println("WARNING: NDT server has different version number (" + vVersion.substring(1) + ")");
     2767                                _log.warn("WARNING: NDT server has different version number (" + vVersion.substring(1) + ")");
    27262768                        }
    27272769                }
     
    27292771                        _resultsTxtPane.append(_resBundDisplayMsgs
    27302772                                        .getString("diffrentVersion") + " (" + vVersion.substring(1) + ")\n");
    2731                         System.out.println("WARNING: NDT server has different version number (" + vVersion.substring(1) + ")");
     2773                        _log.warn("WARNING: NDT server has different version number (" + vVersion.substring(1) + ")");
    27322774                }
    27332775
     
    29002942                                        .getString("resultsTimeout") + "\n");
    29012943                }
    2902                 System.err.println("Calling InetAddress.getLocalHost() twice");
     2944                _log.warn("Calling InetAddress.getLocalHost() twice");
    29032945                try {
    29042946                        _txtDiagnosis.append(_resBundDisplayMsgs.getString("client") + ": "
     
    29863028                                                        lSysval3 = Long.parseLong(sStrval);
    29873029                                                } catch (Exception e) {
    2988                                                         System.out.println("Exception occured reading a web100 var " + sSysvar + " - " + e);
     3030                                                        _log.warn("Exception occured reading a web100 var " + sSysvar, e);
    29893031                                                        lSysval3 = -1;
    29903032                                                }
     
    29983040                                                        // If it fails as an int it's probably to big since the values are often unsigned
    29993041                                                } catch (Exception e) {
    3000                                                         System.out.println("Exception occured reading a web100 var " + sSysvar + " - " + e);
     3042                                                        _log.warn("Exception occured reading a web100 var " + sSysvar, e);
    30013043                                                        iSysval = -1;
    30023044                                                }
     
    31583200                                        break;
    31593201                                default: // default block indicating no match
    3160                                         System.err.println("No _iC2sData option match");
     3202                                        _log.warn("No _iC2sData option match");
    31613203                                        break;
    31623204                                }
     
    43384380         * Function that returns a variable corresponding to the parameter passed to
    43394381         * it as a request.
    4340          * @param {String} The parameter which the caller is seeking.
     4382         * @param varName {String} The parameter which the caller is seeking.
    43414383         * @return {String} The value of the desired parameter.
    43424384         */
     
    44154457        }
    44164458
     4459        /** bigly */
     4460        private ThreadGroup thread_group;
     4461       
     4462        /** bigly */
     4463        public void
     4464        killIt()
     4465        {
     4466                while( !thread_group.isDestroyed()){
     4467                        Thread[] threads = new Thread[thread_group.activeCount()];
     4468                        thread_group.enumerate( threads );
     4469                        int     done = 0;
     4470                        for ( int i=0;i<threads.length;i++){
     4471                                if ( threads[i] != null ){
     4472                                        done++;
     4473                                        //SESecurityManager.stopThread( threads[i] );
     4474                                }
     4475                        }
     4476                       
     4477                        if ( done == 0 ){
     4478                                try{
     4479                                        thread_group.destroy();
     4480                                        break;
     4481                                }catch( Throwable e ){
     4482                                        e.printStackTrace();
     4483                                }
     4484                        }
     4485                       
     4486                        try{
     4487                                Thread.sleep(250);
     4488                        }catch( Throwable e ){ 
     4489                        }
     4490                }
     4491        }
     4492       
     4493        /** bigly */
     4494        public void
     4495        runIt()
     4496        {
     4497                //final AESemaphore sem = new AESemaphore( "waiter" );
     4498               
     4499                thread_group = new
     4500                        ThreadGroup( "NDT" )
     4501                        {
     4502                                @Override
     4503                                public void
     4504                                uncaughtException(
     4505                                        Thread t,
     4506                                        Throwable e)
     4507                                {
     4508                                        _log.debug("?", e);
     4509                                }
     4510                        };
     4511               
     4512                thread_group.setDaemon( true );
     4513               
     4514                Thread t =
     4515                        new Thread(
     4516                                thread_group,
     4517                                new Runnable()
     4518                                {
     4519                                        @Override
     4520                                        public void
     4521                                        run()
     4522                                        {
     4523                                                try{
     4524                                                        new TestWorker().run();
     4525                                                }catch( Throwable e ){
     4526                                               
     4527                                                        if ( !( e instanceof ThreadDeath )){
     4528                                                                _log.debug("?", e);
     4529                                                        }
     4530                                                }finally{
     4531                                                        //sem.release();
     4532                                                }
     4533                                        }
     4534                                });
     4535               
     4536                t.setDaemon( true );
     4537                t.start();
     4538                //sem.reserve();
     4539        }
     4540
    44174541} // class: Tcpbw100
Note: See TracChangeset for help on using the changeset viewer.