this.lastActivityTime = establishedTime;
        
        this.bytesSent = new AtomicLong();
        this.bytesReceived = new AtomicLong();
        this.requestsSent = new AtomicLong();
        this.requestsReceived = new AtomicLong();
        this.errors = new AtomicLong();
        
        this.isPrimary = false;
    }
    
    public void updateActivity() {

        void testConcurrentReceived() throws InterruptedException {
            int threadCount = 10;
            CountDownLatch startLatch = new CountDownLatch(1);
            CountDownLatch endLatch = new CountDownLatch(threadCount);

            for (int i = 0; i < threadCount; i++) {
                new Thread(() -> {
                    try {
                        startLatch.await();
                        response.received();

        List<String> missingFiles = new ArrayList<>();

        Gson gson = new Gson();
        List<AdocFileEntry> entries;
        try (FileReader reader = new FileReader(jsonFile)) {
            entries = gson.fromJson(reader, new TypeToken<List<AdocFileEntry>>() {}.getType());
        }

        Set<String> foundAdocFiles = new HashSet<>();

            throw new CIFSException("Invalid offset or length");
        }
        if (!isAlgorithmSupported(algorithm)) {
            throw new CIFSException("Unsupported compression algorithm: " + algorithm);
        }
        if (length < MIN_COMPRESSION_SIZE) {
            log.debug("Data too small for compression ({} bytes), returning uncompressed", length);
            byte[] result = new byte[length];

 *   <li>{@link #createIndexIfNothing()}: Creates a new index if no index exists.</li>
 *   <li>{@link #createNextIndex()}: Creates a new index and replaces the current update alias with the new index.</li>
 *   <li>{@link #switchIndex()}: Switches the search alias to the current update index.</li>
 *   <li>{@link #removeDisableIndices()}: Removes disabled indices.</li>
 *   <li>{@link #indexer()}: Creates a new SuggestIndexer for indexing suggestions.</li>

        assertThrows(SmbException.class, () -> new SMB1SigningDigest(mockTransport, mockAuth));
    }

    @Test
    @DisplayName("Test update method with valid data")
    void testUpdateWithValidData() {
        SMB1SigningDigest digest = new SMB1SigningDigest(testMacSigningKey);
        byte[] data = new byte[] { 0x01, 0x02, 0x03, 0x04 };

        RealisticTestBean bean1 = new RealisticTestBean();
        TestBean bean2 = new TestBean();

        PlexusConfiguration config1 = new XmlPlexusConfiguration("name");
        config1.setValue("testValue");
        optimizedHelper.setProperty(bean1, "name", String.class, config1);
        optimizedHelper.setProperty(bean2, "name", String.class, config1);

        PlexusConfiguration config2 = new XmlPlexusConfiguration("count");

    Random random = new Random();
    for (int i = 0; i < 100; i++) {
      byte[] bytes = new byte[64];
      random.nextBytes(bytes);
      String s = new String(bytes, UTF_16LE); // so all random strings are valid
      assertEquals(
          new Sink(4).putUnencodedChars(s).hash(),
          new Sink(4).putBytes(s.getBytes(UTF_16LE)).hash());
      assertEquals(

        if (token.length <= 0) {
            throw new PACDecodingException("Empty kerberos ticket");
        }

        ASN1Sequence sequence;
        try {
            try (ASN1InputStream stream = new ASN1InputStream(new ByteArrayInputStream(token))) {
                sequence = ASN1Util.as(ASN1Sequence.class, stream);
            }
        } catch (IOException e) {
            throw new PACDecodingException("Malformed kerberos ticket", e);

        session.setScopeManager(new ScopeManagerImpl(Maven4ScopeManagerConfiguration.INSTANCE));
        session.setLocalRepositoryManager(new LegacyLocalRepositoryManager(localRepo));
        request.setRepositorySession(session);

        DefaultMavenExecutionRequest mavenExecutionRequest = new DefaultMavenExecutionRequest();
        MavenSession msession =