X-Git-Url: https://git.jsancho.org/?a=blobdiff_plain;f=src%2Fgacela_server.scm;h=8c45b20ecdb684f95f3e18fd3e0994ff16329154;hb=ca3edcecf937f854c1b5d9eeac566d85dc749cd0;hp=aae6c042f2264ff268090c05d87bb7d74eff50fe;hpb=586ba6fbd6643e4c08748f94528eccbad9108040;p=gacela.git diff --git a/src/gacela_server.scm b/src/gacela_server.scm index aae6c04..8c45b20 100644 --- a/src/gacela_server.scm +++ b/src/gacela_server.scm @@ -57,25 +57,10 @@ (set! eval-from-clients (lambda () + (cond (server-pipes + (eval-from-client (car server-pipes) (cdr server-pipes)))) (for-each - (lambda (cli) - (let ((sock (car cli))) - (cond ((char-ready? sock) - (catch #t - (lambda () - (let ((exp (read sock))) - (format #t "~a~%" exp) - (cond ((eof-object? exp) - (close sock)) - (else - (format #t "~a~%" (primitive-eval (car exp))) - (format sock "~a" (primitive-eval (car exp))))))) - (lambda (key . args) - (let ((fmt (string-concatenate (list (cadr args) "~%"))) - (params (caddr args))) - (if params - (apply format (cons sock (cons fmt params))) - (format sock fmt))))))))) + (lambda (cli) (eval-from-client (car cli) (car cli))) clients))) (set! stop-server @@ -85,3 +70,27 @@ (set! server-socket #f))) (for-each (lambda (cli) (close (car cli))) clients) (set! clients '())))) + +(define (eval-from-client rec-channel send-channel) + (cond ((char-ready? rec-channel) + (catch #t + (lambda () + (let ((exp (read rec-channel))) + (cond ((eof-object? exp) + (close rec-channel)) + (else + (let ((result (eval-string exp))) + (write (if (eq? result *unspecified*) "" (format #f "~a" result)) send-channel)))))) + (lambda (key . args) + (let ((fmt (string-concatenate (list (cadr args) "~%"))) + (params (caddr args))) + (write + (if params + (apply format (cons #f (cons fmt params))) + (format #f fmt)) + send-channel)))) + (force-output send-channel)))) + + +(define (connect-to-server client-socket hostname port) + (connect client-socket AF_INET (car (hostent:addr-list (gethost hostname))) port))