root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

cosmetic

This commit is contained in:
Matthias Radestock 2012-05-30 10:04:53 +01:00
parent 000d40a31b
commit 568724161f
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
deps/rabbitmq_stomp/src/rabbit_stomp_frame.erl vendored
View File

@ -33,11 +33,11 @@ initial_state() -> none.
parse(Content, {resume, Fun}) -> Fun(Content); parse(Content, {resume, Fun}) -> Fun(Content);
parse(Content, none) -> parse_command(Content, []). parse(Content, none) -> parse_command(Content, []).
parse_command(<<$\n, Rest/binary>>, []) -> parse_command(<<$\n, Rest/binary>>, []) ->
parse_command(Rest, []); parse_command(Rest, []);
parse_command(<<$\r, Rest/binary>>, Acc) -> parse_command(<<$\r, Rest/binary>>, Acc) ->
parse_command(Rest, Acc); parse_command(Rest, Acc);
parse_command(<<0, Rest/binary>>, []) -> parse_command(<<0, Rest/binary>>, []) ->
parse_command(Rest, []); parse_command(Rest, []);
parse_command(<<$\n, Rest/binary>>, Acc) -> parse_command(<<$\n, Rest/binary>>, Acc) ->
parse_headers(Rest, #stomp_frame{command = lists:reverse(Acc)}, [], []); parse_headers(Rest, #stomp_frame{command = lists:reverse(Acc)}, [], []);
@ -75,11 +75,9 @@ parse_header_value(<<$\n, Rest/binary>>, Frame, HeaderAcc, KeyAcc, ValAcc) ->
HeaderAcc] HeaderAcc]
end, end,
parse_headers(Rest, Frame, NewHeaders, []); parse_headers(Rest, Frame, NewHeaders, []);
parse_header_value(<<$\\, Rest/binary>>, Frame, parse_header_value(<<$\\, Rest/binary>>, Frame, HeaderAcc, KeyAcc, ValAcc) ->
HeaderAcc, KeyAcc, ValAcc) ->
parse_header_value_escape(Rest, Frame, HeaderAcc, KeyAcc, ValAcc); parse_header_value_escape(Rest, Frame, HeaderAcc, KeyAcc, ValAcc);
parse_header_value(<<Ch:8, Rest/binary>>, Frame, HeaderAcc, KeyAcc, parse_header_value(<<Ch:8, Rest/binary>>, Frame, HeaderAcc, KeyAcc, ValAcc) ->
ValAcc) ->
parse_header_value(Rest, Frame, HeaderAcc, KeyAcc, [Ch | ValAcc]). parse_header_value(Rest, Frame, HeaderAcc, KeyAcc, [Ch | ValAcc]).
parse_header_value_escape(<<>>, Frame, HeaderAcc, KeyAcc, ValAcc) -> parse_header_value_escape(<<>>, Frame, HeaderAcc, KeyAcc, ValAcc) ->