n, err := io.ReadFull(r, hashBuf)
		if err != nil {
			// Read's failed for object with right size, file is corrupt.
			return err
		}
		// Subtract hash length..
		left -= int64(n)
		if left < shardSize {
			shardSize = left
		}

		read, err := io.CopyBuffer(h, io.LimitReader(r, shardSize), *bufp)
		if err != nil {
			// Read's failed for object with right size, at different offsets.
			return errFileCorrupt

            log.debug("TCP RDMA connection established to {}", remoteAddress);

        } catch (IOException e) {
            state = RdmaConnectionState.ERROR;
            throw new IOException("TCP RDMA connection failed", e);
        }
    }

    @Override
    public void send(ByteBuffer data, RdmaMemoryRegion region) throws IOException {
        if (state != RdmaConnectionState.ESTABLISHED && state != RdmaConnectionState.CONNECTED) {

            mockContext = new BaseContext(config);
            response = new SmbComNegotiateResponse(mockContext);
        } catch (Exception e) {
            throw new RuntimeException("Failed to set up test", e);
        }
    }

    @Test
    public void testConstructor() {
        assertNotNull(response);
        assertEquals(DialectVersion.SMB1, response.getSelectedDialect());
    }

    public TestSystemProperties() {
        // Create a temporary file to satisfy DynamicProperties constructor
        super(createTempFile());
        loadTestProperties();
    }

    private static File createTempFile() {
        try {
            File tempFile = File.createTempFile("test-system", ".properties");
            tempFile.deleteOnExit();
            return tempFile;

        }
    ]
}
EOF
	err=$(aws --endpoint-url http://localhost:"$start_port" s3api complete-multipart-upload --upload-id "$uploadId" --bucket bucket --key obj-1 --multipart-upload file://./parts.json 2>&1)
	rv=$?
	if [ $rv -eq 0 ]; then
		echo "Failed to receive an error"
		exit 1
	fi
	echo "Received an error during complete-multipart as expected: $err"
}

function main() {
	start_port=$(shuf -i 10000-65000 -n 1)

		checkRespErr(rec, http.StatusOK)
	}
}

// unzip a file into a specific target dir - used to unzip sample data in cmd/testdata/
func unzipArchive(zipFilePath, targetDir string) error {
	zipReader, err := zip.OpenReader(zipFilePath)
	if err != nil {
		return err
	}
	for _, file := range zipReader.File {
		zippedFile, err := file.Open()
		if err != nil {
			return err
		}

     */
    public String execute() {
        final SearchLogHelper searchLogHelper = ComponentUtil.getSearchLogHelper();

        final StringBuilder resultBuf = new StringBuilder();

        try {
            searchLogHelper.storeSearchLog();
        } catch (final Exception e) {
            logger.error("Failed to store a search log.", e);

class CIFSExceptionTest extends BaseTest {

    @Test
    @DisplayName("Should create CIFSException with message")
    void testCIFSExceptionWithMessage() {
        // Given
        String message = "CIFS operation failed";

        // When
        CIFSException exception = new CIFSException(message);

        // Then
        assertNotNull(exception);
        assertEquals(message, exception.getMessage());

	if err != nil {
		t.Fatalf("Stat failed: %v", err)
	}

	// Debug paths are stored slash-separated, so convert to system-native.
	srcPath = filepath.FromSlash(srcPath)
	fi2, err := os.Stat(srcPath)
	if err != nil {
		t.Fatalf("Stat failed: %v", err)
	}
	if !os.SameFile(fi1, fi2) {
		t.Fatalf("addr2line_test.go and %s are not same file", srcPath)
	}
	if want := "102"; srcLineNo != want {

 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *