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

Last change on this file since 408 was 408, checked in by alain, 6 years ago

Fix several bugs in the fork() syscall.

File size: 7.0 KB
Line 
1/*
2 * dev_nic.c - NIC (Network Controler) generic device API implementation.
3 *
4 * Author  Alain Greiner    (2016,2017)
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_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) , __FUNCTION__ , "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) , __FUNCTION__ , "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    nic_dmsg("\n[DBG] %s enters for NIC-RX thread on core %d in cluster %x\n", 
102                 __FUNCTION__ , core->lid , local_cxy );
103
104    // get pointer on NIC-RX chdev descriptor
105    uint32_t   channel = thread_ptr->chdev->channel; 
106    xptr_t     dev_xp  = chdev_dir.nic_rx[channel];
107    cxy_t      dev_cxy = GET_CXY( dev_xp );
108    chdev_t  * dev_ptr = (chdev_t *)GET_PTR( dev_xp );
109
110    assert( (dev_xp != XPTR_NULL) , __FUNCTION__ , "undefined NIC chdev descriptor" );
111
112    assert( (dev_cxy == local_cxy) , __FUNCTION__ , " chdev must be local" );
113
114    // initialize command in thread descriptor
115    thread_ptr->nic_cmd.dev_xp = dev_xp;
116
117    // call driver to test readable
118    thread_ptr->nic_cmd.cmd = NIC_CMD_READABLE;
119    dev_ptr->cmd( thread_xp );
120
121    // check error
122    error = thread_ptr->nic_cmd.error;
123    if( error ) return error;
124
125    // block and deschedule if queue non readable
126    if( thread_ptr->nic_cmd.status == false ) 
127    {
128        // enable NIC-RX IRQ
129        dev_pic_enable_irq( core->lid , dev_xp );
130
131        // block on THREAD_BLOCKED_IO condition and deschedule
132        thread_block( thread_ptr , THREAD_BLOCKED_IO );
133        sched_yield("client blocked on I/O");
134
135        // disable NIC-RX IRQ
136        dev_pic_disable_irq( core->lid , dev_xp );
137    }
138
139    // call driver for actual read
140    thread_ptr->nic_cmd.cmd     = NIC_CMD_READ;
141    thread_ptr->nic_cmd.buffer  = pkd->buffer;
142    dev_ptr->cmd( thread_xp );
143
144    // check error
145    error = thread_ptr->nic_cmd.error;
146    if( error ) return error;
147
148    // returns packet length   
149    pkd->length = thread_ptr->nic_cmd.length;
150
151    nic_dmsg("\n[DBG] %s exit for NIC-RX thread on core %d in cluster %x\n", 
152             __FUNCTION__ , core->lid , local_cxy );
153
154    return 0;
155
156}   // end dev_nic_read()
157
158
159////////////////////////////////////
160error_t dev_nic_write( pkd_t * pkd )
161{
162    error_t error;
163
164    // get pointers on the NIC-TX kernel tread
165    thread_t * thread_ptr = CURRENT_THREAD;
166    xptr_t     thread_xp  = XPTR( local_cxy , thread_ptr );
167
168    // get local pointer on core running this kernel thead
169    core_t * core = thread_ptr->core;
170
171    nic_dmsg("\n[DBG] %s enters for NIC-RX thread on core %d in cluster %x\n", 
172                 __FUNCTION__ , core->lid , local_cxy );
173
174    // get pointer on NIC-TX chdev descriptor
175    uint32_t   channel = thread_ptr->chdev->channel; 
176    xptr_t     dev_xp  = chdev_dir.nic_tx[channel];
177    cxy_t      dev_cxy = GET_CXY( dev_xp );
178    chdev_t  * dev_ptr = (chdev_t *)GET_PTR( dev_xp );
179
180    assert ( (dev_xp != XPTR_NULL) , __FUNCTION__ , "undefined NIC chdev descriptor" );
181
182    assert( (dev_cxy == local_cxy) , __FUNCTION__ , " chdev must be local" );
183
184    // initialize command in thread descriptor
185    thread_ptr->nic_cmd.dev_xp = dev_xp;
186
187    // call driver to test writable
188    thread_ptr->nic_cmd.cmd = NIC_CMD_WRITABLE;
189    dev_ptr->cmd( thread_xp );
190
191    // check error
192    error = thread_ptr->nic_cmd.error;
193    if( error ) return error;
194
195    // block and deschedule if queue non writable
196    if( thread_ptr->nic_cmd.status == false ) 
197    {
198        // enable NIC-TX IRQ
199        dev_pic_enable_irq( core->lid ,dev_xp );
200
201        // block on THREAD_BLOCKED I/O condition and deschedule
202        thread_block( thread_ptr , THREAD_BLOCKED_IO );
203        sched_yield("client blocked on I/O");
204
205        // disable NIC-TX IRQ
206        dev_pic_disable_irq( core->lid , dev_xp );
207    }
208
209    // call driver for actual write
210    thread_ptr->nic_cmd.cmd    = NIC_CMD_WRITE;
211    thread_ptr->nic_cmd.buffer = pkd->buffer;
212    thread_ptr->nic_cmd.length = pkd->length;
213    dev_ptr->cmd( thread_xp );
214
215    // check error
216    error = thread_ptr->nic_cmd.error;
217    if( error ) return error;
218
219    nic_dmsg("\n[DBG] %s exit for NIC-TX thread on core %d in cluster %x\n", 
220             __FUNCTION__ , core->lid , local_cxy );
221
222    return 0;
223}  // end dev_nic_write()
224
225
226
Note: See TracBrowser for help on using the repository browser.