Permalink
Browse files

fix for updase/downcase in cowboy handler

  • Loading branch information...
maxlapshin committed Oct 29, 2012
1 parent 186ee31 commit c4901d37ea70761f480781af437a2e0a010119e2
Showing with 31 additions and 1 deletion.
  1. +25 −0 doc/README.md
  2. +5 −0 src/bench.erl
  3. +1 −1 src/dps_cowboy_handler.erl
View
@@ -232,4 +232,29 @@ OutRate = PublishCount / Delay
+С такими цифрами:
+8000 клиентов
+800 каналов
+2000 мс задержки
+1-3 канала у клиента
+2 ноды в кластере
+публикация на обе ноды параллельно
+
+Результат:
+
+4000 publish mps
+150000 fetch mps
+
+
+С такими цифрами:
+15000 клиентов
+800 каналов
+1-3 канала у клиента
+2 ноды в кластере
+публикация на обе ноды
+
+Результат:
+
+7500 publish mps
+150000 fetch mps
View
@@ -160,6 +160,11 @@ start_push(#state{channels = Channels, host = Host, publish_interval = Interval}
error:{badmatch,{error,closed}} ->
close_push(C),
start_push(State);
+ throw:{invalid_push_response, Code, _Headers, _} ->
+ close_push(C),
+ io:format("Error response: ~p~n", [Code]),
+ timer:sleep(500),
+ start_push(State);
Class:Error ->
io:format("Push ~p:~p~n~p~n", [Class, Error, erlang:get_stacktrace()])
end.
@@ -13,7 +13,7 @@
init({tcp, http}, Req, [poll]) ->
{Upgrade, Req1} = cowboy_req:header(<<"upgrade">>, Req),
case Upgrade of
- <<"WebSocket">> ->
+ <<"websocket">> ->
{upgrade, protocol, cowboy_websocket};
undefined ->
{ok, Req1, poll}

0 comments on commit c4901d3

Please sign in to comment.