import java.net.Proxy
import java.util.concurrent.TimeUnit

class ClientRuleEventListener(
  var logger: (String) -> Unit,
) : EventListener(),
  EventListener.Factory {
  private var startNs: Long? = null

  override fun create(call: Call): EventListener = this

  override fun callStart(call: Call) {
    startNs = System.nanoTime()

    logWithTime("callStart: ${call.request()}")
  }

     * This method delegates to {@link FileInputStream#skip(long)}.
     *
     * @param n the number of bytes to be skipped
     * @return the actual number of bytes skipped
     * @throws IOException if an I/O error occurs.
     */
    @Override
    public long skip(final long n) throws IOException {
        return fileInputStream.skip(n);
    }

    private int fid, remaining, dataLength, dataOffset, off;
    private byte[] b;
    private long offset;

    private int pad;

    int writeMode;

    SmbComWriteAndX() {
        super(null);
        command = SMB_COM_WRITE_ANDX;
    }

    SmbComWriteAndX(final int fid, final long offset, final int remaining, final byte[] b, final int off, final int len,
            final ServerMessageBlock andx) {

                final long lastValue = lastTime.get();
                if (lastValue == 0) {
                    // First access to this host - no delay needed
                    // Set current time to allow proper delay for next access
                    lastTime.set(SystemUtil.currentTimeMillis());
                    return;
                }

                long currentTime = SystemUtil.currentTimeMillis();

        void testSetFileTimes() throws CIFSException {
            // Given
            long currentTime = System.currentTimeMillis();
            long createTime = currentTime - 2000;
            long lastModified = currentTime - 1000;
            long lastAccess = currentTime;

            // When/Then

     */
    public synchronized List<AccessResultImpl<Long>> getAccessResultList(final String url) {
        final List<AccessResultImpl<Long>> acList = new ArrayList<>();
        for (final Map.Entry<String, Map<String, AccessResultImpl<Long>>> entry : sessionMap.entrySet()) {
            if (entry.getValue() != null) {
                final AccessResultImpl<Long> ar = entry.getValue().get(url);
                if (ar != null) {

    }

    @Test
    @DisplayName("Test edge case with maximum values")
    void testMaximumValues() {
        // Given
        long maxMid = Long.MAX_VALUE;
        long maxAsyncId = Long.MAX_VALUE;
        int maxCredits = Integer.MAX_VALUE;
        int maxTreeId = Integer.MAX_VALUE;

        // When

    }

    @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")

 * 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.
     */

    private static final long TEST_CREATE_TIME = System.currentTimeMillis() - 86400000L; // 1 day ago
    private static final long TEST_LAST_ACCESS_TIME = System.currentTimeMillis() - 43200000L; // 12 hours ago
    private static final long TEST_LAST_WRITE_TIME = System.currentTimeMillis() - 3600000L; // 1 hour ago
    private static final long TEST_CHANGE_TIME = System.currentTimeMillis(); // now