Rev 4719 | Rev 4722 | Go to most recent revision | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed
Rev 4719 | Rev 4720 | ||
---|---|---|---|
1 | /* |
1 | /* |
2 | * Copyright (c) 2009 Lukas Mejdrech |
2 | * Copyright (c) 2009 Lukas Mejdrech |
3 | * All rights reserved. |
3 | * All rights reserved. |
4 | * |
4 | * |
5 | * Redistribution and use in source and binary forms, with or without |
5 | * Redistribution and use in source and binary forms, with or without |
6 | * modification, are permitted provided that the following conditions |
6 | * modification, are permitted provided that the following conditions |
7 | * are met: |
7 | * are met: |
8 | * |
8 | * |
9 | * - Redistributions of source code must retain the above copyright |
9 | * - Redistributions of source code must retain the above copyright |
10 | * notice, this list of conditions and the following disclaimer. |
10 | * notice, this list of conditions and the following disclaimer. |
11 | * - Redistributions in binary form must reproduce the above copyright |
11 | * - Redistributions in binary form must reproduce the above copyright |
12 | * notice, this list of conditions and the following disclaimer in the |
12 | * notice, this list of conditions and the following disclaimer in the |
13 | * documentation and/or other materials provided with the distribution. |
13 | * documentation and/or other materials provided with the distribution. |
14 | * - The name of the author may not be used to endorse or promote products |
14 | * - The name of the author may not be used to endorse or promote products |
15 | * derived from this software without specific prior written permission. |
15 | * derived from this software without specific prior written permission. |
16 | * |
16 | * |
17 | * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR |
17 | * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR |
18 | * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |
18 | * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |
19 | * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
19 | * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
20 | * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, |
20 | * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, |
21 | * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT |
21 | * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT |
22 | * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
22 | * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
23 | * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
23 | * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
24 | * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
24 | * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
25 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF |
25 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF |
26 | * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
26 | * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
27 | */ |
27 | */ |
28 | 28 | ||
29 | /** @addtogroup net |
29 | /** @addtogroup net |
30 | * @{ |
30 | * @{ |
31 | */ |
31 | */ |
32 | 32 | ||
33 | /** @file |
33 | /** @file |
34 | * Networking subsystem central module implementation. |
34 | * Networking subsystem central module implementation. |
35 | */ |
35 | */ |
36 | 36 | ||
37 | #include <async.h> |
37 | #include <async.h> |
38 | #include <ctype.h> |
38 | #include <ctype.h> |
39 | #include <ddi.h> |
39 | #include <ddi.h> |
40 | #include <errno.h> |
40 | #include <errno.h> |
41 | #include <malloc.h> |
41 | #include <malloc.h> |
42 | #include <stdio.h> |
42 | #include <stdio.h> |
43 | #include <string.h> |
43 | #include <string.h> |
44 | 44 | ||
45 | #include <ipc/ipc.h> |
45 | #include <ipc/ipc.h> |
46 | #include <ipc/services.h> |
46 | #include <ipc/services.h> |
47 | 47 | ||
48 | #include "../err.h" |
48 | #include "../err.h" |
49 | #include "../messages.h" |
49 | #include "../messages.h" |
50 | #include "../modules.h" |
50 | #include "../modules.h" |
51 | 51 | ||
52 | #include "../structures/char_map.h" |
52 | #include "../structures/char_map.h" |
53 | #include "../structures/generic_char_map.h" |
53 | #include "../structures/generic_char_map.h" |
54 | #include "../structures/measured_strings.h" |
54 | #include "../structures/measured_strings.h" |
55 | #include "../structures/module_map.h" |
55 | #include "../structures/module_map.h" |
56 | #include "../structures/packet/packet.h" |
56 | #include "../structures/packet/packet.h" |
57 | 57 | ||
58 | #include "../il/il_messages.h" |
58 | #include "../il/il_messages.h" |
59 | #include "../include/device.h" |
59 | #include "../include/device.h" |
60 | #include "../include/netif_interface.h" |
60 | #include "../include/netif_interface.h" |
61 | #include "../include/nil_interface.h" |
61 | #include "../include/nil_interface.h" |
62 | #include "../include/net_interface.h" |
62 | #include "../include/net_interface.h" |
63 | #include "../include/ip_interface.h" |
63 | #include "../include/ip_interface.h" |
64 | 64 | ||
65 | #include "net.h" |
65 | #include "net.h" |
66 | 66 | ||
67 | /** Networking module name. |
67 | /** Networking module name. |
68 | */ |
68 | */ |
69 | #define NAME "Networking" |
69 | #define NAME "Networking" |
70 | 70 | ||
71 | /** Prints the module name. |
71 | /** Prints the module name. |
72 | * @see NAME |
72 | * @see NAME |
73 | */ |
73 | */ |
74 | void module_print_name( void ); |
74 | void module_print_name( void ); |
75 | 75 | ||
76 | /** Starts the networking module. |
76 | /** Starts the networking module. |
77 | * Initializes the client connection serving function, initializes the module, registers the module service and starts the async manager, processing IPC messages in an infinite loop. |
77 | * Initializes the client connection serving function, initializes the module, registers the module service and starts the async manager, processing IPC messages in an infinite loop. |
78 | * @param client_connection The client connection processing function. The module skeleton propagates its own one. Input parameter. |
78 | * @param client_connection The client connection processing function. The module skeleton propagates its own one. Input parameter. |
79 | * @returns EOK on successful module termination. |
79 | * @returns EOK on successful module termination. |
80 | * @returns Other error codes as defined for the net_initialize() function. |
80 | * @returns Other error codes as defined for the net_initialize() function. |
81 | * @returns Other error codes as defined for the REGISTER_ME() macro function. |
81 | * @returns Other error codes as defined for the REGISTER_ME() macro function. |
82 | */ |
82 | */ |
83 | int module_start( async_client_conn_t client_connection ); |
83 | int module_start( async_client_conn_t client_connection ); |
84 | 84 | ||
85 | //int parse_line( measured_strings_ref configuration, char * line ); |
85 | //int parse_line( measured_strings_ref configuration, char * line ); |
86 | 86 | ||
87 | /** Reads the networking subsystem global configuration. |
87 | /** Reads the networking subsystem global configuration. |
88 | * @returns EOK on success. |
88 | * @returns EOK on success. |
89 | * @returns Other error codes as defined for the add_configuration() function. |
89 | * @returns Other error codes as defined for the add_configuration() function. |
90 | */ |
90 | */ |
91 | int read_configuration( void ); |
91 | int read_configuration( void ); |
92 | 92 | ||
93 | /** Starts the network interface according to its configuration. |
93 | /** Starts the network interface according to its configuration. |
94 | * Registers the network interface with the subsystem modules. |
94 | * Registers the network interface with the subsystem modules. |
95 | * Starts the needed subsystem modules. |
95 | * Starts the needed subsystem modules. |
96 | * @param netif The network interface specific data. |
96 | * @param netif The network interface specific data. |
97 | * @returns EOK on success. |
97 | * @returns EOK on success. |
98 | * @returns EINVAL if there are some settings missing. |
98 | * @returns EINVAL if there are some settings missing. |
99 | * @returns ENOENT if the internet protocol module is not known. |
99 | * @returns ENOENT if the internet protocol module is not known. |
100 | * @returns Other error codes as defined for the netif_probe_req() function. |
100 | * @returns Other error codes as defined for the netif_probe_req() function. |
101 | * @returns Other error codes as defined for the nil_device_req() function. |
101 | * @returns Other error codes as defined for the nil_device_req() function. |
102 | * @returns Other error codes as defined for the needed internet layer registering function. |
102 | * @returns Other error codes as defined for the needed internet layer registering function. |
103 | */ |
103 | */ |
104 | int start_device( netif_ref netif ); |
104 | int start_device( netif_ref netif ); |
105 | 105 | ||
106 | /** Reads the configuration and starts all network interfaces. |
106 | /** Reads the configuration and starts all network interfaces. |
107 | * @returns EOK on success. |
107 | * @returns EOK on success. |
108 | * @returns EXDEV if there is no available system-unique device identifier. |
108 | * @returns EXDEV if there is no available system-unique device identifier. |
109 | * @returns EINVAL if any of the network interface names are not configured. |
109 | * @returns EINVAL if any of the network interface names are not configured. |
110 | * @returns ENOMEM if there is not enough memory left. |
110 | * @returns ENOMEM if there is not enough memory left. |
111 | * @returns Other error codes as defined for the read_configuration() function. |
111 | * @returns Other error codes as defined for the read_configuration() function. |
112 | * @returns Other error codes as defined for the read_netif_configuration() function. |
112 | * @returns Other error codes as defined for the read_netif_configuration() function. |
113 | * @returns Other error codes as defined for the start_device() function. |
113 | * @returns Other error codes as defined for the start_device() function. |
114 | */ |
114 | */ |
115 | int startup( void ); |
115 | int startup( void ); |
116 | 116 | ||
117 | /** Generates new system-unique device identifier. |
117 | /** Generates new system-unique device identifier. |
118 | * @returns The system-unique devic identifier. |
118 | * @returns The system-unique devic identifier. |
119 | */ |
119 | */ |
120 | device_id_t generate_new_device_id( void ); |
120 | device_id_t generate_new_device_id( void ); |
121 | 121 | ||
122 | /** Returns the configured values. |
122 | /** Returns the configured values. |
123 | * The network interface configuration is searched first. |
123 | * The network interface configuration is searched first. |
124 | * @param netif_conf The network interface configuration setting. Input parameter. |
124 | * @param netif_conf The network interface configuration setting. Input parameter. |
125 | * @param configuration The found configured values. Output parameter. |
125 | * @param configuration The found configured values. Output parameter. |
126 | * @param count The desired settings count. Input parameter. |
126 | * @param count The desired settings count. Input parameter. |
127 | * @param data The found configuration settings data. Output parameter. |
127 | * @param data The found configuration settings data. Output parameter. |
128 | * @returns EOK. |
128 | * @returns EOK. |
129 | */ |
129 | */ |
130 | int net_get_conf( measured_strings_ref netif_conf, measured_string_ref configuration, size_t count, char ** data ); |
130 | int net_get_conf( measured_strings_ref netif_conf, measured_string_ref configuration, size_t count, char ** data ); |
131 | 131 | ||
- | 132 | /** Initializes the networking module. |
|
- | 133 | * @param client_connection The client connection processing function. The module skeleton propagates its own one. Input parameter. |
|
- | 134 | * @returns EOK on success. |
|
- | 135 | * @returns ENOMEM if there is not enough memory left. |
|
- | 136 | */ |
|
- | 137 | int net_initialize( async_client_conn_t client_connection ); |
|
- | 138 | ||
- | 139 | /** Reads the network interface specific configuration. |
|
- | 140 | * @param name The network interface name. Input parameter. |
|
- | 141 | * @param netif The network interface structure. Input/output parameter. |
|
- | 142 | * @returns EOK on success. |
|
- | 143 | * @returns Other error codes as defined for the add_configuration() function. |
|
- | 144 | */ |
|
- | 145 | int read_netif_configuration( char * name, netif_ref netif ); |
|
- | 146 | ||
132 | /** Networking module global data. |
147 | /** Networking module global data. |
133 | */ |
148 | */ |
134 | net_globals_t net_globals; |
149 | net_globals_t net_globals; |
135 | 150 | ||
136 | DEVICE_MAP_IMPLEMENT( netifs, netif_t ) |
151 | DEVICE_MAP_IMPLEMENT( netifs, netif_t ) |
137 | 152 | ||
138 | GENERIC_CHAR_MAP_IMPLEMENT( measured_strings, measured_string_t ) |
153 | GENERIC_CHAR_MAP_IMPLEMENT( measured_strings, measured_string_t ) |
139 | 154 | ||
140 | void module_print_name( void ){ |
155 | void module_print_name( void ){ |
141 | printf( "%s", NAME ); |
156 | printf( "%s", NAME ); |
142 | } |
157 | } |
143 | 158 | ||
144 | int module_start( async_client_conn_t client_connection ){ |
159 | int module_start( async_client_conn_t client_connection ){ |
145 | ERROR_DECLARE; |
160 | ERROR_DECLARE; |
146 | 161 | ||
147 | ipcarg_t phonehash; |
162 | ipcarg_t phonehash; |
148 | 163 | ||
149 | async_set_client_connection( client_connection ); |
164 | async_set_client_connection( client_connection ); |
150 | ERROR_PROPAGATE( pm_init()); |
165 | ERROR_PROPAGATE( pm_init()); |
151 | if( ERROR_OCCURRED( net_initialize( client_connection )) |
166 | if( ERROR_OCCURRED( net_initialize( client_connection )) |
152 | || ERROR_OCCURRED( REGISTER_ME( SERVICE_NETWORKING, & phonehash ))){ |
167 | || ERROR_OCCURRED( REGISTER_ME( SERVICE_NETWORKING, & phonehash ))){ |
153 | pm_destroy(); |
168 | pm_destroy(); |
154 | return ERROR_CODE; |
169 | return ERROR_CODE; |
155 | } |
170 | } |
156 | 171 | ||
157 | async_manager(); |
172 | async_manager(); |
158 | 173 | ||
159 | pm_destroy(); |
174 | pm_destroy(); |
160 | return EOK; |
175 | return EOK; |
161 | } |
176 | } |
162 | 177 | ||
- | 178 | int net_initialize( async_client_conn_t client_connection ){ |
|
- | 179 | ERROR_DECLARE; |
|
- | 180 | ||
- | 181 | netifs_initialize( & net_globals.netifs ); |
|
- | 182 | char_map_initialize( & net_globals.netif_names ); |
|
- | 183 | modules_initialize( & net_globals.modules ); |
|
- | 184 | measured_strings_initialize( & net_globals.configuration ); |
|
- | 185 | ||
- | 186 | // TODO dynamic configuration |
|
- | 187 | ERROR_PROPAGATE( read_configuration()); |
|
- | 188 | ||
- | 189 | ERROR_PROPAGATE( add_module( NULL, & net_globals.modules, LO_NAME, LO_FILENAME, SERVICE_LO, 0, connect_to_service )); |
|
- | 190 | ERROR_PROPAGATE( add_module( NULL, & net_globals.modules, DP8390_NAME, DP8390_FILENAME, SERVICE_DP8390, 0, connect_to_service )); |
|
- | 191 | ERROR_PROPAGATE( add_module( NULL, & net_globals.modules, ETHERNET_NAME, ETHERNET_FILENAME, SERVICE_ETHERNET, 0, connect_to_service )); |
|
- | 192 | ERROR_PROPAGATE( add_module( NULL, & net_globals.modules, NILDUMMY_NAME, NILDUMMY_FILENAME, SERVICE_NILDUMMY, 0, connect_to_service )); |
|
- | 193 | ||
- | 194 | // build specific initialization |
|
- | 195 | return net_initialize_build( client_connection ); |
|
- | 196 | } |
|
- | 197 | ||
163 | int net_get_device_conf_req( int net_phone, device_id_t device_id, measured_string_ref * configuration, size_t count, char ** data ){ |
198 | int net_get_device_conf_req( int net_phone, device_id_t device_id, measured_string_ref * configuration, size_t count, char ** data ){ |
164 | netif_ref netif; |
199 | netif_ref netif; |
165 | 200 | ||
166 | if( !( configuration && ( count > 0 ))) return EINVAL; |
201 | if( !( configuration && ( count > 0 ))) return EINVAL; |
167 | netif = netifs_find( & net_globals.netifs, device_id ); |
202 | netif = netifs_find( & net_globals.netifs, device_id ); |
168 | if( netif ){ |
203 | if( netif ){ |
169 | return net_get_conf( & netif->configuration, * configuration, count, data ); |
204 | return net_get_conf( & netif->configuration, * configuration, count, data ); |
170 | }else{ |
205 | }else{ |
171 | return net_get_conf( NULL, * configuration, count, data ); |
206 | return net_get_conf( NULL, * configuration, count, data ); |
172 | } |
207 | } |
173 | } |
208 | } |
174 | 209 | ||
175 | int net_get_conf_req( int net_phone, measured_string_ref * configuration, size_t count, char ** data ){ |
210 | int net_get_conf_req( int net_phone, measured_string_ref * configuration, size_t count, char ** data ){ |
176 | if( !( configuration && ( count > 0 ))) return EINVAL; |
211 | if( !( configuration && ( count > 0 ))) return EINVAL; |
177 | return net_get_conf( NULL, * configuration, count, data ); |
212 | return net_get_conf( NULL, * configuration, count, data ); |
178 | } |
213 | } |
179 | 214 | ||
180 | int net_get_conf( measured_strings_ref netif_conf, measured_string_ref configuration, size_t count, char ** data ){ |
215 | int net_get_conf( measured_strings_ref netif_conf, measured_string_ref configuration, size_t count, char ** data ){ |
181 | measured_string_ref setting; |
216 | measured_string_ref setting; |
182 | size_t index; |
217 | size_t index; |
183 | 218 | ||
184 | if( data ) * data = NULL; |
219 | if( data ) * data = NULL; |
185 | for( index = 0; index < count; ++ index ){ |
220 | for( index = 0; index < count; ++ index ){ |
186 | setting = measured_strings_find( netif_conf, configuration[ index ].value, 0 ); |
221 | setting = measured_strings_find( netif_conf, configuration[ index ].value, 0 ); |
187 | if( ! setting ){ |
222 | if( ! setting ){ |
188 | setting = measured_strings_find( & net_globals.configuration, configuration[ index ].value, 0 ); |
223 | setting = measured_strings_find( & net_globals.configuration, configuration[ index ].value, 0 ); |
189 | } |
224 | } |
190 | if( setting ){ |
225 | if( setting ){ |
191 | configuration[ index ].length = setting->length; |
226 | configuration[ index ].length = setting->length; |
192 | configuration[ index ].value = setting->value; |
227 | configuration[ index ].value = setting->value; |
193 | }else{ |
228 | }else{ |
194 | configuration[ index ].length = 0; |
229 | configuration[ index ].length = 0; |
195 | configuration[ index ].value = NULL; |
230 | configuration[ index ].value = NULL; |
196 | } |
231 | } |
197 | } |
232 | } |
198 | return EOK; |
233 | return EOK; |
199 | } |
234 | } |
200 | 235 | ||
201 | void net_free_settings( measured_string_ref settings, char * data ){ |
236 | void net_free_settings( measured_string_ref settings, char * data ){ |
202 | } |
237 | } |
203 | 238 | ||
204 | int net_connect_module( services_t service ){ |
239 | int net_connect_module( services_t service ){ |
205 | return EOK; |
240 | return EOK; |
206 | } |
241 | } |
207 | 242 | ||
208 | int net_message( ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count ){ |
243 | int net_message( ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count ){ |
209 | ERROR_DECLARE; |
244 | ERROR_DECLARE; |
210 | 245 | ||
211 | measured_string_ref strings; |
246 | measured_string_ref strings; |
212 | char * data; |
247 | char * data; |
213 | 248 | ||
214 | * answer_count = 0; |
249 | * answer_count = 0; |
215 | switch( IPC_GET_METHOD( * call )){ |
250 | switch( IPC_GET_METHOD( * call )){ |
216 | case IPC_M_PHONE_HUNGUP: |
251 | case IPC_M_PHONE_HUNGUP: |
217 | return EOK; |
252 | return EOK; |
218 | case NET_NET_DEVICE: |
253 | case NET_NET_DEVICE: |
219 | // TODO configure, register |
254 | // TODO configure, register |
220 | printf( "Networking: new netif %d\n", IPC_GET_DEVICE( call )); |
255 | printf( "Networking: new netif %d\n", IPC_GET_DEVICE( call )); |
221 | return EOK; |
256 | return EOK; |
222 | case NET_NET_GET_DEVICE_CONF: |
257 | case NET_NET_GET_DEVICE_CONF: |
223 | ERROR_PROPAGATE( measured_strings_receive( & strings, & data, IPC_GET_COUNT( call ))); |
258 | ERROR_PROPAGATE( measured_strings_receive( & strings, & data, IPC_GET_COUNT( call ))); |
224 | net_get_device_conf_req( 0, IPC_GET_DEVICE( call ), & strings, IPC_GET_COUNT( call ), NULL ); |
259 | net_get_device_conf_req( 0, IPC_GET_DEVICE( call ), & strings, IPC_GET_COUNT( call ), NULL ); |
225 | // strings should not contain received data anymore |
260 | // strings should not contain received data anymore |
226 | free( data ); |
261 | free( data ); |
227 | ERROR_CODE = measured_strings_reply( strings, IPC_GET_COUNT( call )); |
262 | ERROR_CODE = measured_strings_reply( strings, IPC_GET_COUNT( call )); |
228 | free( strings ); |
263 | free( strings ); |
229 | return ERROR_CODE; |
264 | return ERROR_CODE; |
230 | case NET_NET_GET_CONF: |
265 | case NET_NET_GET_CONF: |
231 | ERROR_PROPAGATE( measured_strings_receive( & strings, & data, IPC_GET_COUNT( call ))); |
266 | ERROR_PROPAGATE( measured_strings_receive( & strings, & data, IPC_GET_COUNT( call ))); |
232 | net_get_conf_req( 0, & strings, IPC_GET_COUNT( call ), NULL ); |
267 | net_get_conf_req( 0, & strings, IPC_GET_COUNT( call ), NULL ); |
233 | // strings should not contain received data anymore |
268 | // strings should not contain received data anymore |
234 | free( data ); |
269 | free( data ); |
235 | ERROR_CODE = measured_strings_reply( strings, IPC_GET_COUNT( call )); |
270 | ERROR_CODE = measured_strings_reply( strings, IPC_GET_COUNT( call )); |
236 | free( strings ); |
271 | free( strings ); |
237 | return ERROR_CODE; |
272 | return ERROR_CODE; |
238 | case NET_NET_STARTUP: |
273 | case NET_NET_STARTUP: |
239 | return startup(); |
274 | return startup(); |
240 | } |
275 | } |
241 | return ENOTSUP; |
276 | return ENOTSUP; |
242 | } |
277 | } |
243 | 278 | ||
244 | /* |
279 | /* |
245 | int parse_line( measured_strings_ref configuration, char * line ){ |
280 | int parse_line( measured_strings_ref configuration, char * line ){ |
246 | ERROR_DECLARE; |
281 | ERROR_DECLARE; |
247 | 282 | ||
248 | measured_string_ref setting; |
283 | measured_string_ref setting; |
249 | char * name; |
284 | char * name; |
250 | char * value; |
285 | char * value; |
251 | 286 | ||
252 | // from the beginning |
287 | // from the beginning |
253 | name = line; |
288 | name = line; |
254 | // skip spaces |
289 | // skip spaces |
255 | while( isspace( * name )) ++ name; |
290 | while( isspace( * name )) ++ name; |
256 | // remember the name start |
291 | // remember the name start |
257 | value = name; |
292 | value = name; |
258 | // skip the name |
293 | // skip the name |
259 | while( isalnum( * value ) || ( * value == '_' )){ |
294 | while( isalnum( * value ) || ( * value == '_' )){ |
260 | // make uppercase |
295 | // make uppercase |
261 | // * value = toupper( * value ); |
296 | // * value = toupper( * value ); |
262 | ++ value; |
297 | ++ value; |
263 | } |
298 | } |
264 | if( * value == '=' ){ |
299 | if( * value == '=' ){ |
265 | // terminate the name |
300 | // terminate the name |
266 | * value = '\0'; |
301 | * value = '\0'; |
267 | }else{ |
302 | }else{ |
268 | // terminate the name |
303 | // terminate the name |
269 | * value = '\0'; |
304 | * value = '\0'; |
270 | // skip until '=' |
305 | // skip until '=' |
271 | ++ value; |
306 | ++ value; |
272 | while(( * value ) && ( * value != '=' )) ++ value; |
307 | while(( * value ) && ( * value != '=' )) ++ value; |
273 | // not found? |
308 | // not found? |
274 | if( * value != '=' ) return EINVAL; |
309 | if( * value != '=' ) return EINVAL; |
275 | } |
310 | } |
276 | ++ value; |
311 | ++ value; |
277 | // skip spaces |
312 | // skip spaces |
278 | while( isspace( * value )) ++ value; |
313 | while( isspace( * value )) ++ value; |
279 | // create a bulk measured string till the end |
314 | // create a bulk measured string till the end |
280 | setting = measured_string_create_bulk( value, -1 ); |
315 | setting = measured_string_create_bulk( value, -1 ); |
281 | if( ! setting ) return ENOMEM; |
316 | if( ! setting ) return ENOMEM; |
282 | // add the configuration setting |
317 | // add the configuration setting |
283 | if( ERROR_OCCURRED( measured_strings_add( configuration, name, 0, setting ))){ |
318 | if( ERROR_OCCURRED( measured_strings_add( configuration, name, 0, setting ))){ |
284 | free( setting ); |
319 | free( setting ); |
285 | return ERROR_CODE; |
320 | return ERROR_CODE; |
286 | } |
321 | } |
287 | return EOK; |
322 | return EOK; |
288 | } |
323 | } |
289 | */ |
324 | */ |
290 | 325 | ||
291 | int add_configuration( measured_strings_ref configuration, const char * name, const char * value ){ |
326 | int add_configuration( measured_strings_ref configuration, const char * name, const char * value ){ |
292 | ERROR_DECLARE; |
327 | ERROR_DECLARE; |
293 | 328 | ||
294 | measured_string_ref setting; |
329 | measured_string_ref setting; |
295 | 330 | ||
296 | setting = measured_string_create_bulk( value, 0 ); |
331 | setting = measured_string_create_bulk( value, 0 ); |
297 | if( ! setting ) return ENOMEM; |
332 | if( ! setting ) return ENOMEM; |
298 | // add the configuration setting |
333 | // add the configuration setting |
299 | if( ERROR_OCCURRED( measured_strings_add( configuration, name, 0, setting ))){ |
334 | if( ERROR_OCCURRED( measured_strings_add( configuration, name, 0, setting ))){ |
300 | free( setting ); |
335 | free( setting ); |
301 | return ERROR_CODE; |
336 | return ERROR_CODE; |
302 | } |
337 | } |
303 | return EOK; |
338 | return EOK; |
304 | } |
339 | } |
305 | 340 | ||
306 | device_id_t generate_new_device_id( void ){ |
341 | device_id_t generate_new_device_id( void ){ |
307 | return device_assign_devno(); |
342 | return device_assign_devno(); |
308 | } |
343 | } |
309 | 344 | ||
310 | int read_configuration( void ){ |
345 | int read_configuration( void ){ |
311 | ERROR_DECLARE; |
346 | ERROR_DECLARE; |
312 | 347 | ||
313 | // read general configuration |
348 | // read general configuration |
314 | ERROR_PROPAGATE( add_configuration( & net_globals.configuration, "IPV", "4" )); |
349 | ERROR_PROPAGATE( add_configuration( & net_globals.configuration, "IPV", "4" )); |
315 | ERROR_PROPAGATE( add_configuration( & net_globals.configuration, "MTU", "1500" )); |
350 | ERROR_PROPAGATE( add_configuration( & net_globals.configuration, "MTU", "1500" )); |
- | 351 | ERROR_PROPAGATE( add_configuration( & net_globals.configuration, "ICMP_ERROR_REPORTING", "yes" )); //anything else not starting with 'y' |
|
- | 352 | ERROR_PROPAGATE( add_configuration( & net_globals.configuration, "ICMP_ECHO_REPLYING", "yes" )); //anything else not starting with 'y' |
|
316 | return EOK; |
353 | return EOK; |
317 | } |
354 | } |
318 | 355 | ||
- | 356 | int read_netif_configuration( char * name, netif_ref netif ){ |
|
- | 357 | ERROR_DECLARE; |
|
- | 358 | ||
- | 359 | if( str_lcmp( name, "lo", 2 ) == 0 ){ |
|
- | 360 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "NAME", LO_NAME )); |
|
- | 361 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "NETIF", LO_NAME )); |
|
- | 362 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "IL", IP_NAME )); |
|
- | 363 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "IP_CONFIG", "static" )); |
|
- | 364 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "IP_ADDR", "127.0.0.1" )); |
|
- | 365 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "IP_ROUTING", "yes" )); |
|
- | 366 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "NETMASK", "255.0.0.0" )); |
|
- | 367 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "MTU", "15535" )); |
|
- | 368 | }else if( str_lcmp( name, "ne2k", 4 ) == 0 ){ |
|
- | 369 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "NAME", "eth0" )); |
|
- | 370 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "NETIF", DP8390_NAME )); |
|
- | 371 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "ETH_MODE", "DIX" )); //8023_2_LSAP( not supported ), 8023_2_SNAP |
|
- | 372 | // ERROR_PROPAGATE( add_configuration( & netif->configuration, "ETH_DUMMY", "yes" )); //anything else not starting with 'y' |
|
- | 373 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "IL", IP_NAME )); |
|
- | 374 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "IRQ", "9" )); |
|
- | 375 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "IO", "300" )); |
|
- | 376 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "MTU", "576" )); |
|
- | 377 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "IP_CONFIG", "static" )); |
|
- | 378 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "IP_ADDR", "10.0.2.15" )); |
|
- | 379 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "IP_ROUTING", "yes" )); |
|
- | 380 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "NETMASK", "255.255.255.240" )); |
|
- | 381 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "BROADCAST", "10.0.2.255" )); |
|
- | 382 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "GATEWAY", "10.0.2.2" )); |
|
- | 383 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "DNS1", "10.0.2.2" )); |
|
- | 384 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "DNS2", "10.0.2.2" )); |
|
- | 385 | ERROR_PROPAGATE( add_configuration( & netif->configuration, "ARP", "arp" )); |
|
- | 386 | } |
|
- | 387 | return read_netif_configuration_build( name, netif ); |
|
- | 388 | } |
|
- | 389 | ||
319 | int start_device( netif_ref netif ){ |
390 | int start_device( netif_ref netif ){ |
320 | ERROR_DECLARE; |
391 | ERROR_DECLARE; |
321 | 392 | ||
322 | measured_string_ref setting; |
393 | measured_string_ref setting; |
323 | services_t internet_service; |
394 | services_t internet_service; |
324 | int irq; |
395 | int irq; |
325 | int io; |
396 | int io; |
326 | int mtu; |
397 | int mtu; |
327 | 398 | ||
328 | // mandatory netif |
399 | // mandatory netif |
329 | setting = measured_strings_find( & netif->configuration, CONF_NETIF, 0 ); |
400 | setting = measured_strings_find( & netif->configuration, CONF_NETIF, 0 ); |
330 | netif->driver = get_running_module( & net_globals.modules, setting->value ); |
401 | netif->driver = get_running_module( & net_globals.modules, setting->value ); |
331 | if( ! netif->driver ){ |
402 | if( ! netif->driver ){ |
332 | printf( "Failed to start the network interface driver %s\n", setting->value ); |
403 | printf( "Failed to start the network interface driver %s\n", setting->value ); |
333 | return EINVAL; |
404 | return EINVAL; |
334 | } |
405 | } |
335 | // optional network interface layer |
406 | // optional network interface layer |
336 | setting = measured_strings_find( & netif->configuration, CONF_NIL, 0 ); |
407 | setting = measured_strings_find( & netif->configuration, CONF_NIL, 0 ); |
337 | if( setting ){ |
408 | if( setting ){ |
338 | netif->nil = get_running_module( & net_globals.modules, setting->value ); |
409 | netif->nil = get_running_module( & net_globals.modules, setting->value ); |
339 | if( ! netif->nil ){ |
410 | if( ! netif->nil ){ |
340 | printf( "Failed to start the network interface layer %s\n", setting->value ); |
411 | printf( "Failed to start the network interface layer %s\n", setting->value ); |
341 | return EINVAL; |
412 | return EINVAL; |
342 | } |
413 | } |
343 | }else{ |
414 | }else{ |
344 | netif->nil = NULL; |
415 | netif->nil = NULL; |
345 | } |
416 | } |
346 | // mandatory internet layer |
417 | // mandatory internet layer |
347 | setting = measured_strings_find( & netif->configuration, CONF_IL, 0 ); |
418 | setting = measured_strings_find( & netif->configuration, CONF_IL, 0 ); |
348 | netif->il = get_running_module( & net_globals.modules, setting->value ); |
419 | netif->il = get_running_module( & net_globals.modules, setting->value ); |
349 | if( ! netif->il ){ |
420 | if( ! netif->il ){ |
350 | printf( "Failed to start the internet layer %s\n", setting->value ); |
421 | printf( "Failed to start the internet layer %s\n", setting->value ); |
351 | return EINVAL; |
422 | return EINVAL; |
352 | } |
423 | } |
353 | // end of the static loopback initialization |
424 | // end of the static loopback initialization |
354 | // startup the loopback interface |
425 | // startup the loopback interface |
355 | setting = measured_strings_find( & netif->configuration, CONF_IRQ, 0 ); |
426 | setting = measured_strings_find( & netif->configuration, CONF_IRQ, 0 ); |
356 | irq = setting ? strtol( setting->value, NULL, 10 ) : 0; |
427 | irq = setting ? strtol( setting->value, NULL, 10 ) : 0; |
357 | setting = measured_strings_find( & netif->configuration, CONF_IO, 0 ); |
428 | setting = measured_strings_find( & netif->configuration, CONF_IO, 0 ); |
358 | io = setting ? strtol( setting->value, NULL, 16 ) : 0; |
429 | io = setting ? strtol( setting->value, NULL, 16 ) : 0; |
359 | ERROR_PROPAGATE( netif_probe_req( netif->driver->phone, netif->id, irq, io )); |
430 | ERROR_PROPAGATE( netif_probe_req( netif->driver->phone, netif->id, irq, io )); |
360 | if( netif->nil ){ |
431 | if( netif->nil ){ |
361 | setting = measured_strings_find( & netif->configuration, CONF_MTU, 0 ); |
432 | setting = measured_strings_find( & netif->configuration, CONF_MTU, 0 ); |
362 | if( ! setting ){ |
433 | if( ! setting ){ |
363 | setting = measured_strings_find( & net_globals.configuration, CONF_MTU, 0 ); |
434 | setting = measured_strings_find( & net_globals.configuration, CONF_MTU, 0 ); |
364 | } |
435 | } |
365 | mtu = setting ? strtol( setting->value, NULL, 10 ) : 0; |
436 | mtu = setting ? strtol( setting->value, NULL, 10 ) : 0; |
366 | ERROR_PROPAGATE( nil_device_req( netif->nil->phone, netif->id, mtu, netif->driver->service )); |
437 | ERROR_PROPAGATE( nil_device_req( netif->nil->phone, netif->id, mtu, netif->driver->service )); |
367 | internet_service = netif->nil->service; |
438 | internet_service = netif->nil->service; |
368 | }else{ |
439 | }else{ |
369 | internet_service = netif->driver->service; |
440 | internet_service = netif->driver->service; |
370 | } |
441 | } |
371 | switch( netif->il->service ){ |
442 | switch( netif->il->service ){ |
372 | case SERVICE_IP: |
443 | case SERVICE_IP: |
373 | ERROR_PROPAGATE( ip_device_req( netif->il->phone, netif->id, internet_service )); |
444 | ERROR_PROPAGATE( ip_device_req( netif->il->phone, netif->id, internet_service )); |
374 | break; |
445 | break; |
375 | default: |
446 | default: |
376 | return ENOENT; |
447 | return ENOENT; |
377 | } |
448 | } |
378 | ERROR_PROPAGATE( netif_start_req( netif->driver->phone, netif->id )); |
449 | ERROR_PROPAGATE( netif_start_req( netif->driver->phone, netif->id )); |
379 | return EOK; |
450 | return EOK; |
380 | } |
451 | } |
381 | 452 | ||
382 | int startup( void ){ |
453 | int startup( void ){ |
383 | ERROR_DECLARE; |
454 | ERROR_DECLARE; |
384 | 455 | ||
385 | char * conf_files[] = { "lo", "ne2k" }; |
456 | char * conf_files[] = { "lo", "ne2k" }; |
386 | int count = sizeof( conf_files ) / sizeof( char * ); |
457 | int count = sizeof( conf_files ) / sizeof( char * ); |
387 | int index; |
458 | int index; |
388 | netif_ref netif; |
459 | netif_ref netif; |
389 | int i; |
460 | int i; |
390 | measured_string_ref setting; |
461 | measured_string_ref setting; |
391 | 462 | ||
392 | // TODO dynamic configuration |
- | |
393 | ERROR_PROPAGATE( read_configuration()); |
- | |
394 | - | ||
395 | for( i = 0; i < count; ++ i ){ |
463 | for( i = 0; i < count; ++ i ){ |
396 | netif = ( netif_ref ) malloc( sizeof( netif_t )); |
464 | netif = ( netif_ref ) malloc( sizeof( netif_t )); |
397 | if( ! netif ) return ENOMEM; |
465 | if( ! netif ) return ENOMEM; |
398 | 466 | ||
399 | netif->id = generate_new_device_id(); |
467 | netif->id = generate_new_device_id(); |
400 | if( ! netif->id ) return EXDEV; |
468 | if( ! netif->id ) return EXDEV; |
401 | ERROR_PROPAGATE( measured_strings_initialize( & netif->configuration )); |
469 | ERROR_PROPAGATE( measured_strings_initialize( & netif->configuration )); |
402 | // read configuration files |
470 | // read configuration files |
403 | if( ERROR_OCCURRED( read_netif_configuration( conf_files[ i ], netif ))){ |
471 | if( ERROR_OCCURRED( read_netif_configuration( conf_files[ i ], netif ))){ |
404 | measured_strings_destroy( & netif->configuration ); |
472 | measured_strings_destroy( & netif->configuration ); |
405 | free( netif ); |
473 | free( netif ); |
406 | return ERROR_CODE; |
474 | return ERROR_CODE; |
407 | } |
475 | } |
408 | // mandatory name |
476 | // mandatory name |
409 | setting = measured_strings_find( & netif->configuration, CONF_NAME, 0 ); |
477 | setting = measured_strings_find( & netif->configuration, CONF_NAME, 0 ); |
410 | if( ! setting ){ |
478 | if( ! setting ){ |
411 | printf( "The name is missing\n" ); |
479 | printf( "The name is missing\n" ); |
412 | measured_strings_destroy( & netif->configuration ); |
480 | measured_strings_destroy( & netif->configuration ); |
413 | free( netif ); |
481 | free( netif ); |
414 | return EINVAL; |
482 | return EINVAL; |
415 | } |
483 | } |
416 | netif->name = setting->value; |
484 | netif->name = setting->value; |
417 | // add to the netifs map |
485 | // add to the netifs map |
418 | index = netifs_add( & net_globals.netifs, netif->id, netif ); |
486 | index = netifs_add( & net_globals.netifs, netif->id, netif ); |
419 | if( index < 0 ){ |
487 | if( index < 0 ){ |
420 | measured_strings_destroy( & netif->configuration ); |
488 | measured_strings_destroy( & netif->configuration ); |
421 | free( netif ); |
489 | free( netif ); |
422 | return index; |
490 | return index; |
423 | } |
491 | } |
424 | // add to the netif names map |
492 | // add to the netif names map |
425 | if( ERROR_OCCURRED( char_map_add( & net_globals.netif_names, netif->name, 0, index )) |
493 | if( ERROR_OCCURRED( char_map_add( & net_globals.netif_names, netif->name, 0, index )) |
426 | // start network interfaces and needed modules |
494 | // start network interfaces and needed modules |
427 | || ERROR_OCCURRED( start_device( netif ))){ |
495 | || ERROR_OCCURRED( start_device( netif ))){ |
428 | measured_strings_destroy( & netif->configuration ); |
496 | measured_strings_destroy( & netif->configuration ); |
429 | netifs_exclude_index( & net_globals.netifs, index ); |
497 | netifs_exclude_index( & net_globals.netifs, index ); |
430 | return ERROR_CODE; |
498 | return ERROR_CODE; |
431 | } |
499 | } |
432 | // increment modules' usage |
500 | // increment modules' usage |
433 | ++ netif->driver->usage; |
501 | ++ netif->driver->usage; |
434 | if( netif->nil ) ++ netif->nil->usage; |
502 | if( netif->nil ) ++ netif->nil->usage; |
435 | ++ netif->il->usage; |
503 | ++ netif->il->usage; |
436 | printf( "New network interface started:\n\tname\t= %s\n\tid\t= %d\n\tdriver\t= %s\n\tnil\t= %s\n\til\t= %s\n", netif->name, netif->id, netif->driver->name, netif->nil ? netif->nil->name : NULL, netif->il->name ); |
504 | printf( "New network interface started:\n\tname\t= %s\n\tid\t= %d\n\tdriver\t= %s\n\tnil\t= %s\n\til\t= %s\n", netif->name, netif->id, netif->driver->name, netif->nil ? netif->nil->name : NULL, netif->il->name ); |
437 | } |
505 | } |
438 | return EOK; |
506 | return EOK; |
439 | } |
507 | } |
440 | 508 | ||
441 | /** @} |
509 | /** @} |
442 | */ |
510 | */ |
443 | 511 |