long ops = operations.get();
            if (ops == 0) return 0;
            return (double) latencyTotal.get() / ops;
        }
        
        public long getThroughput() {
            return bytesSent.get() + bytesReceived.get();
        }
    }
    
    public void recordOperation(String channelId, long bytes, long latency, boolean success) {

 */
@DisplayName("Smb2TransformHeader Tests")
class Smb2TransformHeaderTest extends BaseTest {

    private Smb2TransformHeader transformHeader;
    private byte[] testNonce;
    private long testSessionId;

    @BeforeEach
    void setUp() {
        transformHeader = new Smb2TransformHeader();
        testNonce = new byte[16];
        new SecureRandom().nextBytes(testNonce);

 * actual free allocation units, sectors per allocation unit, and bytes per sector.
 */
public class FileFsFullSizeInformation implements AllocInfo, FileSystemInformation, Decodable {

    private long alloc; // Also handles SmbQueryFSSizeInfo
    private long free;
    private int sectPerAlloc;
    private int bytesPerSect;

    /**
     * Default constructor for decoding file system full size information.
     */

    }

    @Test
    @DisplayName("Should get long property with default value")
    void testGetLongWithDefault() {
        assertEquals(1234567890123L, Config.getLong(testProperties, "test.long", 0L));
        assertEquals(987654321L, Config.getLong(testProperties, "nonexistent.long", 987654321L));
    }

    @Test
    @DisplayName("Should get InetAddress property with default value")

     */
    public boolean isExpired(long timeoutMs) {
        return System.currentTimeMillis() - lastHeartbeat > timeoutMs;
    }

    // Getters and setters

    /**
     * Gets the last heartbeat timestamp.
     *
     * @return the last heartbeat timestamp in milliseconds
     */
    public long getLastHeartbeat() {
        return lastHeartbeat;
    }

    /**

        return this;
    }

    public void setCreatedTime_Equal(Long createdTime) {
        setCreatedTime_Term(createdTime, null);
    }

    public void setCreatedTime_Equal(Long createdTime, ConditionOptionCall<TermQueryBuilder> opLambda) {
        setCreatedTime_Term(createdTime, opLambda);
    }

    public void setCreatedTime_Term(Long createdTime) {
        setCreatedTime_Term(createdTime, null);
    }

    private static final long serialVersionUID = 1L;

    public String getId() {
        return asDocMeta().id();
    }

    public void setId(final String id) {
        asDocMeta().id(id);
    }

    public Long getVersionNo() {
        return asDocMeta().version();
    }

    public void setVersionNo(final Long version) {
        asDocMeta().version(version);
    }

    out.write(0xFF & (v >> 24));
  }

  /**
   * Writes a {@code long} as specified by {@link DataOutputStream#writeLong(long)}, except using
   * little-endian byte order.
   *
   * @throws IOException if an I/O error occurs
   */
  @Override
  public void writeLong(long v) throws IOException {
    ((DataOutputStream) out).writeLong(Long.reverseBytes(v));
  }

  /**

     */
    public String expiredTime;

    /**
     * The timestamp when this crawling session was created.
     * Stored as a long value representing milliseconds since epoch.
     */
    @ValidateTypeFailure
    public Long createdTime;

    /**
     * Initializes the form with default null values.
     * This method resets all fields to their default state for creating a new entry.
     */

        listener.onFailure(
          this,
          IllegalStateException("Invalid content-type: ${body.contentType()}"),
          response,
        )
        return
      }

      // This is a long-lived response. Cancel full-call timeouts.
      call?.timeout()?.cancel()

      // Replace the body with a stripped one so the callbacks can't see real data.
      val response = response.stripBody()