'500':
          $ref: '#/components/responses/InternalServerError'

  /documents/{docId}/favorite:
    post:
      tags:
        - favorite
      summary: Set a favorite mark
      description: Set a favorite mark to the document
      operationId: setFavorite
      parameters:
        - name: docId
          in: path
          description: Document ID to be favorited

   *
   * <ul>
   *   <li>{@code padStart("7", 3, '0')} returns {@code "007"}
   *   <li>{@code padStart("2010", 3, '0')} returns {@code "2010"}
   * </ul>
   *
   * <p>See {@link java.util.Formatter} for a richer set of formatting capabilities.
   *
   * @param string the string which should appear at the end of the result
   * @param minLength the minimum length the resulting string must have. Can be zero or negative, in

        // Initially should be false
        assertFalse(request.isResolveInDfs());

        // Set to true
        request.setResolveInDfs(true);
        assertTrue(request.isResolveInDfs());

        // Set to false
        request.setResolveInDfs(false);
        assertFalse(request.isResolveInDfs());
    }

    @Test

     */
    @Test
    public void testOnConnectListenerInvoked() {
        final AtomicBoolean listenerCalled = new AtomicBoolean(false);
        final OnConnectListener listener = () -> listenerCalled.set(true);

        fesenClient.addOnConnectListener(listener);

        // Manually invoke listeners as if connect() succeeded
        fesenClient.onConnectListenerList.forEach(l -> {
            try {

    @DisplayName("Should return initial credits from getCredit")
    void testGetInitialCredits() throws Exception {
        // Given - set credit using reflection
        Field creditField = ServerMessageBlock2.class.getDeclaredField("credit");
        creditField.setAccessible(true);
        creditField.set(response, 128);

        // When
        int credits = response.getInitialCredits();

        // Then

    }

    /**
     * Clear all cached buffers (for testing or cleanup)
     */
    public static void clearCache() {
        bufferQueue.clear();
        queueSize.set(0);
    }

}

// APIs returns supported APIs
func (s StubKMS) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
	return []madmin.KMSAPI{
		{Method: http.MethodGet, Path: "stub/path"},
	}, nil
}

// Status returns a set of endpoints and their KMS status.
func (s StubKMS) Status(context.Context) (map[string]madmin.ItemState, error) {
	return map[string]madmin.ItemState{
		"127.0.0.1": madmin.ItemOnline,
	}, nil
}

import com.google.common.base.Preconditions;
import com.google.common.collect.ImmutableList;
import com.google.errorprone.annotations.CanIgnoreReturnValue;
import java.util.HashSet;
import java.util.Set;
import junit.framework.AssertionFailedError;
import junit.framework.TestCase;
import org.jspecify.annotations.NullUnmarked;
import org.jspecify.annotations.Nullable;

/**
 * Unit tests for {@link EqualsTester}.
 *

        if (systemProperties != null) {
            this.systemProperties = new Properties();
            synchronized (
                    systemProperties) { // avoid concurrentmodification if someone else sets/removes an unrelated system
                // property
                this.systemProperties.putAll(systemProperties);
            }
        } else {
            this.systemProperties = null;
        }

        return selectVersionsFrom(currentGradleVersion, minimumSupported?.let { VersionNumber.parse(it) }, fetchVersionsFromMavenMetadata(mavenMetadataUrl))
    }

    private
    fun fetchAapt2Versions(agpVersions: Set<String>, mavenMetadataUrl: String): List<String> {
        return fetchVersionsFromMavenMetadata(mavenMetadataUrl)
            .filter { version -> version.substringBeforeLast("-") in agpVersions }