steve
/
factor
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix IO timeouts

db4
Slava Pestov 2008-02-02 00:30:47 -06:00
parent a114819088
commit 4d24978507
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
extra/io/unix/backend/backend.factor
View File

@ -104,8 +104,21 @@ M: integer close-handle ( fd -- )
: handle-io-task ( mx task -- ) : handle-io-task ( mx task -- )
dup do-io-task [ pop-callbacks ] [ 2drop ] if ; dup do-io-task [ pop-callbacks ] [ 2drop ] if ;
: handle-timeout ( mx task -- ) : handle-timeout ( port mx assoc -- )
"Timeout" over io-task-port report-error pop-callbacks ; >r swap port-handle r> delete-at* [
"I/O operation cancelled" over io-task-port report-error
pop-callbacks
] [
2drop
] if ;
: cancel-io-tasks ( port mx -- )
2dup
dup mx-reads handle-timeout
dup mx-writes handle-timeout ;
M: unix-io cancel-io ( port -- )
mx get-global cancel-io-tasks ;
! Readers ! Readers
: reader-eof ( reader -- ) : reader-eof ( reader -- )
@ -165,7 +178,7 @@ M: port port-flush ( port -- )
dup buffer-empty? [ drop ] [ (wait-to-write) ] if ; dup buffer-empty? [ drop ] [ (wait-to-write) ] if ;
M: unix-io io-multiplex ( ms -- ) M: unix-io io-multiplex ( ms -- )
mx get-global wait-for-events ; expire-timeouts mx get-global wait-for-events ;
M: unix-io init-stdio ( -- ) M: unix-io init-stdio ( -- )
0 1 handle>duplex-stream io:stdio set-global 0 1 handle>duplex-stream io:stdio set-global