src/java.net.http/share/classes/jdk/internal/net/http/websocket/WebSocketImpl.java
equal
deleted
inserted
replaced
521 id, statusCode, reason.length()); |
521 id, statusCode, reason.length()); |
522 } |
522 } |
523 try { |
523 try { |
524 cs = listener.onClose(WebSocketImpl.this, statusCode, reason); |
524 cs = listener.onClose(WebSocketImpl.this, statusCode, reason); |
525 } finally { |
525 } finally { |
526 System.out.printf("[WebSocket] exit onClose %s returned %s%n", |
526 if (DEBUG) { |
527 id, cs); |
527 System.out.printf("[WebSocket] exit onClose %s returned %s%n", |
|
528 id, cs); |
|
529 } |
528 } |
530 } |
529 if (cs == null) { |
531 if (cs == null) { |
530 cs = DONE; |
532 cs = DONE; |
531 } |
533 } |
532 int code; |
534 int code; |
560 } |
562 } |
561 CompletionStage<?> cs = null; |
563 CompletionStage<?> cs = null; |
562 try { |
564 try { |
563 cs = listener.onPong(WebSocketImpl.this, binaryData); |
565 cs = listener.onPong(WebSocketImpl.this, binaryData); |
564 } finally { |
566 } finally { |
565 System.out.printf("[WebSocket] exit onPong %s returned %s%n", |
567 if (DEBUG) { |
566 id, cs); |
568 System.out.printf("[WebSocket] exit onPong %s returned %s%n", |
|
569 id, cs); |
|
570 } |
567 } |
571 } |
568 } |
572 } |
569 |
573 |
570 private void processPing() { |
574 private void processPing() { |
571 if (DEBUG) { |
575 if (DEBUG) { |
604 |
608 |
605 private void processBinary() { |
609 private void processBinary() { |
606 long id; |
610 long id; |
607 if (DEBUG) { |
611 if (DEBUG) { |
608 id = receiveCounter.incrementAndGet(); |
612 id = receiveCounter.incrementAndGet(); |
609 System.out.printf("[WebSocket] enter onBinary %s payload=%s, part=%s%n", |
613 System.out.printf("[WebSocket] enter onBinary %s payload=%s part=%s%n", |
610 id, binaryData, part); |
614 id, binaryData, part); |
611 } |
615 } |
612 CompletionStage<?> cs = null; |
616 CompletionStage<?> cs = null; |
613 try { |
617 try { |
614 cs = listener.onBinary(WebSocketImpl.this, binaryData, part); |
618 cs = listener.onBinary(WebSocketImpl.this, binaryData, part); |