1

/*

     2

 * Etherlab execution code

     3

 *

     4

 * */

     5

     6

#include <rtdm/rtdm.h>

     7

#include <native/task.h>

     8

#include <native/timer.h>

     9

    10

#include "ecrt.h"

    11

#include "ec_rtdm.h"

    12

    15

    16

// declaration of interface variables

    17

%(located_variables_declaration)s

    18

    19

// process data

    20

uint8_t *domain1_pd = NULL;

    21

%(used_pdo_entry_offset_variables_declaration)s

    22

    23

const static ec_pdo_entry_reg_t domain1_regs[] = {

    24

%(used_pdo_entry_configuration)s

    25

    {}

    26

};

    27

/*****************************************************************************/

    28

    29

%(pdos_configuration_declaration)s

    30

    31

int rt_fd = -1;

    32

CstructMstrAttach MstrAttach;

    33

char rt_dev_file[64];

    34

long long wait_period_ns = 100000LL;

    35

    36

// EtherCAT

    37

static ec_master_t *master = NULL;

    38

static ec_domain_t *domain1 = NULL;

    39

static int first_sent=0;

    40

%(slaves_declaration)s

    41

    42

/* Beremiz plugin functions */

    43

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

    44

{

    45

    uint32_t abort_code;

    46

    size_t result_size;

    47

    int rtstatus;

    48

    49

	MstrAttach.masterindex = %(master_number)d;

    50

    51

	master = ecrt_request_master(MstrAttach.masterindex);

    52

	if (!master) return -1;

    53

    54

	domain1 = ecrt_master_create_domain(master);

    55

	if (!domain1) return -1;

    56

    57

    // slaves PDO configuration

    58

%(slaves_configuration)s

    59

    60

    if (ecrt_domain_reg_pdo_entry_list(domain1, domain1_regs)) {

    61

        fprintf(stderr, "PDO entry registration failed!\n");

    62

        return -1;

    63

    }

    64

    65

	ecrt_master_set_send_interval(master, common_ticktime__);

    66

    67

    // slaves initialization

    68

%(slaves_initialization)s

    69

    70

    // extracting default value for not mapped entry in output PDOs

    71

%(slaves_output_pdos_default_values_extraction)s

    72

    73

    sprintf(&rt_dev_file[0],"%%s%%u",EC_RTDM_DEV_FILE_NAME,0);

    74

    rt_fd = rt_dev_open( &rt_dev_file[0], 0);

    75

    if (rt_fd < 0) {

    76

        fprintf(stderr, "Can't open %%s\n", &rt_dev_file[0]);

    77

        return -1;

    78

    }

    79

    80

    // attach the master over rtdm driver

    81

    MstrAttach.domainindex = ecrt_domain_index(domain1);

    82

    rtstatus = ecrt_rtdm_master_attach(rt_fd, &MstrAttach);

    83

    if (rtstatus < 0) {

    84

        fprintf(stderr, "Cannot attach to master over rtdm\n");

    85

        return -1;

    86

    }

    87

    88

    if (ecrt_master_activate(master))

    89

        return -1;

    90

    91

    if (!(domain1_pd = ecrt_domain_data(domain1))) {

    92

        fprintf(stderr, "domain1_pd:  0x%%.6lx\n", (unsigned long)domain1_pd);

    93

        return -1;

    94

    }

    95

    96

    fprintf(stdout, "Master %(master_number)d activated...\n");

    97

    98

    first_sent = 0;

    99

   100

    return 0;

   101

}

   102

   103

void __cleanup_%(location)s(void)

   104

{

   105

	if (rt_fd >= 0) {

   106

		rt_dev_close(rt_fd);

   107

	}

   108

	//release master

   109

	ecrt_release_master(master);

   110

    first_sent = 0;

   111

}

   112

   113

void __retrieve_%(location)s(void)

   114

{

   115

    // receive ethercat

   116

    if(first_sent){

   117

        ecrt_rtdm_master_recieve(rt_fd);

   118

        ecrt_rtdm_domain_process(rt_fd);

   119

%(retrieve_variables)s

   120

    }

   121

   122

}

   123

   124

static RTIME _last_occur=0;

   125

static RTIME _last_publish=0;

   126

RTIME _current_lag=0;

   127

RTIME _max_jitter=0;

   128

static inline RTIME max(RTIME a,RTIME b){return a>b?a:b;}

   129

   130

void __publish_%(location)s(void)

   131

{

   132

%(publish_variables)s

   133

    ecrt_rtdm_domain_queque(rt_fd);

   134

    {

   135

        RTIME current_time = rt_timer_read();

   136

        // Limit spining max 1/5 of common_ticktime

   137

        RTIME maxdeadline = current_time + (common_ticktime__ / 5);

   138

        RTIME deadline = _last_occur ? 

   139

            _last_occur + common_ticktime__ : 

   140

            current_time + _max_jitter; 

   141

        if(deadline > maxdeadline) deadline = maxdeadline;

   142

        _current_lag = deadline - current_time;

   143

        if(_last_publish != 0){

   144

            RTIME period = current_time - _last_publish;

   145

            if(period > common_ticktime__ )

   146

                _max_jitter = max(_max_jitter, period - common_ticktime__);

   147

            else

   148

                _max_jitter = max(_max_jitter, common_ticktime__ - period);

   149

        }

   150

        _last_publish = current_time;

   151

        _last_occur = current_time;

   152

        while(current_time < deadline) {

   153

            _last_occur = current_time; //Drift backward by default

   154

            current_time = rt_timer_read();

   155

        }

   156

        if( _max_jitter * 10 < common_ticktime__ && _current_lag < _max_jitter){

   157

            //Consuming security margin ?

   158

            _last_occur = current_time; //Drift forward

   159

        }

   160

    }

   161

    ecrt_rtdm_master_send(rt_fd);

   162

    first_sent = 1;

   163

}