final boolean forceSigning) {
        this.transportContext = tc;

        this.signingEnforced = forceSigning || this.getContext().getConfig().isSigningEnforced();
        this.sessionExpiration = System.currentTimeMillis() + tc.getConfig().getSessionTimeout();

        this.address = address;
        this.port = port;
        this.localAddr = localAddr;
        this.localPort = localPort;

        final CoordinatorHelper helper = createCapturingHelper("node1@host1", null, capturedBody, createMockResponse(200, "{}"));

        final long before = System.currentTimeMillis();
        helper.sendHeartbeat();
        final long after = System.currentTimeMillis();

        assertNotNull(capturedBody.get());
        final Map<String, Object> body = coordinatorHelper.parseJson(capturedBody.get());

        assertEquals("false", config.getApiJsonResponseExceptionIncluded());
    }

    // Test error code generation
    @Test
    public void test_errorCodeGeneration() {
        long timestamp = System.currentTimeMillis();
        String errorCode = "error_code:" + Long.toHexString(timestamp);

        assertTrue(errorCode.startsWith("error_code:"));
        assertTrue(errorCode.length() > 11); // "error_code:" is 11 chars
    }

            this.registrationId = registrationId;
            this.shareName = shareName;
            this.serverAddress = serverAddress;
            this.flags = flags;
            this.timestamp = System.currentTimeMillis();
        }
    }

    /**
     * Start the mock witness service
     *
     * @throws IOException if service startup fails
     */
    public void start() throws IOException {

     * @param resultData The result data from content processing.
     */
    @Override
    public void init(final ResponseData responseData, final ResultData resultData) {

        setCreateTime(System.currentTimeMillis());
        if (responseData != null) {
            BeanUtil.copyBeanToBean(responseData, this);
        }

        final OpenSearchAccessResultData accessResultData = new OpenSearchAccessResultData();

            this.attributes = info.getAttributes() & ATTR_GET_MASK;
            this.attrExpiration = System.currentTimeMillis() + th.getConfig().getAttributeCacheTimeout();

            this.size = info.getSize();
            this.sizeExpiration = System.currentTimeMillis() + th.getConfig().getAttributeCacheTimeout();
            return (T) createResp.getNextResponse();

        private final AtomicInteger activeConnections = new AtomicInteger(0);
        private volatile boolean isHealthy = true;
        private volatile long lastHealthCheck = System.currentTimeMillis();

        public ChannelInfo(String channelId, InetAddress localAddress, InetAddress remoteAddress, NetworkInterface networkInterface,
                SmbTransportImpl transport) {

    void testWriteUTimeWithDST() {
        when(mockConfig.getLocalTimezone()).thenReturn(mockTimeZone);

        byte[] dst = new byte[4];
        long testTime = System.currentTimeMillis();

        // Test when both current time and test time are in DST
        when(mockTimeZone.inDaylightTime(any(Date.class))).thenReturn(true);
        SMB1SigningDigest.writeUTime(mockConfig, testTime, dst, 0);

                mappingWriter.write(output, metadata.getDelegate());
            }
        } else {
            metadataFile.setLastModified(System.currentTimeMillis());
        }
    }

    @Override
    public String toString() {
        return "repository metadata for: '" + getKey() + "'";
    }

        if (DOMAIN == null) {
            throw new SmbException("A domain was not specified");
        }
        synchronized (DOMAIN) {
            final long now = System.currentTimeMillis();
            int retry = 1;

            do {
                if (dc_list_expiration < now) {
                    final NbtAddress[] list = NbtAddress.getAllByName(DOMAIN, 0x1C, null, null);