* complements {@link Multiset#remove(Object)}, which removes only one occurrence at a time.
     *
     * @param element the element whose occurrences should all be removed
     * @return the number of occurrences successfully removed, possibly zero
     */
    private int removeAllOccurrences(@Nullable Object element) {
      try {
        return unbox(countMap.remove(element));
      } catch (NullPointerException | ClassCastException e) {

                fos = new FileOutputStream(newFile);
                writer = new BufferedWriter(new OutputStreamWriter(fos, Constants.UTF_8));
                fos = null; // Successfully wrapped, no need to close explicitly
            } catch (final Exception e) {
                if (fos != null) {
                    try {
                        fos.close();

    @Nested
    @DisplayName("Header Decoding Tests")
    class HeaderDecodingTests {

        @Test
        @DisplayName("decode_header should successfully parse valid header")
        void testDecodeHeaderSuccess() throws NdrException {
            // Mock NdrBuffer methods for successful decoding
            when(mockBuffer.dec_ndr_small()).thenReturn(5)
                    .thenReturn(0) // RPC version

	if err != nil {
		return err
	}

	eventData, eErr := target.store.Get(key)
	if eErr != nil {
		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
		// Such events will not exist and wouldve been already been sent successfully.
		if os.IsNotExist(eErr) {
			return nil
		}
		return eErr
	}

	if err := target.send(eventData); err != nil {
		return err

     * @param numberOfShards the number of shards for the new index
     * @param autoExpandReplicas the auto expand replicas setting for the new index
     * @return true if the reindex operation started successfully, false otherwise
     */
    protected boolean startReindex(final boolean replaceAliases, final boolean resetDictionaries, final String numberOfShards,
            final String autoExpandReplicas) {

	if err != nil {
		return err
	}

	eventData, eErr := target.store.Get(key)
	if eErr != nil {
		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
		// Such events will not exist and wouldve been already been sent successfully.
		if os.IsNotExist(eErr) {
			return nil
		}
		return eErr
	}

	if err := target.send(eventData); err != nil {

            byte[] smallBuffer = new byte[10];
            int[] ciphers = { 1, 2 };

            EncryptionNegotiateContext context = new EncryptionNegotiateContext(mockConfig, ciphers);

            // Should encode successfully at the beginning
            int encoded = context.encode(smallBuffer, 0);
            assertEquals(6, encoded);

            // Should handle encoding at the end of buffer correctly

        response = new NetShareEnumResponse(mockConfig);
    }

    @Test
    @DisplayName("Test constructor with configuration")
    void testConstructor() {
        assertNotNull(response);
        // Response is successfully created with configuration
        assertTrue(response instanceof NetShareEnumResponse);
    }

    @Test
    @DisplayName("Test writeSetupWireFormat returns 0")
    void testWriteSetupWireFormat() {

![hive-config](https://github.com/minio/minio/blob/master/docs/bigdata/images/image14.png?raw=true "restart hive services")

## **4. Run Sample Applications**

        SocketInputStream sis = new SocketInputStream(in);

        // Read in chunks
        byte[] buffer = new byte[10];

        // The read will either:
        // 1. Successfully read all 5 bytes
        // 2. Throw IOException if it tries to read past the message
        try {
            int read = sis.read(buffer, 0, 10);

            // Should read all 5 available bytes