assertNull(exception.getCause());
    }

    public void test_constructorWithMessageAndNullCause() {
        // Test constructor with message and null cause
        String message = "Query processing error";

        SearchQueryException exception = new SearchQueryException(message, null);

        assertEquals(message, exception.getMessage());
        assertNull(exception.getCause());
    }

	}
	if !result.Healthy {
		// As a maintenance call we are purposefully asked to be taken
		// down, this is for orchestrators to know if we can safely
		// take this server down, return appropriate error.
		if opts.Maintenance {
			writeResponse(w, http.StatusPreconditionFailed, nil, mimeNone)
		} else {
			writeResponse(w, http.StatusServiceUnavailable, nil, mimeNone)
		}
		return
	}

                SmbFile file = createSmbFileFromCache(directoryPath, fileInfo);
                files.add(file);
            } catch (Exception e) {
                log.warn("Error creating SmbFile from cache for {}: {}", fileInfo.getName(), e.getMessage());
                // For testing purposes, continue processing other files
                // In a real scenario, you might want to handle this differently

    }

    // Test handling of processing exception
    public void test_execute_withProcessingException() {
        // Create a mock that returns 0 to simulate processing error
        SearchEngineClient errorClient = new SearchEngineClient() {
            @Override
            public long updateByQuery(String index,

            final String content = response.getContentAsString();
            logger.info(content);
            assertTrue(content.length() > 0);
        }, e -> {
            logger.log(Level.SEVERE, "error", e);
            fail();
        });
    }

    @Test
    public void test_GetFactoryMethod() {
        // ## Arrange ##
        final String url = "http://example.com";

        // ## Act ##

        running.set(false);

        if (serverSocket != null && !serverSocket.isClosed()) {
            try {
                serverSocket.close();
            } catch (IOException e) {
                log.debug("Error closing server socket", e);
            }
        }

        if (serverThread != null) {
            try {
                serverThread.join(5000); // Wait up to 5 seconds
            } catch (InterruptedException e) {

Decommission of pool http://minio{1...2}/data{1...4} is complete, you may now remove it from server command line
```

### A pool not under decommissioning will throw an error

```
λ mc admin decommission status alias/ http://minio{1...2}/data{1...4}
ERROR: This pool is not scheduled for decommissioning currently.
```

## Canceling a decommission

- QueueingHint got error in its returning value. If QueueingHint returns error, the scheduler logs the error and treats the event as QueueAfterBackoff so that the Pod wouldn't be stuck in the unschedulable pod pool. ([#119290](https://github.com/kubernetes/kubernetes/pull/119290), [@carlory](https://github.com/carlory))...

// Code generated by "stringer -type=format -trimprefix=format untar.go"; DO NOT EDIT.

package cmd

import "strconv"

func _() {
	// An "invalid array index" compiler error signifies that the constant values have changed.
	// Re-run the stringer command to generate them again.
	var x [1]struct{}
	_ = x[formatUnknown-0]
	_ = x[formatGzip-1]
	_ = x[formatZstd-2]
	_ = x[formatLZ4-3]
	_ = x[formatS2-4]
	_ = x[formatBZ2-5]
}

     * Handles file download requests for SMB files.
     * @param req the HTTP servlet request
     * @param resp the HTTP servlet response
     * @param file the SMB file to download
     * @throws IOException if an I/O error occurs
     */
    protected void doFile(final HttpServletRequest req, final HttpServletResponse resp, final SmbFile file) throws IOException {
        final byte[] buf = new byte[8192];