Build the 'examples' using rebar3

Author: emqplus

examples/tcp_window/README.md examples/README.mdexamples/tcp_window/README.md renamed to examples/README.md

@@ -1,5 +1,72 @@
+## active_n 
 
-## TCP Window Full
+Benchmark the `{active, N}` and `async_recv`.
+
+```
+recv_eprof:start(Port = 6000, async_recv, 10000).
+
+recv_eprof:start(Port = 5000, active_n, 10000).
+```
+
+## async_recv
+
+## client
+
+TCP echo client.
+
+## dtls
+
+The DTLS echo server which listens on port 5000.
+
+Start a DTLS client:
+
+```
+openssl s_client -dtls1 -connect 127.0.0.1:5000 -debug
+```
+
+## dtls_psk
+
+The DTLS echo server which listens on port 5000.
+
+Start a DTLS client:
+```
+Client = dtls_psk_client:connect().
+dtls_psk_client:send(Client, <<"hi">>).
+```
+
+## gen_server
+
+## plain
+
+## proxy_protocol
+
+## simple
+
+## ssl
+
+Start the SSL echo server which listens on port 5000:
+
+```
+ssl_echo_server:start(5000).
+```
+
+Start a SSL client:
+```
+openssl s_client -tls1 -debug -connect 127.0.0.1:5000
+```
+
+## tcp_window
+
+`rebar3 shell` and run `tcp_window` test:
+
+```
+tcp_window:start(5000, sync).
+tcp_window:start(5000, async).
+tcp_window:start(5000, async_force).
+tcp_window:start(5000, async_nosuspend).
+```
+
+TCP Window Full:
 
 Send Function                           | Socket Options           | TCP Window full
 ----------------------------------------|--------------------------|-------------------------------------------
@@ -12,8 +79,16 @@ port_command(Socket, Data)              | {send_timeout, 5000}     | Return true
 port_command(Socket, Data, [force])     | {send_timeout, 5000}     | Return true always. Write to TCP Stack.
 port_command(Socket, Data, [nosuspend]) | {send_timeout, 5000}     | Return false first, and true after timeout. Drop the packets silently.
 
-## Conclusions
+Conclusions:
 
 1. Should set the `send_timeout` option if using `gen_tcp:send`
 2. Should not set the `nosuspend` option if using `port_command`, for the busy sock will be killed at once.
 
+## udp
+
+Start the UDP echo server which listens on port 5000.
+
+```
+udp_echo_server:start(5000).
+```
+

examples/active_n/README

@@ -17,37 +17,41 @@
 %% @doc Async Recv Echo Server.
 -module(async_recv_echo_server).
 
--include("../../../include/esockd.hrl").
+-include("esockd.hrl").
 
 -behaviour(gen_server).
 
 %% start
--export([start/0, start/1]).
+-export([start/1]).
 
 -export([start_link/2]).
 
 %% gen_server Function Exports
--export([init/1, handle_call/3, handle_cast/2, handle_info/2,
-         terminate/2, code_change/3]).
+-export([ init/1
+        , handle_call/3
+        , handle_cast/2
+        , handle_info/2
+        , terminate/2
+        , code_change/3
+        ]).
 
 -record(state, {transport, socket}).
 
-start() -> start(5000).
-start([Port]) when is_atom(Port) ->
-    start(list_to_integer(atom_to_list(Port)));
-start(Port) when is_integer(Port) ->
-    [{ok, _} =  application:ensure_all_started(App)
-     || App <- [crypto, ssl, esockd]],
+start(Port) ->
+    ok = esockd:start(),
     TcpOpts = [binary,
                {reuseaddr, true},
                {backlog, 512},
-               {nodelay, false}],
+               {nodelay, false}
+              ],
     SslOpts = [{certfile, "./crt/demo.crt"},
-               {keyfile,  "./crt/demo.key"}],
+               {keyfile,  "./crt/demo.key"}
+              ],
     Options = [{acceptors, 8},
                {max_connections, 100000},
                {tcp_options, TcpOpts},
-               {ssl_options, SslOpts}],
+               {ssl_options, SslOpts}
+              ],
     MFArgs = {?MODULE, start_link, []},
     esockd:open(echo, Port, Options, MFArgs).
 

examples/async_recv/Makefile

@@ -17,14 +17,10 @@
 %% @doc Echo test client
 -module(echo_client).
 
--export([start/1, start/3, send/2, run/4, connect/4, loop/2]).
+-export([start/3, send/2, run/4, connect/4, loop/2]).
 
 -define(TCP_OPTIONS, [binary, {packet, raw}, {active, true}]).
 
-%%shell
-start([Host, Port, Num]) when is_atom(Host), is_atom(Port), is_atom(Num) ->
-    start(atom_to_list(Host), a2i(Port), a2i(Num)).
-
 start(Host, Port, Num) ->
     spawn(?MODULE, run, [self(), Host, Port, Num]),
     mainloop(1).
@@ -72,5 +68,3 @@ loop(Num, Sock) ->
 send(N, Sock) ->
     gen_tcp:send(Sock, [integer_to_list(N), ":", <<"Hello, eSockd!">>]).
 
-a2i(A) -> list_to_integer(atom_to_list(A)).
-