Navigation Menu

Skip to content

Commit

Permalink
Output log messages for FluentMessageSender with target node name always
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 7, 2015
1 parent e902dbf commit 83db9b9
Showing 1 changed file with 14 additions and 14 deletions.
28 changes: 14 additions & 14 deletions lib/droonga/fluent_message_sender.rb
Expand Up @@ -39,25 +39,25 @@ def initialize(loop, host, port, options={})
end

def start
logger.trace("start: start for #{target_node}")
logger.trace("start: done for #{target_node}")
logger.trace("start: start")
logger.trace("start: done")
end

def shutdown
logger.trace("shutdown: start for #{target_node}")
logger.trace("shutdown: start")
shutdown_socket
logger.trace("shutdown: done for #{target_node}")
logger.trace("shutdown: done")
end

def send(tag, data)
logger.trace("send: start for #{target_node}")
logger.trace("send: start")
packed_fluent_message = create_packed_fluent_message(tag, data)
unless connected?
logger.trace("send: reconnect to #{target_node}")
logger.trace("send: reconnect")
connect
end
@socket.write(packed_fluent_message)
logger.trace("send: done for #{target_node}")
logger.trace("send: done")
end

def resume
Expand All @@ -73,20 +73,20 @@ def connected?
end

def connect
logger.trace("connect: start for #{target_node}")
logger.trace("connect: start")

log_write_complete = lambda do
logger.trace("write completed for #{target_node}")
logger.trace("write completed")
end
log_connect = lambda do
logger.trace("connected to #{target_node}")
logger.trace("connected")
end
log_failed = lambda do
logger.error("failed to connect to #{target_node}")
logger.error("failed to connect")
@socket = nil
end
on_close = lambda do
logger.trace("connection to #{target_node} is closed by someone")
logger.trace("connection is closed by someone")
@socket = nil
end

Expand Down Expand Up @@ -116,7 +116,7 @@ def connect
:host => @host,
:port => @port)

logger.trace("connect: done for #{target_node}")
logger.trace("connect: done")
end

def shutdown_socket
Expand All @@ -142,7 +142,7 @@ def target_node
end

def log_tag
"[#{Process.ppid}] fluent-message-sender"
"[#{Process.ppid}] fluent-message-sender: #{target_node}"
end
end
end

0 comments on commit 83db9b9

Please sign in to comment.