8c35227c6e3c4a6b85d2f719c9a62031f5e4ca6f,src/python/pants/java/nailgun_io.py,NailgunStreamWriter,run,#NailgunStreamWriter#,136

Before Change

          if data:
            NailgunProtocol.write_chunk(self._socket, self._chunk_type, data)
          else:
            try:
              if self._chunk_eof_type is not None:
                NailgunProtocol.write_chunk(self._socket, self._chunk_eof_type)
                self._socket.shutdown(socket.SHUT_WR)  // Shutdown socket sends.
            except socket.error:  // Can happen if response is quick.
              pass
            finally:
              self.stop()

After Change

      if errored:
        for fh in errored:
          self._in_files.remove(fh)

Instances