') + ')', 'gi'); if (regex.test(text)) { found = true; var frag = document.createDocumentFragment(); var parts = text.split(regex); parts.forEach(function(part, i) { if (i % 2 === 0) { frag.appendChild(document.createTextNode(part)); } else { var span = document.createElement('span'); span.className = 'userscript-highlight'; span.textContent = part; frag.appendChild(span); } }); node.parentNode.replaceChild(frag, node); } }); } else if (node.nodeType === 1 && node.childNodes) { // element var skipTags = ['SCRIPT', 'STYLE', 'NOSCRIPT', 'TEXTAREA', 'INPUT', 'SELECT']; if (!skipTags.includes(node.tagName)) { Array.from(node.childNodes).forEach(highlight); } } } highlight(document.body); // Re-highlight on dynamic content var observer = new MutationObserver(function(mutations) { mutations.forEach(function(m) { m.addedNodes.forEach(function(node) { if (node.nodeType === 1 || node.nodeType === 3) highlight(node); }); }); }); observer.observe(document.body, { childList: true, subtree: true }); })(); } } catch(__e) { console.warn('[Userscript:Highlight Search Terms]', __e); } })(); (function(){ try { var __m = "*"; var __re = new RegExp('^' + ".*" + ', 'i'); if (__m === '*' || __re.test(location.href)) { // Strip utm_, fbclid, gclid, etc. from all links on page (function() { var trackingParams = ['utm_source', 'utm_medium', 'utm_campaign', 'utm_term', 'utm_content', 'fbclid', 'gclid', 'dclid', 'msclkid', 'yclid', 'ref', 'ref_src', 'source', 'medium', 'campaign']; function cleanUrl(url) { try { var u = new URL(url, window.location.origin); var changed = false; trackingParams.forEach(function(p) { if (u.searchParams.has(p)) { u.searchParams.delete(p); changed = true; } }); return changed ? u.toString() : url; } catch (e) { return url; } } function cleanLinks() { document.querySelectorAll('a[href]').forEach(function(a) { var clean = cleanUrl(a.href); if (clean !== a.href) a.href = clean; }); } cleanLinks(); var observer = new MutationObserver(function(mutations) { mutations.forEach(function(m) { m.addedNodes.forEach(function(node) { if (node.nodeType === 1) { if (node.tagName === 'A') cleanLinks(); node.querySelectorAll('a[href]').forEach(function(a) { var clean = cleanUrl(a.href); if (clean !== a.href) a.href = clean; }); } }); }); }); observer.observe(document.body, { childList: true, subtree: true }); })(); } } catch(__e) { console.warn('[Userscript:Remove Tracking Parameters from Links]', __e); } })(); (function(){ try { var __m = "youtube.com"; var __re = new RegExp('^' + "youtube\\.com" + ', 'i'); if (__m === '*' || __re.test(location.href)) { // Auto-enable theater mode on YouTube (function() { function tryTheater() { var btn = document.querySelector('button[aria-label="Theater mode"], ytd-player #player button[title="Theater mode"]'); if (btn && !btn.classList.contains('activated')) { btn.click(); } } // Try immediately tryTheater(); // Try after navigation (SPA) var lastUrl = location.href; setInterval(function() { if (location.href !== lastUrl) { lastUrl = location.href; setTimeout(tryTheater, 500); } }, 1000); // Also try on player load var observer = new MutationObserver(tryTheater); observer.observe(document.body, { childList: true, subtree: true }); })(); } } catch(__e) { console.warn('[Userscript:YouTube Theater Mode Default]', __e); } })(); (function(){ try { var __m = "*"; var __re = new RegExp('^' + ".*" + ', 'i'); if (__m === '*' || __re.test(location.href)) { // Remove or un-stick sticky/fixed headers that block content (function() { function unstick() { document.querySelectorAll('header, nav, [role="banner"], .header, .navbar, .sticky, .fixed-top, [style*="position: fixed"], [style*="position:sticky"]').forEach(function(el) { if (el.style.position === 'fixed' || el.style.position === 'sticky' || getComputedStyle(el).position === 'fixed' || getComputedStyle(el).position === 'sticky') { el.style.position = 'static'; el.style.top = 'auto'; el.style.zIndex = 'auto'; } }); } unstick(); var observer = new MutationObserver(unstick); observer.observe(document.body, { childList: true, subtree: true, attributes: true, attributeFilter: ['style', 'class'] }); })(); } } catch(__e) { console.warn('[Userscript:Kill Sticky Headers]', __e); } })(); })(); Configure HTTP/2 timeouts via environment by wyeth93 · Pull Request #76 · DeepLink-org/Pulsing · GitHub
Skip to content

Configure HTTP/2 timeouts via environment - #76

Merged
wyeth930203 merged 2 commits into
DeepLink-org:mainfrom
wyeth93:agent/http2-timeout-env
Jul 27, 2026
Merged

Configure HTTP/2 timeouts via environment#76
wyeth930203 merged 2 commits into
DeepLink-org:mainfrom
wyeth93:agent/http2-timeout-env

Conversation

@wyeth93

@wyeth93wyeth93 commented Jul 27, 2026

Copy link
Copy Markdown
Collaborator

Summary

  • add strict PULSING_HTTP2_* timeout environment variables across ActorSystem, Connect, Python, and RustPython entry points
  • preserve explicit Http2Config precedence over environment-derived defaults
  • enforce a hard streaming deadline and surface typed RequestTimeout errors
  • document defaults, validation, precedence, and scope in English and Chinese
  • add regression coverage for environment parsing and silent streaming timeouts

Why

HTTP/2 timeouts were hard-coded, and the stream timeout was only checked when frames arrived. A silent stream could therefore remain open indefinitely and terminate without a typed timeout error.

Impact

Operators can tune remote HTTP/2 transport timeouts per process without code changes. Existing defaults remain 5s / 30s / 300s when variables are unset. Invalid or zero values fail configuration loading. Local actor asks and server handler deadlines are unchanged.

Validation

  • cargo fmt --all -- --check
  • cargo test -p pulsing-actor
  • cargo check --workspace
  • cargo clippy -p pulsing-actor --all-targets -- -D warnings
  • git diff --check

@codecov-commenter

codecov-commenter commented Jul 27, 2026•
edited
Loading

Copy link
Copy Markdown

Codecov Report

❌ Patch coverage is 64.92891% with 74 lines in your changes missing coverage. Please review.

Files with missing linesPatch %Lines
crates/pulsing-actor/src/transport/http2/client.rs46.55%31 Missing ⚠️
crates/pulsing-actor/src/system/config.rs14.28%18 Missing ⚠️
crates/pulsing-actor/src/transport/http2/config.rs91.74%9 Missing ⚠️
crates/pulsing-actor/src/connect/mod.rs50.00%7 Missing ⚠️
crates/pulsing-rpymod/src/bindings/message.rs0.00%5 Missing ⚠️
crates/pulsing-rpymod/src/runtime.rs0.00%4 Missing ⚠️
Files with missing linesCoverage Δ
crates/pulsing-rpymod/src/runtime.rs0.00% <0.00%> (ø)
crates/pulsing-rpymod/src/bindings/message.rs0.00% <0.00%> (ø)
crates/pulsing-actor/src/connect/mod.rs25.66% <50.00%> (+3.66%)⬆️
crates/pulsing-actor/src/transport/http2/config.rs83.21% <91.74%> (+7.51%)⬆️
crates/pulsing-actor/src/system/config.rs81.08% <14.28%> (-2.70%)⬇️
crates/pulsing-actor/src/transport/http2/client.rs59.74% <46.55%> (+3.68%)⬆️

... and 5 files with indirect coverage changes

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

@wyeth93
wyeth93 marked this pull request as ready for review July 27, 2026 10:49
@wyeth930203
wyeth930203 merged commit 857bfa8 into DeepLink-org:mainJul 27, 2026
22 of 23 checks passed
Sign up for freeto join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

No reviews

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

2 participants

@wyeth93@codecov-commenter