source: trunk/kernel/devices/dev_nic.c@ 527

Last change on this file since 527 was 492, checked in by viala@…, 8 years ago

Refactoring assert calling to conform with new assert macro.

Made with this command for the general case.
find ./kernel/ hal/ -name "*.c" | xargs sed -i -e '/assert(/ s/,[ ]*FUNCTION[ ]*,/,/'

And some done by hand.
File size: 7.3 KB
Line 
1/*
2 * dev_nic.c - NIC (Network Controler) generic device API implementation.
3 *
4 * Author Alain Greiner (2016,2017,2018)
5 *
6 * Copyright (c) UPMC Sorbonne Universites
7 *
8 * This file is part of ALMOS-MKH.
9 *
10 * ALMOS-MKH is free software; you can redistribute it and/or modify it
11 * under the terms of the GNU General Public License as published by
12 * the Free Software Foundation; version 2.0 of the License.
13 *
14 * ALMOS-MKH is distributed in the hope that it will be useful, but
15 * WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
17 * General Public License for more details.
18 *
19 * You should have received a copy of the GNU General Public License
20 * along with ALMOS-MKH; if not, write to the Free Software Foundation,
21 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
22 */
23
24#include <hal_kernel_types.h>
25#include <hal_special.h>
26#include <printk.h>
27#include <chdev.h>
28#include <thread.h>
29#include <hal_drivers.h>
30#include <dev_nic.h>
31
32/////////////////////////////////////////////////////////////////////////////////////////
33// Extern global variables
34/////////////////////////////////////////////////////////////////////////////////////////
35
36extern chdev_directory_t chdev_dir; // allocated in kernel_init.c
37
38//////////////////////////////////
39void dev_nic_init( chdev_t * nic )
40{
41 // the PIC chdev must be initialized before the NIC chdev, because
42 // the NIC chdev initialisation requires the routing of an external IRQ.
43 xptr_t pic_xp = chdev_dir.pic;
44
45 assert( (pic_xp != XPTR_NULL) , "ICU not initialised before NIC" );
46
47 // get "impl" , "channel" , "is_rx" fields from chdev descriptor
48 uint32_t impl = nic->impl;
49 uint32_t channel = nic->channel;
50 bool_t is_rx = nic->is_rx;
51
52 // set chdev name
53 if( is_rx ) snprintf( nic->name , 16 , "nic%d_rx" , channel );
54 else snprintf( nic->name , 16 , "nic%d_tx" , channel );
55
56 // call driver init function
57 hal_drivers_nic_init( nic , impl );
58
59 // select a core to execute the NIC server thread
60 lid_t lid = cluster_select_local_core();
61
62 // bind the NIC IRQ to the selected core
63 // but does NOT enable it
64 dev_pic_bind_irq( lid , nic );
65
66 // create server thread
67 thread_t * new_thread;
68 error_t error;
69
70 error = thread_kernel_create( &new_thread,
71 THREAD_DEV,
72 &chdev_sequencial_server,
73 nic,
74 lid );
75
76 assert( (error == 0) , "cannot create server thread" );
77
78 // set "server" field in chdev descriptor
79 nic->server = new_thread;
80
81 // set "chdev" field in thread descriptor
82 new_thread->chdev = nic;
83
84 // unblock server thread
85 thread_unblock( XPTR( local_cxy , new_thread ) , THREAD_BLOCKED_GLOBAL );
86
87} // end dev_nic_init()
88
89///////////////////////////////////
90error_t dev_nic_read( pkd_t * pkd )
91{
92 error_t error;
93
94 // get pointers on this NIC-RX kernel thread
95 thread_t * thread_ptr = CURRENT_THREAD;
96 xptr_t thread_xp = XPTR( local_cxy , thread_ptr );
97
98 // get local pointer on core running this kernel thead
99 core_t * core = thread_ptr->core;
100
101#if DEBUG_DEV_NIC_RX
102uint32_t cycle = (uint32_t)hal_get_cycles();
103if( DEBUG_DEV_NIC_RX < cycle )
104printk("\n[DBG] %s : thread %x enters for packet %x in cluster %x\n",
105__FUNCTION__ , thread_ptr , pkd , local_cxy );
106#endif
107
108 // get pointer on NIC-RX chdev descriptor
109 uint32_t channel = thread_ptr->chdev->channel;
110 xptr_t dev_xp = chdev_dir.nic_rx[channel];
111 cxy_t dev_cxy = GET_CXY( dev_xp );
112 chdev_t * dev_ptr = (chdev_t *)GET_PTR( dev_xp );
113
114 assert( (dev_xp != XPTR_NULL) , "undefined NIC chdev descriptor" );
115
116 assert( (dev_cxy == local_cxy) , " chdev must be local" );
117
118 // initialize command in thread descriptor
119 thread_ptr->nic_cmd.dev_xp = dev_xp;
120
121 // call driver to test readable
122 thread_ptr->nic_cmd.cmd = NIC_CMD_READABLE;
123 dev_ptr->cmd( thread_xp );
124
125 // check error
126 error = thread_ptr->nic_cmd.error;
127 if( error ) return error;
128
129 // block and deschedule if queue non readable
130 if( thread_ptr->nic_cmd.status == false )
131 {
132 // enable NIC-RX IRQ
133 dev_pic_enable_irq( core->lid , dev_xp );
134
135 // block on THREAD_BLOCKED_IO condition and deschedule
136 thread_block( XPTR( local_cxy , thread_ptr ) , THREAD_BLOCKED_IO );
137 sched_yield("client blocked on I/O");
138
139 // disable NIC-RX IRQ
140 dev_pic_disable_irq( core->lid , dev_xp );
141 }
142
143 // call driver for actual read
144 thread_ptr->nic_cmd.cmd = NIC_CMD_READ;
145 thread_ptr->nic_cmd.buffer = pkd->buffer;
146 dev_ptr->cmd( thread_xp );
147
148 // check error
149 error = thread_ptr->nic_cmd.error;
150 if( error ) return error;
151
152 // returns packet length
153 pkd->length = thread_ptr->nic_cmd.length;
154
155#if DEBUG_DEV_NIC_RX
156cycle = (uint32_t)hal_get_cycles();
157if( DEBUG_DEV_NIC_RX < cycle )
158printk("\n[DBG] %s : thread %x exit for packet %x in cluster %x\n",
159__FUNCTION__ , thread_ptr , pkd , local_cxy );
160#endif
161
162 return 0;
163
164} // end dev_nic_read()
165
166
167////////////////////////////////////
168error_t dev_nic_write( pkd_t * pkd )
169{
170 error_t error;
171
172 // get pointers on the NIC-TX kernel tread
173 thread_t * thread_ptr = CURRENT_THREAD;
174 xptr_t thread_xp = XPTR( local_cxy , thread_ptr );
175
176 // get local pointer on core running this kernel thead
177 core_t * core = thread_ptr->core;
178
179#if DEBUG_DEV_NIC_RX
180uint32_t cycle = (uint32_t)hal_get_cycles();
181if( DEBUG_DEV_NIC_RX < cycle )
182printk("\n[DBG] %s : thread %x enters for packet %x in cluster %x\n",
183__FUNCTION__ , thread_ptr , pkd , local_cxy );
184#endif
185
186 // get pointer on NIC-TX chdev descriptor
187 uint32_t channel = thread_ptr->chdev->channel;
188 xptr_t dev_xp = chdev_dir.nic_tx[channel];
189 cxy_t dev_cxy = GET_CXY( dev_xp );
190 chdev_t * dev_ptr = (chdev_t *)GET_PTR( dev_xp );
191
192 assert( (dev_xp != XPTR_NULL) , "undefined NIC chdev descriptor" );
193
194 assert( (dev_cxy == local_cxy) , " chdev must be local" );
195
196 // initialize command in thread descriptor
197 thread_ptr->nic_cmd.dev_xp = dev_xp;
198
199 // call driver to test writable
200 thread_ptr->nic_cmd.cmd = NIC_CMD_WRITABLE;
201 dev_ptr->cmd( thread_xp );
202
203 // check error
204 error = thread_ptr->nic_cmd.error;
205 if( error ) return error;
206
207 // block and deschedule if queue non writable
208 if( thread_ptr->nic_cmd.status == false )
209 {
210 // enable NIC-TX IRQ
211 dev_pic_enable_irq( core->lid ,dev_xp );
212
213 // block on THREAD_BLOCKED I/O condition and deschedule
214 thread_block( XPTR( local_cxy , thread_ptr ) , THREAD_BLOCKED_IO );
215 sched_yield("client blocked on I/O");
216
217 // disable NIC-TX IRQ
218 dev_pic_disable_irq( core->lid , dev_xp );
219 }
220
221 // call driver for actual write
222 thread_ptr->nic_cmd.cmd = NIC_CMD_WRITE;
223 thread_ptr->nic_cmd.buffer = pkd->buffer;
224 thread_ptr->nic_cmd.length = pkd->length;
225 dev_ptr->cmd( thread_xp );
226
227 // check error
228 error = thread_ptr->nic_cmd.error;
229 if( error ) return error;
230
231#if DEBUG_DEV_NIC_RX
232cycle = (uint32_t)hal_get_cycles();
233if( DEBUG_DEV_NIC_RX < cycle )
234printk("\n[DBG] %s : thread %x exit for packet %x in cluster %x\n",
235__FUNCTION__ , thread_ptr , pkd , local_cxy );
236#endif
237
238 return 0;
239} // end dev_nic_write()
240
241
242
Note: See TracBrowser for help on using the repository browser.