-(define (agenda-handle-port-request! agenda port-request)
- "Update an agenda for a port-request"
- (define (handle-selector request-selector port-map-selector)
- (if (request-selector port-request)
- ;; @@: Should we remove if #f?
- (hash-set! (port-map-selector agenda)
- (port-request-port port-request)
- (request-selector port-request))))
- (handle-selector port-request-read agenda-read-port-map)
- (handle-selector port-request-write agenda-write-port-map)
- (handle-selector port-request-except agenda-except-port-map))
-
-
-(define (agenda-handle-port-remove-request! agenda port-remove-request)
- "Update an agenda for a port-remove-request"
- (let ((port (port-remove-request-port port-remove-request)))
- (hash-remove! (agenda-read-port-map agenda) port)
- (hash-remove! (agenda-write-port-map agenda) port)
- (hash-remove! (agenda-except-port-map agenda) port)))
-
+(define-record-type <read-request>
+ (make-read-request port proc)
+ read-request?
+ (port read-request-port)
+ (proc read-request-proc))
+
+(define-record-type <write-request>
+ (make-write-request port proc)
+ write-request?
+ (port write-request-port)
+ (proc write-request-proc))
+
+(define (agenda-handle-read-request! agenda read-request)
+ "Handle <read-request>, which is a request to add this port to the poll/select
+on suspendable ports."
+ (hashq-set! (agenda-read-port-map agenda)
+ (read-request-port read-request)
+ (read-request-proc read-request)))
+
+(define (agenda-handle-write-request! agenda write-request)
+ (hashq-set! (agenda-write-port-map agenda)
+ (write-request-port write-request)
+ (write-request-proc write-request)))