aboutsummaryrefslogtreecommitdiffstats
path: root/research/experiments/035-push/push.py
diff options
context:
space:
mode:
authoreunhhu <[email protected]>2026-10-04 16:20:17 +0100
committereunhhu <[email protected]>2026-10-04 16:20:17 +0100
commitbcfc4fe3baa94bc054f949e65389e05969b7ff50 (patch)
tree80b6540957659890e9c45a45404e710f6a2b2097 /research/experiments/035-push/push.py
parent50d8263492d69ca8521d3b1d51f60b551c76c443 (diff)
downloadpure-bcfc4fe3baa94bc054f949e65389e05969b7ff50.tar.gz
pure-bcfc4fe3baa94bc054f949e65389e05969b7ff50.zip
Wake each thread at most once a push, end streams only of stopped apps, and show a subscriber costs writes nothing (019)
Diffstat (limited to 'research/experiments/035-push/push.py')
-rwxr-xr-xresearch/experiments/035-push/push.py1
1 files changed, 1 insertions, 0 deletions
diff --git a/research/experiments/035-push/push.py b/research/experiments/035-push/push.py
index 28334dd..f854bb3 100755
--- a/research/experiments/035-push/push.py
+++ b/research/experiments/035-push/push.py
@@ -40,6 +40,7 @@ def main():
runs = sys.argv[5:]
work = Path(tempfile.mkdtemp(prefix='pure-035-', dir='/dev/shm'))
try:
+ subprocess.run(['cc', '-O2', '-Wall', '-Wextra', '-Werror', '-o', str(WATCH), str(WATCH) + '.c'], check=True)
subprocess.run([str(aup), 'build', str(HERE / 'counter.aup'), '-o', str(work / 'counter.pmod')], check=True)
for run in runs:
clients, rate, way = run.split(':', 2)