Skip to content

Commit 11a8b0b

Browse files
committed
feat: revokes affected inbound connections only
Signed-off-by: nilekh <[email protected]>
1 parent 361dac3 commit 11a8b0b

File tree

15 files changed

+532
-154
lines changed

15 files changed

+532
-154
lines changed

Cargo.lock

Lines changed: 130 additions & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/config.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -317,13 +317,13 @@ pub struct Config {
317317

318318
pub ipv6_enabled: bool,
319319

320-
/// Enable CRL (Certificate Revocation List) checking
320+
// Enable CRL (Certificate Revocation List) checking
321321
pub enable_crl: bool,
322322

323-
/// Path to CRL file
323+
// Path to CRL file
324324
pub crl_path: PathBuf,
325325

326-
/// Allow expired CRL (for testing/rollout scenarios)
326+
// Allow expired CRL (for testing/rollout scenarios)
327327
pub allow_expired_crl: bool,
328328
}
329329

src/proxy.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -263,7 +263,6 @@ pub(super) struct ProxyInputs {
263263
resolver: Option<Arc<dyn Resolver + Send + Sync>>,
264264
// If true, inbound connections created with these inputs will not attempt to preserve the original source IP.
265265
pub disable_inbound_freebind: bool,
266-
// CRL manager for certificate revocation checking
267266
pub(super) crl_manager: Option<Arc<tls::crl::CrlManager>>,
268267
}
269268

@@ -303,6 +302,10 @@ impl Proxy {
303302
// We setup all the listeners first so we can capture any errors that should block startup
304303
let inbound = Inbound::new(pi.clone(), drain.clone()).await?;
305304

305+
if let Some(ref crl_mgr) = pi.crl_manager {
306+
crl_mgr.register_connection_manager(pi.connection_manager.clone());
307+
}
308+
306309
// This exists for `direct` integ tests, no other reason
307310
#[cfg(any(test, feature = "testing"))]
308311
if pi.cfg.fake_self_inbound {

0 commit comments

Comments
 (0)