if m.expMovingAvg == 0 {
		// Should address initial calculation and should be fine for resuming from 0
		m.expMovingAvg = float64(bytesSinceLastWindow) / duration.Seconds()
		return
	}

	increment := float64(bytesSinceLastWindow) / duration.Seconds()
	m.expMovingAvg = exponentialMovingAverage(beta, m.expMovingAvg, increment)
}

// exponentialMovingAverage calculates the exponential moving average

      "ConnectionReleased",
    )
  }

  @Test
  fun failedCallEventSequence() {
    server!!.enqueue(
      MockResponse
        .Builder()
        .headersDelay(2, TimeUnit.SECONDS)
        .build(),
    )
    client =
      client
        .newBuilder()
        .readTimeout(Duration.ofMillis(250))
        .build()
    val call =
      client.newCall(
        Request

          <description>
            This element includes the specification of report plugins to use
            to generate the reports on the Maven-generated site.
            These reports will be run when a user executes {@code mvn site}.
            All the reports will be included in the navigation bar for browsing.
          </description>
          <association>
            <type>Reporting</type>

                } finally {
                    latch.countDown();
                }
            });
        }

        assertTrue(latch.await(10, TimeUnit.SECONDS));
        executor.shutdown();
    }

    @Test
    @DisplayName("Test invalid session ID handling")
    public void testInvalidSessionIdHandling() {
        assertThrows(CIFSException.class, () -> {

    int tableSize = Hashing.closedTableSize(n, MAX_LOAD_FACTOR);
    @Nullable ImmutableMapEntry<K, V>[] table = createEntryArray(tableSize);
    int mask = tableSize - 1;
    // If duplicates are allowed, this IdentityHashMap will record the final Entry for each
    // duplicated key. We will use this final Entry to overwrite earlier slots in the entries array
    // that have the same key. Then a second pass will remove all but the first of the slots that

        // Load persisted handles on startup
        loadPersistedHandles();

        // Schedule periodic persistence and cleanup
        scheduler.scheduleAtFixedRate(this::periodicMaintenance, 30, 30, TimeUnit.SECONDS);
    }

    /**
     * Request a new durable handle
     * @param path the file path
     * @param type the handle type
     * @param timeout the timeout in milliseconds

        Smb2LeaseKey key = leaseManager.requestLease(path, initialState);
        leaseManager.updateLease(key, initialState);

        // Call with default timeout (should use 60 seconds from config)
        leaseManager.handleLeaseBreakWithTimeout(key, newState);

        LeaseEntry entry = leaseManager.getLease(key);
        assertNotNull(entry);
        assertEquals(newState, entry.getLeaseState());

        });

        DirFileEntryEnumIterator1 it = new DirFileEntryEnumIterator1(tree, parent, "*", null, 0);
        assertFalse(it.hasNext(), "Iterator should be empty when server reports no such file");

        // FindClose2 is sent during cleanup
        verify(tree, times(1)).send(isA(SmbComFindClose2.class), any());
        verify(tree, atLeastOnce()).release();
    }

        when(sh.isSMB2()).thenReturn(true);
        when(dh.isSMB2()).thenReturn(true);
        when(sh.isSameTree(dh)).thenReturn(true);

        // Source open returns a handle that reports size 0
        SmbFileHandleImpl sfd = mock(SmbFileHandleImpl.class);
        when(sfd.getInitialSize()).thenReturn(0L);

/settings.gradle*                           @gradle/bt-developer-productivity
gradle/shared-with-buildSrc/                @gradle/bt-developer-productivity
packaging/internal-build-reports/           @gradle/bt-developer-productivity
testing/distributions-basics/               @gradle/bt-developer-productivity
testing/distributions-core/                 @gradle/bt-developer-productivity