final IndexResponse response = builder.execute().actionGet(indexTimeout);
        esEntity.asDocMeta().id(response.getId());
        return response.getResult() == Result.CREATED ? 1 : 0;
    }

    protected IndexRequestBuilder createInsertRequest(final EsAbstractEntity esEntity) {
        final IndexRequestBuilder builder = client.prepareIndex().setIndex(asEsIndex()).setSource(toSource(esEntity));

        return new RegularImmutableList<E>(castedList);
    }
  }

  /**
   * Views the array as an immutable list. The array must have only {@code E} elements.
   *
   * <p>The array must be internally created.
   */
  @SuppressWarnings("unchecked") // caller is reponsible for getting this right
  static <E> ImmutableList<E> asImmutableList(Object[] elements) {
    return unsafeDelegateList((List) Arrays.asList(elements));
  }

        // maxDataCount should be 0
        // maxSetupCount should be 0

        // Since these are protected fields, we can't access them directly
        // But we can verify the object is created successfully with these values
        assertNotNull(trans2SetFileInfo);
    }

    @Test
    @DisplayName("Test concurrent access")
    void testConcurrentAccess() throws InterruptedException {

        System.arraycopy(testStats, 0, src, srcIndex + 25, 6);

        int result = response.readRDataWireFormat(src, srcIndex);
        assertEquals(31, result);

        // Verify stats array was created with correct size
        // statsLength = rDataLength - (numberOfNames * 18) - 1 = 31 - 18 - 1 = 12
        Field statsField = NodeStatusResponse.class.getDeclaredField("stats");
        statsField.setAccessible(true);

        // When - constructor accepts null config without throwing
        Smb2ReadResponse responseWithNull = new Smb2ReadResponse(null, outputBuffer, outputBufferOffset);

        // Then - response is created successfully
        assertNotNull(responseWithNull);
    }

    @Test
    @DisplayName("Should handle large data offset value")
    void testReadBytesWireFormatLargeDataOffset() throws Exception {

        @Test
        @DisplayName("Should create appropriate response")
        void testCreateResponse() {
            Smb2WriteResponse response = request.createResponse(mockContext, request);
            assertNotNull(response);
            assertTrue(response instanceof Smb2WriteResponse);
        }

        @Test
        @DisplayName("Should create response with same configuration")

		case "Name":
			z.Name, bts, err = msgp.ReadStringBytes(bts)
			if err != nil {
				err = msgp.WrapError(err, "Name")
				return
			}
		case "Created":
			z.Created, bts, err = msgp.ReadTimeBytes(bts)
			if err != nil {
				err = msgp.WrapError(err, "Created")
				return
			}
		case "Deleted":
			z.Deleted, bts, err = msgp.ReadTimeBytes(bts)
			if err != nil {
				err = msgp.WrapError(err, "Deleted")
				return

        }
        ComponentUtil.getSsoManager().register(this);
    }

    /**
     * Gets or creates the SPNEGO authenticator instance.
     *
     * This method implements lazy initialization with synchronization to ensure
     * the authenticator is only created once. It configures the authenticator
     * with the appropriate SPNEGO settings and marks initialization as complete.
     *

    }

    /**
     * Creates a Type-3 message using default values from the current
     * environment.
     */
    public Type3Message() {
        setFlags(getDefaultFlags());
        setDomain(getDefaultDomain());
        setUser(getDefaultUser());
        setWorkstation(getDefaultWorkstation());
    }

    /**
     * Creates a Type-3 message in response to the given Type-2 message

	// Copy all other files from GOROOT.
	dirents, err := os.ReadDir(goroot)
	if err != nil {
		return err
	}
	for _, de := range dirents {
		switch de.Name() {
		case "bin", "pkg":
			// We already created GOROOT/bin and GOROOT/pkg above; skip those.
			continue
		}
		if err := adb("push", filepath.Join(goroot, de.Name()), path.Join(deviceGoroot, de.Name())); err != nil {
			return err
		}
	}