akkartik
/
mu
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

270

This commit is contained in:
Kartik K. Agaram 2014-11-18 04:39:24 -08:00
parent 4c97ba914e
commit 67feef8318
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
mu.arc
View File

@ -876,6 +876,13 @@
((channel-buffer-address tagged-value-array-address-address deref) <- new (tagged-value-array literal) (capacity integer))
(reply (result channel-address)))
(init-fn capacity
((default-scope scope-address) <- new (scope literal) (30 literal))
((chan channel) <- arg)
((q tagged-value-array-address) <- get (chan channel) (circular-buffer offset))
((qlen integer) <- len (q tagged-value-array-address deref))
(reply (qlen integer)))
(init-fn write
((default-scope scope-address) <- new (scope literal) (30 literal))
((chan channel) <- arg)
@ -949,11 +956,10 @@
((chan channel) <- arg)
; curr = chan.first-free + 1
((curr integer) <- get (chan channel) (first-free offset))
((q tagged-value-array-address) <- get (chan channel) (circular-buffer offset))
((qlen integer) <- len (q tagged-value-array-address deref))
((curr integer) <- add (curr integer) (1 literal))
{ begin
; if (curr == chan.capacity) curr = 0
((qlen integer) <- capacity (chan channel))
((remaining? boolean) <- lt (curr integer) (qlen integer))
(break-if (remaining? boolean))
((curr integer) <- copy (0 literal))