umgeher/cowboy
0
Fork 0
mirror of https://github.com/ninenines/cowboy.git synced 2025-07-14 12:20:24 +00:00
Code Issues Wiki Activity

Compile the binary match pattern for websockets only once.

Browse source
This commit is contained in:
Loïc Hoguin 2011-06-06 13:48:41 +02:00
parent 919fa638ee
commit 2fa1e53928
1 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

10
src/cowboy_http_websocket.erl
View file

@ -23,12 +23,14 @@
origin = undefined :: undefined | binary(), origin = undefined :: undefined | binary(),
challenge = undefined :: undefined | binary(), challenge = undefined :: undefined | binary(),
timeout = infinity :: timeout(), timeout = infinity :: timeout(),
messages = undefined :: undefined | {atom(), atom(), atom()} messages = undefined :: undefined | {atom(), atom(), atom()},
eop :: tuple()
}). }).
-spec upgrade(module(), any(), #http_req{}) -> ok. -spec upgrade(module(), any(), #http_req{}) -> ok.
upgrade(Handler, Opts, Req) -> upgrade(Handler, Opts, Req) ->
case catch websocket_upgrade(#state{handler=Handler, opts=Opts}, Req) of EOP = binary:compile_pattern(<< 255 >>),
case catch websocket_upgrade(#state{handler=Handler, opts=Opts, eop=EOP}, Req) of
{ok, State, Req2} -> handler_init(State, Req2); {ok, State, Req2} -> handler_init(State, Req2);
{'EXIT', _Reason} -> upgrade_error(Req) {'EXIT', _Reason} -> upgrade_error(Req)
end. end.
@ -135,8 +137,8 @@ websocket_data(State, Req, HandlerState, Data) ->
%% We do not support any frame type other than 0 yet. Just like the specs. %% We do not support any frame type other than 0 yet. Just like the specs.
-spec websocket_frame(#state{}, #http_req{}, any(), binary(), byte()) -> ok. -spec websocket_frame(#state{}, #http_req{}, any(), binary(), byte()) -> ok.
websocket_frame(State, Req, HandlerState, Data, 0) -> websocket_frame(State=#state{eop=EOP}, Req, HandlerState, Data, 0) ->
case binary:match(Data, << 255 >>) of case binary:match(Data, EOP) of
{Pos, 1} -> {Pos, 1} ->
Pos2 = Pos - 1, Pos2 = Pos - 1,
<< 0, Frame:Pos2/binary, 255, Rest/bits >> = Data, << 0, Frame:Pos2/binary, 255, Rest/bits >> = Data,