Synnefo » snf-ganeti

    # Wait for client to close

    try:

      try:

        conn.settimeout(cls._CLIENT_CONFIRM_TIMEOUT)

        conn.recv(1)

      except socket.error, err:

    reporter = _JobQueueTestReporter()

    try:

      SubmitOpCode(op, reporter=reporter, opts=opts)

      if not fail:

        raise

      # Ignore error