)

	decoder := NewDecoder(mkReader(body), 1)

	for mv = range decoder.Stream() {
		counter++
		t.Logf("depth=%d offset=%d len=%d (%v)", mv.Depth, mv.Offset, mv.Length, mv.Value)
	}

	if err := decoder.Err(); err != nil {
		t.Fatalf("decoder error: %s", err)
	}
}

func TestDecoderNested(t *testing.T) {
	var (
		counter int
		mv      *MetaValue
		body    = `{

    /**
     * The name of the access token.
     * This is a required field with a maximum length of 1000 characters.
     */
    @Required
    @Size(max = 1000)
    public String name;

    /**
     * The actual access token string.
     * This is the token value that will be used for authentication.
     * Maximum length is 10000 characters.
     */
    @Size(max = 10000)
    public String token;

    /**

    }

    @Override
    public K[] createKeyArray(int length) {
      return ((TestMultimapGenerator<K, V, M>) multimapGenerator.getInnerGenerator())
          .createKeyArray(length);
    }

    @SuppressWarnings("unchecked")
    @Override
    public Collection<V>[] createValueArray(int length) {
      return (Collection<V>[]) new Collection<?>[length];
    }
  }

        assertEquals(2, arrayFields.length);

        String[] dateFields = fessConfig.getIndexAdminDateFields().split(",");
        assertNotNull(dateFields);
        assertEquals(3, dateFields.length);

        String[] requiredFields = fessConfig.getIndexAdminRequiredFields().split(",");
        assertNotNull(requiredFields);
        assertEquals(4, requiredFields.length);
    }

}

func evalSQLSubstring(s string, startIdx, length int) (res string, err error) {
	rs := []rune(s)

	// According to s3 document, if startIdx < 1, it is set to 1.
	if startIdx < 1 {
		startIdx = 1
	}

	if startIdx > len(rs) {
		startIdx = len(rs) + 1
	}

	// StartIdx is 1-based in the input
	startIdx--
	endIdx := len(rs)
	if length != -1 {
		if length < 0 {
			return "", errInvalidSubstringIndexLen

            // Provide empty arrays to satisfy code paths
            rpc.names = new lsarpc.LsarTransNameArray();
            rpc.names.count = sids.length;
            rpc.names.names = new lsarpc.LsarTranslatedName[sids.length];
            for (int i = 0; i < sids.length; i++) {
                rpc.names.names[i] = new lsarpc.LsarTranslatedName();
                rpc.names.names[i].sid_type = (short) jcifs.SID.SID_TYPE_UNKNOWN;

                .addMessageParameter("max", max)
                .buildConstraintViolationWithTemplate(message)
                .addConstraintViolation();
        final int length = value.length();
        return length >= min && length <= max;
    }

    private void validateParameters() {
        if (min < 0) {
            throw new IllegalArgumentException("The min parameter cannot be negative.");
        }

showTable(title, headers, content) { text = "<h3>" + title + "</h3><p>"; if (content.length > 0) { text += "<table border=\"1\" cellpadding=\"5\" cellspacing=\"0\">"; if (headers.length > 0) { text += "<tr>"; headerArray = headers.split(","); for (i = 0; i < headerArray.length; i++) { text += "<th>" + headerArray[i] + "</th>"; } text += "</tr>"; } rows = content.split(";"); for (i = 0; i < rows.length; i++) { if (rows[i].length > 0) { columns = rows[i].split(","); text += "<tr>"; for (j = 0; j < columns.length;...

        // Prepare test data with zeros
        byte[] buffer = new byte[22];

        // All zeros
        for (int i = 0; i < buffer.length; i++) {
            buffer[i] = 0;
        }

        // Decode
        smbInfoAllocation.decode(buffer, 0, buffer.length);

        // Verify - all zeros should result in 0 capacity and free
        assertEquals(0L, smbInfoAllocation.getCapacity());

                assertEquals(TEST_DOMAIN.getBytes(Type2Message.UNI_ENCODING).length, Type2Message.readUShort(targetInfo, 2)); // Length
                assertEquals(TEST_DOMAIN,
                        new String(Arrays.copyOfRange(targetInfo, 4, 4 + TEST_DOMAIN.getBytes(Type2Message.UNI_ENCODING).length),
                                Type2Message.UNI_ENCODING));