Skip to content

Commit e03923c

Browse files
committed
Tidy CABI: renaming 'results' to 'result' when it's 0-or-1
1 parent 65e53e0 commit e03923c

File tree

2 files changed

+43
-43
lines changed

2 files changed

+43
-43
lines changed

design/mvp/CanonicalABI.md

Lines changed: 22 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -973,11 +973,11 @@ dropped all borrowed handles by the time `task.return` is called which means
973973
that the caller can assume that all its lent handles have been returned to it
974974
when it receives the `SUBTASK` `RETURNED` event.
975975
```python
976-
def return_(self, results):
976+
def return_(self, result):
977977
trap_if(self.state == Task.State.RESOLVED)
978978
trap_if(self.num_borrows > 0)
979-
assert(results is not None)
980-
self.on_resolve(results)
979+
assert(result is not None)
980+
self.on_resolve(result)
981981
self.state = Task.State.RESOLVED
982982
```
983983

@@ -1061,11 +1061,11 @@ transitions:
10611061
self.state = Subtask.State.STARTED
10621062
return on_start()
10631063

1064-
def sync_on_resolve(results):
1065-
assert(results is not None)
1064+
def sync_on_resolve(result):
1065+
assert(result is not None)
10661066
assert(self.state == Subtask.State.STARTED)
10671067
self.state = Subtask.State.RETURNED
1068-
on_resolve(results)
1068+
on_resolve(result)
10691069

10701070
await Task.call_sync(self.supertask, callee, sync_on_start, sync_on_resolve)
10711071
```
@@ -1114,8 +1114,8 @@ cancellation:
11141114
self.state = Subtask.State.STARTED
11151115
return on_start()
11161116

1117-
def async_on_resolve(results):
1118-
if results is None:
1117+
def async_on_resolve(result):
1118+
if result is None:
11191119
if self.state == Subtask.State.STARTING:
11201120
self.state = Subtask.State.CANCELLED_BEFORE_STARTED
11211121
else:
@@ -1124,7 +1124,7 @@ cancellation:
11241124
else:
11251125
assert(self.state == Subtask.State.STARTED)
11261126
self.state = Subtask.State.RETURNED
1127-
on_resolve(results)
1127+
on_resolve(result)
11281128

11291129
async def async_on_block(awaitable):
11301130
relinquish_control()
@@ -1690,7 +1690,7 @@ def contains(t, p):
16901690
case VariantType(cases):
16911691
return p(t) or any(contains(c.t, p) for c in cases)
16921692
case FuncType():
1693-
return any(p(u) for u in t.param_types() + t.result_types())
1693+
return any(p(u) for u in t.param_types() + t.result_type())
16941694
case _:
16951695
assert(False)
16961696
```
@@ -2595,7 +2595,7 @@ MAX_FLAT_RESULTS = 1
25952595

