Rev 3886 | Rev 3912 | Go to most recent revision | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed
Rev 3886 | Rev 3901 | ||
---|---|---|---|
1 | /* |
1 | /* |
2 | * Copyright (c) 2008 Lukas Mejdrech |
2 | * Copyright (c) 2008 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 | */ |
34 | */ |
35 | 35 | ||
36 | #include <async.h> |
36 | #include <async.h> |
37 | #include <ctype.h> |
37 | #include <ctype.h> |
38 | #include <errno.h> |
38 | #include <errno.h> |
39 | #include <malloc.h> |
39 | #include <malloc.h> |
40 | #include <stdio.h> |
40 | #include <stdio.h> |
41 | #include <task.h> |
41 | #include <task.h> |
42 | #include <unistd.h> |
42 | #include <unistd.h> |
43 | 43 | ||
44 | #include <ipc/ipc.h> |
44 | #include <ipc/ipc.h> |
45 | #include <ipc/services.h> |
45 | #include <ipc/services.h> |
46 | 46 | ||
47 | #include "../err.h" |
47 | #include "../err.h" |
48 | #include "../messages.h" |
48 | #include "../messages.h" |
49 | #include "../modules.h" |
49 | #include "../modules.h" |
50 | //#include "../self_test.h" |
50 | //#include "../self_test.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/packet/packet.h" |
|
- | 56 | #include "../structures/packet/packet_server.h" |
|
55 | 57 | ||
56 | #include "../il/ip/ip_messages.h" |
58 | #include "../il/ip/ip_messages.h" |
57 | #include "../netif/device.h" |
59 | #include "../netif/device.h" |
58 | 60 | ||
59 | #if IP_BUNDLE |
61 | #if IP_BUNDLE |
60 | 62 | ||
61 | #include "../ip/ip_module.h" |
63 | #include "../ip/ip_module.h" |
62 | 64 | ||
63 | #endif |
65 | #endif |
64 | 66 | ||
65 | #if TCP_BUNDLE |
67 | #if TCP_BUNDLE |
66 | 68 | ||
67 | #include "../tcp/tcp_module.h" |
69 | #include "../tcp/tcp_module.h" |
68 | 70 | ||
69 | #endif |
71 | #endif |
70 | 72 | ||
- | 73 | #define NAME "Networking" |
|
- | 74 | ||
71 | #define LO_NAME "lo" |
75 | #define LO_NAME "lo" |
72 | #define LO_FILENAME "/sbin/lo" |
76 | #define LO_FILENAME "/sbin/lo" |
73 | #define DP8390_ISA_NAME "dp8390_isa" |
77 | #define DP8390_ISA_NAME "dp8390_isa" |
74 | #define DP8390_ISA_FILENAME "/sbin/dp8380_isa" |
78 | #define DP8390_ISA_FILENAME "/sbin/dp8380_isa" |
75 | #define ETHERNET_NAME "ethernet" |
79 | #define ETHERNET_NAME "ethernet" |
76 | #define ETHERNET_FILENAME "/sbin/ethernet" |
80 | #define ETHERNET_FILENAME "/sbin/ethernet" |
77 | #define IP_NAME "ip" |
81 | #define IP_NAME "ip" |
78 | #define IP_FILENAME "/sbin/ip" |
82 | #define IP_FILENAME "/sbin/ip" |
79 | 83 | ||
- | 84 | #define IPC_GET_DEVICE( call ) ( device_id_t ) IPC_GET_ARG1( * call ) |
|
- | 85 | #define IPC_GET_COUNT( call ) ( int ) IPC_GET_ARG2( * call ) |
|
- | 86 | ||
80 | typedef struct module_struct module_t; |
87 | typedef struct module_struct module_t; |
81 | typedef module_t * module_ref; |
88 | typedef module_t * module_ref; |
82 | 89 | ||
83 | typedef struct netif netif_t; |
90 | typedef struct netif netif_t; |
84 | typedef netif_t * netif_ref; |
91 | typedef netif_t * netif_ref; |
85 | 92 | ||
86 | typedef struct networking_globals networking_globals_t; |
93 | typedef struct networking_globals networking_globals_t; |
87 | 94 | ||
88 | DEVICE_MAP_DECLARE( netifs, netif_t ) |
95 | DEVICE_MAP_DECLARE( netifs, netif_t ) |
89 | 96 | ||
90 | GENERIC_CHAR_MAP_DECLARE( measured_strings, measured_string_t ) |
97 | GENERIC_CHAR_MAP_DECLARE( measured_strings, measured_string_t ) |
91 | 98 | ||
92 | GENERIC_CHAR_MAP_DECLARE( modules, module_t ) |
99 | GENERIC_CHAR_MAP_DECLARE( modules, module_t ) |
93 | 100 | ||
94 | struct module_struct{ |
101 | struct module_struct{ |
95 | task_id_t task_id; |
102 | task_id_t task_id; |
96 | services_t service; |
103 | services_t service; |
97 | int phone; |
104 | int phone; |
98 | int usage; |
105 | int usage; |
99 | const char * name; |
106 | const char * name; |
100 | const char * filename; |
107 | const char * filename; |
101 | }; |
108 | }; |
102 | 109 | ||
103 | /** A present network interface device. |
110 | /** A present network interface device. |
104 | */ |
111 | */ |
105 | struct netif{ |
112 | struct netif{ |
106 | /** A system-unique network interface identifier. |
113 | /** A system-unique network interface identifier. |
107 | */ |
114 | */ |
108 | device_id_t id; |
115 | device_id_t id; |
109 | /** A serving network interface driver module index. |
116 | /** A serving network interface driver module index. |
110 | */ |
117 | */ |
111 | module_ref driver; |
118 | module_ref driver; |
112 | /** A serving link layer module index. |
119 | /** A serving link layer module index. |
113 | */ |
120 | */ |
114 | module_ref nil; |
121 | module_ref nil; |
115 | /** A serving internet layer module index. |
122 | /** A serving internet layer module index. |
116 | */ |
123 | */ |
117 | module_ref il; |
124 | module_ref il; |
118 | /** A system-unique network interface name. |
125 | /** A system-unique network interface name. |
119 | */ |
126 | */ |
120 | char * name; |
127 | char * name; |
121 | /** Configuration. |
128 | /** Configuration. |
122 | */ |
129 | */ |
123 | measured_strings_t configuration; |
130 | measured_strings_t configuration; |
124 | }; |
131 | }; |
125 | 132 | ||
126 | /** A networking module global variables. |
133 | /** A networking module global variables. |
127 | */ |
134 | */ |
128 | struct networking_globals{ |
135 | struct networking_globals{ |
129 | /** Present network interfaces. |
136 | /** Present network interfaces. |
130 | */ |
137 | */ |
131 | netifs_t netifs; |
138 | netifs_t netifs; |
132 | /** Network interface structure indices by names. |
139 | /** Network interface structure indices by names. |
133 | */ |
140 | */ |
134 | char_map_t netif_names; |
141 | char_map_t netif_names; |
135 | /** Available modules. |
142 | /** Available modules. |
136 | */ |
143 | */ |
137 | modules_t modules; |
144 | modules_t modules; |
138 | /** Global configuration. |
145 | /** Global configuration. |
139 | */ |
146 | */ |
140 | measured_strings_t configuration; |
147 | measured_strings_t configuration; |
141 | }; |
148 | }; |
142 | 149 | ||
- | 150 | void networking_print_name( void ); |
|
143 | int add_module( module_ref * module, modules_ref modules, const char const * name, const char const * filename, services_t service, task_id_t task_id ); |
151 | int add_module( module_ref * module, modules_ref modules, const char const * name, const char const * filename, services_t service, task_id_t task_id ); |
144 | static void client_connection( ipc_callid_t iid, ipc_call_t * icall ); |
152 | static void client_connection( ipc_callid_t iid, ipc_call_t * icall ); |
145 | measured_string_ref configuration_find( measured_strings_ref configuration, const char * name ); |
153 | measured_string_ref configuration_find( measured_strings_ref configuration, const char * name ); |
146 | int main( int argc, char * argv[] ); |
154 | int networking_start_module( async_client_conn_t client_connection ); |
147 | int networking_initialize( void ); |
155 | int networking_initialize( void ); |
148 | int networking_message( ipcarg_t method, ipcarg_t arg1, ipcarg_t arg2, ipcarg_t arg3, ipcarg_t * result1, ipcarg_t * result2, ipcarg_t * result3 ); |
156 | int networking_message( ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count ); |
- | 157 | int net_message( ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count ); |
|
149 | //int parse_line( measured_strings_ref configuration, char * line ); |
158 | //int parse_line( measured_strings_ref configuration, char * line ); |
150 | int add_configuration( measured_strings_ref configuration, const char * name, const char * value ); |
159 | int add_configuration( measured_strings_ref configuration, const char * name, const char * value ); |
151 | int read_configuration( void ); |
160 | int read_configuration( void ); |
152 | task_id_t spawn( const char * fname ); |
161 | task_id_t spawn( const char * fname ); |
153 | int startup( void ); |
162 | int startup( void ); |
154 | device_id_t generate_new_device_id( void ); |
163 | device_id_t generate_new_device_id( void ); |
155 | 164 | ||
156 | static networking_globals_t networking_globals; |
165 | static networking_globals_t networking_globals; |
157 | 166 | ||
158 | DEVICE_MAP_IMPLEMENT( netifs, netif_t ) |
167 | DEVICE_MAP_IMPLEMENT( netifs, netif_t ) |
159 | 168 | ||
160 | GENERIC_CHAR_MAP_IMPLEMENT( measured_strings, measured_string_t ) |
169 | GENERIC_CHAR_MAP_IMPLEMENT( measured_strings, measured_string_t ) |
161 | 170 | ||
162 | GENERIC_CHAR_MAP_IMPLEMENT( modules, module_t ) |
171 | GENERIC_CHAR_MAP_IMPLEMENT( modules, module_t ) |
163 | 172 | ||
- | 173 | void networking_print_name( void ){ |
|
- | 174 | printf( NAME ); |
|
- | 175 | } |
|
- | 176 | ||
164 | int add_module( module_ref * module, modules_ref modules, const char * name, const char * filename, services_t service, task_id_t task_id ){ |
177 | int add_module( module_ref * module, modules_ref modules, const char * name, const char * filename, services_t service, task_id_t task_id ){ |
165 | ERROR_DECLARE; |
178 | ERROR_DECLARE; |
166 | 179 | ||
167 | module_ref tmp_module; |
180 | module_ref tmp_module; |
168 | 181 | ||
169 | tmp_module = ( module_ref ) malloc( sizeof( module_t )); |
182 | tmp_module = ( module_ref ) malloc( sizeof( module_t )); |
170 | if( ! tmp_module ) return ENOMEM; |
183 | if( ! tmp_module ) return ENOMEM; |
171 | tmp_module->task_id = task_id; |
184 | tmp_module->task_id = task_id; |
172 | tmp_module->phone = 0; |
185 | tmp_module->phone = 0; |
173 | tmp_module->usage = 0; |
186 | tmp_module->usage = 0; |
174 | tmp_module->name = name; |
187 | tmp_module->name = name; |
175 | tmp_module->filename = filename; |
188 | tmp_module->filename = filename; |
176 | tmp_module->service = service; |
189 | tmp_module->service = service; |
177 | if( ERROR_OCCURED( modules_add( modules, tmp_module->name, 0, tmp_module ))){ |
190 | if( ERROR_OCCURED( modules_add( modules, tmp_module->name, 0, tmp_module ))){ |
178 | free( tmp_module ); |
191 | free( tmp_module ); |
179 | return ERROR_CODE; |
192 | return ERROR_CODE; |
180 | } |
193 | } |
181 | if( module ) * module = tmp_module; |
194 | if( module ) * module = tmp_module; |
182 | return EOK; |
195 | return EOK; |
183 | } |
196 | } |
184 | 197 | ||
185 | static void client_connection( ipc_callid_t iid, ipc_call_t * icall ){ |
198 | int networking_message( ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count ){ |
186 | ipc_callid_t callid; |
- | |
187 | ipc_call_t call; |
- | |
188 | ipcarg_t arg1, arg2, arg3; |
- | |
189 | int res; |
- | |
190 | - | ||
191 | /* |
- | |
192 | * Accept the connection |
- | |
193 | * - Answer the first IPC_M_CONNECT_ME_TO call. |
- | |
194 | */ |
- | |
195 | // printf( "\nNET-%d got %d on %x from %x", fibril_get_id(), IPC_GET_METHOD( * icall ), icall->in_phone_hash, iid ); |
- | |
196 | ipc_answer_0( iid, EOK ); |
- | |
197 | - | ||
198 | while( true ){ |
- | |
199 | callid = async_get_call( & call ); |
- | |
200 | arg1 = 0; |
- | |
201 | arg2 = 0; |
- | |
202 | arg3 = 0; |
- | |
203 | // printf( "\nNET-%d got %d on %x from %x", fibril_get_id(), IPC_GET_METHOD( call ), call.in_phone_hash, callid ); |
- | |
204 | #ifdef NETWORKING_module |
199 | #ifdef NETWORKING_module |
- | 200 | //TODO map to *_message |
|
205 | if( IS_NET_IL_MESSAGE( call ) || IS_NET_IP_MESSAGE( call )){ |
201 | if( IS_NET_IL_MESSAGE( call ) || IS_NET_IP_MESSAGE( call )){ |
206 | res = ip_message( IPC_GET_METHOD( call ), IPC_GET_ARG1( call ), IPC_GET_ARG2( call ), IPC_GET_ARG3( call ), & arg1, & arg2, & arg3 ); |
202 | return ip_message( callid, call, answer, answer_count ); |
207 | /* }else if( IS_NET_ARP_MESSAGE( call )){ |
203 | /* }else if( IS_NET_ARP_MESSAGE( call )){ |
208 | res = arp_message( IPC_GET_METHOD( call ), IPC_GET_ARG1( call ), IPC_GET_ARG2( call ), IPC_GET_ARG3( call ), & arg1, & arg2, & arg3 ); |
204 | return arp_message( callid, call, answer, answer_count ); |
209 | *//* }else if( IS_NET_RARP_MESSAGE( call )){ |
205 | *//* }else if( IS_NET_RARP_MESSAGE( call )){ |
210 | res = rarp_message( IPC_GET_METHOD( call ), IPC_GET_ARG1( call ), IPC_GET_ARG2( call ), IPC_GET_ARG3( call ), & arg1, & arg2, & arg3 ); |
206 | return rarp_message( callid, call, answer, answer_count ); |
211 | *//* }else if( IS_NET_ICMP_MESSAGE( call )){ |
207 | *//* }else if( IS_NET_ICMP_MESSAGE( call )){ |
212 | res = icmp_message( IPC_GET_METHOD( call ), IPC_GET_ARG1( call ), IPC_GET_ARG2( call ), IPC_GET_ARG3( call ), & arg1, & arg2, & arg3 ); |
208 | return icmp_message( callid, call, answer, answer_count ); |
213 | *//* }else if( IS_NET_UDP_MESSAGE( call )){ |
209 | *//* }else if( IS_NET_UDP_MESSAGE( call )){ |
214 | res = udp_message( IPC_GET_METHOD( call ), IPC_GET_ARG1( call ), IPC_GET_ARG2( call ), IPC_GET_ARG3( call ), & arg1, & arg2, & arg3 ); |
210 | return udp_message( callid, call, answer, answer_count ); |
215 | */ }else if( IS_NET_TCP_MESSAGE( call )){ |
211 | */ }else if( IS_NET_TCP_MESSAGE( call )){ |
216 | res = tcp_message( IPC_GET_METHOD( call ), IPC_GET_ARG1( call ), IPC_GET_ARG2( call ), IPC_GET_ARG3( call ), & arg1, & arg2, & arg3 ); |
212 | return tcp_message( callid, call, answer, answer_count ); |
217 | /* }else if( IS_NET_SOCKET_MESSAGE( call )){ |
213 | /* }else if( IS_NET_SOCKET_MESSAGE( call )){ |
218 | res = socket_message( IPC_GET_METHOD( call ), IPC_GET_ARG1( call ), IPC_GET_ARG2( call ), IPC_GET_ARG3( call ), & arg1, & arg2, & arg3 ); |
214 | return socket_message( callid, call, answer, answer_count ); |
219 | *//* }else if( IS_NET_NIL_MESSAGE( call ) || IS_NET_ETHERNET_MESSAGE( call )){ |
215 | *//* }else if( IS_NET_NIL_MESSAGE( call ) || IS_NET_ETHERNET_MESSAGE( call )){ |
220 | res = ethernet_message( IPC_GET_METHOD( call ), IPC_GET_ARG1( call ), IPC_GET_ARG2( call ), IPC_GET_ARG3( call ), & arg1, & arg2, & arg3 ); |
216 | return ethernet_message( callid, call, answer, answer_count ); |
221 | */ }else{ |
217 | */ }else{ |
222 | #endif |
218 | #endif |
- | 219 | if( IS_NET_PACKET_MESSAGE( call )){ |
|
223 | res = networking_message( IPC_GET_METHOD( call ), IPC_GET_ARG1( call ), IPC_GET_ARG2( call ), IPC_GET_ARG3( call ), & arg1, & arg2, & arg3 ); |
220 | return packet_server_message( callid, call, answer, answer_count ); |
- | 221 | }else{ |
|
- | 222 | return net_message( callid, call, answer, answer_count ); |
|
- | 223 | } |
|
224 | #ifdef NETWORKING_module |
224 | #ifdef NETWORKING_module |
225 | } |
225 | } |
226 | #endif |
226 | #endif |
227 | ipc_answer_2( callid, res, arg1, arg2 ); |
- | |
228 | } |
- | |
229 | } |
227 | } |
230 | 228 | ||
231 | int main( int argc, char * argv[] ){ |
229 | int networking_start_module( async_client_conn_t client_connection ){ |
232 | ERROR_DECLARE; |
230 | ERROR_DECLARE; |
233 | 231 | ||
234 | ipcarg_t phonehash; |
232 | ipcarg_t phonehash; |
235 | 233 | ||
236 | printf("\nTask %d - HelenOS Networking subsystem", task_get_id()); |
- | |
237 | - | ||
238 | async_set_client_connection( client_connection ); |
234 | async_set_client_connection( client_connection ); |
239 | ERROR_PROPAGATE( networking_initialize()); |
235 | ERROR_PROPAGATE( networking_initialize()); |
240 | ERROR_PROPAGATE( REGISTER_ME( SERVICE_NETWORKING, & phonehash )); |
236 | ERROR_PROPAGATE( REGISTER_ME( SERVICE_NETWORKING, & phonehash )); |
241 | - | ||
- | 237 | ERROR_PROPAGATE( pm_init()); |
|
242 | async_manager(); |
238 | async_manager(); |
243 | 239 | ||
244 | return EOK; |
240 | return EOK; |
245 | } |
241 | } |
246 | 242 | ||
247 | int networking_initialize( void ){ |
243 | int networking_initialize( void ){ |
248 | ERROR_DECLARE; |
244 | ERROR_DECLARE; |
249 | 245 | ||
250 | task_id_t task_id; |
246 | task_id_t task_id; |
251 | 247 | ||
252 | netifs_initialize( & networking_globals.netifs ); |
248 | netifs_initialize( & networking_globals.netifs ); |
253 | char_map_initialize( & networking_globals.netif_names ); |
249 | char_map_initialize( & networking_globals.netif_names ); |
254 | modules_initialize( & networking_globals.modules ); |
250 | modules_initialize( & networking_globals.modules ); |
255 | measured_strings_initialize( & networking_globals.configuration ); |
251 | measured_strings_initialize( & networking_globals.configuration ); |
256 | 252 | ||
257 | // run self tests |
253 | // run self tests |
258 | // ERROR_PROPAGATE( self_test()); |
254 | // ERROR_PROPAGATE( self_test()); |
259 | 255 | ||
260 | ERROR_PROPAGATE( add_module( NULL, & networking_globals.modules, LO_NAME, LO_FILENAME, SERVICE_LO, 0 )); |
256 | ERROR_PROPAGATE( add_module( NULL, & networking_globals.modules, LO_NAME, LO_FILENAME, SERVICE_LO, 0 )); |
261 | ERROR_PROPAGATE( add_module( NULL, & networking_globals.modules, DP8390_ISA_NAME, DP8390_ISA_FILENAME, SERVICE_DP8390_ISA, 0 )); |
257 | ERROR_PROPAGATE( add_module( NULL, & networking_globals.modules, DP8390_ISA_NAME, DP8390_ISA_FILENAME, SERVICE_DP8390_ISA, 0 )); |
262 | ERROR_PROPAGATE( add_module( NULL, & networking_globals.modules, ETHERNET_NAME, ETHERNET_FILENAME, SERVICE_ETHERNET, 0 )); |
258 | ERROR_PROPAGATE( add_module( NULL, & networking_globals.modules, ETHERNET_NAME, ETHERNET_FILENAME, SERVICE_ETHERNET, 0 )); |
263 | 259 | ||
264 | #ifdef NETWORKING_modular |
260 | #ifdef NETWORKING_modular |
265 | task_id = spawn( "/sbin/ip" ); |
261 | task_id = spawn( "/sbin/ip" ); |
266 | if( ! task_id ) return EINVAL; |
262 | if( ! task_id ) return EINVAL; |
267 | ERROR_PROPAGATE( add_module( NULL, & networking_globals.modules, IP_NAME, IP_FILENAME, SERVICE_IP, task_id )); |
263 | ERROR_PROPAGATE( add_module( NULL, & networking_globals.modules, IP_NAME, IP_FILENAME, SERVICE_IP, task_id )); |
268 | // if( ! spawn( "/sbin/udp" )) return EINVAL; |
264 | // if( ! spawn( "/sbin/udp" )) return EINVAL; |
269 | if( ! spawn( "/sbin/tcp" )) return EINVAL; |
265 | if( ! spawn( "/sbin/tcp" )) return EINVAL; |
270 | // if( ! spawn( "/sbin/socket" )) return EINVAL; |
266 | // if( ! spawn( "/sbin/socket" )) return EINVAL; |
271 | // not always necesssary |
267 | // not always necesssary |
272 | // if( ! spawn( "/sbin/arp" )) return EINVAL; |
268 | // if( ! spawn( "/sbin/arp" )) return EINVAL; |
273 | // if( ! spawn( "/sbin/rarp" )) return EINVAL; |
269 | // if( ! spawn( "/sbin/rarp" )) return EINVAL; |
274 | // if( ! spawn( "/sbin/icmp" )) return EINVAL; |
270 | // if( ! spawn( "/sbin/icmp" )) return EINVAL; |
275 | 271 | ||
276 | #else |
272 | #else |
277 | #ifdef NETWORKING_module |
273 | #ifdef NETWORKING_module |
278 | ipcarg_t phonehash; |
274 | ipcarg_t phonehash; |
279 | 275 | ||
280 | ERROR_PROPAGATE( REGISTER_ME( SERVICE_IP, & phonehash )); |
276 | ERROR_PROPAGATE( REGISTER_ME( SERVICE_IP, & phonehash )); |
281 | ERROR_PROPAGATE( add_module( NULL, & networking_globals.modules, IP_NAME, IP_FILENAME, SERVICE_IP, task_get_id())); |
277 | ERROR_PROPAGATE( add_module( NULL, & networking_globals.modules, IP_NAME, IP_FILENAME, SERVICE_IP, task_get_id())); |
282 | ERROR_PROPAGATE( ip_initialize()); |
278 | ERROR_PROPAGATE( ip_initialize()); |
283 | // ERROR_PROPAGATE( REGISTER_ME( SERVICE_ARP, & phonehash )); |
279 | // ERROR_PROPAGATE( REGISTER_ME( SERVICE_ARP, & phonehash )); |
284 | // ERROR_PROPAGATE( arp_initialize()); |
280 | // ERROR_PROPAGATE( arp_initialize()); |
285 | // ERROR_PROPAGATE( REGISTER_ME( SERVICE_RARP, & phonehash )); |
281 | // ERROR_PROPAGATE( REGISTER_ME( SERVICE_RARP, & phonehash )); |
286 | // ERROR_PROPAGATE( rarp_initialize()); |
282 | // ERROR_PROPAGATE( rarp_initialize()); |
287 | // ERROR_PROPAGATE( REGISTER_ME( SERVICE_ICMP, & phonehash )); |
283 | // ERROR_PROPAGATE( REGISTER_ME( SERVICE_ICMP, & phonehash )); |
288 | // ERROR_PROPAGATE( icmp_initialize()); |
284 | // ERROR_PROPAGATE( icmp_initialize()); |
289 | // ERROR_PROPAGATE( REGISTER_ME( SERVICE_UDP, & phonehash )); |
285 | // ERROR_PROPAGATE( REGISTER_ME( SERVICE_UDP, & phonehash )); |
290 | // ERROR_PROPAGATE( udp_initialize()); |
286 | // ERROR_PROPAGATE( udp_initialize()); |
291 | ERROR_PROPAGATE( REGISTER_ME( SERVICE_TCP, & phonehash )); |
287 | ERROR_PROPAGATE( REGISTER_ME( SERVICE_TCP, & phonehash )); |
292 | ERROR_PROPAGATE( tcp_initialize()); |
288 | ERROR_PROPAGATE( tcp_initialize()); |
293 | // ERROR_PROPAGATE( REGISTER_ME( SERVICE_SOCKET, & phonehash )); |
289 | // ERROR_PROPAGATE( REGISTER_ME( SERVICE_SOCKET, & phonehash )); |
294 | // ERROR_PROPAGATE( socket_initialize()); |
290 | // ERROR_PROPAGATE( socket_initialize()); |
295 | // ERROR_PROPAGATE( REGISTER_ME( SERVICE_ETHERNET, & phonehash )); |
291 | // ERROR_PROPAGATE( REGISTER_ME( SERVICE_ETHERNET, & phonehash )); |
296 | // ERROR_PROPAGATE( ethernet_initialize()); |
292 | // ERROR_PROPAGATE( ethernet_initialize()); |
297 | #endif |
293 | #endif |
298 | #endif |
294 | #endif |
299 | 295 | ||
300 | return EOK; |
296 | return EOK; |
301 | } |
297 | } |
302 | 298 | ||
- | 299 | //TODO as ip.c |
|
303 | int networking_message( ipcarg_t method, ipcarg_t arg1, ipcarg_t arg2, ipcarg_t arg3, ipcarg_t * result1, ipcarg_t * result2, ipcarg_t * result3 ){ |
300 | int net_message( ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count ){ |
304 | ERROR_DECLARE; |
301 | ERROR_DECLARE; |
305 | 302 | ||
306 | measured_string_ref strings; |
303 | measured_string_ref strings; |
307 | char * data; |
304 | char * data; |
308 | int index; |
305 | int index; |
309 | measured_string_ref setting; |
306 | measured_string_ref setting; |
310 | measured_strings_ref configuration; |
307 | measured_strings_ref configuration; |
311 | netif_ref netif; |
308 | netif_ref netif; |
312 | 309 | ||
- | 310 | * answer_count = 0; |
|
313 | switch( method ){ |
311 | switch( IPC_GET_METHOD( * call )){ |
314 | case IPC_M_PHONE_HUNGUP: |
312 | case IPC_M_PHONE_HUNGUP: |
315 | return EOK; |
313 | return EOK; |
316 | case NET_NET_DEVICE: |
314 | case NET_NET_DEVICE: |
317 | // TODO configure, register |
315 | // TODO configure, register |
318 | // arg1 = netif id |
- | |
319 | printf( "\nNetworking: new netif %d", arg1 ); |
316 | printf( "\nNetworking: new netif %d", IPC_GET_DEVICE( call )); |
320 | return EOK; |
317 | return EOK; |
321 | case NET_NET_GET_DEVICE_CONF: |
318 | case NET_NET_GET_DEVICE_CONF: |
322 | // arg1 = netif id |
- | |
323 | // arg2 = count |
- | |
324 | ERROR_PROPAGATE( measured_strings_receive( & strings, & data, arg2 )); |
319 | ERROR_PROPAGATE( measured_strings_receive( & strings, & data, IPC_GET_COUNT( call ))); |
325 | netif = netifs_find( & networking_globals.netifs, arg1 ); |
320 | netif = netifs_find( & networking_globals.netifs, IPC_GET_DEVICE( call )); |
326 | if( netif ){ |
321 | if( netif ){ |
327 | configuration = & netif->configuration; |
322 | configuration = & netif->configuration; |
328 | }else{ |
323 | }else{ |
329 | configuration = NULL; |
324 | configuration = NULL; |
330 | } |
325 | } |
331 | for( index = 0; index < arg2; ++ index ){ |
326 | for( index = 0; index < IPC_GET_COUNT( call ); ++ index ){ |
332 | setting = measured_strings_find( configuration, strings[ index ].value, 0 ); |
327 | setting = measured_strings_find( configuration, strings[ index ].value, 0 ); |
333 | if( ! setting ){ |
328 | if( ! setting ){ |
334 | setting = measured_strings_find( & networking_globals.configuration, strings[ index ].value, 0 ); |
329 | setting = measured_strings_find( & networking_globals.configuration, strings[ index ].value, 0 ); |
335 | } |
330 | } |
336 | if( setting ){ |
331 | if( setting ){ |
337 | strings[ index ].length = setting->length; |
332 | strings[ index ].length = setting->length; |
338 | strings[ index ].value = setting->value; |
333 | strings[ index ].value = setting->value; |
339 | }else{ |
334 | }else{ |
340 | strings[ index ].length = 0; |
335 | strings[ index ].length = 0; |
341 | strings[ index ].value = NULL; |
336 | strings[ index ].value = NULL; |
342 | } |
337 | } |
343 | } |
338 | } |
344 | // strings should not contain received data anymore |
339 | // strings should not contain received data anymore |
345 | free( data ); |
340 | free( data ); |
346 | ERROR_CODE = measured_strings_reply( strings, arg2 ); |
341 | ERROR_CODE = measured_strings_reply( strings, IPC_GET_COUNT( call )); |
347 | free( strings ); |
342 | free( strings ); |
348 | return ERROR_CODE; |
343 | return ERROR_CODE; |
349 | case NET_NET_GET_CONF: |
344 | case NET_NET_GET_CONF: |
350 | // arg1 = count |
345 | // arg1 = count |
351 | ERROR_PROPAGATE( measured_strings_receive( & strings, & data, arg1 )); |
346 | ERROR_PROPAGATE( measured_strings_receive( & strings, & data, IPC_GET_COUNT( call ))); |
352 | for( index = 0; index < arg1; ++ index ){ |
347 | for( index = 0; index < IPC_GET_COUNT( call ); ++ index ){ |
353 | setting = measured_strings_find( & networking_globals.configuration, strings[ index ].value, 0 ); |
348 | setting = measured_strings_find( & networking_globals.configuration, strings[ index ].value, 0 ); |
354 | if( setting ){ |
349 | if( setting ){ |
355 | strings[ index ].length = setting->length; |
350 | strings[ index ].length = setting->length; |
356 | strings[ index ].value = setting->value; |
351 | strings[ index ].value = setting->value; |
357 | }else{ |
352 | }else{ |
358 | strings[ index ].length = 0; |
353 | strings[ index ].length = 0; |
359 | strings[ index ].value = NULL; |
354 | strings[ index ].value = NULL; |
360 | } |
355 | } |
361 | } |
356 | } |
362 | // strings should not contain received data anymore |
357 | // strings should not contain received data anymore |
363 | free( data ); |
358 | free( data ); |
364 | ERROR_CODE = measured_strings_reply( strings, arg1 ); |
359 | ERROR_CODE = measured_strings_reply( strings, IPC_GET_COUNT( call )); |
365 | free( strings ); |
360 | free( strings ); |
366 | return ERROR_CODE; |
361 | return ERROR_CODE; |
367 | case NET_NET_STARTUP: |
362 | case NET_NET_STARTUP: |
368 | return startup(); |
363 | return startup(); |
369 | } |
364 | } |
370 | return ENOTSUP; |
365 | return ENOTSUP; |
371 | } |
366 | } |
372 | 367 | ||
373 | /* |
368 | /* |
374 | int parse_line( measured_strings_ref configuration, char * line ){ |
369 | int parse_line( measured_strings_ref configuration, char * line ){ |
375 | ERROR_DECLARE; |
370 | ERROR_DECLARE; |
376 | 371 | ||
377 | measured_string_ref setting; |
372 | measured_string_ref setting; |
378 | char * name; |
373 | char * name; |
379 | char * value; |
374 | char * value; |
380 | 375 | ||
381 | // from the beginning |
376 | // from the beginning |
382 | name = line; |
377 | name = line; |
383 | // skip spaces |
378 | // skip spaces |
384 | while( isspace( * name )) ++ name; |
379 | while( isspace( * name )) ++ name; |
385 | // remember the name start |
380 | // remember the name start |
386 | value = name; |
381 | value = name; |
387 | // skip the name |
382 | // skip the name |
388 | while( isalnum( * value ) || ( * value == '_' )){ |
383 | while( isalnum( * value ) || ( * value == '_' )){ |
389 | // make uppercase |
384 | // make uppercase |
390 | // * value = toupper( * value ); |
385 | // * value = toupper( * value ); |
391 | ++ value; |
386 | ++ value; |
392 | } |
387 | } |
393 | if( * value == '=' ){ |
388 | if( * value == '=' ){ |
394 | // terminate the name |
389 | // terminate the name |
395 | * value = '\0'; |
390 | * value = '\0'; |
396 | }else{ |
391 | }else{ |
397 | // terminate the name |
392 | // terminate the name |
398 | * value = '\0'; |
393 | * value = '\0'; |
399 | // skip until '=' |
394 | // skip until '=' |
400 | ++ value; |
395 | ++ value; |
401 | while(( * value ) && ( * value != '=' )) ++ value; |
396 | while(( * value ) && ( * value != '=' )) ++ value; |
402 | // not found? |
397 | // not found? |
403 | if( * value != '=' ) return EINVAL; |
398 | if( * value != '=' ) return EINVAL; |
404 | } |
399 | } |
405 | ++ value; |
400 | ++ value; |
406 | // skip spaces |
401 | // skip spaces |
407 | while( isspace( * value )) ++ value; |
402 | while( isspace( * value )) ++ value; |
408 | // create a bulk measured string till the end |
403 | // create a bulk measured string till the end |
409 | setting = measured_string_create_bulk( value, -1 ); |
404 | setting = measured_string_create_bulk( value, -1 ); |
410 | if( ! setting ) return ENOMEM; |
405 | if( ! setting ) return ENOMEM; |
411 | // add the configuration setting |
406 | // add the configuration setting |
412 | if( ERROR_OCCURED( measured_strings_add( configuration, name, 0, setting ))){ |
407 | if( ERROR_OCCURED( measured_strings_add( configuration, name, 0, setting ))){ |
413 | free( setting ); |
408 | free( setting ); |
414 | return ERROR_CODE; |
409 | return ERROR_CODE; |
415 | } |
410 | } |
416 | return EOK; |
411 | return EOK; |
417 | } |
412 | } |
418 | */ |
413 | */ |
419 | 414 | ||
420 | int add_configuration( measured_strings_ref configuration, const char * name, const char * value ){ |
415 | int add_configuration( measured_strings_ref configuration, const char * name, const char * value ){ |
421 | ERROR_DECLARE; |
416 | ERROR_DECLARE; |
422 | 417 | ||
423 | measured_string_ref setting; |
418 | measured_string_ref setting; |
424 | 419 | ||
425 | setting = measured_string_create_bulk( value, 0 ); |
420 | setting = measured_string_create_bulk( value, 0 ); |
426 | if( ! setting ) return ENOMEM; |
421 | if( ! setting ) return ENOMEM; |
427 | // add the configuration setting |
422 | // add the configuration setting |
428 | if( ERROR_OCCURED( measured_strings_add( configuration, name, 0, setting ))){ |
423 | if( ERROR_OCCURED( measured_strings_add( configuration, name, 0, setting ))){ |
429 | free( setting ); |
424 | free( setting ); |
430 | return ERROR_CODE; |
425 | return ERROR_CODE; |
431 | } |
426 | } |
432 | return EOK; |
427 | return EOK; |
433 | } |
428 | } |
434 | 429 | ||
435 | device_id_t generate_new_device_id( void ){ |
430 | device_id_t generate_new_device_id( void ){ |
436 | return netifs_count( & networking_globals.netifs ) + 1; |
431 | return netifs_count( & networking_globals.netifs ) + 1; |
437 | } |
432 | } |
438 | 433 | ||
439 | int read_configuration( void ){ |
434 | int read_configuration( void ){ |
440 | ERROR_DECLARE; |
435 | ERROR_DECLARE; |
441 | 436 | ||
442 | netif_ref netif; |
437 | netif_ref netif; |
443 | measured_string_ref setting; |
438 | measured_string_ref setting; |
444 | services_t internet_service; |
439 | services_t internet_service; |
445 | int index; |
440 | int index; |
446 | 441 | ||
447 | // read general configuration |
442 | // read general configuration |
448 | ERROR_PROPAGATE( add_configuration( & networking_globals.configuration, "IPV", "4" )); |
443 | ERROR_PROPAGATE( add_configuration( & networking_globals.configuration, "IPV", "4" )); |
449 | 444 | ||
450 | // read network interfaces configuration |
445 | // read network interfaces configuration |
451 | 446 | ||
452 | // static loopback initialization |
447 | // static loopback initialization |
453 | // printf( "\nloopback initialization" ); |
448 | // printf( "\nloopback initialization" ); |
454 | netif = ( netif_ref ) malloc( sizeof( netif_t )); |
449 | netif = ( netif_ref ) malloc( sizeof( netif_t )); |
455 | if( ! netif ) return ENOMEM; |
450 | if( ! netif ) return ENOMEM; |
456 | netif->id = generate_new_device_id(); |
451 | netif->id = generate_new_device_id(); |
457 | ERROR_PROPAGATE( measured_strings_initialize( & netif->configuration )); |
452 | ERROR_PROPAGATE( measured_strings_initialize( & netif->configuration )); |
458 | if( ERROR_OCCURED( add_configuration( & netif->configuration, "NAME", LO_NAME )) |
453 | if( ERROR_OCCURED( add_configuration( & netif->configuration, "NAME", LO_NAME )) |
459 | || ERROR_OCCURED( add_configuration( & netif->configuration, "NETIF", LO_NAME )) |
454 | || ERROR_OCCURED( add_configuration( & netif->configuration, "NETIF", LO_NAME )) |
460 | || ERROR_OCCURED( add_configuration( & netif->configuration, "IL", IP_NAME )) |
455 | || ERROR_OCCURED( add_configuration( & netif->configuration, "IL", IP_NAME )) |
461 | || ERROR_OCCURED( add_configuration( & netif->configuration, "MTU", "1500" )) |
456 | || ERROR_OCCURED( add_configuration( & netif->configuration, "MTU", "1500" )) |
462 | || ERROR_OCCURED( add_configuration( & netif->configuration, "IP_CONFIG", "STATIC" )) |
457 | || ERROR_OCCURED( add_configuration( & netif->configuration, "IP_CONFIG", "STATIC" )) |
463 | || ERROR_OCCURED( add_configuration( & netif->configuration, "IP_ADDR", "127.0.0.1" )) |
458 | || ERROR_OCCURED( add_configuration( & netif->configuration, "IP_ADDR", "127.0.0.1" )) |
464 | || ERROR_OCCURED( add_configuration( & netif->configuration, "NETMASK", "255.0.0.0" ))){ |
459 | || ERROR_OCCURED( add_configuration( & netif->configuration, "NETMASK", "255.0.0.0" ))){ |
465 | measured_strings_destroy( & netif->configuration ); |
460 | measured_strings_destroy( & netif->configuration ); |
466 | free( netif ); |
461 | free( netif ); |
467 | return ERROR_CODE; |
462 | return ERROR_CODE; |
468 | } |
463 | } |
469 | // mandatory name |
464 | // mandatory name |
470 | // printf( "\n\tname" ); |
465 | // printf( "\n\tname" ); |
471 | setting = measured_strings_find( & netif->configuration, "NAME", 0 ); |
466 | setting = measured_strings_find( & netif->configuration, "NAME", 0 ); |
472 | if( ! setting ){ |
467 | if( ! setting ){ |
473 | measured_strings_destroy( & netif->configuration ); |
468 | measured_strings_destroy( & netif->configuration ); |
474 | free( netif ); |
469 | free( netif ); |
475 | return EINVAL; |
470 | return EINVAL; |
476 | } |
471 | } |
477 | netif->name = setting->value; |
472 | netif->name = setting->value; |
478 | // printf( " %s OK", netif->name ); |
473 | // printf( " %s OK", netif->name ); |
479 | // mandatory netif |
474 | // mandatory netif |
480 | // printf( "\n\tnetif" ); |
475 | // printf( "\n\tnetif" ); |
481 | setting = measured_strings_find( & netif->configuration, "NETIF", 0 ); |
476 | setting = measured_strings_find( & netif->configuration, "NETIF", 0 ); |
482 | if( ! setting ){ |
477 | if( ! setting ){ |
483 | // printf( " unknown" ); |
478 | // printf( " unknown" ); |
484 | measured_strings_destroy( & netif->configuration ); |
479 | measured_strings_destroy( & netif->configuration ); |
485 | free( netif ); |
480 | free( netif ); |
486 | return EINVAL; |
481 | return EINVAL; |
487 | } |
482 | } |
488 | // printf( " find %s in %d?", setting->value, modules_count( & networking_globals.modules )); |
483 | // printf( " find %s in %d?", setting->value, modules_count( & networking_globals.modules )); |
489 | netif->driver = modules_find( & networking_globals.modules, setting->value, 0 ); |
484 | netif->driver = modules_find( & networking_globals.modules, setting->value, 0 ); |
490 | if( ! netif->driver ){ |
485 | if( ! netif->driver ){ |
491 | // printf( " not found" ); |
486 | // printf( " not found" ); |
492 | // TODO register the unknown one |
487 | // TODO register the unknown one |
493 | measured_strings_destroy( & netif->configuration ); |
488 | measured_strings_destroy( & netif->configuration ); |
494 | free( netif ); |
489 | free( netif ); |
495 | return EINVAL; |
490 | return EINVAL; |
496 | } |
491 | } |
497 | // printf( " found" ); |
492 | // printf( " found" ); |
498 | if( ! netif->driver->task_id ){ |
493 | if( ! netif->driver->task_id ){ |
499 | netif->driver->task_id = spawn( netif->driver->filename ); |
494 | netif->driver->task_id = spawn( netif->driver->filename ); |
500 | if( ! netif->driver->task_id ){ |
495 | if( ! netif->driver->task_id ){ |
501 | measured_strings_destroy( & netif->configuration ); |
496 | measured_strings_destroy( & netif->configuration ); |
502 | free( netif ); |
497 | free( netif ); |
503 | return EINVAL; |
498 | return EINVAL; |
504 | } |
499 | } |
505 | } |
500 | } |
506 | // printf( " OK" ); |
501 | // printf( " OK" ); |
507 | // optional link layer |
502 | // optional link layer |
508 | // printf( "\n\tlink layer" ); |
503 | // printf( "\n\tlink layer" ); |
509 | setting = measured_strings_find( & netif->configuration, "NIL", 0 ); |
504 | setting = measured_strings_find( & netif->configuration, "NIL", 0 ); |
510 | if( setting ){ |
505 | if( setting ){ |
511 | netif->nil = modules_find( & networking_globals.modules, setting->value, 0 ); |
506 | netif->nil = modules_find( & networking_globals.modules, setting->value, 0 ); |
512 | if( ! netif->nil ){ |
507 | if( ! netif->nil ){ |
513 | // TODO register the unknown one |
508 | // TODO register the unknown one |
514 | -- netif->driver->usage; |
509 | -- netif->driver->usage; |
515 | measured_strings_destroy( & netif->configuration ); |
510 | measured_strings_destroy( & netif->configuration ); |
516 | free( netif ); |
511 | free( netif ); |
517 | return EINVAL; |
512 | return EINVAL; |
518 | } |
513 | } |
519 | if( ! netif->nil->task_id ){ |
514 | if( ! netif->nil->task_id ){ |
520 | netif->nil->task_id = spawn( netif->nil->filename ); |
515 | netif->nil->task_id = spawn( netif->nil->filename ); |
521 | if( ! netif->nil->task_id ){ |
516 | if( ! netif->nil->task_id ){ |
522 | -- netif->driver->usage; |
517 | -- netif->driver->usage; |
523 | measured_strings_destroy( & netif->configuration ); |
518 | measured_strings_destroy( & netif->configuration ); |
524 | free( netif ); |
519 | free( netif ); |
525 | return EINVAL; |
520 | return EINVAL; |
526 | } |
521 | } |
527 | } |
522 | } |
528 | }else{ |
523 | }else{ |
529 | netif->nil = NULL; |
524 | netif->nil = NULL; |
530 | } |
525 | } |
531 | // mandatory internet layer |
526 | // mandatory internet layer |
532 | // printf( "\n\tinternet layer" ); |
527 | // printf( "\n\tinternet layer" ); |
533 | setting = measured_strings_find( & netif->configuration, "IL", 0 ); |
528 | setting = measured_strings_find( & netif->configuration, "IL", 0 ); |
534 | if( ! setting ){ |
529 | if( ! setting ){ |
535 | -- netif->driver->usage; |
530 | -- netif->driver->usage; |
536 | -- netif->nil->usage; |
531 | -- netif->nil->usage; |
537 | measured_strings_destroy( & netif->configuration ); |
532 | measured_strings_destroy( & netif->configuration ); |
538 | free( netif ); |
533 | free( netif ); |
539 | return EINVAL; |
534 | return EINVAL; |
540 | } |
535 | } |
541 | // printf( " set %s", setting->value ); |
536 | // printf( " set %s", setting->value ); |
542 | netif->il = modules_find( & networking_globals.modules, setting->value, 0 ); |
537 | netif->il = modules_find( & networking_globals.modules, setting->value, 0 ); |
543 | if( ! netif->il ){ |
538 | if( ! netif->il ){ |
544 | // TODO register the unknown one |
539 | // TODO register the unknown one |
545 | -- netif->driver->usage; |
540 | -- netif->driver->usage; |
546 | -- netif->nil->usage; |
541 | -- netif->nil->usage; |
547 | measured_strings_destroy( & netif->configuration ); |
542 | measured_strings_destroy( & netif->configuration ); |
548 | free( netif ); |
543 | free( netif ); |
549 | return EINVAL; |
544 | return EINVAL; |
550 | } |
545 | } |
551 | // printf( " found" ); |
546 | // printf( " found" ); |
552 | if( ! netif->il->task_id ){ |
547 | if( ! netif->il->task_id ){ |
553 | netif->il->task_id = spawn( netif->il->filename ); |
548 | netif->il->task_id = spawn( netif->il->filename ); |
554 | if( ! netif->il->task_id ){ |
549 | if( ! netif->il->task_id ){ |
555 | -- netif->driver->usage; |
550 | -- netif->driver->usage; |
556 | -- netif->nil->usage; |
551 | -- netif->nil->usage; |
557 | measured_strings_destroy( & netif->configuration ); |
552 | measured_strings_destroy( & netif->configuration ); |
558 | free( netif ); |
553 | free( netif ); |
559 | return EINVAL; |
554 | return EINVAL; |
560 | } |
555 | } |
561 | } |
556 | } |
562 | index = netifs_add( & networking_globals.netifs, netif->id, netif ); |
557 | index = netifs_add( & networking_globals.netifs, netif->id, netif ); |
563 | if( index < 0 ){ |
558 | if( index < 0 ){ |
564 | free( netif ); |
559 | free( netif ); |
565 | return ERROR_CODE; |
560 | return ERROR_CODE; |
566 | } |
561 | } |
567 | if( ERROR_OCCURED( char_map_add( & networking_globals.netif_names, netif->name, 0, index ))){ |
562 | if( ERROR_OCCURED( char_map_add( & networking_globals.netif_names, netif->name, 0, index ))){ |
568 | netifs_exclude_index( & networking_globals.netifs, index ); |
563 | netifs_exclude_index( & networking_globals.netifs, index ); |
569 | return ERROR_CODE; |
564 | return ERROR_CODE; |
570 | } |
565 | } |
571 | // printf( "\nloopback OK" ); |
566 | // printf( "\nloopback OK" ); |
572 | // end of the static loopback initialization |
567 | // end of the static loopback initialization |
573 | // startup the loopback interface |
568 | // startup the loopback interface |
574 | if( ! netif->driver->phone ){ |
569 | if( ! netif->driver->phone ){ |
575 | // printf( " connect?" ); |
570 | // printf( " connect?" ); |
576 | netif->driver->phone = connect_to_service( netif->driver->service ); |
571 | netif->driver->phone = connect_to_service( netif->driver->service ); |
577 | } |
572 | } |
578 | // printf( " connected" ); |
573 | // printf( " connected" ); |
579 | // TODO io, irq |
574 | // TODO io, irq |
580 | ERROR_PROPAGATE( async_req_3_0( netif->driver->phone, NET_NETIF_PROBE, netif->id, 0, 0 )); |
575 | ERROR_PROPAGATE( async_req_3_0( netif->driver->phone, NET_NETIF_PROBE, netif->id, 0, 0 )); |
581 | ++ netif->driver->usage; |
576 | ++ netif->driver->usage; |
582 | if( netif->nil ){ |
577 | if( netif->nil ){ |
583 | if( ! netif->nil->phone ){ |
578 | if( ! netif->nil->phone ){ |
584 | netif->nil->phone = connect_to_service( netif->nil->service ); |
579 | netif->nil->phone = connect_to_service( netif->nil->service ); |
585 | } |
580 | } |
586 | ERROR_PROPAGATE( async_req_2_0( netif->nil->phone, NET_NIL_DEVICE, netif->id, netif->driver->service )); |
581 | ERROR_PROPAGATE( async_req_2_0( netif->nil->phone, NET_NIL_DEVICE, netif->id, netif->driver->service )); |
587 | ++ netif->nil->usage; |
582 | ++ netif->nil->usage; |
588 | internet_service = netif->nil->service; |
583 | internet_service = netif->nil->service; |
589 | // printf( " OK" ); |
584 | // printf( " OK" ); |
590 | }else{ |
585 | }else{ |
591 | internet_service = netif->driver->service; |
586 | internet_service = netif->driver->service; |
592 | // printf( " none" ); |
587 | // printf( " none" ); |
593 | } |
588 | } |
594 | if( ! netif->il->phone ){ |
589 | if( ! netif->il->phone ){ |
595 | // printf( " connect" ); |
590 | // printf( " connect" ); |
596 | netif->il->phone = connect_to_service( netif->il->service ); |
591 | netif->il->phone = connect_to_service( netif->il->service ); |
597 | } |
592 | } |
598 | // TODO IL_BUNDLE |
593 | // TODO IL_BUNDLE |
599 | ERROR_PROPAGATE( async_req_2_0( netif->il->phone, NET_IL_DEVICE, netif->id, internet_service )); |
594 | ERROR_PROPAGATE( async_req_2_0( netif->il->phone, NET_IL_DEVICE, netif->id, internet_service )); |
600 | ++ netif->il->usage; |
595 | ++ netif->il->usage; |
601 | // TODO startup? |
596 | // TODO startup? |
602 | ERROR_PROPAGATE( async_req_1_0( netif->driver->phone, NET_NETIF_START, netif->id )); |
597 | ERROR_PROPAGATE( async_req_1_0( netif->driver->phone, NET_NETIF_START, netif->id )); |
603 | // printf( "\n LO OK" ); |
598 | // printf( "\n LO OK" ); |
604 | return EOK; |
599 | return EOK; |
605 | } |
600 | } |
606 | 601 | ||
607 | task_id_t spawn( const char * fname ){ |
602 | task_id_t spawn( const char * fname ){ |
608 | const char * argv[ 2 ]; |
603 | const char * argv[ 2 ]; |
609 | task_id_t res; |
604 | task_id_t res; |
610 | 605 | ||
611 | // printf( "Spawning %s\n", fname ); |
606 | // printf( "Spawning %s\n", fname ); |
612 | argv[ 0 ] = fname; |
607 | argv[ 0 ] = fname; |
613 | argv[ 1 ] = NULL; |
608 | argv[ 1 ] = NULL; |
614 | res = task_spawn( fname, argv ); |
609 | res = task_spawn( fname, argv ); |
615 | if( res != 0 ){ |
610 | if( res != 0 ){ |
616 | /* Success */ |
611 | /* Success */ |
617 | usleep( 50000 ); |
612 | usleep( 50000 ); |
618 | } |
613 | } |
619 | return res; |
614 | return res; |
620 | } |
615 | } |
621 | 616 | ||
622 | int startup( void ){ |
617 | int startup( void ){ |
623 | ERROR_DECLARE; |
618 | ERROR_DECLARE; |
624 | 619 | ||
625 | // read configuration files |
620 | // read configuration files |
626 | if( ERROR_OCCURED( read_configuration())) return ERROR_CODE; |
621 | if( ERROR_OCCURED( read_configuration())) return ERROR_CODE; |
627 | 622 | ||
628 | // start network interfaces and needed modules |
623 | // start network interfaces and needed modules |
629 | // start_device( "/sbin/lo", "/sbin/dummy_link_layer" ); |
624 | // start_device( "/sbin/lo", "/sbin/dummy_link_layer" ); |
630 | return EOK; |
625 | return EOK; |
631 | } |
626 | } |
632 | 627 | ||
633 | /** @} |
628 | /** @} |
634 | */ |
629 | */ |
635 | 630 |