FA-27536 / HTTP ranges / Open access
A zero-copy range sender accounts for partial progress reported with syscall errors: aborted and truncated range streams release the source handle · case 01
A zero-copy range sender accounts for partial progress reported with syscall errors: aborted and truncated range streams release the source handle.
ROOT CAUSE
The sendfile-range-events-terminal-handle-close decision uses offset=x['offset'] remaining=x['remaining'] state='running' opened=True out=[] for accepted,error in x['events']: if state in ('complete','aborted','truncated'): out.append([offset,remaining,state,opened]) continue if accepted<0 or accepted>remaining: state='aborted' opened=False out.append([offset,remaining,state,opened]) continue offset+=accepted remaining-=accepted if error=='fatal': state='aborted' elif remaining==0: state='complete' elif error=='again': state='blocked' elif error=='interrupt': state='running' elif accepted==0: state='truncated' else: state='running' opened=state!='complete' out.append([offset,remaining,state,opened]) return out.
VERIFIED REPAIR
Apply the bounded decision exactly: offset=x['offset'] remaining=x['remaining'] state='running' opened=True out=[] for accepted,error in x['events']: if state in ('complete','aborted','truncated'): out.append([offset,remaining,state,opened]) continue if accepted<0 or accepted>remaining: state='aborted' opened=False out.append([offset,remaining,state,opened]) continue offset+=accepted remaining-=accepted if error=='fatal': state='aborted' elif remaining==0: state='complete' elif error=='again': state='blocked' elif error=='interrupt': state='running' elif accepted==0: state='truncated' else: state='running' opened=state not in ('complete','aborted','truncated') out.append([offset,remaining,state,opened]) return out
Unsuccessful approach: The partial repair uses offset=x['offset'] remaining=x['remaining'] state='running' opened=True out=[] for accepted,error in x['events']: if state in ('complete','aborted','truncated'): out.append([offset,remaining,state,opened]) continue if accepted<0 or accepted>remaining: state='aborted' opened=False out.append([offset,remaining,state,opened]) continue offset+=accepted remaining-=accepted if error=='fatal': state='aborted' elif remaining==0: state='complete' elif error=='again': state='blocked' elif error=='interrupt': state='running' elif accepted==0: state='truncated' else: state='running' opened=state not in ('complete','aborted') out.append([offset,remaining,state,opened]) return out, which still violates the stated contract.
Case contract
x contains absolute offset, remaining promised bytes, and syscall events [accepted,error], where error is none,again,interrupt,fatal. Counts outside0..remaining abort without advancing. Valid accepted bytes advance even when again or interrupt accompanies them. Fatal errors abort; zero remaining completes; again blocks; interrupt reschedules; zero bytes with none truncates. Terminal states ignore later events. Return state snapshots [offset,remaining,state,handle-open] after each event.
Why this case matters
Range responses combine representation identity, conditional requests, framing, and partial-object state.
1 / The failure
Exit 1"""Failure Map reference implementation. Python standard library only."""
import json
N = 1
observations = []
def solve(x):
offset=x['offset']
remaining=x['remaining']
state='running'
opened=True
out=[]
for accepted,error in x['events']:
if state in ('complete','aborted','truncated'):
out.append([offset,remaining,state,opened])
continue
if accepted<0 or accepted>remaining:
state='aborted'
opened=False
out.append([offset,remaining,state,opened])
continue
offset+=accepted
remaining-=accepted
if error=='fatal': state='aborted'
elif remaining==0: state='complete'
elif error=='again': state='blocked'
elif error=='interrupt': state='running'
elif accepted==0: state='truncated'
else: state='running'
opened=state!='complete'
out.append([offset,remaining,state,opened])
return out
def check(label, actual, expected):
observations.append({"check": label, "actual": actual, "expected": expected, "passed": actual == expected})
check('terminal-handle-close fixture 0', json.loads(json.dumps(solve({'offset':10,'remaining':5,'events':[[2,'interrupt'],[1,'again'],[2,'none']]}))), json.loads(json.dumps([[12,3,'running',True],[13,2,'blocked',True],[15,0,'complete',False]])))
check('terminal-handle-close fixture 1', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[0,'again'],[0,'interrupt'],[0,'none'],[1,'none']]}))), json.loads(json.dumps([[0,2,'blocked',True],[0,2,'running',True],[0,2,'truncated',False],[0,2,'truncated',False]])))
check('terminal-handle-close fixture 2', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[1,'fatal'],[1,'none']]}))), json.loads(json.dumps([[1,1,'aborted',False],[1,1,'aborted',False]])))
check('terminal-handle-close fixture 3', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[-1,'none']]}))), json.loads(json.dumps([[0,2,'aborted',False]])))
check('terminal-handle-close fixture 4', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[3,'none']]}))), json.loads(json.dumps([[0,2,'aborted',False]])))
check('terminal-handle-close fixture 5', json.loads(json.dumps(solve({'offset':N,'remaining':N,'events':[[N,'again'],[0,'fatal']]}))), json.loads(json.dumps([[2*N,0,'complete',False],[2*N,0,'complete',False]])))
check('terminal-handle-close fixture 6', json.loads(json.dumps(solve({'offset':0,'remaining':0,'events':[[0,'none']]}))), json.loads(json.dumps([[0,0,'complete',False]])))
check('terminal-handle-close fixture 7', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[2,'fatal']]}))), json.loads(json.dumps([[2,0,'aborted',False]])))
print(json.dumps({"observations": observations, "passed": all(x["passed"] for x in observations)}, ensure_ascii=False))
raise SystemExit(0 if all(x["passed"] for x in observations) else 1)
| Boundary fixture | Actual | Expected | Outcome |
|---|---|---|---|
| terminal-handle-close fixture 0 | [[12, 3, 'running', True], [13, 2, 'blocked', True], [15, 0, 'complete', False]] | [[12, 3, 'running', True], [13, 2, 'blocked', True], [15, 0, 'complete', False]] | Passed |
| terminal-handle-close fixture 1 | [[0, 2, 'blocked', True], [0, 2, 'running', True], [0, 2, 'truncated', True], [0, 2, 'truncated', True]] | [[0, 2, 'blocked', True], [0, 2, 'running', True], [0, 2, 'truncated', False], [0, 2, 'truncated', False]] | Failed |
| terminal-handle-close fixture 2 | [[1, 1, 'aborted', True], [1, 1, 'aborted', True]] | [[1, 1, 'aborted', False], [1, 1, 'aborted', False]] | Failed |
| terminal-handle-close fixture 3 | [[0, 2, 'aborted', False]] | [[0, 2, 'aborted', False]] | Passed |
| terminal-handle-close fixture 4 | [[0, 2, 'aborted', False]] | [[0, 2, 'aborted', False]] | Passed |
| terminal-handle-close fixture 5 | [[2, 0, 'complete', False], [2, 0, 'complete', False]] | [[2, 0, 'complete', False], [2, 0, 'complete', False]] | Passed |
| terminal-handle-close fixture 6 | [[0, 0, 'complete', False]] | [[0, 0, 'complete', False]] | Passed |
| terminal-handle-close fixture 7 | [[2, 0, 'aborted', True]] | [[2, 0, 'aborted', False]] | Failed |
SHA-256 / a90e555e91d577080e6f11c031f45dcf750d00ed8d6290002c7ed541efab8126
2 / The unsuccessful fix
Exit 1"""Failure Map reference implementation. Python standard library only."""
import json
N = 1
observations = []
def solve(x):
offset=x['offset']
remaining=x['remaining']
state='running'
opened=True
out=[]
for accepted,error in x['events']:
if state in ('complete','aborted','truncated'):
out.append([offset,remaining,state,opened])
continue
if accepted<0 or accepted>remaining:
state='aborted'
opened=False
out.append([offset,remaining,state,opened])
continue
offset+=accepted
remaining-=accepted
if error=='fatal': state='aborted'
elif remaining==0: state='complete'
elif error=='again': state='blocked'
elif error=='interrupt': state='running'
elif accepted==0: state='truncated'
else: state='running'
opened=state not in ('complete','aborted')
out.append([offset,remaining,state,opened])
return out
def check(label, actual, expected):
observations.append({"check": label, "actual": actual, "expected": expected, "passed": actual == expected})
check('terminal-handle-close fixture 0', json.loads(json.dumps(solve({'offset':10,'remaining':5,'events':[[2,'interrupt'],[1,'again'],[2,'none']]}))), json.loads(json.dumps([[12,3,'running',True],[13,2,'blocked',True],[15,0,'complete',False]])))
check('terminal-handle-close fixture 1', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[0,'again'],[0,'interrupt'],[0,'none'],[1,'none']]}))), json.loads(json.dumps([[0,2,'blocked',True],[0,2,'running',True],[0,2,'truncated',False],[0,2,'truncated',False]])))
check('terminal-handle-close fixture 2', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[1,'fatal'],[1,'none']]}))), json.loads(json.dumps([[1,1,'aborted',False],[1,1,'aborted',False]])))
check('terminal-handle-close fixture 3', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[-1,'none']]}))), json.loads(json.dumps([[0,2,'aborted',False]])))
check('terminal-handle-close fixture 4', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[3,'none']]}))), json.loads(json.dumps([[0,2,'aborted',False]])))
check('terminal-handle-close fixture 5', json.loads(json.dumps(solve({'offset':N,'remaining':N,'events':[[N,'again'],[0,'fatal']]}))), json.loads(json.dumps([[2*N,0,'complete',False],[2*N,0,'complete',False]])))
check('terminal-handle-close fixture 6', json.loads(json.dumps(solve({'offset':0,'remaining':0,'events':[[0,'none']]}))), json.loads(json.dumps([[0,0,'complete',False]])))
check('terminal-handle-close fixture 7', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[2,'fatal']]}))), json.loads(json.dumps([[2,0,'aborted',False]])))
print(json.dumps({"observations": observations, "passed": all(x["passed"] for x in observations)}, ensure_ascii=False))
raise SystemExit(0 if all(x["passed"] for x in observations) else 1)
| Boundary fixture | Actual | Expected | Outcome |
|---|---|---|---|
| terminal-handle-close fixture 0 | [[12, 3, 'running', True], [13, 2, 'blocked', True], [15, 0, 'complete', False]] | [[12, 3, 'running', True], [13, 2, 'blocked', True], [15, 0, 'complete', False]] | Passed |
| terminal-handle-close fixture 1 | [[0, 2, 'blocked', True], [0, 2, 'running', True], [0, 2, 'truncated', True], [0, 2, 'truncated', True]] | [[0, 2, 'blocked', True], [0, 2, 'running', True], [0, 2, 'truncated', False], [0, 2, 'truncated', False]] | Failed |
| terminal-handle-close fixture 2 | [[1, 1, 'aborted', False], [1, 1, 'aborted', False]] | [[1, 1, 'aborted', False], [1, 1, 'aborted', False]] | Passed |
| terminal-handle-close fixture 3 | [[0, 2, 'aborted', False]] | [[0, 2, 'aborted', False]] | Passed |
| terminal-handle-close fixture 4 | [[0, 2, 'aborted', False]] | [[0, 2, 'aborted', False]] | Passed |
| terminal-handle-close fixture 5 | [[2, 0, 'complete', False], [2, 0, 'complete', False]] | [[2, 0, 'complete', False], [2, 0, 'complete', False]] | Passed |
| terminal-handle-close fixture 6 | [[0, 0, 'complete', False]] | [[0, 0, 'complete', False]] | Passed |
| terminal-handle-close fixture 7 | [[2, 0, 'aborted', False]] | [[2, 0, 'aborted', False]] | Passed |
SHA-256 / 57f0de742d15415a442ce92d61716743172c239e51dcd75802f0744f7fb9e3f5
3 / The verified repair
Exit 0"""Failure Map reference implementation. Python standard library only."""
import json
N = 1
observations = []
def solve(x):
offset=x['offset']
remaining=x['remaining']
state='running'
opened=True
out=[]
for accepted,error in x['events']:
if state in ('complete','aborted','truncated'):
out.append([offset,remaining,state,opened])
continue
if accepted<0 or accepted>remaining:
state='aborted'
opened=False
out.append([offset,remaining,state,opened])
continue
offset+=accepted
remaining-=accepted
if error=='fatal': state='aborted'
elif remaining==0: state='complete'
elif error=='again': state='blocked'
elif error=='interrupt': state='running'
elif accepted==0: state='truncated'
else: state='running'
opened=state not in ('complete','aborted','truncated')
out.append([offset,remaining,state,opened])
return out
def check(label, actual, expected):
observations.append({"check": label, "actual": actual, "expected": expected, "passed": actual == expected})
check('terminal-handle-close fixture 0', json.loads(json.dumps(solve({'offset':10,'remaining':5,'events':[[2,'interrupt'],[1,'again'],[2,'none']]}))), json.loads(json.dumps([[12,3,'running',True],[13,2,'blocked',True],[15,0,'complete',False]])))
check('terminal-handle-close fixture 1', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[0,'again'],[0,'interrupt'],[0,'none'],[1,'none']]}))), json.loads(json.dumps([[0,2,'blocked',True],[0,2,'running',True],[0,2,'truncated',False],[0,2,'truncated',False]])))
check('terminal-handle-close fixture 2', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[1,'fatal'],[1,'none']]}))), json.loads(json.dumps([[1,1,'aborted',False],[1,1,'aborted',False]])))
check('terminal-handle-close fixture 3', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[-1,'none']]}))), json.loads(json.dumps([[0,2,'aborted',False]])))
check('terminal-handle-close fixture 4', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[3,'none']]}))), json.loads(json.dumps([[0,2,'aborted',False]])))
check('terminal-handle-close fixture 5', json.loads(json.dumps(solve({'offset':N,'remaining':N,'events':[[N,'again'],[0,'fatal']]}))), json.loads(json.dumps([[2*N,0,'complete',False],[2*N,0,'complete',False]])))
check('terminal-handle-close fixture 6', json.loads(json.dumps(solve({'offset':0,'remaining':0,'events':[[0,'none']]}))), json.loads(json.dumps([[0,0,'complete',False]])))
check('terminal-handle-close fixture 7', json.loads(json.dumps(solve({'offset':0,'remaining':2,'events':[[2,'fatal']]}))), json.loads(json.dumps([[2,0,'aborted',False]])))
print(json.dumps({"observations": observations, "passed": all(x["passed"] for x in observations)}, ensure_ascii=False))
raise SystemExit(0 if all(x["passed"] for x in observations) else 1)
| Boundary fixture | Actual | Expected | Outcome |
|---|---|---|---|
| terminal-handle-close fixture 0 | [[12, 3, 'running', True], [13, 2, 'blocked', True], [15, 0, 'complete', False]] | [[12, 3, 'running', True], [13, 2, 'blocked', True], [15, 0, 'complete', False]] | Passed |
| terminal-handle-close fixture 1 | [[0, 2, 'blocked', True], [0, 2, 'running', True], [0, 2, 'truncated', False], [0, 2, 'truncated', False]] | [[0, 2, 'blocked', True], [0, 2, 'running', True], [0, 2, 'truncated', False], [0, 2, 'truncated', False]] | Passed |
| terminal-handle-close fixture 2 | [[1, 1, 'aborted', False], [1, 1, 'aborted', False]] | [[1, 1, 'aborted', False], [1, 1, 'aborted', False]] | Passed |
| terminal-handle-close fixture 3 | [[0, 2, 'aborted', False]] | [[0, 2, 'aborted', False]] | Passed |
| terminal-handle-close fixture 4 | [[0, 2, 'aborted', False]] | [[0, 2, 'aborted', False]] | Passed |
| terminal-handle-close fixture 5 | [[2, 0, 'complete', False], [2, 0, 'complete', False]] | [[2, 0, 'complete', False], [2, 0, 'complete', False]] | Passed |
| terminal-handle-close fixture 6 | [[0, 0, 'complete', False]] | [[0, 0, 'complete', False]] | Passed |
| terminal-handle-close fixture 7 | [[2, 0, 'aborted', False]] | [[2, 0, 'aborted', False]] | Passed |
SHA-256 / dbe3edcad054c0bc22df079a4571a321d3edc6c92a768083e4b3ee0dc525fe01
Verification & scope
Deterministic simplified range service, with stipulated local policies and already parsed trusted inputs; not a complete HTTP implementation. This reproducer isolates one failure mechanism. Results cover the supplied fixtures. Variants within a family share a test contract and should remain grouped when constructing evaluation splits. Related mechanisms with a shared evaluation_group must also remain together; these controlled models are not independent production incidents.
Observations recorded using Python 3.12.14 at 2026-09-29T14:41:25.881469+00:00.
Case digest / 1b3c73d0a796b7f12ebadf141f26895dd2e64d206943aa08d0d53041268eaafa