setConnectSuccess() — netty Function Reference
Architecture documentation for the setConnectSuccess() function in ProxyHandler.java from the netty codebase.
Entity Profile
Dependency Diagram
graph TD cb0b2332_f25d_1f61_9378_a90a595d13ac["setConnectSuccess()"] 3f5c9c39_cf82_6deb_e43b_1a9ad5499a99["ProxyHandler"] cb0b2332_f25d_1f61_9378_a90a595d13ac -->|defined in| 3f5c9c39_cf82_6deb_e43b_1a9ad5499a99 f71d1b6f_991f_8b73_bb78_675b65214707["channelRead()"] f71d1b6f_991f_8b73_bb78_675b65214707 -->|calls| cb0b2332_f25d_1f61_9378_a90a595d13ac 328894d0_bee6_45f1_df68_901e71965fde["cancelConnectTimeoutFuture()"] cb0b2332_f25d_1f61_9378_a90a595d13ac -->|calls| 328894d0_bee6_45f1_df68_901e71965fde dea41db8_eaaa_a763_38f0_d529f90bc538["safeRemoveEncoder()"] cb0b2332_f25d_1f61_9378_a90a595d13ac -->|calls| dea41db8_eaaa_a763_38f0_d529f90bc538 a3c87264_9e04_d235_a76b_def97aa550e7["safeRemoveDecoder()"] cb0b2332_f25d_1f61_9378_a90a595d13ac -->|calls| a3c87264_9e04_d235_a76b_def97aa550e7 3a0a34d2_5ea7_98c5_9064_2be33b66bcc4["writePendingWrites()"] cb0b2332_f25d_1f61_9378_a90a595d13ac -->|calls| 3a0a34d2_5ea7_98c5_9064_2be33b66bcc4 2d49a670_3970_60e0_a8e9_e3dcb4609aa0["flush()"] cb0b2332_f25d_1f61_9378_a90a595d13ac -->|calls| 2d49a670_3970_60e0_a8e9_e3dcb4609aa0 836da478_f946_4379_526a_81d89011dd4b["failPendingWritesAndClose()"] cb0b2332_f25d_1f61_9378_a90a595d13ac -->|calls| 836da478_f946_4379_526a_81d89011dd4b style cb0b2332_f25d_1f61_9378_a90a595d13ac fill:#6366f1,stroke:#818cf8,color:#fff
Relationship Graph
Source Code
handler-proxy/src/main/java/io/netty/handler/proxy/ProxyHandler.java lines 280–308
private void setConnectSuccess() {
finished = true;
cancelConnectTimeoutFuture();
if (!connectPromise.isDone()) {
boolean removedCodec = true;
removedCodec &= safeRemoveEncoder();
ctx.fireUserEventTriggered(
new ProxyConnectionEvent(protocol(), authScheme(), proxyAddress, destinationAddress));
removedCodec &= safeRemoveDecoder();
if (removedCodec) {
writePendingWrites();
if (flushedPrematurely) {
ctx.flush();
}
connectPromise.trySuccess(ctx.channel());
} else {
// We are at inconsistent state because we failed to remove all codec handlers.
Exception cause = new ProxyConnectException(
"failed to remove all codec handlers added by the proxy handler; bug?");
failPendingWritesAndClose(cause);
}
}
}
Domain
Subdomains
Calls
Called By
Source
Frequently Asked Questions
What does setConnectSuccess() do?
setConnectSuccess() is a function in the netty codebase, defined in handler-proxy/src/main/java/io/netty/handler/proxy/ProxyHandler.java.
Where is setConnectSuccess() defined?
setConnectSuccess() is defined in handler-proxy/src/main/java/io/netty/handler/proxy/ProxyHandler.java at line 280.
What does setConnectSuccess() call?
setConnectSuccess() calls 6 function(s): cancelConnectTimeoutFuture, failPendingWritesAndClose, flush, safeRemoveDecoder, safeRemoveEncoder, writePendingWrites.
What calls setConnectSuccess()?
setConnectSuccess() is called by 1 function(s): channelRead.
Analyze Your Own Codebase
Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.
Try Supermodel Free