Merge pull request #4 from OneSignal/marked-bad-reason

Require a reason for `marked_bad` server fn

Author: nicolasvan

src/client.rs

@@ -1448,7 +1448,7 @@ where
                         match write_all_flush(&mut self.write, &response).await {
                             Ok(_) => (),
                             Err(err) => {
-                                server.mark_bad();
+                                server.mark_bad(err.clone().to_string().as_str());
                                 return Err(err);
                             }
                         };
@@ -1650,7 +1650,7 @@ where
             match write_all_flush(&mut self.write, &response).await {
                 Ok(_) => (),
                 Err(err) => {
-                    server.mark_bad();
+                    server.mark_bad(err.clone().to_string().as_str());
                     return Err(err);
                 }
             };
@@ -1713,11 +1713,13 @@ where
                     }
                 },
                 Err(_) => {
-                    error!(
-                        "Statement timeout while talking to {:?} with user {}",
-                        address, pool.settings.user.username
+                    server.mark_bad(
+                        format!(
+                            "Statement timeout while talking to {:?} with user {}",
+                            address, pool.settings.user.username
+                        )
+                        .as_str(),
                     );
-                    server.mark_bad();
                     pool.ban(address, BanReason::StatementTimeout, Some(client_stats));
                     error_response_terminal(&mut self.write, "pool statement timeout").await?;
                     Err(Error::StatementTimeout)

src/mirrors.rs

@@ -82,8 +82,10 @@ impl MirroredClient {
                         match recv_result {
                             Ok(message) => trace!("Received from mirror: {} {:?}", String::from_utf8_lossy(&message[..]), address.clone()),
                             Err(err) => {
-                                server.mark_bad();
-                                error!("Failed to receive from mirror {:?} {:?}", err, address.clone());
+                                server.mark_bad(
+                                    format!("Failed to receive from mirror {:?} {:?}", err, address.clone()).as_str()
+                                );
+
                             }
                         }
                     }
@@ -95,8 +97,10 @@ impl MirroredClient {
                                 match server.send(&BytesMut::from(&bytes[..])).await {
                                     Ok(_) => trace!("Sent to mirror: {} {:?}", String::from_utf8_lossy(&bytes[..]), address.clone()),
                                     Err(err) => {
-                                        server.mark_bad();
-                                        error!("Failed to send to mirror, Discarding message {:?}, {:?}", err, address.clone())
+                                        server.mark_bad(
+                                            format!("Failed to send to mirror, Discarding message {:?}, {:?}", err, address.clone()).as_str()
+                                        );
+
                                     }
                                 }
                             }

src/pool.rs

@@ -746,7 +746,7 @@ impl ConnectionPool {
         }
 
         // Don't leave a bad connection in the pool.
-        server.mark_bad();
+        server.mark_bad("failed health check");
 
         self.ban(&address, BanReason::FailedHealthCheck, Some(client_info));
         return false;

src/server.rs

@@ -1092,8 +1092,8 @@ impl Server {
     }
 
     /// Indicate that this server connection cannot be re-used and must be discarded.
-    pub fn mark_bad(&mut self) {
-        error!("Server {:?} marked bad", self.address);
+    pub fn mark_bad(&mut self, reason: &str) {
+        error!("Server {:?} marked bad, reason: {}", self.address, reason);
         self.bad = true;
     }