blob: a9f69e2631ba68687d1bfb365da6a9caa9edc531 (
plain)
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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
/*
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*
*/
/**
* \file time_ns.h
*
* Qpid asynchronous store plugin library
*
* Messaging journal time struct mrg::journal::time_ns, derived from
* the timespec struct and provided with helper functions.
*
* \author Kim van der Riet
*/
#ifndef QPID_LEGACYSTORE_JRNL_TIME_NS_H
#define QPID_LEGACYSTORE_JRNL_TIME_NS_H
#include <cerrno>
#include <ctime>
#include <string>
namespace mrg
{
namespace journal
{
struct time_ns : public timespec
{
inline time_ns() { tv_sec = 0; tv_nsec = 0; }
inline time_ns(const std::time_t sec, const long nsec = 0) { tv_sec = sec; tv_nsec = nsec; }
inline time_ns(const time_ns& t) { tv_sec = t.tv_sec; tv_nsec = t.tv_nsec; }
inline void set_zero() { tv_sec = 0; tv_nsec = 0; }
inline bool is_zero() const { return tv_sec == 0 && tv_nsec == 0; }
inline int now() { if(::clock_gettime(CLOCK_REALTIME, this)) return errno; return 0; }
const std::string str(int precision = 6) const;
inline time_ns& operator=(const time_ns& rhs)
{ tv_sec = rhs.tv_sec; tv_nsec = rhs.tv_nsec; return *this; }
inline time_ns& operator+=(const time_ns& rhs)
{
tv_nsec += rhs.tv_nsec;
if (tv_nsec >= 1000000000L) { tv_sec++; tv_nsec -= 1000000000L; }
tv_sec += rhs.tv_sec;
return *this;
}
inline time_ns& operator+=(const long ns)
{
tv_nsec += ns;
if (tv_nsec >= 1000000000L) { tv_sec++; tv_nsec -= 1000000000L; }
return *this;
}
inline time_ns& operator-=(const long ns)
{
tv_nsec -= ns;
if (tv_nsec < 0) { tv_sec--; tv_nsec += 1000000000L; }
return *this;
}
inline time_ns& operator-=(const time_ns& rhs)
{
tv_nsec -= rhs.tv_nsec;
if (tv_nsec < 0) { tv_sec--; tv_nsec += 1000000000L; }
tv_sec -= rhs.tv_sec;
return *this;
}
inline const time_ns operator+(const time_ns& rhs)
{ time_ns t(*this); t += rhs; return t; }
inline const time_ns operator-(const time_ns& rhs)
{ time_ns t(*this); t -= rhs; return t; }
inline bool operator==(const time_ns& rhs)
{ return tv_sec == rhs.tv_sec && tv_nsec == rhs.tv_nsec; }
inline bool operator!=(const time_ns& rhs)
{ return tv_sec != rhs.tv_sec || tv_nsec != rhs.tv_nsec; }
inline bool operator>(const time_ns& rhs)
{ if(tv_sec == rhs.tv_sec) return tv_nsec > rhs.tv_nsec; return tv_sec > rhs.tv_sec; }
inline bool operator>=(const time_ns& rhs)
{ if(tv_sec == rhs.tv_sec) return tv_nsec >= rhs.tv_nsec; return tv_sec >= rhs.tv_sec; }
inline bool operator<(const time_ns& rhs)
{ if(tv_sec == rhs.tv_sec) return tv_nsec < rhs.tv_nsec; return tv_sec < rhs.tv_sec; }
inline bool operator<=(const time_ns& rhs)
{ if(tv_sec == rhs.tv_sec) return tv_nsec <= rhs.tv_nsec; return tv_sec <= rhs.tv_sec; }
};
} // namespace journal
} // namespace mrg
#endif // ifndef QPID_LEGACYSTORE_JRNL_TIME_NS_H
|
