}

    public void test_constructor_withMessageAndCause() {
        // Test with both message and cause
        String message = "Data store connection failed";
        Exception cause = new RuntimeException("Connection timeout");
        DataStoreException exception = new DataStoreException(message, cause);

        assertNotNull(exception);
        assertEquals(message, exception.getMessage());
        assertEquals(cause, exception.getCause());

        for (Thread thread : threads) {
            thread.start();
        }

        // Wait for all threads to complete
        for (Thread thread : threads) {
            thread.join(5000); // 5 second timeout
        }

        // Verify no errors occurred during concurrent execution
        assertFalse(hasError.get());
    }

            }
            if (exitValue != 0) {
                final StringBuilder out = new StringBuilder();
                if (processTimeout) {
                    out.append("Process is terminated due to ").append(timeout).append(" second exceeded.\n");
                }
                out.append("Exit Code: ").append(exitValue).append("\nOutput:\n").append(it.getOutput());
                throw new JobProcessingException(out.toString());

	// Make sure only 1 callhome is running on the cluster.
	locker := objAPI.NewNSLock(minioMetaBucket, "callhome/runCallhome.lock")
	lkctx, err := locker.GetLock(ctx, callhomeLeaderLockTimeout)
	if err != nil {
		// lock timedout means some other node is the leader,
		// cycle back return 'true'
		return true
	}

	ctx = lkctx.Context()
	defer locker.Unlock(lkctx)

	// Perform callhome once and then keep running it at regular intervals.

import org.junit.jupiter.api.BeforeEach
import org.junit.jupiter.api.Tag
import org.junit.jupiter.api.Test
import org.junit.jupiter.api.Timeout
import org.junit.jupiter.api.extension.RegisterExtension

@Flaky // STDOUT logging enabled for test
@Timeout(30)
@Tag("Slow")
class EventListenerTest {
  @RegisterExtension
  val platform = PlatformRule()

  @RegisterExtension

        assertEquals(SmbComTransaction.TRANS_CALL_NAMED_PIPE, transCallNamedPipe.getSubCommand());
        assertEquals(0xFFFFFFFF, transCallNamedPipe.timeout);
        assertEquals(0, transCallNamedPipe.maxParameterCount);
        assertEquals(0xFFFF, transCallNamedPipe.maxDataCount);
        assertEquals((byte) 0x00, transCallNamedPipe.maxSetupCount);

        // Test throwing with cause and catching
        int expectedStatusCode = 500;
        String expectedMessage = "Database error";
        Exception expectedCause = new RuntimeException("Connection timeout");

        try {
            throw new WebApiException(expectedStatusCode, expectedMessage, expectedCause);
        } catch (WebApiException e) {
            assertEquals(expectedStatusCode, e.getStatusCode());

        addCreateContext(new jcifs.internal.smb2.persistent.DurableHandleRequest());
    }

    /**
     * Add a durable handle V2 context to this request
     * @param timeoutMs the timeout in milliseconds (0 for persistent handles)
     * @param persistent true if this should be a persistent handle
     * @return the create GUID for this handle
     */

        .headersDelay(500, TimeUnit.MILLISECONDS)
        .setHeader("content-type", "text/event-stream")
        .body("data: hey\n\n")
        .build(),
    )
    newEventSource()
    listener.assertFailure("timeout")
  }

  @Test
  fun retainsAccept() {
    server.enqueue(
      MockResponse
        .Builder()
        .body(
          """
          |data: hey
          |
          |

				} else {
					if xnet.IsNetworkOrHostDown(err, false) {
						network[nodeName] = string(madmin.ItemOffline)
					} else if xnet.IsNetworkOrHostDown(err, true) {
						network[nodeName] = "connection attempt timedout"
					}
				}
			}
		}
	}

	var memstats runtime.MemStats
	runtime.ReadMemStats(&memstats)

	gcStats := debug.GCStats{
		// If stats.PauseQuantiles is non-empty, ReadGCStats fills