comparison: bmsd/fermenters.c
bmsd/fermenters.c
- changeset 686
- ca1fbb3bd3db
- parent 684
- ccb9f24d0fe9
- child 698
- c7b4cb53b37c
equal
deleted
inserted
replaced
| 685:a4fcdf24b5e7 | 686:ca1fbb3bd3db |
|---|---|
| 720 } | 720 } |
| 721 fermenter_mysql_insert(fermenter); | 721 fermenter_mysql_insert(fermenter); |
| 722 } else { | 722 } else { |
| 723 fermenter_mysql_update(fermenter); | 723 fermenter_mysql_update(fermenter); |
| 724 } | 724 } |
| 725 status_change(); | |
| 726 } | 725 } |
| 727 | 726 |
| 728 | 727 |
| 729 | 728 |
| 730 /* | 729 /* |
| 1058 | 1057 |
| 1059 void fermenter_death(char *topic) | 1058 void fermenter_death(char *topic) |
| 1060 { | 1059 { |
| 1061 char *edge_node, *alias, *msg = NULL; | 1060 char *edge_node, *alias, *msg = NULL; |
| 1062 sys_fermenter_list *tmpp; | 1061 sys_fermenter_list *tmpp; |
| 1063 bool report = false; | |
| 1064 | 1062 |
| 1065 printf("fermenter_death: %s\n", topic); | 1063 printf("fermenter_death: %s\n", topic); |
| 1066 strtok(topic, "/"); // ignore namespace | 1064 strtok(topic, "/"); // ignore namespace |
| 1067 strtok(NULL, "/"); // ignore group_id | 1065 strtok(NULL, "/"); // ignore group_id |
| 1068 strtok(NULL, "/"); // ignore message_type | 1066 strtok(NULL, "/"); // ignore message_type |
| 1083 msg = xstrcat(msg, alias); | 1081 msg = xstrcat(msg, alias); |
| 1084 msg = xstrcat(msg, (char *)"\",\"online\":0}"); | 1082 msg = xstrcat(msg, (char *)"\",\"online\":0}"); |
| 1085 ws_broadcast(msg); | 1083 ws_broadcast(msg); |
| 1086 free(msg); | 1084 free(msg); |
| 1087 msg = NULL; | 1085 msg = NULL; |
| 1088 report = true; | |
| 1089 } | 1086 } |
| 1090 break; | 1087 break; |
| 1091 } | 1088 } |
| 1092 } | 1089 } |
| 1093 } else { | 1090 } else { |
| 1102 msg = xstrcat(msg, tmpp->alias); | 1099 msg = xstrcat(msg, tmpp->alias); |
| 1103 msg = xstrcat(msg, (char *)"\",\"online\":0}"); | 1100 msg = xstrcat(msg, (char *)"\",\"online\":0}"); |
| 1104 ws_broadcast(msg); | 1101 ws_broadcast(msg); |
| 1105 free(msg); | 1102 free(msg); |
| 1106 msg = NULL; | 1103 msg = NULL; |
| 1107 report = true; | |
| 1108 } | 1104 } |
| 1109 } | 1105 } |
| 1110 } | 1106 } |
| 1111 } | 1107 } |
| 1112 if (report) | |
| 1113 status_change(); | |
| 1114 } | 1108 } |
| 1115 | 1109 |
| 1116 | 1110 |
