diff options
| -rw-r--r-- | daemon/mutatorserver.c | 31 |
1 files changed, 15 insertions, 16 deletions
diff --git a/daemon/mutatorserver.c b/daemon/mutatorserver.c index c3224d7..bc683f8 100644 --- a/daemon/mutatorserver.c +++ b/daemon/mutatorserver.c @@ -30,10 +30,12 @@ Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.* /**********************************************************************************************************************/ int main (int argc, char *argv[]) { - int socket_desc, client_sock, c, read_size; + int socket_desc, client_sock, socketlength, read_size; struct sockaddr_in server, client; char client_message[2000]; + FILE* clientistream; + char runresponse[4000]; /*create socket*/ socket_desc = socket(AF_INET, SOCK_STREAM, 0); @@ -42,7 +44,6 @@ int main (int argc, char *argv[]) { printf("could not create socket."); } - puts ("socket created."); server.sin_family = AF_INET; @@ -63,44 +64,42 @@ int main (int argc, char *argv[]) /*Accept incoming connection*/ puts("Waiting for incoming connections..."); - c = sizeof(struct sockaddr_in); + socketlength = sizeof(struct sockaddr_in); /*accept incoming connection from client*/ - client_sock = accept(socket_desc, (struct sockaddr*)&client, (socklen_t*)&c); + 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) { - FILE* clientistream; - char runresponse[2000]; -#if 0 - /*get the mutator driver command*/ - if (system(client_message) < 0) - { - puts("server returned an error."); - } -#endif + fflush(stdin); + /*open pipe, run command*/ if (!(clientistream = popen(client_message, "r"))) { - + perror("client command did not run successfully."); } puts ("task completed."); + for (int i = 0; i < 2000; ++i) + { + client_message[i] = 0; + } + while (fgets(runresponse, sizeof(runresponse), clientistream) != NULL) { write(client_sock, runresponse, strlen(runresponse)); } - puts("read from temp file."); + puts("response sent to client."); + fflush(stdout); /*close pipe*/ pclose(clientistream); } |