context
            );
            
            // Bind to witness interface
            handle.bind();
            
        } catch (Exception e) {
            throw new IOException("Failed to connect to witness service", e);
        }
    }
    
    public WitnessRegisterResponse register(WitnessRegisterRequest request) throws IOException {
        try {

        // Node without id attribute
        MockNode nodeWithoutId = new MockNode("div");
        assertFalse(tag.matches(nodeWithoutId));

        // Wrong tag with correct id
        MockNode wrongTag = new MockNode("span");
        wrongTag.addAttribute("id", "test-id");
        assertFalse(tag.matches(wrongTag));
    }

    public void test_matches_withCss() {

import com.google.common.eventbus.EventBus;
import junit.framework.TestCase;
import org.jspecify.annotations.Nullable;

/**
 * Abstract base class for tests that EventBus finds the correct subscribers.
 *
 * <p>The actual tests are distributed among the other classes in this package based on whether they
 * are annotated or abstract in the superclass.
 *

            assertEquals(16, result);
            verify(request, times(1)).encode(buffer, 0);
        }

        @Test
        @DisplayName("size() method should return correct size")
        void testSizeMethod() {
            CreateContextRequest request = mock(CreateContextRequest.class);
            when(request.size()).thenReturn(64);

            int size = request.size();

 * specific language governing permissions and limitations
 * under the License.
 */
package org.apache.maven.artifact.resolver;

import javax.inject.Named;
import javax.inject.Singleton;

/**
 * Artifact collector - takes a set of original artifacts and resolves the best versions to use
 * along with their metadata. No artifacts are downloaded.
 */
@Deprecated
@Named
@Singleton

@ExtendWith(MockitoExtension.class)
class Smb2TreeDisconnectRequestTest {

    private static final short SMB2_TREE_DISCONNECT = 0x0004;

    @Test
    @DisplayName("Should create request with correct command type")
    void testConstructorSetsCorrectCommand() throws Exception {
        // Given
        Configuration mockConfig = mock(Configuration.class);

        // When

/**
 * Unit tests for DirectoryLeaseState
 */
public class DirectoryLeaseStateTest {

    @Test
    public void testDirectoryLeaseConstants() {
        // Test that directory lease states use correct base values
        assertEquals(Smb2LeaseState.SMB2_LEASE_READ_CACHING | Smb2LeaseState.SMB2_LEASE_HANDLE_CACHING,
                DirectoryLeaseState.DIRECTORY_READ_HANDLE);

            deliveries.incrementAndGet();
          }
        });

    String EVENT = "Hello!";
    bus.post(EVENT);

    assertEquals("Only one event should be delivered.", 1, deliveries.get());
    assertEquals("Correct string should be delivered.", EVENT, holder.get());
  }

  internal fun connectFailed(
    client: OkHttpClient,
    failedRoute: Route,
    failure: IOException,
  ) {
    // Tell the proxy selector when we fail to connect on a fresh connection.
    if (failedRoute.proxy.type() != Proxy.Type.DIRECT) {
      val address = failedRoute.address
      address.proxySelector.connectFailed(
        address.url.toUri(),

@DoNotMock("Use an instance of one of the Finalizable*Reference classes")
@J2ktIncompatible
@GwtIncompatible
public interface FinalizableReference {
  /**
   * Invoked on a background thread after the referent has been garbage collected unless security
   * restrictions prevented starting a background thread, in which case this method is invoked when
   * new references are created.
   */
  void finalizeReferent();