Hallo zusammen,also es funktioniert nun sowohl mit dem ISKRAemeco MT174 als auch dem Siemens TD3511. Anbei findet ihr den Patch. Ich hab versucht sowenig Änderungen zu machen wie es geht. Hier nochmal die Zusammenfassungen:
1) Das Device wird im blocking mode geöffnet. Das führte bei mir dazu, dass die read() Funktion mit 0 zurückkehrt. Das heißt normalerweise ein eof oder derartiges. Sowas sollte bei einem seriellen Device niemals passieren. Ich weiß auch nicht warum das der Fall ist.
-> Ich hab den Code dahingehend geändert, dass das Device im non-blocking mode geöffnet wird. Damit funktioniert's nun.
2) Die Statemachine sollte niemals unendlich warten und irgendwo hängen bleiben.
-> Ich hab ein Timeout von 10s eingebaut. Also wenn innerhalb 10s keine Daten empfangen werden bzw. beim Start kein Sync-byte kommt, wird dieser Lesevorgang abgebrochen.
3) Die Statemaching wird immer beim Empfang eines '/' zurückgesetzt. Da mein Zähler ein '/' im Identification String sendet, hängt sich die Statemachine auf.
-> Das habe ich rausgenommen.4) Mein Zähler sendet ca. 330 obis-codes. Da ist dann sowas dabei wie 2.8.1*16, 2.8.1*15 usw. Ich interessiere mich eigentlich nur für die Einträge von 2.8.0. Das ist insofern ein Problem, dass der D0-Meter nur maximal 32 Einträge zulässt. Das heißt bis die interessanten codes ankommen, sind die 32 Einträge schon längst belegt.
-> Ich filtere jetzt nur noch obis-codes heraus die ein value und eine Einheit besitzen. Damit kommen bei meinem Zähler genau 32 zusammen.
5) Der Zähler sendet ungültige Obis-Codes. Zumindest ist der string für die Klasse Obis.cpp nicht auswertbar. Das führt dazu, dass vzlogger abstürzt. Vermutlich sind es die obis-codes die unter anderem Buchstaben statt Zahlen haben.
-> Ich hab die Stellen mit einem try-except Block abgefangen und überspringe die betroffenen obis-codes.
6) Fehler beim Setzen der Parity -> Das hab ich korrigiert.Weiterhin habe ich mal die Ausgaben der beiden Zähler angehangen, mit denen das getestet wurde.
Gruß Sebastian
ISKRAemeco_MT174.txt
Description: Binary data
Siemens_TD-3511.txt
Description: Binary data
diff --git a/src/Obis.cpp b/src/Obis.cpp
index f918797..eebf5f8 100644
--- a/src/Obis.cpp
+++ b/src/Obis.cpp
@@ -192,7 +192,7 @@ int Obis::parse(const char *str) {
}
int Obis::lookup_alias(const char *alias) {
- for (const obis_alias_t *it = aliases; it != NULL; it++) {
+ for (const obis_alias_t *it = aliases; !it->id.isNull(); it++) {
if (strcmp(it->name, alias) == 0) {
*this = it->id;
return SUCCESS;
diff --git a/src/protocols/MeterD0.cpp b/src/protocols/MeterD0.cpp
index f48f864..cc74146 100644
--- a/src/protocols/MeterD0.cpp
+++ b/src/protocols/MeterD0.cpp
@@ -204,6 +204,13 @@ ssize_t MeterD0::read(std::vector<Reading>&rds, size_t max_readings) {
char byte; /* we parse our input byte wise */
int byte_iterator;
size_t number_of_tuples;
+ int bytes_read;
+
+ time_t start_time;
+ time_t end_time;
+
+ // get current time
+ time(&start_time);
if(_pull.size()) {
int wlen=write(_fd,_pull.c_str(),_pull.size());
@@ -215,12 +222,41 @@ ssize_t MeterD0::read(std::vector<Reading>&rds, size_t max_readings) {
context = START; /* start with context START */
- while (::read(_fd, &byte, 1)) {
- if (byte == '/') context = START; /* reset to START if "/" reoccurs */
- else if (byte == '!') context = END; /* "!" is the identifier for the END */
+ while (1) {
+
+ // check if timed out
+ time(&end_time);
+ if (difftime(end_time, start_time) > 10)
+ {
+ print(log_error, "nothing received for more than 10 seconds", name().c_str());
+ break;
+ }
+
+ // now read a single byte
+ bytes_read = ::read(_fd, &byte, 1);
+ if (bytes_read == 0 || bytes_read == -1 && errno == EAGAIN)
+ {
+ // wait and read again
+ usleep(5000); // 5 ms
+ continue;
+ }
+ else if (bytes_read == -1)
+ {
+ // an error occured reading a byte
+ print(log_error, "error reading a byte (%d)", name().c_str(), errno);
+ break;
+ }
+
+ // reset timeout
+ if (context != START)
+ {
+ time(&start_time);
+ }
+
+ if (byte == '!') context = END; /* "!" is the identifier for the END */
switch (context) {
case START: /* strip the initial "/" */
- if (byte != '\r' && byte != '\n') { /*allow extra new line at the start */
+ if (byte == '/') {
byte_iterator = number_of_tuples = 0; /* start */
context = VENDOR; /* set new context: START -> VENDOR */
}
@@ -239,6 +275,7 @@ ssize_t MeterD0::read(std::vector<Reading>&rds, size_t max_readings) {
case BAUDRATE: /* BAUDRATE consists of 1 char only */
baudrate = byte;
+ print(log_debug, "Meter supports baudrate of %d", name().c_str(), 300 * (1 << (baudrate-0x30)));
context = IDENTIFICATION; /* set new context: BAUDRATE -> IDENTIFICATION */
byte_iterator = 0;
break;
@@ -305,19 +342,24 @@ ssize_t MeterD0::read(std::vector<Reading>&rds, size_t max_readings) {
if (byte == '\r' || byte == '\n') {
/* free slots available and sain content? */
if ((number_of_tuples < max_readings) && (strlen(obis_code) > 0) &&
- (strlen(value) > 0)) {
+ (strlen(value) > 0) && (strlen(unit) > 0)) {
print(log_debug, "Parsed reading (OBIS code=%s, value=%s, unit=%s)", name().c_str(), obis_code, value, unit);
- rds[number_of_tuples].value(strtof(value, NULL));
- Obis obis(obis_code);
- ReadingIdentifier *rid(new ObisIdentifier(obis));
- rds[number_of_tuples].identifier(rid);
- rds[number_of_tuples].time();
-
- byte_iterator = 0;
- number_of_tuples++;
-
- context = OBIS_CODE;
+ try
+ {
+ Obis obis(obis_code);
+ rds[number_of_tuples].value(strtof(value, NULL));
+ ReadingIdentifier *rid(new ObisIdentifier(obis));
+ rds[number_of_tuples].identifier(rid);
+ rds[number_of_tuples].time();
+ number_of_tuples++;
+ } catch(std::exception &e)
+ {
+ print(log_debug, "--> skipped because of parse errors", name().c_str());
+ }
}
+
+ byte_iterator = 0;
+ context = OBIS_CODE;
}
break;
@@ -366,7 +408,7 @@ int MeterD0::_openDevice(struct termios *old_tio, speed_t baudrate) {
struct termios tio;
memset(&tio, 0, sizeof(struct termios));
- int fd = ::open(device(), O_RDWR);
+ int fd = ::open(device(), O_RDWR | O_NOCTTY | O_NONBLOCK);
if (fd < 0) {
print(log_error, "open(%s): %s", name().c_str(), device(), strerror(errno));
return ERR;
@@ -385,26 +427,28 @@ int MeterD0::_openDevice(struct termios *old_tio, speed_t baudrate) {
switch(_parity) {
case parity_8n1:
tio.c_cflag &= ~ PARENB;
+ tio.c_cflag &= ~ PARODD;
tio.c_cflag &= ~ CSTOPB;
tio.c_cflag &= ~ CSIZE;
tio.c_cflag |= CS8;
break;
case parity_7n1:
tio.c_cflag &= ~ PARENB;
+ tio.c_cflag &= ~ PARODD;
tio.c_cflag &= ~ CSTOPB;
tio.c_cflag &= ~ CSIZE;
tio.c_cflag |= CS7;
break;
case parity_7e1:
- tio.c_cflag |= ~ PARENB;
+ tio.c_cflag |= PARENB;
tio.c_cflag &= ~ PARODD;
tio.c_cflag &= ~ CSTOPB;
tio.c_cflag &= ~ CSIZE;
tio.c_cflag |= CS7;
break;
case parity_7o1:
- tio.c_cflag |= ~ PARENB;
- tio.c_cflag |= ~ PARODD;
+ tio.c_cflag &= ~ PARENB;
+ tio.c_cflag |= PARODD;
tio.c_cflag &= ~ CSTOPB;
tio.c_cflag &= ~ CSIZE;
tio.c_cflag |= CS7;
