Commit | Line | Data |
---|---|---|
b97bf3fd PL |
1 | /* |
2 | * net/tipc/core.c: TIPC module code | |
3 | * | |
4 | * Copyright (c) 2003-2005, Ericsson Research Canada | |
5 | * Copyright (c) 2005, Wind River Systems | |
6 | * Copyright (c) 2005-2006, Ericsson AB | |
7 | * All rights reserved. | |
8 | * | |
9ea1fd3c | 9 | * Redistribution and use in source and binary forms, with or without |
b97bf3fd PL |
10 | * modification, are permitted provided that the following conditions are met: |
11 | * | |
9ea1fd3c PL |
12 | * 1. Redistributions of source code must retain the above copyright |
13 | * notice, this list of conditions and the following disclaimer. | |
14 | * 2. Redistributions in binary form must reproduce the above copyright | |
15 | * notice, this list of conditions and the following disclaimer in the | |
16 | * documentation and/or other materials provided with the distribution. | |
17 | * 3. Neither the names of the copyright holders nor the names of its | |
18 | * contributors may be used to endorse or promote products derived from | |
19 | * this software without specific prior written permission. | |
b97bf3fd | 20 | * |
9ea1fd3c PL |
21 | * Alternatively, this software may be distributed under the terms of the |
22 | * GNU General Public License ("GPL") version 2 as published by the Free | |
23 | * Software Foundation. | |
24 | * | |
25 | * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" | |
26 | * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE | |
27 | * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE | |
28 | * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE | |
29 | * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR | |
30 | * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF | |
31 | * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS | |
32 | * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN | |
33 | * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) | |
34 | * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE | |
b97bf3fd PL |
35 | * POSSIBILITY OF SUCH DAMAGE. |
36 | */ | |
37 | ||
38 | #include <linux/init.h> | |
39 | #include <linux/module.h> | |
40 | #include <linux/kernel.h> | |
41 | #include <linux/version.h> | |
42 | #include <linux/random.h> | |
43 | ||
44 | #include "core.h" | |
45 | #include "dbg.h" | |
46 | #include "ref.h" | |
47 | #include "net.h" | |
48 | #include "user_reg.h" | |
49 | #include "name_table.h" | |
50 | #include "subscr.h" | |
51 | #include "config.h" | |
52 | ||
53 | int eth_media_start(void); | |
54 | void eth_media_stop(void); | |
55 | int handler_start(void); | |
56 | void handler_stop(void); | |
57 | int socket_init(void); | |
58 | void socket_stop(void); | |
59 | int netlink_start(void); | |
60 | void netlink_stop(void); | |
61 | ||
62 | #define MOD_NAME "tipc_start: " | |
63 | ||
64 | #ifndef CONFIG_TIPC_ZONES | |
65 | #define CONFIG_TIPC_ZONES 3 | |
66 | #endif | |
67 | ||
68 | #ifndef CONFIG_TIPC_CLUSTERS | |
69 | #define CONFIG_TIPC_CLUSTERS 1 | |
70 | #endif | |
71 | ||
72 | #ifndef CONFIG_TIPC_NODES | |
73 | #define CONFIG_TIPC_NODES 255 | |
74 | #endif | |
75 | ||
76 | #ifndef CONFIG_TIPC_SLAVE_NODES | |
77 | #define CONFIG_TIPC_SLAVE_NODES 0 | |
78 | #endif | |
79 | ||
80 | #ifndef CONFIG_TIPC_PORTS | |
81 | #define CONFIG_TIPC_PORTS 8191 | |
82 | #endif | |
83 | ||
84 | #ifndef CONFIG_TIPC_LOG | |
85 | #define CONFIG_TIPC_LOG 0 | |
86 | #endif | |
87 | ||
88 | /* global variables used by multiple sub-systems within TIPC */ | |
89 | ||
90 | int tipc_mode = TIPC_NOT_RUNNING; | |
91 | int tipc_random; | |
92 | atomic_t tipc_user_count = ATOMIC_INIT(0); | |
93 | ||
94 | const char tipc_alphabet[] = | |
95 | "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789_"; | |
96 | ||
97 | /* configurable TIPC parameters */ | |
98 | ||
99 | u32 tipc_own_addr; | |
100 | int tipc_max_zones; | |
101 | int tipc_max_clusters; | |
102 | int tipc_max_nodes; | |
103 | int tipc_max_slaves; | |
104 | int tipc_max_ports; | |
105 | int tipc_max_subscriptions; | |
106 | int tipc_max_publications; | |
107 | int tipc_net_id; | |
108 | int tipc_remote_management; | |
109 | ||
110 | ||
111 | int tipc_get_mode(void) | |
112 | { | |
113 | return tipc_mode; | |
114 | } | |
115 | ||
116 | /** | |
117 | * stop_net - shut down TIPC networking sub-systems | |
118 | */ | |
119 | ||
120 | void stop_net(void) | |
121 | { | |
122 | eth_media_stop(); | |
123 | tipc_stop_net(); | |
124 | } | |
125 | ||
126 | /** | |
127 | * start_net - start TIPC networking sub-systems | |
128 | */ | |
129 | ||
130 | int start_net(void) | |
131 | { | |
132 | int res; | |
133 | ||
134 | if ((res = tipc_start_net()) || | |
135 | (res = eth_media_start())) { | |
136 | stop_net(); | |
137 | } | |
138 | return res; | |
139 | } | |
140 | ||
141 | /** | |
142 | * stop_core - switch TIPC from SINGLE NODE to NOT RUNNING mode | |
143 | */ | |
144 | ||
145 | void stop_core(void) | |
146 | { | |
147 | if (tipc_mode != TIPC_NODE_MODE) | |
148 | return; | |
149 | ||
150 | tipc_mode = TIPC_NOT_RUNNING; | |
151 | ||
152 | netlink_stop(); | |
153 | handler_stop(); | |
154 | cfg_stop(); | |
155 | subscr_stop(); | |
156 | reg_stop(); | |
157 | nametbl_stop(); | |
158 | ref_table_stop(); | |
159 | socket_stop(); | |
160 | } | |
161 | ||
162 | /** | |
163 | * start_core - switch TIPC from NOT RUNNING to SINGLE NODE mode | |
164 | */ | |
165 | ||
166 | int start_core(void) | |
167 | { | |
168 | int res; | |
169 | ||
170 | if (tipc_mode != TIPC_NOT_RUNNING) | |
171 | return -ENOPROTOOPT; | |
172 | ||
173 | get_random_bytes(&tipc_random, sizeof(tipc_random)); | |
174 | tipc_mode = TIPC_NODE_MODE; | |
175 | ||
176 | if ((res = handler_start()) || | |
177 | (res = ref_table_init(tipc_max_ports + tipc_max_subscriptions, | |
178 | tipc_random)) || | |
179 | (res = reg_start()) || | |
180 | (res = nametbl_init()) || | |
181 | (res = k_signal((Handler)subscr_start, 0)) || | |
182 | (res = k_signal((Handler)cfg_init, 0)) || | |
183 | (res = netlink_start()) || | |
184 | (res = socket_init())) { | |
185 | stop_core(); | |
186 | } | |
187 | return res; | |
188 | } | |
189 | ||
190 | ||
191 | static int __init tipc_init(void) | |
192 | { | |
193 | int res; | |
194 | ||
195 | log_reinit(CONFIG_TIPC_LOG); | |
196 | info("Activated (compiled " __DATE__ " " __TIME__ ")\n"); | |
197 | ||
198 | tipc_own_addr = 0; | |
199 | tipc_remote_management = 1; | |
200 | tipc_max_publications = 10000; | |
201 | tipc_max_subscriptions = 2000; | |
202 | tipc_max_ports = delimit(CONFIG_TIPC_PORTS, 127, 65536); | |
203 | tipc_max_zones = delimit(CONFIG_TIPC_ZONES, 1, 511); | |
204 | tipc_max_clusters = delimit(CONFIG_TIPC_CLUSTERS, 1, 1); | |
205 | tipc_max_nodes = delimit(CONFIG_TIPC_NODES, 8, 2047); | |
206 | tipc_max_slaves = delimit(CONFIG_TIPC_SLAVE_NODES, 0, 2047); | |
207 | tipc_net_id = 4711; | |
208 | ||
209 | if ((res = start_core())) | |
210 | err("Unable to start in single node mode\n"); | |
211 | else | |
212 | info("Started in single node mode\n"); | |
213 | return res; | |
214 | } | |
215 | ||
216 | static void __exit tipc_exit(void) | |
217 | { | |
218 | stop_net(); | |
219 | stop_core(); | |
220 | info("Deactivated\n"); | |
221 | log_stop(); | |
222 | } | |
223 | ||
224 | module_init(tipc_init); | |
225 | module_exit(tipc_exit); | |
226 | ||
227 | MODULE_DESCRIPTION("TIPC: Transparent Inter Process Communication"); | |
228 | MODULE_LICENSE("Dual BSD/GPL"); | |
229 | ||
230 | /* Native TIPC API for kernel-space applications (see tipc.h) */ | |
231 | ||
232 | EXPORT_SYMBOL(tipc_attach); | |
233 | EXPORT_SYMBOL(tipc_detach); | |
234 | EXPORT_SYMBOL(tipc_get_addr); | |
235 | EXPORT_SYMBOL(tipc_get_mode); | |
236 | EXPORT_SYMBOL(tipc_createport); | |
237 | EXPORT_SYMBOL(tipc_deleteport); | |
238 | EXPORT_SYMBOL(tipc_ownidentity); | |
239 | EXPORT_SYMBOL(tipc_portimportance); | |
240 | EXPORT_SYMBOL(tipc_set_portimportance); | |
241 | EXPORT_SYMBOL(tipc_portunreliable); | |
242 | EXPORT_SYMBOL(tipc_set_portunreliable); | |
243 | EXPORT_SYMBOL(tipc_portunreturnable); | |
244 | EXPORT_SYMBOL(tipc_set_portunreturnable); | |
245 | EXPORT_SYMBOL(tipc_publish); | |
246 | EXPORT_SYMBOL(tipc_withdraw); | |
247 | EXPORT_SYMBOL(tipc_connect2port); | |
248 | EXPORT_SYMBOL(tipc_disconnect); | |
249 | EXPORT_SYMBOL(tipc_shutdown); | |
250 | EXPORT_SYMBOL(tipc_isconnected); | |
251 | EXPORT_SYMBOL(tipc_peer); | |
252 | EXPORT_SYMBOL(tipc_ref_valid); | |
253 | EXPORT_SYMBOL(tipc_send); | |
254 | EXPORT_SYMBOL(tipc_send_buf); | |
255 | EXPORT_SYMBOL(tipc_send2name); | |
256 | EXPORT_SYMBOL(tipc_forward2name); | |
257 | EXPORT_SYMBOL(tipc_send_buf2name); | |
258 | EXPORT_SYMBOL(tipc_forward_buf2name); | |
259 | EXPORT_SYMBOL(tipc_send2port); | |
260 | EXPORT_SYMBOL(tipc_forward2port); | |
261 | EXPORT_SYMBOL(tipc_send_buf2port); | |
262 | EXPORT_SYMBOL(tipc_forward_buf2port); | |
263 | EXPORT_SYMBOL(tipc_multicast); | |
264 | /* EXPORT_SYMBOL(tipc_multicast_buf); not available yet */ | |
265 | EXPORT_SYMBOL(tipc_ispublished); | |
266 | EXPORT_SYMBOL(tipc_available_nodes); | |
267 | ||
268 | /* TIPC API for external bearers (see tipc_bearer.h) */ | |
269 | ||
270 | EXPORT_SYMBOL(tipc_block_bearer); | |
271 | EXPORT_SYMBOL(tipc_continue); | |
272 | EXPORT_SYMBOL(tipc_disable_bearer); | |
273 | EXPORT_SYMBOL(tipc_enable_bearer); | |
274 | EXPORT_SYMBOL(tipc_recv_msg); | |
275 | EXPORT_SYMBOL(tipc_register_media); | |
276 | ||
277 | /* TIPC API for external APIs (see tipc_port.h) */ | |
278 | ||
279 | EXPORT_SYMBOL(tipc_createport_raw); | |
280 | EXPORT_SYMBOL(tipc_set_msg_option); | |
281 | EXPORT_SYMBOL(tipc_reject_msg); | |
282 | EXPORT_SYMBOL(tipc_send_buf_fast); | |
283 | EXPORT_SYMBOL(tipc_acknowledge); | |
284 | EXPORT_SYMBOL(tipc_get_port); | |
285 | EXPORT_SYMBOL(tipc_get_handle); | |
286 |