  #include <sys/socket.h>
  #include <pthread.h>
  #include <iostream>
-@@ -126,7 +127,7 @@ namespace HadoopPipes {
+@@ -126,7 +127,7 @@
      static const char lineSeparator = '\n';
  
      void writeBuffer(const string& buffer) {

 #include <rpc/types.h>
 #include <rpc/xdr.h>
 #include <string>
@@ -252,13 +253,15 @@ namespace HadoopUtils {
     stream.write(buf, sizeof(float));
   }
 

 import org.apache.hadoop.mapreduce.security.SecureShuffleUtils;
 import org.apache.hadoop.mapreduce.security.TokenCache;
 import org.apache.hadoop.mapreduce.security.token.JobTokenIdentifier;
@@ -95,14 +96,21 @@
     env.put("hadoop.pipes.command.port", 
             Integer.toString(serverSocket.getLocalPort()));
     
