System.out.println("wait for ack...");
while (isRunning) {
- if (null != (result = controlReader.readLine())
- && !result.isEmpty()) {
- break;
+ char cbuf[] = new char[64];
+ int readsize = controlReader.read(cbuf);
+// System.out.println(readsize);
+
+ if(readsize > 0)
+ {
+ result = String.copyValueOf(cbuf, 0, readsize);
+ System.out.println(result.length() + "="+ result);
+
+ if (null != result && !result.isEmpty()) {
+ break;
+ }
}
- System.out.println("wait!!");
+// System.out.println("wait!!");
}
System.out.println("pass");
// result = "test ack message";
// NEW_COM
public static boolean sendVersionMessage() {
String message = AnalyzerConstants.MSG_VERSION
- + CommonConstants.CMD_SPLIT + AnalyzerConstants.DA_VERSION;
+ + CommonConstants.CMD_SPLIT + AnalyzerConstants.DA_VERSION.length() +
+ CommonConstants.CMD_SPLIT + AnalyzerConstants.DA_VERSION;
System.out.println("Send control message :" + message); //$NON-NLS-1$
String result = handleControlMessage(message);
- // test
- result = "901|1|0";
- // result = "902|3|2.0";
if (null != result) {
System.out.println("version message ack :" + result);
String[] splitResult = result.split(CommonConstants.CMD_SPLIT_READ);
return 0;
}
String valuestr = data.get(key);
- if (valuestr.equalsIgnoreCase(ConfigureLabels.ON)) {
- return 1;
- } else {
+ if(valuestr == null)
return 0;
- }
+ else
+ return Integer.parseInt(valuestr);
+// if (valuestr.equalsIgnoreCase(ConfigureLabels.ON)) {
+// return 1;
+// } else {
+// return 0;
+// }
}
public void setValue(String key, String val) {
}
});
- if (DACommunicator.isRunning()) {
- String message = AnalyzerConstants.MSG_STOP
- + CommonConstants.CMD_SPLIT + 0 + CommonConstants.CMD_SPLIT;
- DACommunicator.sendMessage(message);
- System.out.println("stop send message :" + message);
- }
+ DACommunicator.sendStopMessage();
+// if (DACommunicator.isRunning()) {
+// String message = AnalyzerConstants.MSG_STOP
+// + CommonConstants.CMD_SPLIT + 0 + CommonConstants.CMD_SPLIT;
+// DACommunicator.sendMessage(message);
+// System.out.println("stop send message :" + message);
+// }
}
}