diff --git a/Wc b/Wc index bda1e13403eea5bfe910110cbbbde42feeb7c194..eefd2132ef5c2f6c15ef8e0203d069a5b54d6c83 100755 Binary files a/Wc and b/Wc differ diff --git a/src/Node.cpp b/src/Node.cpp index b514b32cff9fbc489b9821b9bd8b617ae61ae102..cd24e166a54560f08bac59866ec99994bd3c7b29 100644 --- a/src/Node.cpp +++ b/src/Node.cpp @@ -892,14 +892,14 @@ void Node::handleTcpMessage() pid_t pid = fork(); if (pid){ //parent process, DONT need to waitpid because of signal handler set up close(dataPipe[1]); - handlePipe(dataPipe[0], inMsg[5]); + handlePipe(dataPipe[0], sdfsPre); } else if (pid < 0) { fprintf (stderr, "Fork failed.\n"); break; } else { //child process close(dataPipe[0]); - cout << "[CHUNKACK] processing " << inMsg[3] << endl; + string execName = "./" + inMsg[1]; + cout << "[CHUNKACK] processing " << inMsg[3] << " with " << execName << endl; dup2(dataPipe[1], 1); //stdout -> write end of pipe - string execName = "./" + inMsg[4]; int status = execl(execName.c_str(),execName.c_str(),inMsg[3].c_str(),NULL); if (status < 0) exit(status); } diff --git a/src/Utils.cpp b/src/Utils.cpp index ee9c39c335b7bfd60ae9afc4399bf4ec435dbeec..dbcdc7f5db1d505ffe17c59bafccbfcd0156c310 100644 --- a/src/Utils.cpp +++ b/src/Utils.cpp @@ -52,7 +52,7 @@ bool isInVector(vector<int> v, int i){ void handlePipe(int file, string prefix) { size_t bufSize = 1024; - cout << "[PIPE] sleeping for data " << endl; + cout << "[PIPE] sleeping for data. " << " Prefix: " << prefix << endl; sleep(5); FILE *stream = fdopen(file, "r"); FILE *tmp; char str[bufSize];