}

        @Test
        @DisplayName("should handle conflicting option combinations")
        void shouldHandleConflictingOptionCombinations() {
            // Test case where multiple conflicting options are set
            UpgradeContext context = TestUtils.createMockContext(TestUtils.createOptions(
                    true, // --all
                    false, // --infer (conflicts with --all)

  }

  @J2ktIncompatible // b/239034072: Kotlin varargs copy parameter arrays.
  public void testAsList_isAView() {
    short[] array = {(short) 0, (short) 1};
    List<Short> list = Shorts.asList(array);
    list.set(0, (short) 2);
    assertThat(array).isEqualTo(new short[] {(short) 2, (short) 1});
    array[1] = (short) 3;
    assertThat(list).containsExactly((short) 2, (short) 3).inOrder();
  }

  }

  /**
   * Returns the empty bimap.
   *
   * <p><b>Performance note:</b> the instance returned is a singleton.
   */
  // Casting to any type is safe because the set will never hold any elements.
  @SuppressWarnings("unchecked")
  public static <K, V> ImmutableBiMap<K, V> of() {
    return (ImmutableBiMap<K, V>) RegularImmutableBiMap.EMPTY;
  }

		nerrs = 1
	}
	if wks > nerrs {
		wks = nerrs
	}
	wk, _ := workers.New(wks)
	return &NotificationGroup{errs: make([]NotificationPeerErr, nerrs), workers: wk, retryCount: 3}
}

// WithRetries sets the retry count for all function calls from the Go method.
func (g *NotificationGroup) WithRetries(retryCount int) *NotificationGroup {
	if g != nil {
		g.retryCount = retryCount
	}
	return g
}

        if (current > maxValueDivs[radix]) {
          return true;
        }
        // current == maxValueDivs[radix]
        return digit > maxValueMods[radix];
      }

      // current < 0: high bit is set
      return true;
    }
  }

  /**
   * Returns a string representation of x, where x is treated as unsigned.
   *
   * <p><b>Java 8+ users:</b> use {@link Long#toUnsignedString(long)} instead.
   */

	globalIsTLS = true
	for i, test := range encryptRequestTests {
		content := bytes.NewReader(make([]byte, 64))
		req := &http.Request{Header: http.Header{}}
		for k, v := range test.header {
			req.Header.Set(k, v)
		}
		_, _, err := EncryptRequest(content, req, "bucket", "object", test.metadata)
		if err != nil {
			t.Fatalf("Test %d: Failed to encrypt request: %v", i, err)
		}

import jcifs.smb.SmbTransportInternal;

/**
 * Integration tests for RDMA functionality.
 *
 * This class contains both unit tests (that always run) and integration tests
 * (that require system properties to be set for execution).
 *
 * Integration tests require system properties:
 * - rdma.test.enabled=true (to enable RDMA integration tests)
 * - rdma.test.server=hostname/IP (target server for testing)

        }
    }

    @Nested
    @DisplayName("Configuration Tests")
    class ConfigurationTests {

        @Test
        @DisplayName("Should set security provider")
        void testSetDcerpcSecurityProvider() {
            // When: Setting security provider
            handle.setDcerpcSecurityProvider(mockSecurityProvider);

        assertEquals(0, Encdec.dec_uint32le(buffer, 0)); // Should encode 0 for null
    }

    @Test
    void testToString() {
        ndrBuffer.setIndex(10);
        ndrBuffer.setLength(20); // Set length directly for toString test
        String expected = "start=0,index=10,length=20";
        assertEquals(expected, ndrBuffer.toString());

        NdrBuffer offsetBuffer = new NdrBuffer(buffer, 5);

    }

    /**
     * @return the mechanisms announced by the remote end
     */
    ASN1ObjectIdentifier[] getRemoteMechs() {
        return this.remoteMechs;
    }

    /**
     * Set what mechanism is being used for this context.
     *
     * @param mechs
     */
    void setMechs(final ASN1ObjectIdentifier[] mechs) {
        this.mechs = mechs;
    }

    /**
     * {@inheritDoc}