fix(sync): memory exhaust on large file mesh broadcast by enforcing synchronous stream backpressure, increasing chunk size to 4MB, and bounding priority queues

Fork: 0

yangyangxie / cortex-hub

Browse code fix(sync): memory exhaust on large file mesh broadcast by enforcing synchronous stream backpressure, increasing chunk size to 4MB, and bounding priority queues master
1 parent 8215333 commit ed3725977c7a99c4d480009a038d45f6a723fac1 Antigravity AI authored 8 hours ago

Patch

Unified Split

Showing 4 changed files

Ignore Space Show notes View agent-node/src/agent_node/core/watcher.py

Ignore Space Show notes View agent-node/src/agent_node/node.py

Ignore Space Show notes View ai-hub/app/core/grpc/services/assistant.py

Ignore Space Show notes View ai-hub/app/core/services/node_registry.py

Show line notes below