emit now returns success/failure value

Author: repeatedly

fluent/handler.py

@@ -106,7 +106,7 @@ def __init__(self,
 
     def emit(self, record):
         data = self.format(record)
-        self.sender.emit(None, data)
+        return self.sender.emit(None, data)
 
     def close(self):
         self.acquire()

fluent/sender.py

@@ -61,7 +61,7 @@ def __init__(self,
 
     def emit(self, label, data):
         cur_time = int(time.time())
-        self.emit_with_time(label, cur_time, data)
+        return self.emit_with_time(label, cur_time, data)
 
     def emit_with_time(self, label, timestamp, data):
         try:
@@ -71,7 +71,7 @@ def emit_with_time(self, label, timestamp, data):
                                        {"level": "CRITICAL",
                                         "message": "Can't output to log",
                                         "traceback": traceback.format_exc()})
-        self._send(bytes_)
+        return self._send(bytes_)
 
     def close(self):
         self.lock.acquire()
@@ -101,7 +101,7 @@ def _make_packet(self, label, timestamp, data):
     def _send(self, bytes_):
         self.lock.acquire()
         try:
-            self._send_internal(bytes_)
+            return self._send_internal(bytes_)
         finally:
             self.lock.release()
 
@@ -116,16 +116,21 @@ def _send_internal(self, bytes_):
 
             # send finished
             self.pendings = None
+
+            return True
         except socket.error as e:
             # close socket
             self._close()
+
             # clear buffer if it exceeds max bufer size
             if self.pendings and (len(self.pendings) > self.bufmax):
                 self._call_buffer_overflow_handler(self.pendings)
                 self.pendings = None
             else:
                 self.pendings = bytes_
 
+            return False
+
     def _send_data(self, bytes_):
         # reconnect if possible
         self._reconnect()