is a generic Logging Framework (intended as a log4j successor).
| AbstractSocketAppender.java (logback-1.2.3) | : | AbstractSocketAppender.java (logback-v_1.2.7) |
|---|
| | |
| skipping to change at line 194 | | skipping to change at line 194 |
|---|
| } | | } |
| } | | } |
| | |
| private void connectSocketAndDispatchEvents() { | | private void connectSocketAndDispatchEvents() { |
| try { | | try { |
| while (socketConnectionCouldBeEstablished()) { | | while (socketConnectionCouldBeEstablished()) { |
| try { | | try { |
| ObjectWriter objectWriter = createObjectWriterForSocket(); | | ObjectWriter objectWriter = createObjectWriterForSocket(); |
| addInfo(peerId + "connection established"); | | addInfo(peerId + "connection established"); |
| dispatchEvents(objectWriter); | | dispatchEvents(objectWriter); |
|
| | } catch (javax.net.ssl.SSLHandshakeException she) { |
| | // FIXME |
| | Thread.sleep(DEFAULT_RECONNECTION_DELAY); |
| } catch (IOException ex) { | | } catch (IOException ex) { |
|
| addInfo(peerId + "connection failed: " + ex); | | addInfo(peerId + "connection failed: ", ex); |
| } finally { | | } finally { |
| CloseUtil.closeQuietly(socket); | | CloseUtil.closeQuietly(socket); |
| socket = null; | | socket = null; |
| addInfo(peerId + "connection closed"); | | addInfo(peerId + "connection closed"); |
| } | | } |
| } | | } |
| } catch (InterruptedException ex) { | | } catch (InterruptedException ex) { |
| assert true; // ok... we'll exit now | | assert true; // ok... we'll exit now |
| } | | } |
| addInfo("shutting down"); | | addInfo("shutting down"); |
| | | |
| End of changes. 2 change blocks. |
|---|
| 1 lines changed or deleted | | 4 lines changed or added |
|---|
"Fossies" - the Fresh Open Source Software Archive 