1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
# frozen_string_literal: true
module MessagePack
class Timestamp # a.k.a. "TimeSpec"
# Because the byte-order of MessagePack is big-endian in,
# pack() and unpack() specifies ">".
# See https://docs.ruby-lang.org/en/trunk/Array.html#method-i-pack for details.
# The timestamp extension type defined in the MessagePack spec.
# See https://github.com/msgpack/msgpack/blob/master/spec.md#timestamp-extension-type for details.
TYPE = -1
TIMESTAMP32_MAX_SEC = (1 << 32) - 1
TIMESTAMP64_MAX_SEC = (1 << 34) - 1
# @return [Integer]
attr_reader :sec
# @return [Integer]
attr_reader :nsec
# @param [Integer] sec
# @param [Integer] nsec
def initialize(sec, nsec)
@sec = sec
@nsec = nsec
end
def self.from_msgpack_ext(data)
case data.length
when 4
# timestamp32 (sec: uint32be)
sec, = data.unpack('L>')
new(sec, 0)
when 8
# timestamp64 (nsec: uint30be, sec: uint34be)
n, s = data.unpack('L>2')
sec = ((n & 0b11) << 32) | s
nsec = n >> 2
new(sec, nsec)
when 12
# timestam96 (nsec: uint32be, sec: int64be)
nsec, sec = data.unpack('L>q>')
new(sec, nsec)
else
raise MalformedFormatError, "Invalid timestamp data size: #{data.length}"
end
end
def self.to_msgpack_ext(sec, nsec)
if sec >= 0 && nsec >= 0 && sec <= TIMESTAMP64_MAX_SEC
if nsec === 0 && sec <= TIMESTAMP32_MAX_SEC
# timestamp32 = (sec: uint32be)
[sec].pack('L>')
else
# timestamp64 (nsec: uint30be, sec: uint34be)
nsec30 = nsec << 2
sec_high2 = sec >> 32 # high 2 bits (`x & 0b11` is redandunt)
sec_low32 = sec & 0xffffffff # low 32 bits
[nsec30 | sec_high2, sec_low32].pack('L>2')
end
else
# timestamp96 (nsec: uint32be, sec: int64be)
[nsec, sec].pack('L>q>')
end
end
def to_msgpack_ext
self.class.to_msgpack_ext(sec, nsec)
end
def ==(other)
other.class == self.class && sec == other.sec && nsec == other.nsec
end
end
end
|
