View | Details | Raw Unified | Return to bug 50183
Collapse All | Expand All

(-)transport/bio/BioReplicationTask.java (-2 / +1 lines)
Lines 61-67 Link Here
61
        try {
61
        try {
62
            drainSocket();
62
            drainSocket();
63
        } catch ( Exception x ) {
63
        } catch ( Exception x ) {
64
            log.error("Unable to service bio socket");
64
            log.error("Unable to service bio socket", x);
65
        }finally {
65
        }finally {
66
            try {socket.close();}catch ( Exception ignore){}
66
            try {socket.close();}catch ( Exception ignore){}
67
            try {reader.close();}catch ( Exception ignore){}
67
            try {reader.close();}catch ( Exception ignore){}
Lines 76-82 Link Here
76
    public synchronized void serviceSocket(Socket socket, ObjectReader reader) {
76
    public synchronized void serviceSocket(Socket socket, ObjectReader reader) {
77
        this.socket = socket;
77
        this.socket = socket;
78
        this.reader = reader;
78
        this.reader = reader;
79
        this.notify();		// awaken the thread
80
    }
79
    }
81
    
80
    
82
    protected void execute(ObjectReader reader) throws Exception{
81
    protected void execute(ObjectReader reader) throws Exception{
(-)transport/bio/BioReceiver.java (+1 lines)
Lines 150-155 Link Here
150
            socket.setSoTimeout(getTimeout());
150
            socket.setSoTimeout(getTimeout());
151
            ObjectReader reader = new ObjectReader(socket);
151
            ObjectReader reader = new ObjectReader(socket);
152
            task.serviceSocket(socket,reader);
152
            task.serviceSocket(socket,reader);
153
            getExecutor().execute(task);
153
        }//while
154
        }//while
154
    }
155
    }
155
    
156
    

Return to bug 50183