blob: 73ab10ca7b6da1e95abe33200894c26b502ced4e (
plain)
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
|
# provide a standard epoll-based tcp/ip server
{ <
<
{ 1 } /running deffst
{ 1000000 } /interval deffst
{ "unconfigured accept (of epollServer)" die } /accept deffst
{ "unconfigured port (of epollServer)" die } /port deffst
{ = }' /set deffst
{ scope keys }' /setters deffst
{ =*install
setters { _ { set }_ -01 install }" each
} /installSetters deffst
> _ ==settings "::" via
{ -1010 deffst = }' ::installSetters # TODO: def??? should overwrite existing values
sys .linux "+" via +epoll "++" via
net .tcp "+:" via
<
{ "noHandler .in" die } =*in
{ "noHandler .out" die } =*out
{ "noHandler .err" die } =*err
> ==noHandler
<
{ txt .produce .u defvst }' /add deffst # TODO: possibly do it without text conversion one day
{ noHandler -01 add }' /remove deffst
> ==eventHandlers
{
::port +:listenFd ==listenFd
<
{
listenFd +:acceptFd ==fd
epoll ++EPOLLCTLADD fd ++EPOLLIN ++EPOLLERR bor fd ++ctl
<
{
epoll ++EPOLLCTLDEL fd 0 0 ++ctl
fd eventHandlers .remove
fd +close
} /close deffst
{ ==count
count str .alloc ==buf
fd buf count +read
_ 0 lt { "read failed" die } rep # TODO: real error handling
buf str .inplacePrefix
} /read deff
{ ==buf
fd buf _ len +write
_ 0 lt { "write failed" die } rep # TODO: real error handling
} /write deff
{ ==flags
epoll ++EPOLLCTLMOD fd flags fd ++ctl
} /ctl deffst
> ::accept fd eventHandlers .add
} =*in
{ "unexpected output capability on listening socket" die } =*out
{ "error on main server socket" die } =*err
> listenFd eventHandlers .add
++create ==epoll
epoll ++EPOLLCTLADD listenFd ++EPOLLIN listenFd ++ctl
{ ::running } {
epoll 16 ::interval ++wait -- # TODO: error handling
{
_ .data txt .produce .u eventHandlers -01 . ":" via # TODO: consider saving raw addresses in the epoll data instead
.events
_ ++EPOLLIN band not not { :in } rep
_ ++EPOLLOUT band not not { :out } rep
++EPOLLERR band not not { :err } rep
} each
} loop
} /run deffst
> } /epollServer net .alg .deff
{ <
net .alg .epollServer "^" via
<
{ "unconfigured accept (of bufferedEpollServer)" die } /accept deffst
{ = }' /set deffst
{ scope keys }' /setters deffst
{ _ ^settings .installSetters =*install
setters { _ { set }_ -01 install }" each
} /installSetters deffst
> _ ==settings "::" via
{ -1010 deffst = }' ::installSetters # TODO: def??? should overwrite existing values
sys .linux .epoll "++" via
{ ":" via "" ==inBuffer "" ==outBuffer 0 ==finished
<
{
outBuffer -01 cat =outBuffer
++EPOLLOUT ++EPOLLIN ++EPOLLERR bor bor :ctl
} =*write
{ :close } =*close
{ 1 =finished } =*finish
> ::accept ":::" via <
{
4096 :read _ len
{ inBuffer -01 cat :::in =inBuffer }
{ -- :::end }
? *
} =*in
{
outBuffer _ :write -01 str .postfix
_ =outBuffer
len _ { ++EPOLLOUT } { 0 } ? * ++EPOLLIN ++EPOLLERR bor bor :ctl
not finished and { :close } rep
} =*out
{ :::err } =*err
>
} ^accept
{ ^run } /run deffst
> } /bufferedEpollServer net .alg .deff
# vim: syn=elymas
|
