// Path: remote/src/main/java/org/testng/remote/RemoteTestNG.java
// public static boolean isVerbose() {
//     boolean result = System.getProperty(PROPERTY_VERBOSE) != null || isDebug();
//     return result;
// }
// 
// Path: remote/src/main/java/org/testng/remote/RemoteTestNG.java
// public static boolean isDebug() {
//     return m_debug || System.getProperty(PROPERTY_DEBUG) != null;
// }


import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.Closeable;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.net.ConnectException;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketTimeoutException;
import org.testng.TestNGException;
import static org.testng.remote.RemoteTestNG.isVerbose;
import static org.testng.remote.RemoteTestNG.isDebug;
              m_latestAck = message;
            }
            synchronized(m_ackLock) {
              m_ackLock.notifyAll();
            }
            if (stop) {
              break;
            }
          } else {
            p("Received unknown message: '" + message + "'");
          }
          message = m_inReader != null ? m_inReader.readLine() : null;
        }
//        while((m_reader != null) && (message = m_reader.readLine()) != null) {
//          if (m_debug) {
//            p("Admin message:" + message); //$NON-NLS-1$
//          }
//          boolean acknowledge = MessageHelper.ACK_MSG.equals(message);
//          boolean stop = MessageHelper.STOP_MSG.equals(message);
//          if(acknowledge || stop) {
//            synchronized(m_lock) {
//              m_lock.notifyAll();
//            }
//            if (stop) {
//              break;
//            }
//          }
//        }
      }
      catch(IOException ioe) {
// Path: remote/src/main/java/org/testng/remote/RemoteTestNG.java
// public static boolean isVerbose() {
//     boolean result = System.getProperty(PROPERTY_VERBOSE) != null || isDebug();
//     return result;
// }
// 
// Path: remote/src/main/java/org/testng/remote/RemoteTestNG.java
// public static boolean isDebug() {
//     return m_debug || System.getProperty(PROPERTY_DEBUG) != null;
// }


// Path: remote/src/main/java/org/testng/remote/strprotocol/BaseMessageSender.java
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.Closeable;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.net.ConnectException;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketTimeoutException;
import org.testng.TestNGException;
import static org.testng.remote.RemoteTestNG.isVerbose;
import static org.testng.remote.RemoteTestNG.isDebug;

              m_latestAck = message;
            }
            synchronized(m_ackLock) {
              m_ackLock.notifyAll();
            }
            if (stop) {
              break;
            }
          } else {
            p("Received unknown message: '" + message + "'");
          }
          message = m_inReader != null ? m_inReader.readLine() : null;
        }
//        while((m_reader != null) && (message = m_reader.readLine()) != null) {
//          if (m_debug) {
//            p("Admin message:" + message); //$NON-NLS-1$
//          }
//          boolean acknowledge = MessageHelper.ACK_MSG.equals(message);
//          boolean stop = MessageHelper.STOP_MSG.equals(message);
//          if(acknowledge || stop) {
//            synchronized(m_lock) {
//              m_lock.notifyAll();
//            }
//            if (stop) {
//              break;
//            }
//          }
//        }
      }
      catch(IOException ioe) {
        if (isVerbose()) {