Commit 5d201cc4d50d3b23beef6a9f64ab3307176e5661

Authored by totoro
1 parent e38b1754

message_receiver is now public

net_services/CXM_net_services.anubis
@@ -152,7 +152,7 @@ define One @@ -152,7 +152,7 @@ define One
152 /** 152 /**
153 * this function unflatten muscle message and give the correct message to service_negociation function 153 * this function unflatten muscle message and give the correct message to service_negociation function
154 */ 154 */
155 -define One 155 +public define One
156 message_receiver 156 message_receiver
157 ( 157 (
158 MessageQueue queue, 158 MessageQueue queue,
web/CXM_multihost_http_server.anubis
@@ -3571,16 +3571,16 @@ define Server -> ((RWStream) -> One) @@ -3571,16 +3571,16 @@ define Server -> ((RWStream) -> One)
3571 ( 3571 (
3572 Var(List(DispatcherInfo)) info_v, 3572 Var(List(DispatcherInfo)) info_v,
3573 DenialOfService dos, 3573 DenialOfService dos,
3574 - SState s 3574 + SState ss
3575 ) = 3575 ) =
3576 (Server server) |-> (RWStream conn) |-> 3576 (Server server) |-> (RWStream conn) |->
3577 with start_time = (Int)now, 3577 with start_time = (Int)now,
3578 connection = buffered_connection(tcp(conn), var(constant_byte_array(0, 0)), var(0)), 3578 connection = buffered_connection(tcp(conn), var(constant_byte_array(0, 0)), var(0)),
3579 - if read_request_line(connection, start_time+*request_line_delay(dos), dos, s) is 3579 + if read_request_line(connection, start_time+*request_line_delay(dos), dos, ss) is
3580 { 3580 {
3581 error(msg) then print(format(msg)), 3581 error(msg) then print(format(msg)),
3582 ok(request_line) then 3582 ok(request_line) then
3583 - if read_http_headers(connection, start_time+*headers_delay(dos), dos, s) is 3583 + if read_http_headers(connection, start_time+*headers_delay(dos), dos, ss) is
3584 { 3584 {
3585 error(msg) then print(format(msg)), 3585 error(msg) then print(format(msg)),
3586 ok(headers) then if get_host_header_value(headers) is 3586 ok(headers) then if get_host_header_value(headers) is