Overview
| Comment: | Minor edits to req-rep.scm nanomsg example to make it more readable. |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | v1.65 |
| Files: | files | file ages | folders |
| SHA1: |
a6afe6e1d7adba44262416bd4931e54f |
| User & Date: | mrwellan on 2017-07-07 14:26:36 |
| Other Links: | branch diff | manifest | tags |
Context
|
2017-07-09
| ||
| 18:00 | Merged in changes from v1.64 check-in: 5148b5915f user: matt tags: v1.65 | |
|
2017-07-07
| ||
| 14:26 | Minor edits to req-rep.scm nanomsg example to make it more readable. check-in: a6afe6e1d7 user: mrwellan tags: v1.65 | |
|
2017-07-06
| ||
| 16:35 | Merged recent changes to v1.64 into v1.65 check-in: fc84397e48 user: mrwellan tags: v1.65 | |
Changes
Modified testnanomsg/req-rep.scm from [d17a548c7a] to [4b0d8cd65b].
1 2 3 4 | ;; watch nanomsg's pipeline load-balancer in action. (use nanomsg) (define req (nn-socket 'req)) | > < < < | > > > > > | | | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 |
;; watch nanomsg's pipeline load-balancer in action.
(use nanomsg)
;; client
(define req (nn-socket 'req))
(nn-connect req "inproc://test")
(define (client-send-receive soc msg)
(nn-send soc msg)
(nn-recv soc))
;; server
(define rep (nn-socket 'rep))
(nn-bind rep "inproc://test")
(define ((server soc))
(let loop ((msg-in (nn-recv soc)))
(if (not (equal? msg-in "quit"))
(begin
(nn-send soc (conc "hello " msg-in))
(loop (nn-recv soc))))))
(thread-start! (server rep))
;; client
(print (client-send-receive req "Matt"))
(print (client-send-receive req "Tom"))
;; (client-send-receive req "quit")
(nn-close req) ;; client
(nn-close rep) ;; server
(exit)
|