fluent
diff --git a/‎src/main/java/org/fluentd/logger/sender/RawSocketSender.java
Copy file name to clipboardExpand all lines: src/main/java/org/fluentd/logger/sender/RawSocketSender.java
+2-1Lines changed: 2 additions & 1 deletion b/‎src/main/java/org/fluentd/logger/sender/RawSocketSender.java
Copy file name to clipboardExpand all lines: src/main/java/org/fluentd/logger/sender/RawSocketSender.java
+2-1Lines changed: 2 additions & 1 deletion
@@ -152,6 +152,8 @@ private boolean flushBuffer() {
             flush();
             if (pendings.position() == 0) {
                 return true;
+            } else {
+                LOG.error("Cannot send logs to " + server.toString());
             }
         }
 
@@ -162,7 +164,6 @@ private synchronized boolean send(byte[] bytes) {
         // buffering
         if (pendings.position() + bytes.length > pendings.capacity()) {
             if (!flushBuffer()) {
-                LOG.error("Cannot send logs to " + server.toString());
                 return false;
             }
         }
Original file line number	Diff line number	Diff line change
`@@ -152,6 +152,8 @@ private boolean flushBuffer() {`
`152`	`152`	`flush();`
`153`	`153`	`if (pendings.position() == 0) {`
`154`	`154`	`return true;`
	`155`	`+ } else {`
	`156`	`+ LOG.error("Cannot send logs to " + server.toString());`
`155`	`157`	`}`
`156`	`158`	`}`
`157`	`159`
`@@ -162,7 +164,6 @@ private synchronized boolean send(byte[] bytes) {`
`162`	`164`	`// buffering`
`163`	`165`	`if (pendings.position() + bytes.length > pendings.capacity()) {`
`164`	`166`	`if (!flushBuffer()) {`
`165`		`- LOG.error("Cannot send logs to " + server.toString());`
`166`	`167`	`return false;`
`167`	`168`	`}`
`168`	`169`	`}`