class MessagePack::Timestamp
a.k.a. “TimeSpec”
def self.from_msgpack_ext(data)
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)
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 ==(other)
def ==(other) other.class == self.class && sec == other.sec && nsec == other.nsec end
def initialize(sec, nsec)
-
nsec
(Integer
) -- -
sec
(Integer
) --
def initialize(sec, nsec) @sec = sec @nsec = nsec end
def to_msgpack_ext
def to_msgpack_ext self.class.to_msgpack_ext(sec, nsec) end