Function test_reader_new

clock-bound/src/vmclock/shm_reader.rs:402–451

()

        let vmclock_shm_tempfile = NamedTempFile::new().expect("create vmclock file failed");
        let vmclock_shm_temppath = vmclock_shm_tempfile.into_temp_path();
        let vmclock_shm_path = vmclock_shm_temppath.to_str().unwrap();
        let mut vmclock_shm_file = OpenOptions::new()
            .write(true)
            .open(vmclock_shm_path)
            .expect("open vmclock file failed");
        let vmclock_content = VMClockContent {
            magic: 0x4B4C4356,
            size: 104_u32,
            version: 1_u16,
            counter_id: 1_u8,
            time_type: 0_u8,
            seq_count: 10_u32,
            disruption_marker: 888888_u64,
            flags: 0_u64,
            _padding: [0x00, 0x00],
            clock_status: VMClockClockStatus::Synchronized,
            leap_second_smearing_hint: 0_u8,
            tai_offset_sec: 0_i16,
            leap_indicator: 0_u8,
            counter_period_shift: 0_u8,
            counter_value: 123456_u64,
            counter_period_frac_sec: 0_u64,
            counter_period_esterror_rate_frac_sec: 0_u64,
            counter_period_maxerror_rate_frac_sec: 0_u64,
            time_sec: 0_u64,
            time_frac_sec: 0_u64,
            time_esterror_nanosec: 0_u64,
            time_maxerror_nanosec: 0_u64,
        };
        write_vmclock_content(&mut vmclock_shm_file, &vmclock_content);

        let reader =
            VMClockShmReader::new(&vmclock_shm_path).expect("Failed to create VMClockShmReader");

        let version = unsafe { &*reader.version_ptr };
        let seq_count = unsafe { &*reader.seq_count_ptr };
        let vmclock_shm_body = unsafe { *reader.vmclock_shm_body_ptr };

        assert_eq!(version.load(atomic::Ordering::Relaxed), 1_u16);
        assert_eq!(seq_count.load(atomic::Ordering::Relaxed), 10_u32);
        assert_eq!(vmclock_shm_body.counter_value, 123456_u64);
        assert_eq!(
            vmclock_shm_body.clock_status,
            VMClockClockStatus::Synchronized
        );
        assert_eq!(vmclock_shm_body.disruption_marker, 888888_u64);
    }

    /// Assert that the reader will return an error when it tries to open a file that does not exist.
    #[test]
    fn test_reader_file_does_not_exist() {
        let vmclock_shm_tempfile = NamedTempFile::new().expect("create vmclock file failed");
        let vmclock_shm_temppath = vmclock_shm_tempfile.into_temp_path();