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
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
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
|
<!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/7.4">
<meta name="plugin-version" content="vim7.4_v2">
<meta name="syntax" content="none">
<meta name="settings" content="use_css,pre_wrap,no_foldcolumn,expand_tabs,prevent_copy=">
<meta name="colorscheme" content="minimal">
<style type="text/css">
<!--
pre { white-space: pre-wrap; font-family: monospace; color: #eeeeee; background-color: #080808; }
body { font-size: 12pt; font-family: monospace; color: #eeeeee; background-color: #080808; }
* { font-size: 12pt; font-size: 1em; }
.muData { color: #ffff00; }
.muControl { color: #c0a020; }
.Delimiter { color: #800080; }
.Comment { color: #9090ff; }
.Constant { color: #00a0a0; }
.Special { color: #c00000; }
.CommentedCode { color: #6c6c6c; }
.muRecipe { color: #ff8700; }
.muScenario { color: #00af00; }
-->
</style>
<script type='text/javascript'>
<!--
-->
</script>
</head>
<body>
<pre id='vimCodeElement'>
<span class="Comment"># Wrappers around socket primitives that are easier to test.</span>
<span class="Comment">#</span>
<span class="Comment"># To test client operations, use `assume-resources` with a filename that</span>
<span class="Comment"># begins with a hostname. (Filenames starting with '/' are assumed to be</span>
<span class="Comment"># local.)</span>
<span class="Comment">#</span>
<span class="Comment"># To test server operations, just run a real client against localhost.</span>
<span class="muScenario">scenario</span> example-server-test [
<span class="Constant">local-scope</span>
<span class="Comment"># test server without a fake on a random (real) port</span>
<span class="Comment"># that way repeatedly running the test will give ports time to timeout and</span>
<span class="Comment"># close before reusing them</span>
make-random-nondeterministic
port:num<span class="Special"> <- </span>random-in-range <span class="Constant">0/real-random-numbers</span>, <span class="Constant">8000</span>, <span class="Constant">8100</span>
run [
socket:num<span class="Special"> <- </span>$open-server-socket port
$print <span class="Constant">[server socket: ]</span>, socket, <span class="Constant">10/newline</span>
assert socket, <span class="Constant">[ </span>
<span class="Constant">F - example-server-test: $open-server-socket failed]</span>
$print <span class="Constant">[starting up server routine]</span>, <span class="Constant">10/newline</span>
handler-routine:number<span class="Special"> <- </span>start-running serve-one-request socket, example-handler
]
$print <span class="Constant">[starting to read from port ]</span>, port, <span class="Constant">10/newline</span>
source:&:source:char<span class="Special"> <- </span>start-reading-from-network <span class="Constant">0/real-resources</span>, <span class="Constant">[localhost]</span>, <span class="Constant">[/]</span>, port
response:text<span class="Special"> <- </span>drain source
<span class="Constant">10</span>:@:char/<span class="Special">raw <- </span>copy *response
memory-should-contain [
<span class="Constant">10</span>:array:character<span class="Special"> <- </span><span class="Constant">[abc]</span>
]
]
<span class="Comment"># helper just for this scenario</span>
<span class="muRecipe">def</span> example-handler query:text<span class="muRecipe"> -> </span>response:text [
<span class="Constant">local-scope</span>
<span class="Constant">load-ingredients</span>
<span class="muControl">reply</span> <span class="Constant">[abc]</span>
]
<span class="CommentedCode">#? scenario example-client-test [</span>
<span class="CommentedCode">#? local-scope</span>
<span class="CommentedCode">#? assume-resources [</span>
<span class="CommentedCode">#? [example.com/] -> [abc]</span>
<span class="CommentedCode">#? ]</span>
<span class="CommentedCode">#? run [</span>
<span class="CommentedCode">#? source:&:source:char <- start-reading-from-network resources, [example.com], [/]</span>
<span class="CommentedCode">#? ]</span>
<span class="CommentedCode">#? contents:text <- drain source</span>
<span class="CommentedCode">#? 10:@:char/raw <- copy *contents</span>
<span class="CommentedCode">#? memory-should-contain [</span>
<span class="CommentedCode">#? 10:address:character <- [abc]</span>
<span class="CommentedCode">#? ]</span>
<span class="CommentedCode">#? ]</span>
<span class="muData">type</span> request-handler = (recipe text<span class="muRecipe"> -> </span>text)
<span class="muRecipe">def</span> serve-one-request socket:num, request-handler:request-handler [
<span class="Constant">local-scope</span>
<span class="Constant">load-ingredients</span>
session:num<span class="Special"> <- </span>$accept socket
$print <span class="Constant">[server session socket: ]</span>, session, <span class="Constant">10/newline</span>
assert session, <span class="Constant">[ </span>
<span class="Constant">F - example-server-test: $accept failed]</span>
contents:&:source:char, sink:&:sink:char<span class="Special"> <- </span>new-channel <span class="Constant">30</span>
sink<span class="Special"> <- </span>start-running receive-from-socket session, sink
query:text<span class="Special"> <- </span>drain contents
response:text<span class="Special"> <- </span>call request-handler, query
write-to-socket session, response
$close-socket session
]
<span class="muRecipe">def</span> start-reading-from-network resources:&:resources, host:text, path:text<span class="muRecipe"> -> </span>contents:&:source:char [
<span class="Constant">local-scope</span>
<span class="Constant">load-ingredients</span>
$print <span class="Constant">[running start-reading-from-network]</span>, <span class="Constant">10/newline</span>
<span class="Delimiter">{</span>
port:num, port-found?:boolean<span class="Special"> <- </span><span class="Constant">next-ingredient</span>
<span class="muControl">break-if</span> port-found?
port<span class="Special"> <- </span>copy <span class="Constant">80/http-port</span>
<span class="Delimiter">}</span>
<span class="Delimiter">{</span>
<span class="muControl">break-if</span> resources
<span class="Comment"># real network</span>
socket:num<span class="Special"> <- </span>$open-client-socket host, port
$print <span class="Constant">[client socket: ]</span>, socket, <span class="Constant">10/newline</span>
assert socket, <span class="Constant">[contents]</span>
req:text<span class="Special"> <- </span>interpolate <span class="Constant">[GET _ HTTP/1.1]</span>, path
request-socket socket, req
contents:&:source:char, sink:&:sink:char<span class="Special"> <- </span>new-channel <span class="Constant">10000</span>
start-running receive-from-socket socket, sink
<span class="muControl">return</span>
<span class="Delimiter">}</span>
<span class="Comment"># fake network</span>
<span class="CommentedCode">#? i:num <- copy 0</span>
<span class="CommentedCode">#? data:&:@:resource <- get *fs, data:offset</span>
<span class="CommentedCode">#? len:num <- length *data</span>
<span class="CommentedCode">#? {</span>
<span class="CommentedCode">#? done?:bool <- greater-or-equal i, len</span>
<span class="CommentedCode">#? break-if done?</span>
<span class="CommentedCode">#? tmp:resource <- index *data, i</span>
<span class="CommentedCode">#? i <- add i, 1</span>
<span class="CommentedCode">#? curr-filename:text <- get tmp, name:offset</span>
<span class="CommentedCode">#? found?:bool <- equal filename, curr-filename</span>
<span class="CommentedCode">#? loop-unless found?</span>
<span class="CommentedCode">#? contents:&:source:char, sink:&:sink:char <- new-channel 30</span>
<span class="CommentedCode">#? curr-contents:text <- get tmp, contents:offset</span>
<span class="CommentedCode">#? start-running transmit-from-text curr-contents, sink</span>
<span class="CommentedCode">#? return</span>
<span class="CommentedCode">#? }</span>
<span class="muControl">return</span> <span class="Constant">0/not-found</span>
]
<span class="muRecipe">def</span> request-socket socket:num, s:text<span class="muRecipe"> -> </span>socket:num [
<span class="Constant">local-scope</span>
<span class="Constant">load-ingredients</span>
write-to-socket socket, s
$write-to-socket socket, <span class="Constant">13/cr</span>
$write-to-socket socket, <span class="Constant">10/lf</span>
<span class="Comment"># empty line to delimit request</span>
$write-to-socket socket, <span class="Constant">13/cr</span>
$write-to-socket socket, <span class="Constant">10/lf</span>
]
<span class="CommentedCode">#? def start-writing-socket network:&:local-network, port:num -> sink:&:sink:char, routine-id:num [</span>
<span class="CommentedCode">#? local-scope</span>
<span class="CommentedCode">#? load-ingredients</span>
<span class="CommentedCode">#? source:&:source:char, sink:&:sink:char <- new-channel 30</span>
<span class="CommentedCode">#? {</span>
<span class="CommentedCode">#? break-if network</span>
<span class="CommentedCode">#? socket:num <- $open-server-socket port</span>
<span class="CommentedCode">#? session:num <- $accept socket</span>
<span class="CommentedCode">#? # TODO Create channel implementation of write-to-socket.</span>
<span class="CommentedCode">#? return sink, 0/routine-id</span>
<span class="CommentedCode">#? }</span>
<span class="CommentedCode">#? # fake network</span>
<span class="CommentedCode">#? routine-id <- start-running transmit-to-fake-socket network, port, source</span>
<span class="CommentedCode">#? ]</span>
<span class="CommentedCode">#? def transmit-to-fake-socket network:&:local-network, port:num, source:&:source:char -> network:&:local-network, source:&:source:char [</span>
<span class="CommentedCode">#? local-scope</span>
<span class="CommentedCode">#? load-ingredients</span>
<span class="CommentedCode">#? # compute new port connection contents</span>
<span class="CommentedCode">#? buf:&:buffer <- new-buffer 30</span>
<span class="CommentedCode">#? {</span>
<span class="CommentedCode">#? c:char, done?:bool, source <- read source</span>
<span class="CommentedCode">#? break-unless c</span>
<span class="CommentedCode">#? buf <- append buf, c</span>
<span class="CommentedCode">#? break-if done?</span>
<span class="CommentedCode">#? loop</span>
<span class="CommentedCode">#? }</span>
<span class="CommentedCode">#? contents:text <- buffer-to-array buf</span>
<span class="CommentedCode">#? new-port-connection:&:port-connection <- new-port-connection port, contents</span>
<span class="CommentedCode">#? # Got the contents of the channel, time to write to fake port.</span>
<span class="CommentedCode">#? i:num <- copy 0</span>
<span class="CommentedCode">#? port-connections:&:@:port-connection <- get *network, data:offset</span>
<span class="CommentedCode">#? len:num <- length *port-connections</span>
<span class="CommentedCode">#? {</span>
<span class="CommentedCode">#? done?:bool <- greater-or-equal i, len</span>
<span class="CommentedCode">#? break-if done?</span>
<span class="CommentedCode">#? current:port-connection <- index *port-connections, i</span>
<span class="CommentedCode">#? current-port:num <- get current, port:offset</span>
<span class="CommentedCode">#? ports-match?:bool <- equal current-port, port</span>
<span class="CommentedCode">#? i <- add i, 1</span>
<span class="CommentedCode">#? loop-unless ports-match?</span>
<span class="CommentedCode">#? # Found an existing connection on this port, overwrite.</span>
<span class="CommentedCode">#? put-index *port-connections, i, *new-port-connection</span>
<span class="CommentedCode">#? reply</span>
<span class="CommentedCode">#? }</span>
<span class="CommentedCode">#? # Couldn't find an existing connection on this port, initialize a new one.</span>
<span class="CommentedCode">#? new-len:num <- add len, 1</span>
<span class="CommentedCode">#? new-port-connections:&:@:port-connection <- new port-connection:type, new-len</span>
<span class="CommentedCode">#? put *network, data:offset, new-port-connections</span>
<span class="CommentedCode">#? i:num <- copy 0</span>
<span class="CommentedCode">#? {</span>
<span class="CommentedCode">#? done?:bool <- greater-or-equal i, len</span>
<span class="CommentedCode">#? break-if done?</span>
<span class="CommentedCode">#? tmp:port-connection <- index *port-connections, i</span>
<span class="CommentedCode">#? put-index *new-port-connections, i, tmp</span>
<span class="CommentedCode">#? }</span>
<span class="CommentedCode">#? put-index *new-port-connections, len, *new-port-connection</span>
<span class="CommentedCode">#? ]</span>
<span class="muRecipe">def</span> receive-from-socket socket:num, sink:&:sink:char<span class="muRecipe"> -> </span>sink:&:sink:char [
<span class="Constant">local-scope</span>
<span class="Constant">load-ingredients</span>
<span class="Delimiter">{</span>
$print <span class="Constant">[read-from-socket ]</span>, socket, <span class="Constant">10/newline</span>
req:text, eof?:bool<span class="Special"> <- </span>$read-from-socket socket, <span class="Constant">4096/bytes</span>
<span class="muControl">loop-unless</span> req
bytes-read:num<span class="Special"> <- </span>length *req
i:num<span class="Special"> <- </span>copy <span class="Constant">0</span>
<span class="Delimiter">{</span>
done?:bool<span class="Special"> <- </span>greater-or-equal i, bytes-read
<span class="muControl">break-if</span> done?
c:char<span class="Special"> <- </span>index *req, i <span class="Comment"># todo: unicode</span>
sink<span class="Special"> <- </span>write sink, c
i<span class="Special"> <- </span>add i, <span class="Constant">1</span>
<span class="muControl">loop</span>
<span class="Delimiter">}</span>
<span class="muControl">loop-unless</span> eof?
<span class="Delimiter">}</span>
sink<span class="Special"> <- </span>close sink
]
<span class="muRecipe">def</span> write-to-socket socket:num, s:text [
<span class="Constant">local-scope</span>
<span class="Constant">load-ingredients</span>
len:num<span class="Special"> <- </span>length *s
i:num<span class="Special"> <- </span>copy <span class="Constant">0</span>
<span class="Delimiter">{</span>
done?:bool<span class="Special"> <- </span>greater-or-equal i, len
<span class="muControl">break-if</span> done?
c:char<span class="Special"> <- </span>index *s, i
$write-to-socket socket, c
i<span class="Special"> <- </span>add i, <span class="Constant">1</span>
<span class="muControl">loop</span>
<span class="Delimiter">}</span>
]
</pre>
</body>
</html>
<!-- vim: set foldmethod=manual : -->
|