|
7 | 7 | %%% |
8 | 8 | -module(hackney_tcp). |
9 | 9 | -export([messages/1, |
10 | | - connect/3, connect/4, |
11 | | - recv/2, recv/3, |
12 | | - send/2, |
13 | | - setopts/2, |
14 | | - controlling_process/2, |
15 | | - peername/1, |
16 | | - close/1, |
17 | | - shutdown/2, |
18 | | - sockname/1]). |
| 10 | + connect/3, connect/4, |
| 11 | + recv/2, recv/3, |
| 12 | + send/2, |
| 13 | + setopts/2, |
| 14 | + controlling_process/2, |
| 15 | + peername/1, |
| 16 | + close/1, |
| 17 | + shutdown/2, |
| 18 | + sockname/1]). |
19 | 19 |
|
20 | 20 | %% @doc Atoms used to identify messages in {active, once | true} mode. |
21 | 21 | messages(_) -> {tcp, tcp_closed, tcp_error}. |
22 | 22 |
|
23 | 23 | connect(Host, Port, Opts) -> |
24 | | - connect(Host, Port, Opts, infinity). |
| 24 | + connect(Host, Port, Opts, infinity). |
25 | 25 |
|
26 | 26 | connect(Host, Port, Opts, Timeout) when is_list(Host), is_integer(Port), |
27 | | - (Timeout =:= infinity orelse is_integer(Timeout)) -> |
28 | | - BaseOpts = [binary, {active, false}, {packet, raw}], |
29 | | - Opts1 = hackney_util:merge_opts(BaseOpts, Opts), |
30 | | - %% connect |
31 | | - gen_tcp:connect(Host, Port, Opts1, Timeout). |
| 27 | + (Timeout =:= infinity orelse is_integer(Timeout)) -> |
| 28 | + BaseOpts = [binary, {active, false}, {packet, raw}], |
| 29 | + Opts1 = hackney_util:merge_opts(BaseOpts, Opts), |
| 30 | + %% connect |
| 31 | + gen_tcp:connect(Host, Port, Opts1, Timeout). |
32 | 32 |
|
33 | 33 | recv(Socket, Length) -> |
34 | | - recv(Socket, Length, infinity). |
| 34 | + recv(Socket, Length, infinity). |
35 | 35 |
|
36 | 36 | %% @doc Receive a packet from a socket in passive mode. |
37 | 37 | %% @see gen_tcp:recv/3 |
38 | 38 | -spec recv(inet:socket(), non_neg_integer(), timeout()) |
39 | | - -> {ok, any()} | {error, closed | atom()}. |
| 39 | + -> {ok, any()} | {error, closed | atom()}. |
40 | 40 | recv(Socket, Length, Timeout) -> |
41 | | - gen_tcp:recv(Socket, Length, Timeout). |
| 41 | + gen_tcp:recv(Socket, Length, Timeout). |
42 | 42 |
|
43 | 43 |
|
44 | 44 | %% @doc Send a packet on a socket. |
45 | 45 | %% @see gen_tcp:send/2 |
46 | 46 | -spec send(inet:socket(), iolist()) -> ok | {error, atom()}. |
47 | 47 | send(Socket, Packet) -> |
48 | | - gen_tcp:send(Socket, Packet). |
| 48 | + gen_tcp:send(Socket, Packet). |
49 | 49 |
|
50 | 50 | %% @doc Set one or more options for a socket. |
51 | 51 | %% @see inet:setopts/2 |
52 | 52 | -spec setopts(inet:socket(), list()) -> ok | {error, atom()}. |
53 | 53 | setopts(Socket, Opts) -> |
54 | | - inet:setopts(Socket, Opts). |
| 54 | + inet:setopts(Socket, Opts). |
55 | 55 |
|
56 | 56 | %% @doc Assign a new controlling process <em>Pid</em> to <em>Socket</em>. |
57 | 57 | %% @see gen_tcp:controlling_process/2 |
58 | 58 | -spec controlling_process(inet:socket(), pid()) |
59 | | - -> ok | {error, closed | not_owner | atom()}. |
| 59 | + -> ok | {error, closed | not_owner | atom()}. |
60 | 60 | controlling_process(Socket, Pid) -> |
61 | | - gen_tcp:controlling_process(Socket, Pid). |
| 61 | + gen_tcp:controlling_process(Socket, Pid). |
62 | 62 |
|
63 | 63 | %% @doc Return the address and port for the other end of a connection. |
64 | 64 | %% @see inet:peername/1 |
65 | 65 | -spec peername(inet:socket()) |
66 | | - -> {ok, {inet:ip_address(), inet:port_number()}} | {error, atom()}. |
| 66 | + -> {ok, {inet:ip_address(), inet:port_number()}} | {error, atom()}. |
67 | 67 | peername(Socket) -> |
68 | | - inet:peername(Socket). |
| 68 | + inet:peername(Socket). |
69 | 69 |
|
70 | 70 | %% @doc Close a TCP socket. |
71 | 71 | %% @see gen_tcp:close/1 |
72 | 72 | -spec close(inet:socket()) -> ok. |
73 | 73 | close(Socket) -> |
74 | | - gen_tcp:close(Socket). |
| 74 | + gen_tcp:close(Socket). |
75 | 75 |
|
76 | 76 | %% @doc Immediately close a socket in one or two directions. |
77 | 77 | %% @see gen_tcp:shutdown/2 |
78 | 78 | -spec shutdown(inet:socket(), read | write | read_write) -> ok. |
79 | 79 | shutdown(Socket, How) -> |
80 | | - gen_tcp:shutdown(Socket, How). |
| 80 | + gen_tcp:shutdown(Socket, How). |
81 | 81 |
|
82 | 82 | %% @doc Get the local address and port of a socket |
83 | 83 | %% @see inet:sockname/1 |
84 | 84 | -spec sockname(inet:socket()) |
85 | | - -> {ok, {inet:ip_address(), inet:port_number()}} | {error, atom()}. |
| 85 | + -> {ok, {inet:ip_address(), inet:port_number()}} | {error, atom()}. |
86 | 86 | sockname(Socket) -> |
87 | | - inet:sockname(Socket). |
| 87 | + inet:sockname(Socket). |
0 commit comments