44 lines
988 B
Racket
44 lines
988 B
Racket
#lang racket
|
|
|
|
;; from transport.scm ;;;;;;;
|
|
|
|
(require rnrs
|
|
"bytevector.rkt"
|
|
"sosc.rkt"
|
|
"ip.rkt")
|
|
|
|
(provide (all-defined-out)
|
|
(all-from-out "ip.rkt"))
|
|
|
|
|
|
|
|
;; socket -> osc -> ()
|
|
(define send
|
|
(lambda (fd m)
|
|
(let ((b (encode-osc m)))
|
|
(cond ((udp:socket? fd)
|
|
(udp:send fd b))
|
|
((tcp:socket? fd)
|
|
(tcp:send fd (encode-u32 (bytevector-length b)))
|
|
(tcp:send fd b))))))
|
|
|
|
;; port -> maybe osc
|
|
(define recv
|
|
(lambda (fd)
|
|
(cond ((udp:socket? fd)
|
|
(let ((b (udp:recv fd)))
|
|
(and b (decode-osc b))))
|
|
((tcp:socket? fd)
|
|
(let* ((b (tcp:read fd 4))
|
|
(n (decode-u32 b)))
|
|
(decode-osc (tcp:read fd n)))))))
|
|
|
|
;; port -> string -> osc
|
|
(define wait
|
|
(lambda (fd s)
|
|
(let ((p (recv fd)))
|
|
(cond
|
|
((not p) (error "wait" "timed out"))
|
|
((not (string=? (car p) s)) (error "wait" "bad return packet" p s))
|
|
(else p)))))
|
|
|