mirror of
https://github.com/openjdk/jdk.git
synced 2025-09-22 20:14:43 +02:00
8213490: Networking area typos and inconsistencies cleanup
Reviewed-by: alanb, chegar, dfuchs
This commit is contained in:
parent
56db122656
commit
8c361a3e74
42 changed files with 87 additions and 87 deletions
|
@ -191,8 +191,8 @@ public abstract class HttpRequest {
|
|||
* {@link HttpClient#sendAsync(java.net.http.HttpRequest,
|
||||
* java.net.http.HttpResponse.BodyHandler) HttpClient::sendAsync}
|
||||
* completes exceptionally with an {@code HttpTimeoutException}. The effect
|
||||
* of not setting a timeout is the same as setting an infinite Duration, ie.
|
||||
* block forever.
|
||||
* of not setting a timeout is the same as setting an infinite Duration,
|
||||
* i.e. block forever.
|
||||
*
|
||||
* @param duration the timeout duration
|
||||
* @return this builder
|
||||
|
|
|
@ -127,7 +127,7 @@ class AuthenticationFilter implements HeaderFilter {
|
|||
}
|
||||
|
||||
// our own private scheme for proxy URLs
|
||||
// eg. proxy.http://host:port/
|
||||
// e.g. proxy.http://host:port/
|
||||
String scheme = "proxy." + r.uri().getScheme();
|
||||
try {
|
||||
return new URI(scheme,
|
||||
|
|
|
@ -282,7 +282,7 @@ class Http1AsyncReceiver {
|
|||
// The most recently subscribed delegate will get the error.
|
||||
// If the delegate is null, the error will be handled by the next
|
||||
// delegate that subscribes.
|
||||
// If the queue is not empty, wait until it it is empty before
|
||||
// If the queue is not empty, wait until it is empty before
|
||||
// handling the error.
|
||||
Http1AsyncDelegate delegate = pendingDelegateRef.get();
|
||||
if (delegate == null) delegate = this.delegate;
|
||||
|
|
|
@ -414,7 +414,7 @@ class Http2Connection {
|
|||
|
||||
// call these before assigning a request/stream to a connection
|
||||
// if false returned then a new Http2Connection is required
|
||||
// if true, the the stream may be assigned to this connection
|
||||
// if true, the stream may be assigned to this connection
|
||||
// for server push, if false returned, then the stream should be cancelled
|
||||
synchronized boolean reserveStream(boolean clientInitiated) throws IOException {
|
||||
if (finalStream) {
|
||||
|
|
|
@ -211,7 +211,7 @@ final class HttpClientImpl extends HttpClient implements Trackable {
|
|||
// from the map. This should also take care of push promises.
|
||||
// 2. For WebSocket the count is increased when creating a
|
||||
// DetachedConnectionChannel for the socket, and decreased
|
||||
// when the the channel is closed.
|
||||
// when the channel is closed.
|
||||
// In addition, the HttpClient facade is passed to the WebSocket builder,
|
||||
// (instead of the client implementation delegate).
|
||||
// 3. For HTTP/1.1 the count is incremented before starting to parse the body
|
||||
|
|
|
@ -322,7 +322,7 @@ final class SocketTube implements FlowTube {
|
|||
// onNext is usually called from within a user / executor thread.
|
||||
// Initial writing will be performed in that thread. If for some reason,
|
||||
// not all the data can be written, a writeEvent will be registered, and
|
||||
// writing will resume in the the selector manager thread when the
|
||||
// writing will resume in the selector manager thread when the
|
||||
// writeEvent is fired.
|
||||
//
|
||||
// If this method is invoked in the selector manager thread (because of
|
||||
|
|
|
@ -69,7 +69,7 @@ import jdk.internal.net.http.hpack.DecodingCallback;
|
|||
* RESPONSES
|
||||
*
|
||||
* Multiple responses can be received per request. Responses are queued up on
|
||||
* a LinkedList of CF<HttpResponse> and the the first one on the list is completed
|
||||
* a LinkedList of CF<HttpResponse> and the first one on the list is completed
|
||||
* with the next response
|
||||
*
|
||||
* getResponseAsync() -- queries list of response CFs and returns first one
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue