return Math.max(bufferIndex, ncpos) - start;
        }

        return bufferIndex - start;
    }

    /**
     * Creates a negotiate context response based on the context type.
     *
     * @param type the negotiate context type
     * @return the appropriate negotiate context response, or null if not recognized
     */

        * When a `response_model` is declared, the same `response_model` type declaration won't be used as is, it will be "cloned" to create an new one (a cloned Pydantic `Field` with all the submodels cloned as well).

      .assertHeader("Test", "Redirect from /a to /b")

    // New connection.
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    // Connection reused.
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(1)
    // Connection reused again!
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(2)
  }

  @Test
  fun postRedirectsToGet() {
    server.enqueue(
      MockResponse(

      other entities that control, are controlled by, or are under common
      control with that entity. For the purposes of this definition,
      "control" means (i) the power, direct or indirect, to cause the
      direction or management of such entity, whether by contract or
      otherwise, or (ii) ownership of fifty percent (50%) or more of the
      outstanding shares, or (iii) beneficial ownership of such entity.

      other entities that control, are controlled by, or are under common
      control with that entity. For the purposes of this definition,
      "control" means (i) the power, direct or indirect, to cause the
      direction or management of such entity, whether by contract or
      otherwise, or (ii) ownership of fifty percent (50%) or more of the
      outstanding shares, or (iii) beneficial ownership of such entity.

        message.setType(messageType);

        // Message length
        int messageLength = buf.dec_ndr_long();
        message.setLength(messageLength);

        // Based on message type, decode specific data
        switch (messageType) {
        case WitnessNotificationMessage.WITNESS_RESOURCE_CHANGE:
            decodeResourceChangeMessage(buf, message);
            break;

	Context                  context.Context
	Logger                   logger.Interface
	NowFunc                  func() time.Time
	CreateBatchSize          int
}

// Open initialize db session based on dialector
func Open(dialector Dialector, opts ...Option) (db *DB, err error) {
	config := &Config{}

	sort.Slice(opts, func(i, j int) bool {
		_, isConfig := opts[i].(*Config)
		_, isConfig2 := opts[j].(*Config)

   *
   * <p><b>Java 8+ users:</b> use {@link Integer#parseUnsignedInt(String, int)} instead.
   *
   * @param string the string containing the unsigned integer representation to be parsed.
   * @param radix the radix to use while parsing {@code s}; must be between {@link
   *     Character#MIN_RADIX} and {@link Character#MAX_RADIX}.

            fileIdField.setAccessible(true);
            byte[] actualFileId = (byte[]) fileIdField.get(request);

            // Should be null as passed
            assertNull(actualFileId);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    @Test
    @DisplayName("Test buffer size edge cases")

    }

    /**
     * Parses project properties from the given path.
     *
     * @param propPath The path to the project properties file.
     * @throws FessSystemException if the properties file cannot be parsed.
     */
    protected void parseProjectProperties(final Path propPath) {
        try (final InputStream in = Files.newInputStream(propPath)) {
            final Properties prop = new Properties();