blob: 4cac6beb01cf254564cd5e369c94892e87736620 (
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
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
|
//
// Copyright 2025 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 PLATFORM_POSIX_IMPL_H
#define PLATFORM_POSIX_IMPL_H
// Some dependency notes:
//
// NNG_PLATFORM_POSIX_THREAD depends on NNG_PLATFORM_POSIX_CLOCK. Also,
// when using NNG_PLATFORM_POSIX_CLOCK, your condition variable timeouts need
// to use the same base clock values. Normally these should be used
// together. Almost everything depends on NNG_PLATFORM_POSIX_DEBUG.
#ifdef NNG_PLATFORM_POSIX
#define NNG_PLATFORM_POSIX_ALLOC
#define NNG_PLATFORM_POSIX_DEBUG
#define NNG_PLATFORM_POSIX_CLOCK
#define NNG_PLATFORM_POSIX_IPC
#define NNG_PLATFORM_POSIX_TCP
#define NNG_PLATFORM_POSIX_PIPE
#define NNG_PLATFORM_POSIX_RANDOM
#define NNG_PLATFORM_POSIX_SOCKET
#define NNG_PLATFORM_POSIX_THREAD
#define NNG_PLATFORM_POSIX_PIPEDESC
#define NNG_PLATFORM_POSIX_EPDESC
#define NNG_PLATFORM_POSIX_SOCKADDR
#define NNG_PLATFORM_POSIX_UDP
#include "core/defs.h"
#include "posix_config.h"
#endif
#ifdef NNG_PLATFORM_POSIX_SOCKADDR
#include <sys/socket.h>
extern int nni_posix_sockaddr2nn(nni_sockaddr *, const void *, size_t);
extern size_t nni_posix_nn2sockaddr(void *, const nni_sockaddr *);
#endif
#ifdef NNG_PLATFORM_POSIX_DEBUG
extern int nni_plat_errno(int);
#endif
// Define types that this platform uses.
#ifdef NNG_PLATFORM_POSIX_THREAD
#include <pthread.h>
// These types are provided for here, to permit them to be directly inlined
// elsewhere.
struct nni_plat_mtx {
pthread_mutex_t mtx;
};
#define NNI_MTX_INITIALIZER \
{ \
PTHREAD_MUTEX_INITIALIZER \
}
struct nni_rwlock {
pthread_rwlock_t rwl;
};
#define NNI_RWLOCK_INITIALIZER \
{ \
PTHREAD_RWLOCK_INITIALIZER \
}
// No static form of CV initialization because of the need to use
// attributes to set the clock type.
struct nni_plat_cv {
pthread_cond_t cv;
pthread_mutex_t *mtx;
};
// NOTE: condition variables initialized with this should *NOT*
// be used with nni_cv_until -- the clock attributes are not passed
// and the wake-up times will not be correct.
#define NNI_CV_INITIALIZER(mxp) \
{ \
.mtx = &((mxp)->mtx), .cv = PTHREAD_COND_INITIALIZER \
}
struct nni_plat_thr {
pthread_t tid;
void (*func)(void *);
void *arg;
};
struct nni_plat_flock {
int fd;
};
#define NNG_PLATFORM_DIR_SEP "/"
#ifdef NNG_HAVE_STDATOMIC
#include <stdatomic.h>
struct nni_atomic_flag {
atomic_flag f;
};
struct nni_atomic_int {
atomic_int v;
};
struct nni_atomic_u64 {
atomic_uint_fast64_t v;
};
struct nni_atomic_bool {
atomic_bool v;
};
struct nni_atomic_ptr {
atomic_uintptr_t v;
};
#else // NNG_HAVE_C11_ATOMIC
struct nni_atomic_flag {
bool f;
};
struct nni_atomic_bool {
bool b;
};
struct nni_atomic_int {
int v;
};
struct nni_atomic_u64 {
uint64_t v;
};
struct nni_atomic_ptr {
void *v;
};
#endif
#endif
extern int nni_posix_pollq_sysinit(nng_init_params *);
extern void nni_posix_pollq_sysfini(void);
extern int nni_posix_resolv_sysinit(nng_init_params *);
extern void nni_posix_resolv_sysfini(void);
#endif // PLATFORM_POSIX_IMPL_H
|
