aboutsummaryrefslogtreecommitdiff
path: root/src/mod_proxy65/mod_proxy65_stream.erl
diff options
context:
space:
mode:
authorAlexey Shchepin <alexey@process-one.net>2007-02-22 05:03:51 +0000
committerAlexey Shchepin <alexey@process-one.net>2007-02-22 05:03:51 +0000
commit6dc78ef0b5a9fd9198c3e7eedbb1092b5e87026d (patch)
treed4b319bde7cd23f3d090498cb10c146cb7dad429 /src/mod_proxy65/mod_proxy65_stream.erl
parent* src/ejabberd_c2s.erl: Init shaper with a default value first (diff)
* src/mod_proxy65/mod_proxy65_sm.erl: Cluster support (thanks to
Evgeniy Khramtsov) * src/mod_proxy65/mod_proxy65_stream.erl: Code cleanup (thanks to Evgeniy Khramtsov) * src/mod_proxy65/mod_proxy65.hrl: Fixed typo (thanks to Evgeniy Khramtsov) SVN Revision: 736
Diffstat (limited to '')
-rw-r--r--src/mod_proxy65/mod_proxy65_stream.erl9
1 files changed, 4 insertions, 5 deletions
diff --git a/src/mod_proxy65/mod_proxy65_stream.erl b/src/mod_proxy65/mod_proxy65_stream.erl
index 1f4a75dd8..1a1503384 100644
--- a/src/mod_proxy65/mod_proxy65_stream.erl
+++ b/src/mod_proxy65/mod_proxy65_stream.erl
@@ -51,8 +51,7 @@
sha1, %% SHA1 key
host, %% virtual host
auth_type, %% authentication type: anonymous or plain
- shaper, %% Shaper name
- active = false %% Activity flag
+ shaper %% Shaper name
}).
%% Unused callbacks
@@ -83,9 +82,9 @@ init([Socket, Host, Opts]) ->
shaper = Shaper,
timer = TRef}}.
-terminate(_Reason, _StateName, #state{sha1=SHA1,active=Flag}) ->
+terminate(_Reason, StateName, #state{sha1=SHA1}) ->
catch mod_proxy65_sm:unregister_stream(SHA1),
- if Flag==true ->
+ if StateName == stream_established ->
?INFO_MSG("Bytestream terminated", []);
true ->
ok
@@ -199,7 +198,7 @@ handle_info({activate, PeerPid, PeerSocket, IJid, TJid},
Host = StateData#state.host,
MaxRate = find_maxrate(Shaper, IJid, TJid, Host),
spawn_link(?MODULE, relay, [MySocket, PeerSocket, MaxRate]),
- {next_state, stream_established, StateData#state{active=true}};
+ {next_state, stream_established, StateData};
%% Socket closed
handle_info({tcp_closed, _Socket}, _StateName, StateData) ->