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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
#!/usr/bin/env newlisp
(println)
(println "Testing UDP communicatiobs with spawned processes")
; benchmark net work functions with spawned processes
; non-blocking simole UDP communications
(set 'N
(case ostype
("Linux" 1000)
("Cygwin" 1000)
("BSD" 1000)
("OSX" 10000)
("Tru64Unix" 1000)
("Solaris" 1000)
("SunOS" 1000)
(true (println ">>>>> UDP Not supported on this OS - will exit")
(exit))
)
)
(set 'cpid (spawn 'r
(begin
(sleep 300)
(for (i 1 N)
(sleep 0.2) ; increase if losing to much
(net-send-udp "localhost" 12345 (string i))
)
(exit)
)
))
(println (sync))
(set 'start (time-of-day))
(set 'counter 0)
(set 'timeout '2000000)
(until finished
(set 'buff (net-receive-udp 12345 100 timeout))
(if buff
(begin
(inc counter)
(print "-> " (first buff) "\r")
(if (= (int (first buff)) N) (set 'finished true)))
(begin
(println "finished ->" (net-error))
(if (= (first (net-error)) 17)
(inc start (/ timeout 1000))) ; account for timeout
(set 'finished true))
)
)
(set 'duration (- (time-of-day) start))
(println "received " counter " (" (mul (div counter N) 100)
"%) of " N " messages in " duration " ms")
(println (div duration counter) " ms per message")
(abort)
(println ">>>>> Benchmarked UDP API")
(exit)
|
