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
|
//
// Copyright 2016 Garrett D'Amore <garrett@damore.org>
//
// This software is supplied under the terms of the MIT License, a
// copy of which should be located in the distribution where this
// file was obtained (LICENSE.txt). A copy of the license may also be
// found online at https://opensource.org/licenses/MIT.
//
#include "convey.h"
#include "nng.h"
#include "core/nng_impl.h"
#ifndef _WIN32
#include <sys/time.h>
#endif
uint64_t getms(void) {
#ifdef _WIN32
return (GetTickCount()) ;
#else
static time_t epoch;
struct timeval tv;
if (epoch == 0) {
epoch = time(NULL);
}
gettimeofday(&tv, NULL);
if (tv.tv_sec < epoch) {
// Broken clock.
// This will force all other timing tests to fail
return (0);
}
tv.tv_sec -= epoch;
return (((uint64_t)(tv.tv_sec ) * 1000) + (tv.tv_usec / 1000));
#endif
}
TestMain("Platform Operations", {
int rv = nni_init(); // This is required for anything else to work
Convey("Platform init worked", {
So(rv == 0);
})
Convey("The clock works", {
uint64_t now = getms();
Convey("usleep works", {
nni_usleep(100000);
So((getms() - now) > 100); // cannot be *shorter*!!
So((getms() - now) < 150); // crummy clock resolution?
})
Convey("times work", {
uint64_t msend;
int usdelta;
int msdelta;
nni_time usend;
nni_time usnow = nni_clock();
nni_usleep(200000);
usend = nni_clock();
msend = getms();
So(usend > usnow);
So(msend > now);
usdelta = (int)((usend - usnow) / 1000);
msdelta = (int)((msend - now));
So(usdelta > 200);
So(usdelta < 220);
So(abs(msdelta - usdelta) < 20);
})
})
Convey("Mutexes work", {
nni_mutex mx;
int rv;
rv = nni_mutex_init(&mx);
So(rv == 0);
Convey("We can lock a mutex", {
nni_mutex_enter(&mx);
So(1);
Convey("And cannot recursively lock", {
rv = nni_mutex_tryenter(&mx);
So(rv != 0);
})
Convey("And we can unlock it", {
nni_mutex_exit(&mx);
So(1);
Convey("And then lock it again", {
rv = nni_mutex_tryenter(&mx);
So(rv == 0);
})
})
})
Convey("We can finalize it", {
nni_mutex_fini(&mx);
})
})
})
|
