24 lines
924 B
Forth
24 lines
924 B
Forth
( Byte Stream / Ring Buffer )
|
|
|
|
: stream ( n "name" ) create 1+ dup , 0 , 0 , allot align ;
|
|
: >write ( st -- wr ) cell+ ; : >read ( st -- rd ) 2 cells + ;
|
|
: >offset ( n st -- a ) 3 cells + + ;
|
|
: stream# ( sz -- n ) >r r@ >write @ r@ >read @ - r> @ mod ;
|
|
: full? ( st -- f ) dup stream# swap @ 1- = ;
|
|
: empty? ( st -- f ) stream# 0= ;
|
|
: wait-write ( st -- ) begin dup full? while pause repeat drop ;
|
|
: wait-read ( st -- ) begin dup empty? while pause repeat drop ;
|
|
: ch>stream ( ch st -- )
|
|
dup wait-write
|
|
>r r@ >write @ r@ >offset c!
|
|
r@ >write @ 1+ r@ @ mod r> >write ! ;
|
|
: stream>ch ( st -- ch )
|
|
dup wait-read
|
|
>r r@ >read @ r@ >offset c@
|
|
r@ >read @ 1+ r@ @ mod r> >read ! ;
|
|
: >stream ( a n st -- )
|
|
swap 0 do over c@ over ch>stream swap 1+ swap loop 2drop ;
|
|
: stream> ( a n st -- )
|
|
begin over 1 > over empty? 0= and while
|
|
dup stream>ch >r rot dup r> swap c! 1+ rot 1- rot repeat 2drop 0 swap c! ;
|