Comparator<? super E> comparator, E... elements) {
    checkNotNull(elements);
    switch (elements.length) {
      case 0:
        return emptySet(comparator);
      default:
        SortedSet<E> delegate = new TreeSet<E>(comparator);
        for (E element : elements) {
          checkNotNull(element);
          delegate.add(element);
        }

                    if (binding != null) {
                        binding.setOption(key, val);
                    }
                    key = null;
                }
                break;
            default:
                si = arr.length;
            }

            si++;
        } while (si < arr.length);

        if (binding == null || binding.getEndpoint() == null) {

            assertEquals(EncryptionNegotiateContext.CIPHER_AES128_CCM, ccm.getCipherId());
            assertEquals(DialectVersion.SMB300, ccm.getDialect());

            // SMB 3.1.1 -> default AES-128-GCM when server did not choose
            Smb2NegotiateResponse smb311 = new Smb2NegotiateResponse(cfg);
            setField(smb311, "selectedDialect", DialectVersion.SMB311);

        @Test
        @DisplayName("Should handle source key with all zeros")
        void testSourceKeyAllZeros() {
            // Given
            byte[] zeroKey = new byte[SOURCE_KEY_SIZE]; // All zeros by default
            SrvCopychunk chunk = new SrvCopychunk(1, 2, 3);
            SrvCopychunkCopy copy = new SrvCopychunkCopy(zeroKey, chunk);
            byte[] buffer = new byte[100];

            // When

      try {
        return input.readUTF();
      } catch (IOException e) {
        throw new IllegalStateException(e);
      }
    }
  }

  /** Returns a new {@link ByteArrayDataOutput} instance with a default size. */
  @J2ktIncompatible
  public static ByteArrayDataOutput newDataOutput() {
    return newDataOutput(new ByteArrayOutputStream());
  }

  /**

    public static final String LABELS_app_value = "{labels.app_value}";

    /** The key of the message: Default Label Value */
    public static final String LABELS_default_label_value = "{labels.default_label_value}";

    /** The key of the message: Default Sort Value */
    public static final String LABELS_default_sort_value = "{labels.default_sort_value}";

import org.lastaflute.web.Execute;
import org.lastaflute.web.response.HtmlResponse;

/**
 * The action for admin pages.
 */
public class AdminAction extends FessAdminAction {

    /**
     * Default constructor.
     */
    public AdminAction() {
        super();
    }

    @Override
    protected String getActionRole() {
        return "admin";
    }

                break;
              case REPLACED:
                stats[2]++;
                break;
              case SIZE:
                stats[3]++;
                break;
              default:
                throw new IllegalStateException("No collected exceptions in GWT CacheBuilder.");
            }
          }
        };

    Cache<Integer, Integer> cache =
        CacheBuilder.newBuilder()

        lenient().when(mockConfig.getOemEncoding()).thenReturn("UTF-8");
        lenient().when(mockConfig.getRandom()).thenReturn(mockRandom);
        lenient().when(mockConfig.getLanManCompatibility()).thenReturn(3); // Default NTLMv2
        lenient().when(mockConfig.getMachineId()).thenReturn(machineId);
        lenient().when(mockCtx.getConfig()).thenReturn(mockConfig);

    void unknownPacketTypeHandled() throws IOException {
        // According to the SocketInputStream implementation, unknown packet types
        // are handled in the switch statement's default case which continues the loop
        byte[] data = new byte[] { 1, 2 };

        // Use a type that's not SESSION_MESSAGE or SESSION_KEEP_ALIVE
        byte[] unknownHeader = new byte[] { (byte) 0x90, 0, 0, 0 };