Add GET /reconnect/CHANNEL to work

web_pages.c

@@ -109,9 +109,29 @@ void cmd_getconfig(int clientsock) {
 	pthread_mutex_unlock(&cfg->channels_lock);
 }
 
-void cmd_reconnect(int clientsock) {
+void cmd_reconnect(int clientsock, char *channel) {
 	send_200_ok(clientsock);
 	send_header_textplain(clientsock);
+	if (channel) {
+		int found = 0;
+		struct config *cfg = get_config();
+		list_lock(cfg->restreamer);
+		LNODE *l, *tmp;
+		list_for_each(cfg->restreamer, l, tmp) {
+			RESTREAMER *r = l->data;
+			if (strcmp(r->name, channel) == 0) {
+				found = 1;
+				r->reconnect = 1;
+				fdputsf(clientsock, "\nReconnecting %s input.\n", r->name);
+				break;
+			}
+		}
+		list_unlock(cfg->restreamer);
+		if (!found) {
+			fdputsf(clientsock, "\nERROR: Can not find %s channel.\n", channel);
+		}
+		return;
+	}
 	struct config *cfg = get_config();
 	pthread_mutex_lock(&cfg->channels_lock);
 	fdputsf(clientsock, "\nReconnecting %d inputs.\n", cfg->chanconf->items);

web_pages.h

@@ -21,7 +21,7 @@
 void cmd_index(int clientsock);
 void cmd_status(int clientsock);
 void cmd_getconfig(int clientsock);
-void cmd_reconnect(int clientsock);
+void cmd_reconnect(int clientsock, char *channel);
 void cmd_reload(int clientsock);
 
 #endif

web_server.c

@@ -130,8 +130,10 @@ void *process_web_request(void *in_req) {
 		cmd_index(clientsock);
 	} else if (strstr(path,"getconfig")==path) {
 		cmd_getconfig(clientsock);
+	} else if (strstr(path,"reconnect/")==path) {
+		cmd_reconnect(clientsock, path + 10); // 10 = reconnect/
 	} else if (strstr(path,"reconnect")==path) {
-		cmd_reconnect(clientsock);
+		cmd_reconnect(clientsock, NULL);
 	} else if (strstr(path,"reload")==path) {
 		cmd_reload(clientsock);
 	} else if (strstr(path,"status")==path) {