src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/Http2Connection.java
equal
deleted
inserted
replaced
71 import jdk.incubator.http.internal.frame.SettingsFrame; |
71 import jdk.incubator.http.internal.frame.SettingsFrame; |
72 import jdk.incubator.http.internal.frame.WindowUpdateFrame; |
72 import jdk.incubator.http.internal.frame.WindowUpdateFrame; |
73 import jdk.incubator.http.internal.hpack.Encoder; |
73 import jdk.incubator.http.internal.hpack.Encoder; |
74 import jdk.incubator.http.internal.hpack.Decoder; |
74 import jdk.incubator.http.internal.hpack.Decoder; |
75 import jdk.incubator.http.internal.hpack.DecodingCallback; |
75 import jdk.incubator.http.internal.hpack.DecodingCallback; |
76 |
76 import static java.nio.charset.StandardCharsets.UTF_8; |
77 import static jdk.incubator.http.internal.frame.SettingsFrame.*; |
77 import static jdk.incubator.http.internal.frame.SettingsFrame.*; |
78 |
78 |
79 |
79 |
80 /** |
80 /** |
81 * An Http2Connection. Encapsulates the socket(channel) and any SSLEngine used |
81 * An Http2Connection. Encapsulates the socket(channel) and any SSLEngine used |
485 return serverSettings.getParameter(INITIAL_WINDOW_SIZE); |
485 return serverSettings.getParameter(INITIAL_WINDOW_SIZE); |
486 } |
486 } |
487 |
487 |
488 void close() { |
488 void close() { |
489 Log.logTrace("Closing HTTP/2 connection: to {0}", connection.address()); |
489 Log.logTrace("Closing HTTP/2 connection: to {0}", connection.address()); |
490 GoAwayFrame f = new GoAwayFrame(0, ErrorFrame.NO_ERROR, "Requested by user".getBytes()); |
490 GoAwayFrame f = new GoAwayFrame(0, |
|
491 ErrorFrame.NO_ERROR, |
|
492 "Requested by user".getBytes(UTF_8)); |
491 // TODO: set last stream. For now zero ok. |
493 // TODO: set last stream. For now zero ok. |
492 sendFrame(f); |
494 sendFrame(f); |
493 } |
495 } |
494 |
496 |
495 long count; |
497 long count; |