/dongfang_FC_rewrite_tool/src/dongfang/mkt/comm/FrameQueue.java |
---|
17,7 → 17,7 |
private final MKOutputStream output; |
// private List responseQueue; |
private ResponseFrame lastResponseFrame; |
private boolean doQueue = true; |
private volatile boolean doQueue = true; |
class Receiver extends Thread { |
public void run() { |
47,7 → 47,9 |
super(); |
this.input = new MKInputStream (in); |
this.output = new MKOutputStream(out); |
new Receiver().start(); |
Receiver r = new Receiver(); |
r.setDaemon(false); |
r.start(); |
} |
public void sendRequest(RequestFrame f) throws IOException { |
/dongfang_FC_rewrite_tool/src/dongfang/mkt/comm/MKInputStream.java |
---|
447,9 → 447,9 |
VersionResponseFrame f = new VersionResponseFrame(address); |
f.setSWMajor(base64InputStream.readByte()); |
f.setSWMinor(base64InputStream.readByte()); |
f.setSWPatch(base64InputStream.readByte()); |
f.setProtoMajor(base64InputStream.readByte()); |
f.setProtoMinor(base64InputStream.readByte()); |
f.setSWPatch(base64InputStream.readByte()); |
f.setHardwareErrors(base64InputStream.readBytes(5)); |
result = f; |
break; |