blob: 1354709bbc044123fdb95acaaf0e57f362135f15 (
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
|
//
// Copyright 2024 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_WIN_IMPL_H
#define PLATFORM_WIN_IMPL_H
#ifndef WIN32_LEAN_AND_MEAN
#define WIN32_LEAN_AND_MEAN
#endif
// These headers must be included first.
#include <windows.h>
#include <winsock2.h>
#include <mswsock.h>
#include <process.h>
#include <ws2tcpip.h>
#include "core/list.h"
// These types are provided for here, to permit them to be directly inlined
// elsewhere.
struct nni_plat_thr {
void (*func)(void *);
void *arg;
HANDLE handle;
DWORD id;
};
struct nni_plat_mtx {
SRWLOCK srl;
};
#define NNI_MTX_INITIALIZER \
{ \
SRWLOCK_INIT \
}
struct nni_rwlock {
SRWLOCK rwl;
BOOLEAN exclusive;
};
#define NNI_RWLOCK_INITIALIZER \
{ \
SRWLOCK_INIT \
}
struct nni_plat_cv {
CONDITION_VARIABLE cv;
PSRWLOCK srl;
};
#define NNI_CV_INITIALIZER(mxp) \
{ \
.srl = (void *) mxp, .cv = CONDITION_VARIABLE_INIT \
}
struct nni_atomic_flag {
LONG f;
};
struct nni_atomic_bool {
LONG v;
};
struct nni_atomic_int {
LONG v;
};
struct nni_atomic_u64 {
LONGLONG v;
};
struct nni_atomic_ptr {
LONGLONG v;
};
// nni_win_io is used with io completion ports. This allows us to get
// to a specific completion callback without requiring the poller (in the
// completion port) to know anything about the event itself.
typedef struct nni_win_io nni_win_io;
typedef void (*nni_win_io_cb)(nni_win_io *, int, size_t);
struct nni_win_io {
OVERLAPPED olpd;
HANDLE f;
void *ptr;
nni_aio *aio;
nni_win_io_cb cb;
};
struct nni_plat_flock {
HANDLE h;
};
extern int nni_win_error(int);
extern int nni_win_tcp_conn_init(nni_tcp_conn **, SOCKET);
extern int nni_win_io_sysinit(void);
extern void nni_win_io_sysfini(void);
extern int nni_win_ipc_sysinit(void);
extern void nni_win_ipc_sysfini(void);
extern int nni_win_tcp_sysinit(void);
extern void nni_win_tcp_sysfini(void);
extern int nni_win_udp_sysinit(void);
extern void nni_win_udp_sysfini(void);
extern int nni_win_resolv_sysinit(void);
extern void nni_win_resolv_sysfini(void);
extern void nni_win_io_init(nni_win_io *, nni_win_io_cb, void *);
extern int nni_win_io_register(HANDLE);
extern int nni_win_sockaddr2nn(nni_sockaddr *, const SOCKADDR_STORAGE *);
extern int nni_win_nn2sockaddr(SOCKADDR_STORAGE *, const nni_sockaddr *);
#define NNG_PLATFORM_DIR_SEP "\\"
#endif // PLATFORM_WIN_IMPL_H
|
