lib/fluent/plugin/input_session.rb in fluent-plugin-secure-forward-0.4.2 vs lib/fluent/plugin/input_session.rb in fluent-plugin-secure-forward-0.4.3

- old
+ new

@@ -70,11 +70,11 @@ # ['PING', self_hostname, shared_key\_salt, sha512\_hex(shared_key\_salt + self_hostname + nonce + shared_key), # username || '', sha512\_hex(auth\_salt + username + password) || ''] unless message.size == 6 && message[0] == 'PING' return false, 'invalid ping message' end - ping, hostname, shared_key_salt, shared_key_hexdigest, username, password_digest = message + _ping, hostname, shared_key_salt, shared_key_hexdigest, username, password_digest = message shared_key = if @node && @node[:shared_key] @node[:shared_key] else @receiver.shared_key @@ -154,10 +154,10 @@ log.debug "failed to establish ssl session", error_class: e.class, error: e self.shutdown return end - proto, port, host, ipaddr = @socket.io.peeraddr + _proto, port, host, ipaddr = @socket.io.peeraddr @node = check_node(ipaddr) if @node.nil? && (! @receiver.allow_anonymous_source) log.warn "Connection required from unknown host '#{host}' (#{ipaddr}), disconnecting..." self.shutdown return