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

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

Complete restructuration of kernel locks.

File size: 7.6 KB
RevLine 
[1]1/*
2 * dev_nic.c - NIC (Network Controler) generic device API implementation.
3 *
[437]4 * Author  Alain Greiner    (2016,2017,2018)
[1]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
[457]24#include <hal_kernel_types.h>
[1]25#include <hal_special.h>
26#include <printk.h>
[3]27#include <chdev.h>
[1]28#include <thread.h>
[259]29#include <hal_drivers.h>
[1]30#include <dev_nic.h>
31
32/////////////////////////////////////////////////////////////////////////////////////////
33// Extern global variables
34/////////////////////////////////////////////////////////////////////////////////////////
35
[3]36extern chdev_directory_t  chdev_dir;         // allocated in kernel_init.c
[1]37
[188]38//////////////////////////////////
39void dev_nic_init( chdev_t * nic )
[1]40{
[188]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;
[1]44
[492]45    assert( (pic_xp != XPTR_NULL) , "ICU not initialised before NIC" );
[188]46
[3]47    // get "impl" , "channel" , "is_rx" fields from chdev descriptor
[188]48    uint32_t  impl    = nic->impl;
49    uint32_t  channel = nic->channel;
50    bool_t    is_rx   = nic->is_rx;
[1]51
[23]52    // set chdev name
[407]53    if( is_rx ) snprintf( nic->name , 16 , "nic%d_rx" , channel );
54    else        snprintf( nic->name , 16 , "nic%d_tx" , channel );
[23]55
[259]56    // call driver init function
57    hal_drivers_nic_init( nic , impl );
[1]58
[188]59    // select a core to execute the NIC server thread
[3]60    lid_t lid = cluster_select_local_core();
[1]61
[188]62    // bind the NIC IRQ to the selected core
63    // but does NOT enable it
64    dev_pic_bind_irq( lid , nic );
[3]65
[1]66    // create server thread
[3]67    thread_t * new_thread;
[1]68    error_t    error;
69
[3]70    error = thread_kernel_create( &new_thread,
71                                  THREAD_DEV,
72                                  &chdev_sequencial_server,
[188]73                                  nic,
[3]74                                  lid ); 
[1]75
[492]76    assert( (error == 0) , "cannot create server thread" );
[1]77
[3]78    // set "server" field in chdev descriptor
[188]79    nic->server = new_thread;
[1]80   
[408]81    // set "chdev" field in thread descriptor
82    new_thread->chdev = nic;
83
84    // unblock server thread
[3]85    thread_unblock( XPTR( local_cxy , new_thread ) , THREAD_BLOCKED_GLOBAL );
[1]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
[565]101// check thread can yield
102assert( (thread_ptr->busylocks == 0),
103"cannot yield : busylocks = %d\n", thread_ptr->busylocks );
104
[438]105#if DEBUG_DEV_NIC_RX
[437]106uint32_t cycle = (uint32_t)hal_get_cycles();
[438]107if( DEBUG_DEV_NIC_RX < cycle )
[437]108printk("\n[DBG] %s : thread %x enters for packet %x in cluster %x\n", 
109__FUNCTION__ , thread_ptr , pkd , local_cxy );
110#endif
[1]111
[3]112    // get pointer on NIC-RX chdev descriptor
[408]113    uint32_t   channel = thread_ptr->chdev->channel; 
[3]114    xptr_t     dev_xp  = chdev_dir.nic_rx[channel];
[1]115    cxy_t      dev_cxy = GET_CXY( dev_xp );
[3]116    chdev_t  * dev_ptr = (chdev_t *)GET_PTR( dev_xp );
[1]117
[492]118    assert( (dev_xp != XPTR_NULL) , "undefined NIC chdev descriptor" );
[1]119
[492]120    assert( (dev_cxy == local_cxy) , " chdev must be local" );
[1]121
122    // initialize command in thread descriptor
[279]123    thread_ptr->nic_cmd.dev_xp = dev_xp;
[1]124
125    // call driver to test readable
[279]126    thread_ptr->nic_cmd.cmd = NIC_CMD_READABLE;
[1]127    dev_ptr->cmd( thread_xp );
128
129    // check error
[279]130    error = thread_ptr->nic_cmd.error;
[1]131    if( error ) return error;
132
133    // block and deschedule if queue non readable
[279]134    if( thread_ptr->nic_cmd.status == false ) 
[1]135    {
136        // enable NIC-RX IRQ
[238]137        dev_pic_enable_irq( core->lid , dev_xp );
[1]138
[565]139        // block client thread on THREAD_BLOCKED_IO
[436]140        thread_block( XPTR( local_cxy , thread_ptr ) , THREAD_BLOCKED_IO );
[565]141
142        // deschedule client thread
[408]143        sched_yield("client blocked on I/O");
[1]144
[188]145        // disable NIC-RX IRQ
[238]146        dev_pic_disable_irq( core->lid , dev_xp );
[1]147    }
148
149    // call driver for actual read
[279]150    thread_ptr->nic_cmd.cmd     = NIC_CMD_READ;
151    thread_ptr->nic_cmd.buffer  = pkd->buffer;
[1]152    dev_ptr->cmd( thread_xp );
153
154    // check error
[279]155    error = thread_ptr->nic_cmd.error;
[1]156    if( error ) return error;
157
158    // returns packet length   
[279]159    pkd->length = thread_ptr->nic_cmd.length;
[1]160
[438]161#if DEBUG_DEV_NIC_RX
[437]162cycle = (uint32_t)hal_get_cycles();
[438]163if( DEBUG_DEV_NIC_RX < cycle )
[437]164printk("\n[DBG] %s : thread %x exit for packet %x in cluster %x\n", 
165__FUNCTION__ , thread_ptr , pkd , local_cxy );
166#endif
[1]167
168    return 0;
169
170}   // end dev_nic_read()
171
172
173////////////////////////////////////
174error_t dev_nic_write( pkd_t * pkd )
175{
176    error_t error;
177
178    // get pointers on the NIC-TX kernel tread
179    thread_t * thread_ptr = CURRENT_THREAD;
180    xptr_t     thread_xp  = XPTR( local_cxy , thread_ptr );
181
182    // get local pointer on core running this kernel thead
183    core_t * core = thread_ptr->core;
184
[565]185// check thread can yield
186assert( (thread_ptr->busylocks == 0),
187"cannot yield : busylocks = %d\n", thread_ptr->busylocks );
188
[438]189#if DEBUG_DEV_NIC_RX
[437]190uint32_t cycle = (uint32_t)hal_get_cycles();
[438]191if( DEBUG_DEV_NIC_RX < cycle )
[437]192printk("\n[DBG] %s : thread %x enters for packet %x in cluster %x\n", 
193__FUNCTION__ , thread_ptr , pkd , local_cxy );
194#endif
[1]195
[3]196    // get pointer on NIC-TX chdev descriptor
[408]197    uint32_t   channel = thread_ptr->chdev->channel; 
[3]198    xptr_t     dev_xp  = chdev_dir.nic_tx[channel];
[1]199    cxy_t      dev_cxy = GET_CXY( dev_xp );
[3]200    chdev_t  * dev_ptr = (chdev_t *)GET_PTR( dev_xp );
[1]201
[492]202    assert( (dev_xp != XPTR_NULL) , "undefined NIC chdev descriptor" );
[1]203
[492]204    assert( (dev_cxy == local_cxy) , " chdev must be local" );
[1]205
206    // initialize command in thread descriptor
[279]207    thread_ptr->nic_cmd.dev_xp = dev_xp;
[1]208
209    // call driver to test writable
[279]210    thread_ptr->nic_cmd.cmd = NIC_CMD_WRITABLE;
[1]211    dev_ptr->cmd( thread_xp );
212
213    // check error
[279]214    error = thread_ptr->nic_cmd.error;
[1]215    if( error ) return error;
216
217    // block and deschedule if queue non writable
[279]218    if( thread_ptr->nic_cmd.status == false ) 
[1]219    {
220        // enable NIC-TX IRQ
[238]221        dev_pic_enable_irq( core->lid ,dev_xp );
[1]222
[565]223        // block client thread on THREAD_BLOCKED I/O condition
[436]224        thread_block( XPTR( local_cxy , thread_ptr ) , THREAD_BLOCKED_IO );
[565]225
226        // deschedule client thread
[408]227        sched_yield("client blocked on I/O");
[1]228
229        // disable NIC-TX IRQ
[238]230        dev_pic_disable_irq( core->lid , dev_xp );
[1]231    }
232
233    // call driver for actual write
[279]234    thread_ptr->nic_cmd.cmd    = NIC_CMD_WRITE;
235    thread_ptr->nic_cmd.buffer = pkd->buffer;
236    thread_ptr->nic_cmd.length = pkd->length;
[1]237    dev_ptr->cmd( thread_xp );
238
239    // check error
[279]240    error = thread_ptr->nic_cmd.error;
[1]241    if( error ) return error;
242
[438]243#if DEBUG_DEV_NIC_RX
[437]244cycle = (uint32_t)hal_get_cycles();
[438]245if( DEBUG_DEV_NIC_RX < cycle )
[437]246printk("\n[DBG] %s : thread %x exit for packet %x in cluster %x\n", 
247__FUNCTION__ , thread_ptr , pkd , local_cxy );
248#endif
[1]249
250    return 0;
251}  // end dev_nic_write()
252
253
254
Note: See TracBrowser for help on using the repository browser.