// Assert
        assertEquals(0, resultWithNull, "Should return 0 for null buffer");
        assertEquals(0, resultWithData, "Should return 0 regardless of input data");
    }

    @Nested
    class CreateResponseTests {

        @Test
        @DisplayName("createResponse returns Smb2LogoffResponse and requests CIFSContext config")

		statusCode: 400,
		cause:      err,
	}
}

func errInvalidDataSource(err error) *s3Error {
	return &s3Error{
		code:       "InvalidDataSource",
		message:    "Invalid data source type. Only CSV, JSON, and Parquet are supported.",
		statusCode: 400,
		cause:      err,
	}
}

func errInvalidRequestParameter(err error) *s3Error {
	return &s3Error{
		code:       "InvalidRequestParameter",

        if (modelCache != null) {
            Object data = modelCache.get(groupId, artifactId, version, tag.getName());
            if (data != null) {
                return tag.fromCache(tag.getType().cast(data));
            }
        }
        return null;
    }

    private void fireEvent(
            Model model,
            ModelBuildingRequest request,
            ModelProblemCollector problems,

        // Verify total length includes scope
        assertEquals(33 + name.scope.length() + 2, length);
    }

    @Test
    void readWireFormat_shouldDecodeNameCorrectly() {
        // Prepare encoded data for "TEST" with type 0x20
        byte[] src = new byte[100];
        src[0] = 0x20; // First byte

        // Encode "TEST" (0x54 0x45 0x53 0x54)
        // T=0x54: upper nibble 0x5->F(0x46), lower nibble 0x4->E(0x45)

* the data from the client to be sent through the network
* the data sent by your program to be received by the client through the network
* the contents of a file in the disk to be read by the system and given to your program

   * An instance created in {@link #readObject} to be returned from {@link #readResolve}. This field
   * is used only by those methods, and it is never set in a "normal" instance.
   *
   * <p>This class needs to write deserialized data into fields that are {@code final transient}.
   * Such writes will become impossible to perform in {@link #readObject} after JEP 500. Instead, we

 *       once. This reduces the expense of habitually making defensive copies at API boundaries.
 *       However, the precise conditions for skipping the copy operation are undefined.
 *   <li><b>Warning:</b> a view collection such as {@link ImmutableMap#keySet} or {@link
 *       ImmutableList#subList} may retain a reference to the entire data set, preventing it from

		}
	}
	defer syscall.Close(fd)

	bufp := direntPool.Get()
	defer direntPool.Put(bufp)
	buf := *bufp

	boff := 0 // starting read position in buf
	nbuf := 0 // end valid data in buf

	for {
		if boff >= nbuf {
			boff = 0
			stop := globalOSMetrics.time(osMetricReadDirent)
			nbuf, err = syscall.ReadDirent(fd, buf)
			stop()
			if err != nil {
				if isSysErrNotDir(err) {

		}
	}
}

func TestParseReleaseData(t *testing.T) {
	releaseTime, _ := releaseTagToReleaseTime("RELEASE.2016-10-07T01-16-39Z")
	testCases := []struct {
		data                string
		expectedResult      time.Time
		expectedSha256hex   string
		expectedReleaseInfo string
		expectedErr         bool
	}{
		{"more than two fields", time.Time{}, "", "", true},

        void testMalformedBuffer() {
            // Given - buffer with random data
            byte[] buffer = new byte[10];
            for (int i = 0; i < buffer.length; i++) {
                buffer[i] = (byte) (Math.random() * 256);
            }

            // When & Then
            // Should either read successfully if random data happens to be 4,
            // or throw SMBProtocolDecodingException
            try {