aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--daemon/daemon_aux.c156
1 files changed, 156 insertions, 0 deletions
diff --git a/daemon/daemon_aux.c b/daemon/daemon_aux.c
new file mode 100644
index 0000000..31bb2f2
--- /dev/null
+++ b/daemon/daemon_aux.c
@@ -0,0 +1,156 @@
+
+/***************************************************Project Mutator****************************************************/
+/*first line intentionally left blank.*/
+/*Copyright (C) 2017 Farzad Sadeghi
+This source file contains mutator's server called by the daemon.
+
+This program is free software; you can redistribute it and/or
+modify it under the terms of the GNU General Public License
+as published by the Free Software Foundation; either version 2
+of the License, or (at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.*/
+/**********************************************************************************************************************/
+/*macros*/
+#define __DBG
+#if 0
+#undef __DBG
+#endif
+/**********************************************************************************************************************/
+/*inclusion directive*/
+#include "daemon_aux.h"
+/*standard headers*/
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <arpa/inet.h>
+#include <unistd.h>
+/**********************************************************************************************************************/
+int mutator_server(void)
+{
+ int socket_desc, client_sock, socketlength, read_size;
+ struct sockaddr_in server, client;
+
+ char client_message[2000];
+ FILE* clientistream;
+ char runresponse[4000];
+ char NOOUT[]="command did not return any output. could be an error or not.";
+
+ /*create socket*/
+ socket_desc = socket(AF_INET, SOCK_STREAM, 0);
+
+ if (socket_desc < 0)
+ {
+ printf("could not create socket.");
+ }
+ puts ("socket created.");
+
+ server.sin_family = AF_INET;
+ server.sin_addr.s_addr = INADDR_ANY;
+ server.sin_port = htons(8888);
+
+ /*Bind*/
+ if (bind(socket_desc, (struct sockaddr*)&server, sizeof(server)) < 0)
+ {
+ perror("bind failed.error.");
+ return 1;
+ }
+
+ puts("bind done.");
+
+ /*Listen*/
+ listen(socket_desc, 3);
+
+ /*Accept incoming connection*/
+ puts("Waiting for incoming connections...");
+ socketlength = sizeof(struct sockaddr_in);
+
+ /*accept incoming connection from client*/
+ client_sock = accept(socket_desc, (struct sockaddr*)&client, (socklen_t*)&socketlength);
+
+ if (client_sock < 0)
+ {
+ perror("could not accept incoming client.");
+ return 1;
+ }
+ puts("connection accpeted.");
+
+ /*recieve a message from client*/
+ while((read_size = recv(client_sock, client_message, 2000, 0)) > 0)
+ {
+ fflush(stdin);
+
+ puts("got command from client.");
+
+ /*open pipe, run command*/
+ clientistream = popen(client_message, "r");
+
+ if (clientistream == NULL)
+ {
+ perror("client command did not run successfully.");
+ }
+ puts ("task completed.");
+
+ for (int i = 0; i < 2000; ++i)
+ {
+ client_message[i] = 0;
+ }
+
+ if (fgets(runresponse, sizeof(runresponse), clientistream) == NULL)
+ {
+ /*say there was nothing on stdout to send.*/
+ write(client_sock, NOOUT, strlen(NOOUT));
+ }
+
+ rewind(clientistream);
+
+ while (fgets(runresponse, sizeof(runresponse), clientistream) != NULL)
+ {
+#if defined(__DBG)
+ puts("command stdout:");
+ puts(runresponse);
+#endif
+ write(client_sock, runresponse, strlen(runresponse));
+ }
+
+ puts("response sent to client.");
+
+ fflush(stdout);
+ /*close pipe*/
+ pclose(clientistream);
+
+#if defined(__DBG)
+ puts("checkpoint 1");
+#endif
+ }
+
+#if defined(__DBG)
+ puts("checkpoint 10");
+#endif
+
+ if (read_size == 0)
+ {
+ puts("client disconnected");
+ fflush(stdout);
+ }
+ else if (read_size == -1)
+ {
+ perror("recv failed.");
+ }
+ else
+ {
+ /*intentionally left blank*/
+ }
+
+ return 0;
+}
+/**********************************************************************************************************************/
+/*last line intentionally left blank*/
+