src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/PlainHttpConnection.java
equal
deleted
inserted
replaced
82 assert !chan.isBlocking() : "Unexpected blocking channel"; |
82 assert !chan.isBlocking() : "Unexpected blocking channel"; |
83 debug.log(Level.DEBUG, "ConnectEvent: finishing connect"); |
83 debug.log(Level.DEBUG, "ConnectEvent: finishing connect"); |
84 boolean finished = chan.finishConnect(); |
84 boolean finished = chan.finishConnect(); |
85 assert finished : "Expected channel to be connected"; |
85 assert finished : "Expected channel to be connected"; |
86 debug.log(Level.DEBUG, |
86 debug.log(Level.DEBUG, |
87 "ConnectEvent: connect finished: %s", finished); |
87 "ConnectEvent: connect finished: %s Local addr: %s", finished, chan.getLocalAddress()); |
88 connected = true; |
88 connected = true; |
89 // complete async since the event runs on the SelectorManager thread |
89 // complete async since the event runs on the SelectorManager thread |
90 cf.completeAsync(() -> null, client().theExecutor()); |
90 cf.completeAsync(() -> null, client().theExecutor()); |
91 } catch (Throwable e) { |
91 } catch (Throwable e) { |
92 client().theExecutor().execute( () -> cf.completeExceptionally(e)); |
92 client().theExecutor().execute( () -> cf.completeExceptionally(e)); |