Fixed deprecation warnings introduced by Rust 1.6

Author: pierresy

src/topology/mod.rs

@@ -18,6 +18,7 @@ use std::i64;
 use std::str::FromStr;
 use std::sync::{Arc, RwLock};
 use std::thread;
+use std::time::Duration;
 use time;
 
 use self::server::{Server, ServerDescription, ServerType};
@@ -741,12 +742,12 @@ impl Topology {
                         return Err(err)
                     }
                     // Otherwise, sleep for a little while.
-                    thread::sleep_ms(500);
+                    thread::sleep(Duration::from_millis(500));
                 },
             }
-        }        
+        }
     }
-    
+
     /// Returns a server stream for read operations.
     pub fn acquire_stream(&self, read_preference: ReadPreference) -> Result<(PooledStream, bool, bool)> {
         self.acquire_stream_private(Some(read_preference), false)

src/topology/monitor.rs

@@ -15,6 +15,7 @@ use wire_protocol::flags::OpQueryFlags;
 use std::collections::BTreeMap;
 use std::sync::{Arc, Condvar, Mutex, RwLock};
 use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering};
+use std::time::Duration;
 
 use time;
 
@@ -348,8 +349,8 @@ impl Monitor {
                                                   Ordering::SeqCst);
             }
 
-            let frequency = self.heartbeat_frequency_ms.load(Ordering::SeqCst) as u32;
-            guard = self.condvar.wait_timeout_ms(guard, frequency).unwrap().0;
+            let frequency = self.heartbeat_frequency_ms.load(Ordering::SeqCst) as u64;
+            guard = self.condvar.wait_timeout(guard, Duration::from_millis(frequency)).unwrap().0;
         }
     }
 }