-
Notifications
You must be signed in to change notification settings - Fork 4
/
kafkaUint8Trans.cxx
96 lines (76 loc) · 2.65 KB
/
kafkaUint8Trans.cxx
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
96
/** © Copyright 2019 CERN
*
* This software is distributed under the terms of the
* GNU Lesser General Public Licence version 3 (LGPL Version 3),
* copied verbatim in the file “LICENSE”
*
* In applying this licence, CERN does not waive the privileges
* and immunities granted to it by virtue of its status as an
* Intergovernmental Organization or submit itself to any jurisdiction.
*
* Author: Alexandru Savulescu (HSE-CEN-CO)
*
**/
#include "kafkaUint8Trans.hxx"
#include "kafkaHWMapper.hxx"
#include "Common/Logger.hxx"
#include <cmath>
#include <IntegerVar.hxx>
namespace Transformations{
TransformationType kafkaUint8Trans::isA() const {
return (TransformationType) kafkaDrvUint8TransType;
}
TransformationType kafkaUint8Trans::isA(TransformationType type) const {
if (type == isA())
return type;
else
return Transformation::isA(type);
}
Transformation *kafkaUint8Trans::clone() const {
return new kafkaUint8Trans;
}
int kafkaUint8Trans::itemSize() const {
return size;
}
VariableType kafkaUint8Trans::getVariableType() const {
return INTEGER_VAR;
}
PVSSboolean kafkaUint8Trans::toPeriph(PVSSchar *buffer, PVSSuint len, const Variable &var, const PVSSuint subix) const {
if(var.isA() != INTEGER_VAR){
ErrHdl::error(ErrClass::PRIO_SEVERE, // Data will be lost
ErrClass::ERR_PARAM, // Wrong parametrization
ErrClass::UNEXPECTEDSTATE, // Nothing else appropriate
"kafkaUint8Trans", "toPeriph", // File and function name
"Wrong variable type" // Unfortunately we don't know which DP
);
return PVSS_FALSE;
}
// this one is a bit special as the number is handled by wincc oa as int32, but we handle it as 8 bit unsigned integer
// thus any info above the 8 first bits is lost
*(reinterpret_cast<uint8_t *>(buffer + (subix * size))) = (uint8_t)(reinterpret_cast<const IntegerVar &>(var)).getValue();
return PVSS_TRUE;
}
VariablePtr kafkaUint8Trans::toVar(const PVSSchar *buffer, const PVSSuint dlen, const PVSSuint subix) const {
if(buffer == NULL || !dlen){
ErrHdl::error(ErrClass::PRIO_SEVERE, // Data will be lost
ErrClass::ERR_PARAM, // Wrong parametrization
ErrClass::UNEXPECTEDSTATE, // Nothing else appropriate
"kafkaUint8Trans", "toVar", // File and function name
"Null buffer pointer or wrong length: " + CharString(dlen) // Unfortunately we don't know which DP
);
}
else
{
try
{
uint8_t c = std::stoul((char*)buffer);
return new IntegerVar(c);
}
catch(std::exception& e)
{
Common::Logger::globalWarning(__PRETTY_FUNCTION__, e.what());
}
}
return NULL;
}
}//namespace