summaryrefslogtreecommitdiff
path: root/cesar/maximus/processors/src/ClockProcessor.cpp
blob: 711858dc066b2d6683f5fcda63d2b6f0caa72b0d (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
/* Maximus project {{{
 *
 * Copyright (C) 2012 MStar Semiconductor
 *
 * <<<Licence>>>
 *
 * }}} */
/**
 * \file    maximus/processors/src/ClockProcessor.cpp
 * \ingroup maximus_processors
 *
 */
#include "maximus/processors/inc/ClockProcessor.h"
#include "maximus/sci/inc/ClockSciMsg.h"
#include "maximus/scheduler/inc/Scheduler.h"
#include "maximus/utils/inc/Logger.h"

ClockProcessor::ClockProcessor (SciServer &ref1,
                                MaximusCallBack &ref2):
    Processor (ref1, ref2, SCI_MSG_TYPE_NETWORK_CLOCK),
    msg_to_send (0)
{
    logFunction ();

    msg_to_send.set_clock_type (NETWORK_CLOCK_TYPE_STATION);
}

ClockProcessor::~ClockProcessor ()
{
    logFunction ();
}

SciMsg *
ClockProcessor::create_sci_msg (
    struct Sci_Msg_Header &header,
    unsigned char *buffer)
{
    logFunction ();

    return new ClockSciMsg (header, buffer);
}

void
ClockProcessor::dispatchMsgProc (SciMsg *msg_rx)
{
    logFunction ();

    ClockSciMsg &msg = static_cast <ClockSciMsg &> (*msg_rx);

    if (NETWORK_CLOCK_VERSION == msg.get_clock_version ())
    {
        Sci_Msg_Station_Id from_sta_id = msg.get_sci_stationid ();
        Network_Clock_Type type = msg.get_clock_type ();
        Network_Clock_Id id = msg.get_clock_id ();
        Network_Clock_Tick msg_tick = msg.get_clock_tick ();

        switch (type)
        {
        case NETWORK_CLOCK_TYPE_NB:
        case NETWORK_CLOCK_TYPE_NONE:
            maximus_log (LOG_WARNING,
                         "bad event type => do nothing");
            break;

        case NETWORK_CLOCK_TYPE_REMOVE:
            p_scheduler->remove_event (
                msg_tick, from_sta_id, id);
            break;

        case NETWORK_CLOCK_TYPE_STATION:
        case NETWORK_CLOCK_TYPE_FUNCTION_CALL:
        case NETWORK_CLOCK_TYPE_PHY:
        case NETWORK_CLOCK_TYPE_SYSTEM:
        case NETWORK_CLOCK_TYPE_ETHERNET:
            p_scheduler->add_event (
                msg_tick, from_sta_id, id, type);
            break;
        }
    }

    delete (msg_rx);
}

void
ClockProcessor::scheduler_send_event (
    Sci_Msg_Station_Id clock_staid,
    Network_Clock_Id clock_id,
    SciMsg *msg)
{
    logFunction ();

    msg_to_send.set_clock_id (clock_id);
    msg_to_send.set_sci_stationid (clock_staid);
    msg_to_send.setup_and_send (sci_server);
}