class SmbComLockingAndXTest {

    /**
     * Helper for setting a field via reflection.
     */
    private static void setField(Object target, String name, Object value) {
        try {
            Field f = target.getClass().getDeclaredField(name);
            f.setAccessible(true);
            f.set(target, value);
        } catch (Exception e) {
            fail("Failed to set field '" + name + "'", e);
        }
    }

    /**

        super(out);
    }

    @Override
    public synchronized void write(final byte[] b, int off, final int len) throws IOException {
        if (len > 0xFFFF) {
            throw new IOException("write too large: " + len);
        }
        if (off < 4) {
            throw new IOException("NetBIOS socket output buffer requires 4 bytes available before off");
        }

        off -= 4;

        // Adaptive strategy based on message type and size

        if (isLargeTransfer(message)) {
            // For large transfers, prefer high-bandwidth channels
            ChannelInfo maxBandwidthChannel = null;
            int maxBandwidth = 0;
            for (ChannelInfo channel : channels) {

                                    </button>
                                    <c:if test="${editable}">
                                        <button type="button" class="btn btn-danger" name="delete"
                                                data-toggle="modal" data-target="#confirmToDelete"
                                                value="<la:message key="labels.crud_button_delete" />">

                                    </button>
                                    <c:if test="${editable}">
                                        <button type="button" class="btn btn-danger" name="delete"
                                                data-toggle="modal" data-target="#confirmToDelete"
                                                value="<la:message key="labels.searchlog_configuration_button_delete" />">

        when(mockChannelManager.getHealthyChannels()).thenReturn(Arrays.asList(channel1, channel2));

        ChannelInfo selected = loadBalancer.selectChannel(largeRead);
        // Should prefer higher bandwidth channel for large transfers
        assertEquals(channel2, selected);
    }

    @Test
    void testAdaptiveStrategyMetadataOperation() throws Exception {
        loadBalancer.setStrategy(LoadBalancingStrategy.ADAPTIVE);

        ByteArrayInputStream bais = new ByteArrayInputStream(data);
        SessionRetargetResponsePacket packet = new SessionRetargetResponsePacket();

        // Create a buffer large enough to hold the read bytes
        byte[] buffer = new byte[6];
        int bytesRead = packet.readTrailerWireFormat(bais, buffer, 0);

        // Verify that 6 bytes were read, which is the expected length.

        } else {
          val dynamicTableIndex = dynamicTableIndex(index - STATIC_HEADER_TABLE.size)
          if (dynamicTableIndex < 0 || dynamicTableIndex >= dynamicTable.size) {
            throw IOException("Header index too large ${index + 1}")
          }
          headerList += dynamicTable[dynamicTableIndex]!!
        }
      }

      // referencedHeaders is relative to nextHeaderIndex + 1.

        }

        if (buffer.length > maxSize) {
            failedValidations.incrementAndGet();
            bufferOverflowsPrevented.incrementAndGet();
            log.warn("Response buffer too large: {} > {}", buffer.length, maxSize);
            throw new SmbException("Response buffer exceeds maximum: " + buffer.length + " > " + maxSize);
        }
    }

    /**
     * Validate buffer access bounds
     *

      if (digit == -1) {
        throw new NumberFormatException(string);
      }
      if (pos > maxSafePos && ParseOverflowDetection.overflowInParse(value, digit, radix)) {
        throw new NumberFormatException("Too large for unsigned long: " + string);
      }
      value = (value * radix) + digit;
    }

    return value;
  }

  /**
   * Returns the unsigned {@code long} value represented by the given string.