Changeset 659


Ignore:
Timestamp:
Oct 10, 2020, 3:58:01 PM (4 years ago)
Author:
alain
Message:

euh...

Location:
trunk/user
Files:
6 edited

Legend:

Unmodified
Added
Removed

  • trunk/user/convol/convol.c

    r656 r659  
    187187
    188188    // get & check platform parameters
    189     get_config( &x_size , &y_size , &ncores );
     189    hard_config_t  config;
     190    get_config( &config );
     191    x_size = config.x_size;
     192    y_size = config.y_size;
     193    ncores = config.ncores;
    190194
    191195    if((ncores != 1) && (ncores != 2) && (ncores != 4))

  • trunk/user/fft/fft.c

    r656 r659  
    290290
    291291    // get platform parameters
    292     if( get_config( &x_size , &y_size , &ncores ) )
     292    hard_config_t  config;
     293    if( get_config( &config ) )
    293294    {
    294295        printf("\n[fft error] cannot get hardware configuration\n");
    295296        exit( 0 );
    296297    }
     298
     299    x_size = config.x_size;
     300    y_size = config.y_size;
     301    ncores = config.ncores;
    297302
    298303    // check ncores

  • trunk/user/init/init.c

    r635 r659  
    66// This single thread application implement the "init" process for ALMOS-MKH.
    77// It uses the fork/exec syscalls to create N KSH child processes
    8 // (one child process per user terminal).
    9 // Then calls the wait() function to block, and reactivate any child KSH process
     8// (one child process per user TXT terminal).
     9// Then calls the wait() function to block, and recreate any child KSH process
    1010// that has been deleted, using a new fork/exec.
    11 // It includes the hard_config.h file to get th NB_TXT_CHANNELS parameter.
    1211///////////////////////////////////////////////////////////////////////////////////////
    1312
    14 #include <hard_config.h>
    1513#include <unistd.h>
    1614#include <stdlib.h>
    … …  
    2018#include <hal_macros.h>
    2119#include <sys/wait.h>
     20#include <shared_syscalls.h>
    2221
    23 #define DEBUG_PROCESS_INIT    0
    24 
    25 // TODO improve the get_config() syscall to return nb_txt_channels
    26 // and avoid the hard_config include [AG]
     22#define DEBUG_PROCESS_INIT    1
    2723
    2824////////////////
    2925int main( void )
    3026{
    31     int           i;
     27    unsigned int  i;
    3228    int           ret_fork;      // fork return value 
    3329    int           ret_exec;      // exec return value 
    … …  
    4036#endif
    4137
     38    // get Number of TXT channels from hard configuration
     39    hard_config_t config;     
     40    get_config( &config );
     41
     42    unsigned int  txt_channels = config.txt_channels;
     43    unsigned int  x_size       = config.x_size;
     44    unsigned int  y_size       = config.y_size;
     45    unsigned int  ncores       = config.ncores;
     46
    4247    // check number of TXT channels
    43     if( NB_TXT_CHANNELS < 2 )
     48    if( txt_channels < 2 )
    4449    {
    45         printf("\n[ERROR] in init process : number of TXT channels must be larger than 1\n");
     50        snprintf( string , 64 ,
     51        "\n[init ERROR] number of TXT channels must be larger than 1\n");
     52        display_string( string );
    4653        exit( EXIT_FAILURE );
    4754    }
    4855
    4956    // create the KSH processes (one per user terminal)
    50     for( i = 1 ; i <  NB_TXT_CHANNELS ; i++ )
     57    for( i = 1 ; i <  txt_channels ; i++ )
    5158    {
    5259        // INIT process fork process CHILD[i]
    … …  
    5663        {
    5764            // INIT display error message 
    58             snprintf( string , 64 , "[init ERROR] cannot fork child[%d] => suicide" , i );
     65            snprintf( string , 64 ,
     66            "[init ERROR] cannot fork child[%d] => suicide" , i );
    5967            display_string( string );
    6068
    6169            // INIT suicide
    62             exit( 0 );
     70            exit( EXIT_FAILURE );
    6371        }
    6472        else if( ret_fork == 0 )                    // we are in CHILD[i] process
    … …  
    7381                "[init ERROR] CHILD[%d] cannot exec KSH / ret_exec = %d" , i , ret_exec );
    7482                display_string( string );
     83
     84                // CHILD[i] suicide
     85                exit( EXIT_FAILURE );
    7586            }
    7687        }
    … …  
    7889        {
    7990            // INIT display CHILD[i] process PID
    80             snprintf( string , 64 , "[init] (pid 0x1) created ksh[%d] (pid %x)", i , ret_fork );
     91            snprintf( string , 64 ,
     92            "[init] (pid 0x1) created ksh[%d] (pid %x)", i , ret_fork );
    8193            display_string( string );
    8294
    83             // wait signal from KSH[i]
     95            // wait signal from KSH[i] before creating KSH[i+1]
    8496            pause();
    8597        }
    … …  
    88100#if DEBUG_PROCESS_INIT
    89101{
    90     unsigned int  x_size;        // number of clusters in a row
    91     unsigned int  y_size;        // number of clusters in a column
    92     unsigned int  ncores;        // number of cores per cluster
    93102    unsigned int  x;             // cluster x coordinate
    94103    unsigned int  y;             // cluster y coordinate
    95104    unsigned int  cxy;           // cluster identifier
    96105    unsigned int  lid;           // core local index
    97 
    98     // get hardware config
    99     get_config( &x_size , &y_size , &ncores );
    100106
    101107    // INIT displays processes and threads in all clusters

  • trunk/user/ksh/ksh.c

    r657 r659  
    5050#include <sys/mman.h>
    5151#include <fcntl.h>
    52 
    53 #define CMD_MAX_SIZE   (256)    // max number of characters in one command
    54 #define LOG_DEPTH      (32)     // max number of registered commands
    55 #define MAX_ARGS           (32)     // max number of arguments in a command
    56 #define PATH_MAX_SIZE  (256)    // max number of characters in a pathname
     52#include <shared_syscalls.h>
     53
     54#define CMD_MAX_SIZE       (256)    // max number of characters in one command
     55#define LOG_DEPTH          (32)     // max number of registered commands
     56#define MAX_ARGS               (32)     // max number of arguments in a command
     57#define PATH_MAX_SIZE      (256)    // max number of characters in a pathname
    5758
    5859#define DEBUG_MAIN          0
    … …  
    414415               "         display  mapper   path     page     nbytes\n"
    415416               "         display  fat      min      nslots\n"
    416                "         display  fat      cxy      0\n" );
     417               "         display  fat      cxy      0\n"
     418               "         display  socket   pid      fdid\n" );
    417419    }
    418420    ////////////////////////////////////
    … …  
    594596        }
    595597    }
     598    ///////////////////////////////////////////
     599    else if( strcmp( argv[1] , "socket" ) == 0 )
     600    {
     601        if( argc != 4 )
     602        {
     603                    printf("  usage: display socket pid fdid\n");
     604            }
     605        else
     606        {
     607                unsigned int pid   = atoi(argv[2]);
     608            unsigned int fdid = atoi(argv[3]);
     609
     610            if( display_socket( pid , fdid ) )
     611            {
     612                printf("  error: cannot found socket[%x,%d]\n", pid, fdid );
     613            }
     614        }
     615    }
     616    ////
    596617    else
    597618    {
    … …  
    939960    unsigned int x_size;
    940961    unsigned int y_size;
    941     unsigned int ncores;
    942962    unsigned int x;
    943963    unsigned int y;
    … …  
    955975    {
    956976        // get platform config
    957         get_config( &x_size , &y_size , &ncores );
     977        hard_config_t  config;
     978        get_config( &config );
     979        x_size = config.x_size;
     980        y_size = config.y_size;
    958981
    959982        // scan all clusters
    … …  
    12241247        char           cmd[CMD_MAX_SIZE];               // buffer for one command
    12251248
    1226 
    1227 
    1228 // 1. first direct command
    1229 if( sem_wait( &semaphore ) )
    1230 {
    1231     printf("\n[ksh error] cannot found semafore\n" );
    1232     exit( 1 );
    1233 }
    1234 else
    1235 {
    1236     strcpy( cmd , "load bin/user/transpose.elf" );
    1237     printf("[ksh] %s\n", cmd );
    1238     execute( cmd );
    1239 }
    1240 //
    1241 
    1242 
    1243 
    1244 /* 2. second direct command
    1245 if( sem_wait( &semaphore ) )
    1246 {
    1247     printf("\n[ksh error] cannot found semafore\n" );
    1248     exit( 1 );
    1249 }
    1250 else
    1251 {
    1252     strcpy( cmd , "cat home/p_fft_dqt_16384_1_2" );
    1253     printf("[ksh] %s\n", cmd );
    1254     execute( cmd );
    1255 }
     1249/*  direct command to help debug
     1250
     1251    int pid = getpid();
     1252
     1253    if( pid == 3 )
     1254    {
     1255        if( sem_wait( &semaphore ) )
     1256        {
     1257            printf("\n[ksh %d] error : cannot found semafore\n" );
     1258            exit( 1 );
     1259        }
     1260        else
     1261        {
     1262            strcpy( cmd , "load bin/user/tcp_server.elf" );
     1263            printf("[ksh] %s\n", cmd );
     1264            execute( cmd );
     1265        }
     1266    }
     1267    else if( getpid() == 4 )
     1268    {
     1269        if( sem_wait( &semaphore ) )
     1270        {
     1271            printf("\n[ksh %d] error : cannot found semafore\n" );
     1272            exit( 1 );
     1273        }
     1274        else
     1275        {
     1276            strcpy( cmd , "load bin/user/tcp_client.elf" );
     1277            printf("[ksh] %s\n", cmd );
     1278            execute( cmd );
     1279        }
     1280    }
     1281
    12561282*/
    12571283
    … …  
    12941320
    12951321#if DEBUG_INTER
    1296 unsigned int pid = getpid();
    12971322snprintf( string , 128 , "[ksh] %s : request a new command", __FUNCTION__ );
    12981323display_string( string );
    … …  
    13271352snprintf( string , 128 , "[ksh] %s : get command <%s>", __FUNCTION__, cmd );
    13281353display_string( string );
    1329 display_vmm( 0 , 2 );
    13301354#endif
    13311355                        // register command in log_entries[] array

  • trunk/user/sort/sort.c

    r656 r659  
    262262 
    263263    // compute number of working threads (one thread per core)
    264     get_config( &x_size , &y_size , &ncores );
     264    hard_config_t  config;
     265    get_config( &config );
     266    x_size  = config.x_size;
     267    y_size  = config.y_size;
     268    ncores  = config.ncores;
    265269    threads = x_size * y_size * ncores;
    266270

  • trunk/user/transpose/transpose.c

    r657 r659  
    199199
    200200    // get & check plat-form parameters
    201     get_config( &x_size,
    202                 &y_size,
    203                 &ncores );
     201    hard_config_t  config;
     202    get_config( &config );
     203    x_size = config.x_size;
     204    y_size = config.y_size;
     205    ncores = config.ncores;
    204206
    205207    if((ncores != 1) && (ncores != 2) && (ncores != 4))
Note: See TracChangeset for help on using the changeset viewer.