comparison: bmsd/fermenters.c
bmsd/fermenters.c
- changeset 674
- c865e3cdee04
- parent 671
- 4b54d6f79d25
- child 677
- 6e82fece1f8f
equal
deleted
inserted
replaced
| 673:9924b1218d39 | 674:c865e3cdee04 |
|---|---|
| 756 fermenter_mysql_death(edge_node, alias); | 756 fermenter_mysql_death(edge_node, alias); |
| 757 | 757 |
| 758 if (alias) { | 758 if (alias) { |
| 759 for (tmpp = fermenters; tmpp; tmpp = tmpp->next) { | 759 for (tmpp = fermenters; tmpp; tmpp = tmpp->next) { |
| 760 if ((strcmp(tmpp->node, edge_node) == 0) && (strcmp(tmpp->alias, alias) == 0)) { | 760 if ((strcmp(tmpp->node, edge_node) == 0) && (strcmp(tmpp->alias, alias) == 0)) { |
| 761 if (tmpp->online) | 761 if (tmpp->online) { |
| 762 syslog(LOG_NOTICE, "Offline fermenter %s/%s", tmpp->node, tmpp->alias); | 762 syslog(LOG_NOTICE, "Offline fermenter %s/%s", tmpp->node, tmpp->alias); |
| 763 tmpp->online = false; | 763 tmpp->online = false; |
| 764 msg = xstrcpy((char *)"{\"device\":\"fermenter\",\"node\":\""); | 764 msg = xstrcpy((char *)"{\"device\":\"fermenter\",\"node\":\""); |
| 765 msg = xstrcat(msg, edge_node); | 765 msg = xstrcat(msg, edge_node); |
| 766 msg = xstrcat(msg, (char *)"\",\"unit\":\""); | 766 msg = xstrcat(msg, (char *)"\",\"unit\":\""); |
| 767 msg = xstrcat(msg, alias); | 767 msg = xstrcat(msg, alias); |
| 768 msg = xstrcat(msg, (char *)"\",\"online\":0}"); | 768 msg = xstrcat(msg, (char *)"\",\"online\":0}"); |
| 769 ws_broadcast(msg); | 769 ws_broadcast(msg); |
| 770 free(msg); | 770 free(msg); |
| 771 msg = NULL; | 771 msg = NULL; |
| 772 } | |
| 772 break; | 773 break; |
| 773 } | 774 } |
| 774 } | 775 } |
| 775 } else { | 776 } else { |
| 776 for (tmpp = fermenters; tmpp; tmpp = tmpp->next) { | 777 for (tmpp = fermenters; tmpp; tmpp = tmpp->next) { |
| 777 if (strcmp(tmpp->node, edge_node) == 0) { | 778 if (strcmp(tmpp->node, edge_node) == 0) { |
| 778 if (tmpp->online) | 779 if (tmpp->online) { |
| 779 syslog(LOG_NOTICE, "Offline fermenter %s/%s", tmpp->node, tmpp->alias); | 780 syslog(LOG_NOTICE, "Offline fermenter %s/%s", tmpp->node, tmpp->alias); |
| 780 tmpp->online = false; | 781 tmpp->online = false; |
| 781 msg = xstrcpy((char *)"{\"device\":\"fermenter\",\"node\":\""); | 782 msg = xstrcpy((char *)"{\"device\":\"fermenter\",\"node\":\""); |
| 782 msg = xstrcat(msg, edge_node); | 783 msg = xstrcat(msg, edge_node); |
| 783 msg = xstrcat(msg, (char *)"\",\"unit\":\""); | 784 msg = xstrcat(msg, (char *)"\",\"unit\":\""); |
| 784 msg = xstrcat(msg, tmpp->alias); | 785 msg = xstrcat(msg, tmpp->alias); |
| 785 msg = xstrcat(msg, (char *)"\",\"online\":0}"); | 786 msg = xstrcat(msg, (char *)"\",\"online\":0}"); |
| 786 ws_broadcast(msg); | 787 ws_broadcast(msg); |
| 787 free(msg); | 788 free(msg); |
| 788 msg = NULL; | 789 msg = NULL; |
| 790 } | |
| 789 } | 791 } |
| 790 } | 792 } |
| 791 } | 793 } |
| 792 } | 794 } |
| 793 | 795 |
