1

     2

#include "canfestival.h"

     3

#include "dcf.h"

     4

     5

/* CanFestival nodes generated OD headers*/

     6

%(nodes_includes)s

     7

     8

#define BOARD_DECL(nodename, busname, baudrate)\

     9

    s_BOARD nodename##Board = {busname, baudrate};

    10

    11

/* CAN channels declaration */

    12

%(board_decls)s

    13

    14

/* Keep track of init level to cleanup correctly */

    15

static int init_level=0;

    16

/* Retrieve PLC cycle time */

    17

extern int common_ticktime__;

    18

    19

/* Per master node slavebootup callbacks. Checks that

    20

 * every node have booted before calling Master_post_SlaveBootup */

    21

%(slavebootups)s

    22

    23

/* One slave node post_sync callback.

    24

 * Used to align PLC tick-time on CANopen SYNC

    25

 */

    26

%(post_sync)s

    27

    28

/* Triggers DCF transission

    29

 */

    30

%(pre_op)s

    31

    32

#define NODE_FORCE_SYNC(nodename) \

    33

    /* Artificially force sync state to 1 so that it is not started */\

    34

    nodename##_Data.CurrentCommunicationState.csSYNC = -1;\

    35

    /* Force sync period to common_ticktime__ so that other node can read it*/\

    36

    *nodename##_Data.COB_ID_Sync = 0x40000080;\

    37

    *nodename##_Data.Sync_Cycle_Period = common_ticktime__ * 1000;

    38

    39

#define NODE_INIT(nodename, nodeid) \

    40

    /* Defining the node Id */\

    41

    setNodeId(&nodename##_Data, nodeid);\

    42

    /* init */\

    43

    setState(&nodename##_Data, Initialisation);

    44

    45

#define NODE_MASTER_INIT(nodename, nodeid) \

    46

    NODE_FORCE_SYNC(nodename) \

    47

    NODE_INIT(nodename, nodeid)

    48

    49

#define NODE_SLAVE_INIT(nodename, nodeid) \

    50

    NODE_INIT(nodename, nodeid)

    51

    52

void InitNodes(CO_Data* d, UNS32 id)

    53

{

    54

    %(slavebootup_register)s

    55

    %(post_sync_register)s

    56

    %(pre_op_register)s

    57

    %(nodes_init)s

    58

}

    59

    60

#define NODE_STOP(nodename) \

    61

    if(init_level-- > 0)\

    62

    {\

    63

        masterSendNMTstateChange(&nodename##_Data, 0, NMT_Reset_Node);\

    64

        setState(&nodename##_Data, Stopped);\

    65

    }

    66

    67

void Exit(CO_Data* d, UNS32 id)

    68

{

    69

    %(nodes_stop)s

    70

}

    71

    72

#define NODE_CLOSE(nodename) \

    73

    if(init_level_c-- > 0)\

    74

    {\

    75

      canClose(&nodename##_Data);\

    76

    }

    77

    78

void __cleanup_%(locstr)s(void)

    79

{

    80

    // Stop timer thread

    81

    if(init_level-- > 0){

    82

    int init_level_c = init_level;

    83

        StopTimerLoop(&Exit);

    84

        %(nodes_close)s

    85

    }

    86

    87

    TimerCleanup();

    88

}

    89

    90

#ifndef stderr

    91

#define fprintf(...)

    92

#define fflush(...)

    93

#endif

    94

    95

#define NODE_OPEN(nodename)\

    96

    if(!canOpen(&nodename##Board,&nodename##_Data)){\

    97

        fprintf(stderr,"Cannot open CAN intefrace %%s at speed %%s\n for CANopen node \"" #nodename "\"",nodename##Board.busname, nodename##Board.baudrate);\

    98

        fflush(stderr);\

    99

        return -1;\

   100

    }\

   101

    init_level++;

   102

   103

/***************************  INIT  *****************************************/

   104

int __init_%(locstr)s(int argc,char **argv)

   105

{

   106

#ifndef NOT_USE_DYNAMIC_LOADING

   107

    if( !LoadCanDriver("%(candriver)s") ){

   108

        fprintf(stderr, "Cannot load CAN interface library for CanFestival (%(candriver)s)\n");\

   109

        fflush(stderr);\

   110

        return -1;\

   111

    }

   112

#endif

   113

   114

    TimerInit();

   115

   116

    %(nodes_open)s

   117

   118

    // Start timer thread

   119

    StartTimerLoop(&InitNodes);

   120

    init_level++;

   121

    return 0;

   122

}

   123

   124

#define NODE_SEND_SYNC(nodename)\

   125

    if(getState(&nodename##_Data)==Operational){\

   126

        sendSYNCMessage(&nodename##_Data);\

   127

    }

   128

   129

void __retrieve_%(locstr)s(void)

   130

{

   131

    /* Locks the stack, so that no changes occurs while PLC access variables

   132

     * TODO : implement buffers to avoid such a big lock

   133

     *  */

   134

    EnterMutex();

   135

    /* Send Sync */

   136

    %(nodes_send_sync)s

   137

}

   138

   139

#define NODE_PROCEED_SYNC(nodename)\

   140

    proceedSYNC(&nodename##_Data);

   141

   142

void __publish_%(locstr)s(void)

   143

{

   144

    /* Process sync event */

   145

    %(nodes_proceed_sync)s

   146

    LeaveMutex();

   147

}

   148