// Result should contain session ID info
        assertTrue(result.contains("Python Process terminated."));
    }

    // Test execute with timeout
    public void test_execute_withTimeout() {
        pythonJob.filename("timeout.py");
        pythonJob.timeout = 60; // Set timeout
        pythonJob.processTimeout = true;

        testProcessHelper.exitValue = -1;
        testProcessHelper.processOutput = "Process terminated";

          MINIO_KMS_AUTO_ENCRYPTION: on
        run: |
          sudo sysctl net.ipv6.conf.all.disable_ipv6=0
          sudo sysctl net.ipv6.conf.default.disable_ipv6=0
          make verify

            requiresNotEc2Agent()
        }

        applyTestDefaults(
            model,
            this,
            ":smoke-test:$task",
            timeout = 120,
            extraParameters =
                listOf(
                    stage.getBuildScanCustomValueParam(),
                    buildScanTagParam("SmokeTests"),

        assertTrue(result.contains("Session Id: " + thumbnailJob.sessionId));
    }

    // Test execute with timeout
    public void test_execute_withTimeout() {
        thumbnailJob.numOfThreads(2);
        thumbnailJob.timeout = 120; // Set timeout
        thumbnailJob.processTimeout = true;

        testProcessHelper.exitValue = -1;
        testProcessHelper.processOutput = "Process terminated";

        }
    }

    @Override
    public ByteBuffer receive(int timeout) throws IOException {
        if (state != RdmaConnectionState.ESTABLISHED && state != RdmaConnectionState.CONNECTED) {
            throw new IOException("Connection not established");
        }

        try {
            socket.setSoTimeout(timeout);

            // First, read the header to determine message size

      call: RealCall,
      e: IOException?,
    )

    fun noNewExchanges()

    fun cancel()
  }

  companion object {
    /**
     * The timeout to use while discarding a stream of input data. Since this is used for connection
     * reuse, this timeout should be significantly less than the time it takes to establish a new
     * connection.
     */
    const val DISCARD_STREAM_TIMEOUT_MILLIS = 100
  }

            val performanceTestTaskNames = getPerformanceTestTaskNames(performanceSubProject, testProjects, performanceTestTaskSuffix)
            applyPerformanceTestSettings(os = os, arch = arch, timeout = type.timeout)
            artifactRules = INDIVIDUAL_PERFORAMCE_TEST_ARTIFACT_RULES

            params {
                text(
                    "performance.baselines",
                    type.defaultBaselines,

    MINIO_ROOT_PASSWORD: "minio123"
    MINIO_KMS_SECRET_KEY: "my-minio-key:OSMM+vkKUTCvQs9YL/CVMIMt43HFhkUpqJxTmGl6rYw="
  healthcheck:
    test: ["CMD", "mc", "ready", "local"]
    interval: 5s
    timeout: 5s
    retries: 5

# starts 4 docker containers running minio server instances.
# using nginx reverse proxy, load balancing, you can access
# it through port 9000.
services:
  minio1:
    <<: *minio-common

        // Assert
        assertNotNull(transWaitNamedPipe);
        assertEquals(testPipeName, transWaitNamedPipe.name);
        assertEquals(0xFFFFFFFF, transWaitNamedPipe.timeout);
        assertEquals(0, transWaitNamedPipe.maxParameterCount);
        assertEquals(0, transWaitNamedPipe.maxDataCount);
        assertEquals((byte) 0x00, transWaitNamedPipe.maxSetupCount);

        }
    }

    /**
     * Handle a lease break with timeout
     *
     * @param key lease key
     * @param newState new lease state
     * @param timeoutSeconds timeout in seconds (0 or negative uses default)
     */
    public void handleLeaseBreakWithTimeout(Smb2LeaseKey key, int newState, int timeoutSeconds) {
        // Use default timeout if not specified or invalid
        if (timeoutSeconds <= 0) {