mu - Soul of a tiny new machine. More thorough tests → More comprehensible and rewrite-friendly software → More resilient society.

	Commit message (Collapse)	Author	Age	Files	Lines
*	1276 - make C++ version the default	Kartik K. Agaram	2015-05-05	1	-0/+259
	I've tried to update the Readme, but there are at least a couple of issues.

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01//EN" "http://www.w3.org/TR/html4/strict.dtd"> <html> <head> <meta http-equiv="content-type" content="text/html; charset=UTF-8"> <title>Mu - 092socket.mu</title> <meta name="Generator" content="Vim/8.0"> <meta name="plugin-version" content="vim7.4_v2"> <meta name="syntax" content="none"> <meta name="settings" content="number_lines,use_css,pre_wrap,no_foldcolumn,expand_tabs,line_ids,prevent_copy="> <meta name="colorscheme" content="minimal-light"> <style type="text/css">  </style> <script type='text/javascript'>  </script> </head> <body onload='JumpToLine();'> <a href='https://github.com/akkartik/mu/blob/master/092socket.mu'>https://github.com/akkartik/mu/blob/master/092socket.mu</a> <pre id='vimCodeElement'> 1 # Wrappers around socket primitives that are easier to test. 2 3 # To test server operations, just run a real client against localhost. 4 scenario example-server-test [ 5 local-scope 6 # test server without a fake on a random (real) port 7 # that way repeatedly running the test will give ports time to timeout and 8 # close before reusing them 9 make-random-nondeterministic 10 port:num <- <a href='068random.mu.html#L58'>random-in-range</a> null/real-random-numbers, 8000, 8100 11 run [ 12 socket:num <- $open-server-socket port 13 assert socket, [ 14 F - example-server-test: $open-server-socket failed] 15 handler-routine:number <- start-running <a href='092socket.mu.html#L55'>serve-one-request</a> socket, <a href='092socket.mu.html#L26'>example-handler</a> 16 ] 17 <a href='075channel.mu.html#L36'>source</a>:&:<a href='075channel.mu.html#L36'>source</a>:char <- <a href='092socket.mu.html#L69'>start-reading-from-network</a> null/real-resources, [localhost/], port 18 response:text <- <a href='075channel.mu.html#L499'>drain</a> <a href='075channel.mu.html#L36'>source</a> 19 10:@:char/raw <- copy *response 20 memory-should-contain [ 21 10:array:character <- [abc] 22 ] 23 socket <- $close-socket socket 24 ] 25 # helper just for this scenario 26 def <a href='092socket.mu.html#L26'>example-handler</a> query:text -> response:text [ 27 local-scope 28 load-inputs 29 return [abc] 30 ] 31 32 # To test client operations, use 'assume-resources' with a filename that 33 # begins with a hostname. (Filenames starting with '/' are assumed to be 34 # local.) 35 scenario example-client-test [ 36 local-scope 37 assume-resources [ 38 [example.com/] <- [ 39 |abc| 40 ] 41 ] 42 run [ 43 <a href='075channel.mu.html#L36'>source</a>:&:<a href='075channel.mu.html#L36'>source</a>:char <- <a href='092socket.mu.html#L69'>start-reading-from-network</a> <a href='088file.mu.html#L11'>resources</a>, [example.com/] 44 ] 45 contents:text <- <a href='075channel.mu.html#L499'>drain</a> <a href='075channel.mu.html#L36'>source</a> 46 10:@:char/raw <- copy *contents 47 memory-should-contain [ 48 10:array:character <- [abc 49 ] 50 ] 51 ] 52 53 type <a href='092socket.mu.html#L53'>request-handler</a> = (recipe text -> text) 54 55 def <a href='092socket.mu.html#L55'>serve-one-request</a> socket:num, <a href='092socket.mu.html#L53'>request-handler</a>:<a href='092socket.mu.html#L53'>request-handler</a> -> socket:num [ 56 local-scope 57 load-inputs 58 session:num <- $accept socket 59 assert session, [ 60 F - example-server-test: $accept failed] 61 contents:&:<a href='075channel.mu.html#L36'>source</a>:char, <a href='075channel.mu.html#L40'>sink</a>:&:<a href='075channel.mu.html#L40'>sink</a>:char <- <a href='075channel.mu.html#L44'>new-channel</a> 30 62 start-running <a href='092socket.mu.html#L104'>receive-from-socket</a> session, <a href='075channel.mu.html#L40'>sink</a> 63 query:text <- <a href='075channel.mu.html#L499'>drain</a> contents 64 response:text <- call <a href='092socket.mu.html#L53'>request-handler</a>, query 65 <a href='092socket.mu.html#L132'>write-to-socket</a> session, response 66 session <- $close-socket session 67 ] 68 69 def <a href='092socket.mu.html#L69'>start-reading-from-network</a> <a href='088file.mu.html#L11'>resources</a>:&:<a href='088file.mu.html#L11'>resources</a>, uri:text -> contents:&:<a href='075channel.mu.html#L36'>source</a>:char [ 70 local-scope 71 load-inputs 72 { 73 port:num, port-found?:boolean <- next-input 74 break-if port-found? 75 port <- copy 80/http-port 76 } 77 { 78 break-unless <a href='088file.mu.html#L11'>resources</a> 79 # fake network 80 contents <- <a href='088file.mu.html#L53'>start-reading-from-fake-resource</a> <a href='088file.mu.html#L11'>resources</a>, uri 81 return 82 } 83 # real network 84 host:text, path:text <- <a href='092socket.mu.html#L148'>split-at</a> uri, 47/slash 85 socket:num <- $open-client-socket host, port 86 assert socket, [contents] 87 req:text <- <a href='061text.mu.html#L520'>interpolate</a> [GET _ HTTP/1.1], path 88 <a href='092socket.mu.html#L93'>request-socket</a> socket, req 89 contents:&:<a href='075channel.mu.html#L36'>source</a>:char, <a href='075channel.mu.html#L40'>sink</a>:&:<a href='075channel.mu.html#L40'>sink</a>:char <- <a href='075channel.mu.html#L44'>new-channel</a> 10000 90 start-running <a href='092socket.mu.html#L125'>receive-from-client-socket-and-close</a> socket, <a href='075channel.mu.html#L40'>sink</a> 91 ] 92 93 def <a href='092socket.mu.html#L93'>request-socket</a> socket:num, s:text -> socket:num [ 94 local-scope 95 load-inputs 96 <a href='092socket.mu.html#L132'>write-to-socket</a> socket, s 97 $write-to-socket socket, 13/cr 98 $write-to-socket socket, 10/lf 99 # empty line to delimit request 100 $write-to-socket socket, 13/cr 101 $write-to-socket socket, 10/lf 102 ] 103 104 def <a href='092socket.mu.html#L104'>receive-from-socket</a> socket:num, <a href='075channel.mu.html#L40'>sink</a>:&:<a href='075channel.mu.html#L40'>sink</a>:char -> <a href='075channel.mu.html#L40'>sink</a>:&:<a href='075channel.mu.html#L40'>sink</a>:char, socket:num [ 105 local-scope 106 load-inputs 107 { 108 +next-attempt 109 c:char, found?:bool, eof?:bool, error:num <- $read-from-socket socket 110 break-if eof? 111 break-if error 112 { 113 break-unless found? 114 <a href='075channel.mu.html#L40'>sink</a> <- <a href='075channel.mu.html#L60'>write</a> <a href='075channel.mu.html#L40'>sink</a>, c 115 } 116 { 117 break-if found? 118 switch 119 } 120 loop 121 } 122 <a href='075channel.mu.html#L40'>sink</a> <- close <a href='075channel.mu.html#L40'>sink</a> 123 ] 124 125 def <a href='092socket.mu.html#L125'>receive-from-client-socket-and-close</a> socket:num, <a href='075channel.mu.html#L40'>sink</a>:&:<a href='075channel.mu.html#L40'>sink</a>:char -> <a href='075channel.mu.html#L40'>sink</a>:&:<a href='075channel.mu.html#L40'>sink</a>:char, socket:num [ 126 local-scope 127 load-inputs 128 <a href='075channel.mu.html#L40'>sink</a> <- <a href='092socket.mu.html#L104'>receive-from-socket</a> socket, <a href='075channel.mu.html#L40'>sink</a> 129 socket <- $close-socket socket 130 ] 131 132 def <a href='092socket.mu.html#L132'>write-to-socket</a> socket:num, s:text [ 133 local-scope 134 load-inputs 135 len:num <- length *s 136 i:num <- copy 0 137 { 138 done?:bool <- greater-or-equal i, len 139 break-if done? 140 c:char <- index *s, i 141 $write-to-socket socket, c 142 i <- add i, 1 143 loop 144 } 145 ] 146 147 # like split-first, but don't eat the delimiter 148 def <a href='092socket.mu.html#L148'>split-at</a> text:text, delim:char -> x:text, y:text [ 149 local-scope 150 load-inputs 151 # empty text? return empty texts 152 len:num <- length *text 153 { 154 empty?:bool <- equal len, 0 155 break-unless empty? 156 x:text <- new [] 157 y:text <- new [] 158 return 159 } 160 idx:num <- find-next text, delim, 0 161 x:text <- <a href='061text.mu.html#L1287'>copy-range</a> text, 0, idx 162 y:text <- <a href='061text.mu.html#L1287'>copy-range</a> text, idx, len 163 ] 164 165 scenario text-split-at [ 166 local-scope 167 x:text <- new [a/b] 168 run [ 169 y:text, z:text <- <a href='092socket.mu.html#L148'>split-at</a> x, 47/slash 170 10:@:char/raw <- copy *y 171 20:@:char/raw <- copy *z 172 ] 173 memory-should-contain [ 174 10:array:character <- [a] 175 20:array:character <- [/b] 176 ] 177 ] </pre> </body> </html>