package eio
Effect-based direct-style IO API for OCaml
Install
Dune Dependency
Authors
Maintainers
Sources
eio-0.11.tbz
sha256=0c33742074562631677886f4fe4a02f9672cec94297ff85c2ed854db5baa71aa
sha512=590843cb5fb3906fd5ab9911d29206172d164a53c48e635871a23c95d4cdce8ae0999480471187fdddee8c9c523148911ca140feabde6a826c317671a3b33090
doc/src/eio.mock/net.ml.html
Source file net.ml
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 98open Eio.Std type t = < Eio.Net.t; on_listen : Eio.Net.listening_socket Handler.t; on_connect : Eio.Net.stream_socket Handler.t; on_datagram_socket : Eio.Net.datagram_socket Handler.t; on_getaddrinfo : Eio.Net.Sockaddr.t list Handler.t; on_getnameinfo : (string * string) Handler.t; > let make label = let on_listen = Handler.make (`Raise (Failure "Mock listen handler not configured")) in let on_connect = Handler.make (`Raise (Failure "Mock connect handler not configured")) in let on_datagram_socket = Handler.make (`Raise (Failure "Mock datagram_socket handler not configured")) in let on_getaddrinfo = Handler.make (`Raise (Failure "Mock getaddrinfo handler not configured")) in let on_getnameinfo = Handler.make (`Raise (Failure "Mock getnameinfo handler not configured")) in object inherit Eio.Net.t method on_listen = on_listen method on_connect = on_connect method on_datagram_socket = on_datagram_socket method on_getaddrinfo = on_getaddrinfo method on_getnameinfo = on_getnameinfo method listen ~reuse_addr:_ ~reuse_port:_ ~backlog:_ ~sw addr = traceln "%s: listen on %a" label Eio.Net.Sockaddr.pp addr; let socket = Handler.run on_listen in Switch.on_release sw (fun () -> Eio.Flow.close socket); socket method connect ~sw addr = traceln "%s: connect to %a" label Eio.Net.Sockaddr.pp addr; let socket = Handler.run on_connect in Switch.on_release sw (fun () -> Eio.Flow.close socket); socket method datagram_socket ~reuse_addr:_ ~reuse_port:_ ~sw addr = (match addr with | #Eio.Net.Sockaddr.datagram as saddr -> traceln "%s: datagram_socket %a" label Eio.Net.Sockaddr.pp saddr | `UdpV4 -> traceln "%s: datagram_socket UDPv4" label | `UdpV6 -> traceln "%s: datagram_socket UDPv6" label ); let socket = Handler.run on_datagram_socket in Switch.on_release sw (fun () -> Eio.Flow.close socket); socket method getaddrinfo ~service node = traceln "%s: getaddrinfo ~service:%s %s" label service node; Handler.run on_getaddrinfo method getnameinfo sockaddr = traceln "%s: getnameinfo %a" label Eio.Net.Sockaddr.pp sockaddr; Handler.run on_getnameinfo end let on_connect (t:t) actions = let as_socket x = (x :> Eio.Net.stream_socket) in Handler.seq t#on_connect (List.map (Action.map as_socket) actions) let on_listen (t:t) actions = let as_socket x = (x :> Eio.Net.listening_socket) in Handler.seq t#on_listen (List.map (Action.map as_socket) actions) let on_datagram_socket (t:t) actions = let as_socket x = (x :> Eio.Net.datagram_socket) in Handler.seq t#on_datagram_socket (List.map (Action.map as_socket) actions) let on_getaddrinfo (t:t) actions = Handler.seq t#on_getaddrinfo actions let on_getnameinfo (t:t) actions = Handler.seq t#on_getnameinfo actions type listening_socket = < Eio.Net.listening_socket; on_accept : (Flow.t * Eio.Net.Sockaddr.stream) Handler.t; > let listening_socket label = let on_accept = Handler.make (`Raise (Failure "Mock accept handler not configured")) in object inherit Eio.Net.listening_socket method on_accept = on_accept method accept ~sw = let socket, addr = Handler.run on_accept in Flow.attach_to_switch socket sw; traceln "%s: accepted connection from %a" label Eio.Net.Sockaddr.pp addr; (socket :> Eio.Net.stream_socket), addr method close = traceln "%s: closed" label end let on_accept (l:listening_socket) actions = let as_accept_pair x = (x :> Flow.t * Eio.Net.Sockaddr.stream) in Handler.seq l#on_accept (List.map (Action.map as_accept_pair) actions)