25962596
def flatten_functype(opts, ft, context):
25972597
flat_params = flatten_types(ft.param_types())
2598-
flat_results = flatten_types(ft.result_types())
2598+
flat_results = flatten_types(ft.result_type())
25992599
if opts.sync:
26002600
if len(flat_params) > MAX_FLAT_PARAMS:
26012601
flat_params = ['i32']
@@ -3067,7 +3067,7 @@ validation is performed:
30673067
* requires options based on [`lift(param)`](#canonopt-validation) for all parameters in `ft`
30683068
* requires options based on [`lower(result)`](#canonopt-validation) if `ft` has a result
30693069
* if `len(flatten_types(ft.param_types())) > MAX_FLAT_PARAMS`, `realloc` is required
3070-
* if `len(flatten_types(ft.result_types())) > MAX_FLAT_RESULTS`, `memory` is required
3070+
* if `len(flatten_types(ft.result_type())) > MAX_FLAT_RESULTS`, `memory` is required
30713071

30723072
When instantiating component instance `$inst`:
30733073
* Define `$f` to be the partially-bound closure `canon_lift($opts, $inst, $ft, $callee)`
@@ -3114,8 +3114,8 @@ with compound return values.
31143114
if opts.sync:
31153115
flat_results = await call_and_trap_on_throw(callee, task, flat_args)
31163116
assert(types_match_values(flat_ft.results, flat_results))
3117-
results = lift_flat_values(cx, MAX_FLAT_RESULTS, CoreValueIter(flat_results), ft.result_types())
3118-
task.return_(results)
3117+
result = lift_flat_values(cx, MAX_FLAT_RESULTS, CoreValueIter(flat_results), ft.result_type())
3118+
task.return_(result)
31193119
if opts.post_return is not None:
31203120
task.inst.may_leave = False
31213121
[] = await call_and_trap_on_throw(opts.post_return, task, flat_results)
@@ -3218,7 +3218,7 @@ validation is performed where `$callee` has type `$ft`:
32183218
* requires options [based on `lower(param)`](#canonopt-validation) for all parameters in `ft`
32193219
* requires options [based on `lift(result)`](#canonopt-validation) if `ft` has a result
32203220
* if `len(flatten_types(ft.param_types())) > max_flat_params`, `memory` is required
3221-
* if `len(flatten_types(ft.result_types())) > max_flat_results`, `realloc` is required
3221+
* if `len(flatten_types(ft.result_type())) > max_flat_results`, `realloc` is required
32223222
* 🔀 if `async` is specified, `memory` must be present
32233223

32243224
When instantiating component instance `$inst`:
@@ -3252,9 +3252,9 @@ In the synchronous case, `Subtask.call_sync` ensures a fully-synchronous call to
32523252
return lift_flat_values(cx, MAX_FLAT_PARAMS, flat_args, ft.param_types())
32533253

32543254
flat_results = None
3255-
def on_resolve(results):
3255+
def on_resolve(result):
32563256
nonlocal flat_results
3257-
flat_results = lower_flat_values(cx, MAX_FLAT_RESULTS, results, ft.result_types(), flat_args)
3257+
flat_results = lower_flat_values(cx, MAX_FLAT_RESULTS, result, ft.result_type(), flat_args)
32583258

32593259
await subtask.call_sync(callee, on_start, on_resolve)
32603260
assert(types_match_values(flat_ft.results, flat_results))
@@ -3269,10 +3269,10 @@ always returns control flow back to the caller without blocking:
32693269
on_progress()
32703270
return lift_flat_values(cx, MAX_FLAT_ASYNC_PARAMS, flat_args, ft.param_types())
32713271

3272-
def on_resolve(results):
3272+
def on_resolve(result):
32733273
on_progress()
3274-
if results is not None:
3275-
[] = lower_flat_values(cx, 0, results, ft.result_types(), flat_args)
3274+
if result is not None:
3275+
[] = lower_flat_values(cx, 0, result, ft.result_type(), flat_args)
32763276

32773277
subtaski = None
32783278
def on_progress():
@@ -3494,8 +3494,8 @@ async def canon_task_return(task, result_type, opts: LiftOptions, flat_args):
34943494
trap_if(result_type != task.ft.results)
34953495
trap_if(not LiftOptions.equal(opts, task.opts))
34963496
cx = LiftLowerContext(opts, task.inst, task)
3497-
results = lift_flat_values(cx, MAX_FLAT_PARAMS, CoreValueIter(flat_args), task.ft.result_types())
3498-
task.return_(results)
3497+
result = lift_flat_values(cx, MAX_FLAT_PARAMS, CoreValueIter(flat_args), task.ft.result_type())
3498+
task.return_(result)
34993499
return []
35003500
```
35013501
The `trap_if(task.opts.sync)` prevents `task.return` from being called by

design/mvp/canonical-abi/definitions.py

Lines changed: 21 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ class FuncType(ExternType):
8888
results: list[ValType|tuple[str,ValType]]
8989
def param_types(self):
9090
return self.extract_types(self.params)
91-
def result_types(self):
91+
def result_type(self):
9292
return self.extract_types(self.results)
9393
def extract_types(self, vec):
9494
if len(vec) == 0:
@@ -606,11 +606,11 @@ async def poll_for_event(self, waitable_set, sync) -> Optional[EventTuple]:
606606
else:
607607
return (EventCode.NONE, 0, 0)
608608

609-
def return_(self, results):
609+
def return_(self, result):
610610
trap_if(self.state == Task.State.RESOLVED)
611611
trap_if(self.num_borrows > 0)
612-
assert(results is not None)
613-
self.on_resolve(results)
612+
assert(result is not None)
613+
self.on_resolve(result)
614614
self.state = Task.State.RESOLVED
615615

616616
def cancel(self):
@@ -658,11 +658,11 @@ def sync_on_start():
658658
self.state = Subtask.State.STARTED
659659
return on_start()
660660

661-
def sync_on_resolve(results):
662-
assert(results is not None)
661+
def sync_on_resolve(result):
662+
assert(result is not None)
663663
assert(self.state == Subtask.State.STARTED)
664664
self.state = Subtask.State.RETURNED
665-
on_resolve(results)
665+
on_resolve(result)
666666

667667
await Task.call_sync(self.supertask, callee, sync_on_start, sync_on_resolve)
668668

@@ -694,8 +694,8 @@ def async_on_start():
694694
self.state = Subtask.State.STARTED
695695
return on_start()
696696

697-
def async_on_resolve(results):
698-
if results is None:
697+
def async_on_resolve(result):
698+
if result is None:
699699
if self.state == Subtask.State.STARTING:
700700
self.state = Subtask.State.CANCELLED_BEFORE_STARTED
701701
else:
@@ -704,7 +704,7 @@ def async_on_resolve(results):
704704
else:
705705
assert(self.state == Subtask.State.STARTED)
706706
self.state = Subtask.State.RETURNED
707-
on_resolve(results)
707+
on_resolve(result)
708708

709709
async def async_on_block(awaitable):
710710
relinquish_control()
@@ -1003,7 +1003,7 @@ def contains(t, p):
10031003
case VariantType(cases):
10041004
return p(t) or any(contains(c.t, p) for c in cases)
10051005
case FuncType():
1006-
return any(p(u) for u in t.param_types() + t.result_types())
1006+
return any(p(u) for u in t.param_types() + t.result_type())
10071007
case _:
10081008
assert(False)
10091009

@@ -1619,7 +1619,7 @@ def lower_future(cx, v, t):
16191619

16201620
def flatten_functype(opts, ft, context):
16211621
flat_params = flatten_types(ft.param_types())
1622-
flat_results = flatten_types(ft.result_types())
1622+
flat_results = flatten_types(ft.result_type())
16231623
if opts.sync:
16241624
if len(flat_params) > MAX_FLAT_PARAMS:
16251625
flat_params = ['i32']
@@ -1940,8 +1940,8 @@ async def canon_lift(opts, inst, ft, callee, caller, on_start, on_resolve, on_bl
19401940
if opts.sync:
19411941
flat_results = await call_and_trap_on_throw(callee, task, flat_args)
19421942
assert(types_match_values(flat_ft.results, flat_results))
1943-
results = lift_flat_values(cx, MAX_FLAT_RESULTS, CoreValueIter(flat_results), ft.result_types())
1944-
task.return_(results)
1943+
result = lift_flat_values(cx, MAX_FLAT_RESULTS, CoreValueIter(flat_results), ft.result_type())
1944+
task.return_(result)
19451945
if opts.post_return is not None:
19461946
task.inst.may_leave = False
19471947
[] = await call_and_trap_on_throw(opts.post_return, task, flat_results)
@@ -2011,9 +2011,9 @@ def on_start():
20112011
return lift_flat_values(cx, MAX_FLAT_PARAMS, flat_args, ft.param_types())
20122012

20132013
flat_results = None
2014-
def on_resolve(results):
2014+
def on_resolve(result):
20152015
nonlocal flat_results
2016-
flat_results = lower_flat_values(cx, MAX_FLAT_RESULTS, results, ft.result_types(), flat_args)
2016+
flat_results = lower_flat_values(cx, MAX_FLAT_RESULTS, result, ft.result_type(), flat_args)
20172017

20182018
await subtask.call_sync(callee, on_start, on_resolve)
20192019
assert(types_match_values(flat_ft.results, flat_results))
@@ -2024,10 +2024,10 @@ def on_start():
20242024
on_progress()
20252025
return lift_flat_values(cx, MAX_FLAT_ASYNC_PARAMS, flat_args, ft.param_types())
20262026

2027-
def on_resolve(results):
2027+
def on_resolve(result):
20282028
on_progress()
2029-
if results is not None:
2030-
[] = lower_flat_values(cx, 0, results, ft.result_types(), flat_args)
2029+
if result is not None:
2030+
[] = lower_flat_values(cx, 0, result, ft.result_type(), flat_args)
20312031

20322032
subtaski = None
20332033
def on_progress():
@@ -2122,8 +2122,8 @@ async def canon_task_return(task, result_type, opts: LiftOptions, flat_args):
21222122
trap_if(result_type != task.ft.results)
21232123
trap_if(not LiftOptions.equal(opts, task.opts))
21242124
cx = LiftLowerContext(opts, task.inst, task)
2125-
results = lift_flat_values(cx, MAX_FLAT_PARAMS, CoreValueIter(flat_args), task.ft.result_types())
2126-
task.return_(results)
2125+
result = lift_flat_values(cx, MAX_FLAT_PARAMS, CoreValueIter(flat_args), task.ft.result_type())
2126+
task.return_(result)
21272127
return []
21282128

21292129
### 🔀 `canon task.cancel`

0 commit comments

Comments
 (0)