chore: rename revoke_buffer to reclaim_buffer

This commit renames `revoke_buffer` which is used during stream
copying to `reclaim_buffer` which hopefully better conveys (if only
slightly) the handoff/change in ownership of the buffer in use.

Signed-off-by: Victor Adossi <vadossi@cosmonic.com>

Author: vados-cosmonic

design/mvp/CanonicalABI.md

@@ -3880,7 +3880,7 @@ Next, the `copy` method of `{Readable,Writable}{Stream,Future}End` is called to
 perform the actual read/write. The `on_copy*` callbacks passed to `copy` bind
 and store a `stream_event` closure on the readable/writable end (via the
 inherited `Waitable.set_event`) which will be called right before the event is
-delivered to core wasm. `stream_event` first calls `revoke_buffer` to regain
+delivered to core wasm. `stream_event` first calls `reclaim_buffer` to regain
 ownership of `buffer` and prevent any further partial reads/writes. Thus, up
 until event delivery, the other end of the stream is free to repeatedly
 read/write from/to `buffer`, ideally filling it up and minimizing context
@@ -3890,8 +3890,8 @@ all future use of this stream end. Lastly, `stream_event` packs the
 `CopyResult` and number of elements copied up until this point into a single
 `i32` payload for core wasm.
 ```python
-  def stream_event(result, revoke_buffer):
-    revoke_buffer()
+  def stream_event(result, reclaim_buffer):
+    reclaim_buffer()
     assert(e.copying)
     e.copying = False
     if result == CopyResult.DROPPED:
@@ -3902,11 +3902,11 @@ all future use of this stream end. Lastly, `stream_event` packs the
     return (event_code, i, packed_result)
     return (event_code, i, pack_stream_result(result, buffer))
 
-  def on_copy(revoke_buffer):
-    e.set_event(partial(stream_event, CopyResult.COMPLETED, revoke_buffer))
+  def on_copy(reclaim_buffer):
+    e.set_event(partial(stream_event, CopyResult.COMPLETED, reclaim_buffer))
 
   def on_copy_done(result):
-    e.set_event(partial(stream_event, result, revoke_buffer = lambda:()))
+    e.set_event(partial(stream_event, result, reclaim_buffer = lambda:()))
 
   e.copying = True
   e.copy(task.inst, buffer, on_copy, on_copy_done)

design/mvp/canonical-abi/definitions.py

@@ -2259,8 +2259,8 @@ async def stream_copy(EndT, BufferT, event_code, stream_t, opts, task, i, ptr, n
   cx = LiftLowerContext(opts, task.inst, borrow_scope = None)
   buffer = BufferT(stream_t.t, cx, ptr, n)
 
-  def stream_event(result, revoke_buffer):
-    revoke_buffer()
+  def stream_event(result, reclaim_buffer):
+    reclaim_buffer()
     assert(e.copying)
     e.copying = False
     if result == CopyResult.DROPPED:
@@ -2271,11 +2271,11 @@ def stream_event(result, revoke_buffer):
     return (event_code, i, packed_result)
     return (event_code, i, pack_stream_result(result, buffer))
 
-  def on_copy(revoke_buffer):
-    e.set_event(partial(stream_event, CopyResult.COMPLETED, revoke_buffer))
+  def on_copy(reclaim_buffer):
+    e.set_event(partial(stream_event, CopyResult.COMPLETED, reclaim_buffer))
 
   def on_copy_done(result):
-    e.set_event(partial(stream_event, result, revoke_buffer = lambda:()))
+    e.set_event(partial(stream_event, result, reclaim_buffer = lambda:()))
 
   e.copying = True
   e.copy(task.inst, buffer, on_copy, on_copy_done)

design/mvp/canonical-abi/run_tests.py

@@ -1088,8 +1088,8 @@ def __init__(self, shared, chunk, remain = 2**64):
     async def read_all():
       while True:
         await self.write_event.wait()
-        def on_copy(revoke_buffer):
-          revoke_buffer()
+        def on_copy(reclaim_buffer):
+          reclaim_buffer()
           if not f.done():
             f.set_result(None)
         def on_copy_done(result):