| | |
| | | -author("bin.shen"). |
| | | |
| | | %% API |
| | | -export([doWork/2]). |
| | | -import(tcp_server, [loop/2]). |
| | | -export([doWork/3]). |
| | | -import(tcp_server, [loop/3]). |
| | | |
| | | doWork(Socket, Data) -> |
| | | doWork(Socket, Data, Count) -> |
| | | |
| | | TotalLen = byte_size(Data), |
| | | io:format("count ~p~n", [TotalLen]), |
| | | %% io:format("count ~p~n", [TotalLen]), |
| | | |
| | | if |
| | | TotalLen < 12 -> |
| | | loop(Socket, Data); |
| | | loop(Socket, Data, Count); |
| | | |
| | | true -> |
| | | <<Head:6/binary, Rest/binary>> = Data, |
| | |
| | | <<90, 0, 16, 1, 0, 1>> -> |
| | | if |
| | | Len =:= 6 -> |
| | | <<D1, D2, D3, D4, D5, D6>> = Rest, |
| | | io:format("~p~n", [<<90, 0, 16, 1, 0, 1, D1, D2, D3, D4, D5, D6>>]), |
| | | loop(Socket, <<>>); |
| | | %% <<D1, D2, D3, D4, D5, D6>> = Rest, |
| | | %% io:format("~p~n", [<<90, 0, 16, 1, 0, 1, D1, D2, D3, D4, D5, D6>>]), |
| | | loop(Socket, <<>>, Count+1); |
| | | |
| | | Len > 6 -> |
| | | <<A:6/binary, B/binary>> = Rest, |
| | | <<D1, D2, D3, D4, D5, D6>> = A, |
| | | io:format("~p~n", [<<90, 0, 16, 1, 0, 1, D1, D2, D3, D4, D5, D6>>]), |
| | | doWork(Socket, B); |
| | | <<_:6/binary, B/binary>> = Rest, |
| | | %% <<D1, D2, D3, D4, D5, D6>> = A, |
| | | %% io:format("~p~n", [<<90, 0, 16, 1, 0, 1, D1, D2, D3, D4, D5, D6>>]), |
| | | doWork(Socket, B, Count+1); |
| | | |
| | | true -> |
| | | loop(Socket, Data) |
| | | loop(Socket, Data, Count) |
| | | end; |
| | | |
| | | <<90, 0, 16, 1, 0, 2>> -> |