srt 0.3.0 · OCaml Package

OCaml bindings for the libsrt.

type socket

type socket_status = [

| `Init
| `Opened
| `Listening
| `Connecting
| `Connected
| `Broken
| `Closing
| `Closed
| `Nonexist

]

type transtype = [

| `Live
| `File
| `Invalid

]

type ('a, 'b) socket_opt

type listen_callback = socket -> int -> Unix.sockaddr -> string option -> bool

val messageapi : ([ `Write ], bool) socket_opt

val payloadsize : ([ `Write ], int) socket_opt

val transtype : ([ `Write ], transtype) socket_opt

val rcvsyn : ([ `Read | `Write ], bool) socket_opt

val sndsyn : ([ `Read | `Write ], bool) socket_opt

val conntimeo : ([ `Write ], int) socket_opt

val rcvtimeo : ([ `Read | `Write ], int) socket_opt

val sndtimeo : ([ `Read | `Write ], int) socket_opt

val reuseaddr : ([ `Read | `Write ], bool) socket_opt

val rcvbuf : ([ `Read | `Write ], int) socket_opt

val sndbuf : ([ `Read | `Write ], int) socket_opt

val udp_rcvbuf : ([ `Read | `Write ], int) socket_opt

val udp_sndbuf : ([ `Read | `Write ], int) socket_opt

val rcvdata : ([ `Read ], int) socket_opt

val rcvlatency : ([ `Read | `Write ], int) socket_opt

val enforced_encryption : ([ `Write ], bool) socket_opt

val streamid : ([ `Read | `Write ], string) socket_opt

val passphrase : ([ `Write ], string) socket_opt

val pbkeylen : ([ `Read | `Write ], int) socket_opt

type errno = [

| `Easyncfail
| `Easyncrcv
| `Easyncsnd
| `Eboundsock
| `Econgest
| `Econnfail
| `Econnlost
| `Econnrej
| `Econnsetup
| `Econnsock
| `Eduplisten
| `Efile
| `Einvalbufferapi
| `Einvalmsgapi
| `Einvop
| `Einvparam
| `Einvpollid
| `Einvrdoff
| `Einvsock
| `Einvwroff
| `Elargemsg
| `Enobuf
| `Enoconn
| `Enolisten
| `Enoserver
| `Epeererr
| `Epollempty
| `Erdperm
| `Erdvnoserv
| `Erdvunbound
| `Eresource
| `Esclosed
| `Esecfail
| `Esockfail
| `Esysobj
| `Ethread
| `Etimeout
| `Eunboundsock
| `Eunknown
| `Ewrperm
| `Success

]

exception Error of errno * string

val startup : unit -> unit

val cleanup : unit -> unit

val create_socket : unit -> socket

val getsockstate : socket -> socket_status

val bind : socket -> Unix.sockaddr -> unit

val listen_callback : socket -> listen_callback -> unit

val listen : socket -> int -> unit

val accept : socket -> socket * Unix.sockaddr

val connect : socket -> Unix.sockaddr -> unit

val rendez_vous : socket -> Unix.sockaddr -> Unix.sockaddr -> unit

val send : socket -> bytes -> int

val recv : socket -> bytes -> int -> int

val sendmsg : socket -> bytes -> int -> bool -> int

val recvmsg : socket -> bytes -> int -> int

val getsockflag : socket -> ([> `Read ], 'a) socket_opt -> 'a

val setsockflag : socket -> ([> `Write ], 'a) socket_opt -> 'a -> unit

val close : socket -> unit

module Log : sig ... end

module Poll : sig ... end

module Stats : sig ... end

package srt