yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Reset peerport

This commit is contained in:
terry-xiaoyu 2019-09-20 22:57:01 +08:00
parent 8ef7f04d26
commit ab9d7232a9
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/emqx_channel.erl
View File

@ -172,7 +172,7 @@ set_field(Name, Val, Channel) ->
%%--------------------------------------------------------------------
-spec(init(emqx_types:conninfo(), proplists:proplist()) -> channel()).
init(ConnInfo = #{peername := {PeerHost, PeerPort}}, Options) ->
init(ConnInfo = #{peername := {PeerHost, _Port}}, Options) ->
Zone = proplists:get_value(zone, Options),
Peercert = maps:get(peercert, ConnInfo, undefined),
Username = case peer_cert_as_username(Options) of
@ -184,7 +184,6 @@ init(ConnInfo = #{peername := {PeerHost, PeerPort}}, Options) ->
MountPoint = emqx_zone:get_env(Zone, mountpoint),
ClientInfo = #{zone => Zone,
peerhost => PeerHost,
peerport => PeerPort,
peercert => Peercert,
client_id => undefined,
username => Username,