Skip to content

Commit

Permalink
Merge pull request #743 from skippy/standardize-input-logging
Browse files Browse the repository at this point in the history
standardize logging level for source configs
  • Loading branch information
repeatedly committed Dec 10, 2015
2 parents 0383404 + 0a3203f commit 2f99635
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion lib/fluent/plugin/in_stream.rb
Original file line number Diff line number Diff line change
Expand Up @@ -179,7 +179,7 @@ def listen
File.unlink(@path)
end
FileUtils.mkdir_p File.dirname(@path)
log.debug "listening fluent socket on #{@path}"
log.info "listening fluent socket on #{@path}"
s = Coolio::UNIXServer.new(@path, Handler, log, method(:on_message))
s.listen(@backlog) unless @backlog.nil?
s
Expand Down
2 changes: 1 addition & 1 deletion lib/fluent/plugin/in_syslog.rb
Original file line number Diff line number Diff line change
Expand Up @@ -173,7 +173,7 @@ def receive_data(data, addr)
private

def listen(callback)
log.debug "listening syslog socket on #{@bind}:#{@port} with #{@protocol_type}"
log.info "listening syslog socket on #{@bind}:#{@port} with #{@protocol_type}"
if @protocol_type == :udp
@usock = SocketUtil.create_udp_socket(@bind)
@usock.bind(@bind, @port)
Expand Down
2 changes: 1 addition & 1 deletion lib/fluent/plugin/in_tcp.rb
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ class TcpInput < SocketUtil::BaseInput
config_param :delimiter, :string, :default => "\n" # syslog family add "\n" to each message and this seems only way to split messages in tcp stream

def listen(callback)
log.debug "listening tcp socket on #{@bind}:#{@port}"
log.info "listening tcp socket on #{@bind}:#{@port}"
Coolio::TCPServer.new(@bind, @port, SocketUtil::TcpHandler, log, @delimiter, callback)
end
end
Expand Down
2 changes: 1 addition & 1 deletion lib/fluent/plugin/in_udp.rb
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ class UdpInput < SocketUtil::BaseInput
config_param :body_size_limit, :size, :default => 4096

def listen(callback)
log.debug "listening udp socket on #{@bind}:#{@port}"
log.info "listening udp socket on #{@bind}:#{@port}"
@usock = SocketUtil.create_udp_socket(@bind)
@usock.bind(@bind, @port)
SocketUtil::UdpHandler.new(@usock, log, @body_size_limit, callback)
Expand Down

0 comments on commit 2f99635

Please sign in to comment.