lib/fluent/plugin/input_session.rb in fluent-plugin-secure-forward-0.1.7 vs lib/fluent/plugin/input_session.rb in fluent-plugin-secure-forward-0.1.8

@@ -148,10 +148,10 @@
       $log.debug "failed to establish ssl session"
       self.shutdown
       return
     end
 
-    proto, port, host, ipaddr = @socket.io.addr
+    proto, port, host, ipaddr = @socket.io.peeraddr
     @node = check_node(host, ipaddr, port, proto)
     if @node.nil? && (! @receiver.allow_anonymous_source)
       $log.warn "Connection required from unknown host '#{host}' (#{ipaddr}), disconnecting..."
       self.shutdown
       return