123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106 |
- -module(cowboy_tcp_transport).
- -export([name/0, messages/0, listen/1, accept/2, recv/3, send/2, setopts/2,
- controlling_process/2, peername/1, close/1]).
- -spec name() -> tcp.
- name() -> tcp.
- -spec messages() -> {tcp, tcp_closed, tcp_error}.
- messages() -> {tcp, tcp_closed, tcp_error}.
- -spec listen([{port, inet:ip_port()} | {ip, inet:ip_address()}])
- -> {ok, inet:socket()} | {error, atom()}.
- listen(Opts) ->
- {port, Port} = lists:keyfind(port, 1, Opts),
- Backlog = proplists:get_value(backlog, Opts, 1024),
- ListenOpts0 = [binary, {active, false},
- {backlog, Backlog}, {packet, raw}, {reuseaddr, true}],
- ListenOpts =
- case lists:keyfind(ip, 1, Opts) of
- false -> ListenOpts0;
- Ip -> [Ip|ListenOpts0]
- end,
- gen_tcp:listen(Port, ListenOpts).
- -spec accept(inet:socket(), timeout())
- -> {ok, inet:socket()} | {error, closed | timeout | atom()}.
- accept(LSocket, Timeout) ->
- gen_tcp:accept(LSocket, Timeout).
- -spec recv(inet:socket(), non_neg_integer(), timeout())
- -> {ok, any()} | {error, closed | atom()}.
- recv(Socket, Length, Timeout) ->
- gen_tcp:recv(Socket, Length, Timeout).
- -spec send(inet:socket(), iolist()) -> ok | {error, atom()}.
- send(Socket, Packet) ->
- gen_tcp:send(Socket, Packet).
- -spec setopts(inet:socket(), list()) -> ok | {error, atom()}.
- setopts(Socket, Opts) ->
- inet:setopts(Socket, Opts).
- -spec controlling_process(inet:socket(), pid())
- -> ok | {error, closed | not_owner | atom()}.
- controlling_process(Socket, Pid) ->
- gen_tcp:controlling_process(Socket, Pid).
- -spec peername(inet:socket())
- -> {ok, {inet:ip_address(), inet:ip_port()}} | {error, atom()}.
- peername(Socket) ->
- inet:peername(Socket).
- -spec close(inet:socket()) -> ok.
- close(Socket) ->
- gen_tcp:close(Socket).
|