task.cpp

FDMP the body of the kernel, the Information-Technology Promotion Agency (IPA) adopted by the unexpl

/*
 *  TOPPERS/FDMP Kernel
 *      Toyohashi Open Platform for Embedded Real-Time Systems/
 *      Function Distributed Multiprocessor Kernel
 *
 *  Copyright (C) 2005 by Takagi Nobuhisa
 * 
 *  忋婰挊嶌尃幰偼丆埲壓偺 (1)乣(4) 偺忦審偐丆Free Software Foundation 
 *  偵傛偭偰岞昞偝傟偰偄傞 GNU General Public License 偺 Version 2 偵婰
 *  弎偝傟偰偄傞忦審傪枮偨偡応崌偵尷傝丆杮僜僼僩僂僃傾乮杮僜僼僩僂僃傾
 *  傪夵曄偟偨傕偺傪娷傓丏埲壓摨偠乯傪巊梡丒暋惢丒夵曄丒嵞攝晍乮埲壓丆
 *  棙梡偲屇傇乯偡傞偙偲傪柍彏偱嫋戻偡傞丏
 *  (1) 杮僜僼僩僂僃傾傪僜乕僗僐乕僪偺宍偱棙梡偡傞応崌偵偼丆忋婰偺挊嶌
 *      尃昞帵丆偙偺棙梡忦審偍傛傃壓婰偺柍曐徹婯掕偑丆偦偺傑傑偺宍偱僜乕
 *      僗僐乕僪拞偵娷傑傟偰偄傞偙偲丏
 *  (2) 杮僜僼僩僂僃傾傪丆儔僀僽儔儕宍幃側偳丆懠偺僜僼僩僂僃傾奐敪偵巊
 *      梡偱偒傞宍偱嵞攝晍偡傞応崌偵偼丆嵞攝晍偵敽偆僪僉儏儊儞僩乮棙梡
 *      幰儅僯儏傾儖側偳乯偵丆忋婰偺挊嶌尃昞帵丆偙偺棙梡忦審偍傛傃壓婰
 *      偺柍曐徹婯掕傪宖嵹偡傞偙偲丏
 *  (3) 杮僜僼僩僂僃傾傪丆婡婍偵慻傒崬傓側偳丆懠偺僜僼僩僂僃傾奐敪偵巊
 *      梡偱偒側偄宍偱嵞攝晍偡傞応崌偵偼丆師偺偄偢傟偐偺忦審傪枮偨偡偙
 *      偲丏
 *    (a) 嵞攝晍偵敽偆僪僉儏儊儞僩乮棙梡幰儅僯儏傾儖側偳乯偵丆忋婰偺挊
 *        嶌尃昞帵丆偙偺棙梡忦審偍傛傃壓婰偺柍曐徹婯掕傪宖嵹偡傞偙偲丏
 *    (b) 嵞攝晍偺宍懺傪丆暿偵掕傔傞曽朄偵傛偭偰丆TOPPERS僾儘僕僃僋僩偵
 *        曬崘偡傞偙偲丏
 *  (4) 杮僜僼僩僂僃傾偺棙梡偵傛傝捈愙揑傑偨偼娫愙揑偵惗偠傞偄偐側傞懝
 *      奞偐傜傕丆忋婰挊嶌尃幰偍傛傃TOPPERS僾儘僕僃僋僩傪柶愑偡傞偙偲丏
 * 
 *  杮僜僼僩僂僃傾偼丆柍曐徹偱採嫙偝傟偰偄傞傕偺偱偁傞丏忋婰挊嶌尃幰偍
 *  傛傃TOPPERS僾儘僕僃僋僩偼丆杮僜僼僩僂僃傾偵娭偟偰丆偦偺揔梡壜擻惈傕
 *  娷傔偰丆偄偐側傞曐徹傕峴傢側偄丏傑偨丆杮僜僼僩僂僃傾偺棙梡偵傛傝捈
 *  愙揑傑偨偼娫愙揑偵惗偠偨偄偐側傞懝奞偵娭偟偰傕丆偦偺愑擟傪晧傢側偄丏
 * 
 */

/*
 *  toppers/itron/jsp/task.cpp
 */
#include "toppers/itron/jsp/task.hpp"
#include "toppers/itron/jsp/kernel_chk.hpp"
#include "toppers/reporter.hpp"
#include "toppers/misc.hpp"
#include "toppers/s_record.hpp"
#include "toppers/nm_symbol.hpp"

namespace toppers
{
  namespace itron
  {
    namespace jsp
    {

      namespace
      {
        
        long get_id( boost::shared_ptr<kernel_cfg::initial_block> pinib )
        {
          return pinib->id();
        }

      }

      /*!
       *  \brief  torder_table 偺惗惉
       *  \param  cfg   kernel_cfg.c 惗惉忣曬
       *  \param  ostr  弌椡僗僩儕乕儉
       */
      void task_policy::generate_constants( const kernel_cfg& cfg, std::ostream& ostr )
      {
        ostr << "const ID _kernel_torder_table[TNUM_TSKID] = {";
        const kernel_cfg::inib_array* pinibs = cfg.get_inib_array( name_ );
        output_list( pinibs->begin(), pinibs->end(), ostr, get_id, ", " );
        ostr << "};\n\n";
      }

