| 251 | } |
| 252 | |
| 253 | pub fn set_current_version_implicit( |
| 254 | &self, |
| 255 | version: VersionNumber, |
| 256 | epoch_id: u32, |
| 257 | ) -> lmdb::Result<()> { |
| 258 | let mut txn = self.env.begin_rw_txn()?; |
| 259 | let current_version_key = key!(m:current_version); |
| 260 | let version_key = key!(v:version); |
| 261 | |
| 262 | let version_info = VersionInfo::new_implicit(version, epoch_id, Utc::now(), 0, 0, 0); |
| 263 | let version_info_serialized = version_info.serialize(); |
| 264 | |
| 265 | txn.put( |
| 266 | self.db, |
| 267 | ¤t_version_key, |
| 268 | &version.to_le_bytes(), |
| 269 | WriteFlags::empty(), |
| 270 | )?; |
| 271 | txn.put( |
| 272 | self.db, |
| 273 | &version_key, |
| 274 | &version_info_serialized, |
| 275 | WriteFlags::empty(), |
| 276 | )?; |
| 277 | |
| 278 | txn.commit()?; |
| 279 | Ok(()) |
| 280 | } |
| 281 | |
| 282 | pub fn update_version_metadata( |
| 283 | &self, |