Portable: fixed -p option for forall

portable.py

@@ -64,6 +64,12 @@ class file_reader(object):
   def read(self, bufsize):
     return self.fd.read(bufsize)
 
+  def close(self):
+    return self.fd.close()
+
+  def src(self):
+    return self.fd
+
 class socket_reader():
   """select socket with file descriptor class"""
   def __init__(self, src, dest, std_name=''):
@@ -98,12 +104,20 @@ class socket_reader():
       return self.server_socket.recv(bufsize)
     except Exception as e:
       Trace("failed to read from server socket: " + e.strerror)
+      self.close()
+
+  def close(self):
+    if self.client_socket:
       self.client_socket.close()
+    if self.server_socket:
       self.server_socket.close()
 
   def fileno(self):
     return self.server_socket.fileno()
 
+  def src(self):
+    return self.src
+
 
 def os_symlink(src, dst):
   if isUnix():

subcmds/forall.py

@@ -364,12 +364,14 @@ def DoWork(project, mirror, opt, cmd, shell, cnt, config):
         # buf = s.fd.read(4096)
         buf = s.read(4096)
         if not buf:
-          s.fd.close()
+          # s.fd.close()
+          s.close()
           s_in.remove(s)
           continue
 
         if not opt.verbose:
-          if s.fd != p.stdout:
+          # if s.fd != p.stdout:
+          if s.src != p.stdout:
             errbuf += buf
             continue