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
|
//
// Copyright 2025 Staysail Systems, Inc. <info@staysail.tech>
// Copyright 2018 Capitar IT Group BV <info@capitar.com>
// Copyright 2019 Devolutions <info@devolutions.net>
//
// 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 "core/nng_impl.h"
#include <stdio.h>
#include <string.h>
static nni_list sp_tran_list =
NNI_LIST_INITIALIZER(sp_tran_list, nni_sp_tran, tran_link);
void
nni_sp_tran_register(nni_sp_tran *tran)
{
#ifndef NDEBUG
NNI_ASSERT(tran->tran_pipe->p_size != 0);
NNI_ASSERT(tran->tran_pipe->p_init != NULL);
NNI_ASSERT(tran->tran_pipe->p_fini != NULL);
NNI_ASSERT(tran->tran_pipe->p_stop != NULL);
NNI_ASSERT(tran->tran_pipe->p_close != NULL);
NNI_ASSERT(tran->tran_pipe->p_send != NULL);
NNI_ASSERT(tran->tran_pipe->p_recv != NULL);
NNI_ASSERT(tran->tran_pipe->p_peer != NULL);
if (tran->tran_dialer != NULL) {
NNI_ASSERT(tran->tran_dialer->d_size != 0);
NNI_ASSERT(tran->tran_dialer->d_init != NULL);
NNI_ASSERT(tran->tran_dialer->d_fini != NULL);
NNI_ASSERT(tran->tran_dialer->d_close != NULL);
NNI_ASSERT(tran->tran_dialer->d_stop != NULL);
NNI_ASSERT(tran->tran_dialer->d_connect != NULL);
NNI_ASSERT(tran->tran_dialer->d_getopt != NULL);
NNI_ASSERT(tran->tran_dialer->d_setopt != NULL);
}
if (tran->tran_listener != NULL) {
NNI_ASSERT(tran->tran_listener->l_size != 0);
NNI_ASSERT(tran->tran_listener->l_init != NULL);
NNI_ASSERT(tran->tran_listener->l_fini != NULL);
NNI_ASSERT(tran->tran_listener->l_bind != NULL);
NNI_ASSERT(tran->tran_listener->l_accept != NULL);
NNI_ASSERT(tran->tran_listener->l_close != NULL);
NNI_ASSERT(tran->tran_listener->l_stop != NULL);
NNI_ASSERT(tran->tran_listener->l_getopt != NULL);
NNI_ASSERT(tran->tran_listener->l_setopt != NULL);
}
#endif
if (!nni_list_node_active(&tran->tran_link)) {
tran->tran_init();
nni_list_append(&sp_tran_list, tran);
nng_log_info(
"NNG-TRAN", "Registered transport: %s", tran->tran_scheme);
}
}
nni_sp_tran *
nni_sp_tran_find(const char *url)
{
// address is of the form "<scheme>://blah..."
nni_sp_tran *t;
NNI_LIST_FOREACH (&sp_tran_list, t) {
size_t len = strlen(t->tran_scheme);
if ((strncmp(url, t->tran_scheme, len) == 0) &&
(url[len] == ':' || url[len] == '\0')) {
return (t);
}
}
return (NULL);
}
// nni_sp_tran_sys_init initializes the entire transport subsystem, including
// each individual transport.
#ifdef NNG_TRANSPORT_INPROC
extern void nni_sp_inproc_register(void);
#endif
#ifdef NNG_TRANSPORT_IPC
extern void nni_sp_ipc_register(void);
#endif
#ifdef NNG_TRANSPORT_TCP
extern void nni_sp_tcp_register(void);
#endif
#ifdef NNG_TRANSPORT_TLS
extern void nni_sp_tls_register(void);
#endif
#ifdef NNG_TRANSPORT_UDP
extern void nni_sp_udp_register(void);
#endif
#ifdef NNG_TRANSPORT_WS
extern void nni_sp_ws_register(void);
#endif
#ifdef NNG_TRANSPORT_WSS
extern void nni_sp_wss_register(void);
#endif
#ifdef NNG_TRANSPORT_FDC
extern void nni_sp_sfd_register(void);
#endif
#ifdef NNG_TRANSPORT_DTLS
extern void nni_sp_dtls_register(void);
#endif
void
nni_sp_tran_sys_init(void)
{
#ifdef NNG_TRANSPORT_INPROC
nni_sp_inproc_register();
#endif
#ifdef NNG_TRANSPORT_IPC
nni_sp_ipc_register();
#endif
#ifdef NNG_TRANSPORT_TCP
nni_sp_tcp_register();
#endif
#ifdef NNG_TRANSPORT_TLS
nni_sp_tls_register();
#endif
#ifdef NNG_TRANSPORT_UDP
nni_sp_udp_register();
#endif
#ifdef NNG_TRANSPORT_WS
nni_sp_ws_register();
#endif
#ifdef NNG_TRANSPORT_WSS
nni_sp_wss_register();
#endif
#ifdef NNG_TRANSPORT_FDC
nni_sp_sfd_register();
#endif
#ifdef NNG_TRANSPORT_DTLS
nni_sp_dtls_register();
#endif
}
// nni_sp_tran_sys_fini finalizes the entire transport system, including all
// transports.
void
nni_sp_tran_sys_fini(void)
{
nni_sp_tran *t;
while ((t = nni_list_first(&sp_tran_list)) != NULL) {
nni_list_remove(&sp_tran_list, t);
t->tran_fini();
}
}
|
