Subversion Repositories Projects

Rev

Rev 1563 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 1563 Rev 1698
Line 15... Line 15...
15 
public class FrameQueue {
 15 
public class FrameQueue {
16 
        private final MKInputStream input;
 16 
        private final MKInputStream input;
17 
        private final MKOutputStream output;
 17 
        private final MKOutputStream output;
18 
        // private List responseQueue;
 18 
        // private List responseQueue;
19 
        private ResponseFrame lastResponseFrame;
 19 
        private ResponseFrame lastResponseFrame;
20 
        private boolean doQueue = true;
 20 
        private volatile boolean doQueue = true;
Line 21... Line 21...
21 
 
 21 
 
22 
        class Receiver extends Thread {
 22 
        class Receiver extends Thread {
23 
                public void run() {
 23 
                public void run() {
24 
                        while (doQueue) {
 24 
                        while (doQueue) {
Line 45... Line 45...
45 
 
 45 
 
46 
        public FrameQueue(InputStream in, OutputStream out) throws IOException {
 46 
        public FrameQueue(InputStream in, OutputStream out) throws IOException {
47 
                super();
 47 
                super();
48 
                this.input = new MKInputStream (in);
 48 
                this.input = new MKInputStream (in);
- 
 
 49 
                this.output = new MKOutputStream(out);
- 
 
 50 
                Receiver r = new Receiver();
49 
                this.output = new MKOutputStream(out);
 51 
                r.setDaemon(false);
50 
                new Receiver().start();
 52 
                r.start();
Line 51... Line 53...
51 
        }
 53 
        }
52 
 
 54 
 
53 
        public void sendRequest(RequestFrame f) throws IOException {
 55 
        public void sendRequest(RequestFrame f) throws IOException {