      /*!
       *  \brief  僷儔儊乕僞僠僃僢僋僐乕僪 偺惗惉
       *  \param  cfg   kernel_cfg.c 惗惉忣曬
       *  \param  ostr  弌椡僗僩儕乕儉
       */
      void task_policy::generate_assertions( const kernel_cfg& cfg, std::ostream& ostr )
      {
        const kernel_cfg::inib_array* pinibs = cfg.get_inib_array( name_ );
        static const char pattern[] = 
          "#if ((@#tskatr) & (TA_HLNG|TA_ASM)) != TA_HLNG\n"
          "#error \"`tskatr\' of task `@name\' is not TA_HLNG\"\n"
          "#endif\n"
          "__CFG_ASSERT(((@#tskatr) & (TA_HLNG|TA_ASM)) == TA_HLNG);\n"
          "__CFG_ASSERT(TMIN_TPRI <= (@itskpri) && (@itskpri) <= TMAX_TPRI);\n"
          "__CFG_ASSERT((@stksz) > 0);\n"
          "\n"
          "#if ((@#texatr) & (TA_HLNG|TA_ASM)) != TA_HLNG\n"
          "#error \"`texatr\' of task `@name\' is not TA_HLNG\"\n"
          "#endif\n"
          "__CFG_ASSERT(((@#texatr) & (TA_HLNG|TA_ASM)) == TA_HLNG);\n"
          "\n";
        std::transform( pinibs->begin(), pinibs->end(), std::ostream_iterator<std::string>( ostr ), generator( pattern ) );
      }

      /*!
       *  \brief  僞僗僋偑側偄応崌偺 __EMPTY_LABEL 偺惗惉
       *  \param  ostr  弌椡僗僩儕乕儉
       */
      void task_policy::generate_extra_empty_labels( std::ostream& ostr )
      {
        ostr << "__EMPTY_LABEL(const ID, _kernel_torder_table);\n";
      }

      /*!
       *  \brief  specified_object<Plociy> 僋儔僗偑梫媮偡傞 Policy::verify 娭悢
       *  \param  api   夝愅懳徾偺惷揑API忣曬
       *  \param  obj   僇乕僱儖僆僽僕僃僋僩忣曬
       *  \return 敾掕寢壥偑惓忢偱偁傟偽 true 傪曉偡丅
       */
      bool task_policy::verify( const static_api& api, kernel_object& obj )
      {
        if ( obj.get( "stk" ) != "NULL" )
        {
          error( _( "parameter `%1%\' must be `NULL\'" ) % "stk" );
          return false;
        }
        if ( obj.get( "#texatr" ).empty() )
        {
          obj.set( "#texatr", "0" );
        }
        if ( obj.get( "texrtn" ).empty() )
        {
          obj.set( "texrtn", "0" );
        }
        return true;
      }

      /*!
       *  \brief  儕儞僋屻偺僷儔儊乕僞僠僃僢僋
       *  \param  chk   僠僃僢僋忣曬
       *  \param  srec  儘乕僪儌僕儏乕儖偺僟儞僾忣曬
       *  \param  syms  僔儞儃儖僥乕僽儖
       */
      bool task_policy::check( const itron::kernel_chk& chk, const s_record& srec, const nm_symbol& syms )
      {
        nm_symbol::entry entry = syms.find( "_kernel_tinib_table" );
        if ( entry.type < 0 )
        {
          return false;
        }
        long tnum_tskid = chk.get( kernel_chk::countof_TSKID );
        long sizeof_FP = chk.get( kernel_chk::sizeof_FP );
        long sizeof_TINIB = chk.get( kernel_chk::sizeof_TINIB );
        long offsetof_TINIB_task = chk.get( kernel_chk::offsetof_TINIB_task );

        for ( int i = 0; i < tnum_tskid; i++ )
        {
          unsigned long value = 0;
          for ( int j = 0; j < sizeof_FP; j++ )
          {
            int t = srec[entry.address + sizeof_TINIB*i + offsetof_TINIB_task + j];
            if ( t < 0 )
            {
              return false;
            }
            value = ( value << 8 ) | ( t & 0xff );
          }
          if ( value == 0 )
          {
            error( _( "start address of task %1% is null" ) % ( i + 1 ) );
          }
        }
        return true;
      }

      const char task_policy::name_[] = "task";
      const char task_policy::symbol_[] = "tsk";
      const char* const task_policy::apis_[] = { "CRE_TSK", 0 };
      const char* const task_policy::params_[] = { "$tskid { #tskatr exinf task itskpri stksz stk }", 0 };
      const char* const task_policy::apis2_[] = { "DEF_TEX", 0 };
      const char* const task_policy::params2_[] = { "%tskid { #texatr texrtn }", 0 };
      const char* const task_policy::prefix_ = "t";
      const char task_policy::region_format_[] = "static __STK_UNIT __stack_@name[__TCOUNT_STK_UNIT(@stksz)];\n";
      const char task_policy::init_format_[] = "\t{ @#tskatr, (VP_INT)(@exinf), (FP)(@task), INT_PRIORITY(@itskpri), __TROUND_STK_UNIT(@stksz), __stack_@name, @#texatr, (FP)(@texrtn) }";

    }
  }
}