blob: a8fa59e9e61e49c21eb39b3d5bbab1ad3bba9d14 (
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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
//
// Copyright 2018 Staysail Systems, Inc. <info@staysail.tech>
// Copyright 2018 Capitar IT Group BV <info@capitar.com>
//
// 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.
//
#ifndef STUBS_H
#define STUBS_H
#ifdef _WIN32
#ifndef WIN32_LEAN_AND_MEAN
#define WIN32_LEAN_AND_MEAN
#endif
#include <windows.h>
#include <winsock2.h>
// order counts
#include <mswsock.h>
#define PLATFD SOCKET
#define poll WSAPoll
#else
#include <poll.h>
#include <stdint.h>
#include <sys/time.h>
#include <time.h>
#define PLATFD int
#endif
// Stub handlers for some common things.
uint64_t
getms(void)
{
#ifdef _WIN32
return (GetTickCount64());
#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) + (uint64_t)(tv.tv_usec / 1000));
#endif
}
bool
fdready(int fd)
{
struct pollfd pfd;
pfd.fd = (PLATFD) fd;
pfd.events = POLLRDNORM;
pfd.revents = 0;
switch (poll(&pfd, 1, 0)) {
case 0:
return (false);
case 1:
return (true);
default:
ConveyError("BAD POLL RETURN!");
return (false);
}
}
int
nosocket(nng_socket *s)
{
(void) s; // not used
ConveySkip("Protocol unconfigured");
return (NNG_ENOTSUP);
}
uint16_t
test_htons(uint16_t in)
{
#ifdef NNG_LITTLE_ENDIAN
in = ((in >> 8) & 0xff) | ((in & 0xff) << 8);
#endif
return (in);
}
#ifndef NNG_HAVE_REQ0
#define nng_req0_open nosocket
#endif
#ifndef NNG_HAVE_REP0
#define nng_rep0_open nosocket
#endif
#ifndef NNG_HAVE_PUB0
#define nng_pub0_open nosocket
#endif
#ifndef NNG_HAVE_SUB0
#define nng_sub0_open nosocket
#endif
#ifndef NNG_HAVE_PAIR0
#define nng_pair0_open nosocket
#endif
#ifndef NNG_HAVE_PAIR1
#define nng_pair1_open nosocket
#endif
#ifndef NNG_HAVE_PUSH0
#define nng_push0_open nosocket
#endif
#ifndef NNG_HAVE_PULL0
#define nng_pull0_open nosocket
#endif
#ifndef NNG_HAVE_SURVEYOR0
#define nng_surveyor0_open nosocket
#endif
#ifndef NNG_HAVE_RESPONDENT0
#define nng_respondent0_open nosocket
#endif
#ifndef NNG_HAVE_BUS0
#define nng_bus0_open nosocket
#endif
#endif // STUBS_H
|
