diff options
| -rw-r--r-- | daemon/daemon_aux.c | 156 |
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*/ + |