arzmq-sys 0.6.3

Low-level bindings to the zeromq library
Documentation 
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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

/**
* @file protoTime.cpp 
* 
* @brief Provides parsing and comparison time operations.
 
*/
#include "protoTime.h"
#include "protoDebug.h"

#ifndef SIMULATE
static const ProtoTime PROTO_TIME_INIT = ProtoTime().GetCurrentTime();
#else
static const ProtoTime PROTO_TIME_INIT(0);
#endif

ProtoTime::ProtoTime()
{
    tval.tv_sec = tval.tv_usec = 0;
}

ProtoTime::ProtoTime(const struct timeval& timeVal)
 : tval(timeVal)
{
}

ProtoTime::ProtoTime(double seconds)
{
    tval.tv_sec = (time_t)seconds;
    tval.tv_usec = (suseconds_t)(1.0e+06 * (seconds - ((double)tval.tv_sec)));
}

ProtoTime::ProtoTime(unsigned long sec, unsigned long usec)
{
    tval.tv_sec = (time_t)sec;
    tval.tv_usec = (suseconds_t)usec;
}

void ProtoTime::operator+=(const ProtoTime& t)
{
    tval.tv_sec += t.sec();
    tval.tv_usec += t.usec();
    if (tval.tv_usec >= 1000000)
    {
        tval.tv_sec++;
        tval.tv_usec -= 1000000;
    }
}  // end ProtoTime::operator+=() 

void ProtoTime::operator+=(double value)
{
    if (value >= 0.0)
    {
        time_t sec = (time_t)value;
        suseconds_t usec = (suseconds_t)(1.0e+06*(value - (double)sec) + 0.5);
        tval.tv_sec += sec;
        tval.tv_usec += usec;
        if (tval.tv_usec  >= 1000000)
        {
            tval.tv_sec += 1;
            tval.tv_usec -= 1000000;
        }
    }
    else
    {   
        value = -value;
        time_t sec = (time_t)value;
        if (tval.tv_sec >= sec)
        {
            tval.tv_sec -= sec;
            suseconds_t usec = (suseconds_t)(1.0e+06*(value - (double)sec) + 0.5);
            if (tval.tv_usec >= usec)
            {
                tval.tv_usec -= usec;
                return;
            }
            else if (tval.tv_sec > 0)
            {
                tval.tv_sec -= 1;
                tval.tv_usec = usec - tval.tv_usec;
                return;
            }
        }
        tval.tv_sec = 0;
        tval.tv_usec = 0;
    }
}  // end ProtoTime::operator+=() 

double ProtoTime::GetOffsetValue() const
{
    return ProtoTime::Delta(*this, PROTO_TIME_INIT);
}

double ProtoTime::Delta(const ProtoTime& t1, const ProtoTime& t2)
{
    // (TBD) perhaps we should have "long" instead "unsigned long"
    // sec()/usec() methods to simplify this?
    double delta = (t1.sec() >= t2.sec()) ?
                        (double)(t1.sec() - t2.sec()) :
                        -(double)(t2.sec() - t1.sec());
	if (t1.usec() > t2.usec())
		delta += 1.0e-06 * (double)(t1.usec() - t2.usec());
	else
		delta -= 1.0e-06 * (double)(t2.usec() - t1.usec());
    return delta;
}  // end ProtoTime::Delta()


#ifdef WIN32
// These are state variables that are needed to manage
// use of the WIN32 High Performance Counter to get more
// precise timing (needed for WinCE)
bool proto_performance_counter_init = false;
LARGE_INTEGER proto_performance_counter_frequency = {0, 0};
#ifdef USE_PERFORMANCE_COUNTER
//#ifdef _WIN32_WCE
long proto_performance_counter_offset = 0;
long proto_system_time_last_sec = 0;
unsigned long proto_system_count_roll_sec = 0;
LARGE_INTEGER proto_system_count_last = {0, 0};
#endif // USE_PERFORMANCE_COUNTER
//#endif // _WIN32_WCE
#endif // WIN32