Fix treatment of leap seconds

Author: junderw

rmp/src/encode/mod.rs

@@ -136,9 +136,13 @@ pub fn write_timestamp<W: RmpWrite>(wr: &mut W, timestamp: Timestamp) -> Result<
             wr.write_data_u32(secs as u32)?;
         },
         Timestamp::T64(timedate) => {
-            let secs = timedate.timestamp();
-            let nsecs = timedate.timestamp_subsec_nanos();
-            if secs < 0 || secs > 0x3_ffff_ffff || nsecs > crate::MAX_NSECS {
+            let mut secs = timedate.timestamp();
+            let mut nsecs = timedate.timestamp_subsec_nanos();
+            if nsecs > crate::MAX_NSECS {
+                nsecs %= 1_000_000_000;
+                secs += 1;
+            }
+            if secs < 0 || secs > 0x3_ffff_ffff {
                 return Ok(false)
             }
             write_marker(wr, Marker::FixExt8).map_err(|e| e.0)?;
@@ -147,10 +151,11 @@ pub fn write_timestamp<W: RmpWrite>(wr: &mut W, timestamp: Timestamp) -> Result<
             wr.write_data_u64(data)?;
         },
         Timestamp::T96(timedate) => {
-            let secs = timedate.timestamp();
-            let nsecs = timedate.timestamp_subsec_nanos();
+            let mut secs = timedate.timestamp();
+            let mut nsecs = timedate.timestamp_subsec_nanos();
             if nsecs > crate::MAX_NSECS {
-                return Ok(false)
+                nsecs %= 1_000_000_000;
+                secs += 1;
             }
             write_marker(wr, Marker::Ext8).map_err(|e| e.0)?;
             wr.write_data_u8(12)?;