Overview
| Comment: | Got crude nng transport implementation working/ |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | v1.6584-nanomsg |
| Files: | files | file ages | folders |
| SHA1: |
96b5fc4451eb271c0e3b16850a6f54e0 |
| User & Date: | matt on 2021-10-21 16:19:42 |
| Other Links: | branch diff | manifest | tags |
Context
|
2021-11-02
| ||
| 20:21 | Code for server etc. converted to nng but not tested check-in: 9d2d6a97d7 user: matt tags: v1.6584-nanomsg | |
|
2021-10-27
| ||
| 05:22 | Cleaned up the example nng app check-in: 056cbbf3bc user: matt tags: v1.6584-nanomsg | |
|
2021-10-21
| ||
| 16:19 | Got crude nng transport implementation working/ check-in: 96b5fc4451 user: matt tags: v1.6584-nanomsg | |
| 15:08 | yada check-in: 3b6efca64a user: matt tags: v1.6584-nanomsg | |
Changes
Modified nng-trial/nng-test.scm from [3d0cf92ae9] to [1f5de0e9fe].
1 2 3 4 5 6 7 8 9 |
(import (chicken io)
(chicken string)
(chicken process-context)
(chicken process-context posix)
miscmacros
nng
srfi-18
test
matchable
| > > > | > > > | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 |
(import (chicken io)
(chicken file)
(chicken file posix)
(chicken string)
(chicken process-context)
(chicken process-context posix)
miscmacros
nng
srfi-18
srfi-69
test
matchable
typed-records
system-information
directory-utils
)
(define help "Usage: nng-test COMMAND
where COMMAND is one of:
dotest : run the basic req/rep test
")
(define address-tcp-1 "tcp://localhost:5555")
|
| ︙ | ︙ | |||
51 52 53 54 55 56 57 |
"message"
(req-rep-test address-tcp-1))
(test "inproc req-rep"
"message"
(req-rep-test address-inproc-1)))
(test-exit))
| < < < < < < | < < < < < < < < | | | > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > | < > | > > | > > > > > > | > > > > > > > > > > > > > > > > | 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 |
"message"
(req-rep-test address-tcp-1))
(test "inproc req-rep"
"message"
(req-rep-test address-inproc-1)))
(test-exit))
;; talking to self here...
;;
(define (send-n-messages n srvdat)
(let* ((name (srv-name srvdat)))
(let loop ((i 0))
(if (< i n)
(begin
(nng-send (srv-req srvdat) (conc name "-" i))
(print "received: "(nng-recv (srv-rep srvdat)))
(loop (+ i 1)))))))
;; this should be run in a thread
(define (run-listener-responder socket myaddr)
(let loop ((status 'running))
(let* ((msg (nng-recv socket))
(response (process-message msg)))
(if (not (eq? response 'done))
(begin
(nng-send socket response)
(loop status))))))
(define *channels* (make-hash-table))
(define (call channels msg addr)
(let* ((csocket (hash-table-ref/default channels addr #f))
(socket (or csocket (make-dialed-request-socket addr))))
(nng-send socket msg)
(print "Sent: "msg", received: "(nng-recv socket))
(if (not (hash-table-exists? channels addr))
(hash-table-set! channels addr socket))))
;; start => hello 0
;; hello 0 => hello 1
;; hello 1 => hello 2
;; ...
;; hello 11 => 'done
;;
(define (process-message mesg)
(let ((parts (string-split mesg)))
(match
parts
((msg c)
(let ((count (string->number c)))
(if (> count 10)
'done
(conc msg " " (if count count 0)))))
((msg)
(conc msg " 0"))
(else
"hello 0"))))
(define (close-srv srvdat)
(nng-close! (srv-rep srvdat)))
(match
(command-line-arguments)
(("do-test")(do-test))
((run myaddr)
;; start listener
;; put myaddr into file by host-pid in .runners
;; for 1 minute
;; get all in .runners
;; call each with a message
;;
(let* ((socket (make-listening-reply-socket myaddr))
(rfile (conc ".runners/"(get-host-name)"-"(current-process-id)))
(th1 (make-thread (lambda ()
(run-listener-responder socket myaddr)
(delete-file* rfile)
(exit))
"responder")))
(if (not (and (file-exists? ".runners")
(directory? ".runners")))
(create-directory ".runners" #t))
(with-output-to-file rfile
(lambda ()
(print myaddr)))
(thread-start! th1)
(let loop ((entries '()))
(if (null? entries)
(loop (glob ".runners/*"))
(let* ((entry (car entries))
(destaddr (with-input-from-file entry read-line)))
(call *channels* (conc "hello-from-"destaddr) destaddr)
(thread-sleep! 0.25)
(loop (cdr entries)))))))
((cmd)(print "ERROR: command "cmd", not recognised.\n\n"help))
(else
(print help)))
|