response_map.put( request, response );
                doSend( request );
                response.expiration = System.currentTimeMillis() + timeout;
                while (!response.isReceived) {
                    wait( timeout );
                    timeout = response.expiration - System.currentTimeMillis();
                    if (timeout <= 0) {
                        throw new TransportException( name +

    private static class CacheEntry <T> {

        long expiration;
        Map<String, T> map;


        CacheEntry ( long ttl ) {
            this.expiration = System.currentTimeMillis() + ttl * 1000L;
            this.map = new ConcurrentHashMap<>();
        }
    }

    private static class NegativeCacheEntry <T> extends CacheEntry<T> {

        /**
         * @param ttl
         */

        try ( SmbResource f = getDefaultShareRoot() ) {
            f.getDiskFreeSpace();
        }
    }


    public void assertCloseTime ( long timeMs ) {
        if ( timeMs - System.currentTimeMillis() > 5 * 60 * 1000L ) {
            assertTrue("Time is not within 30s, check clocks " + new Date(timeMs), false);
        }
    }


    @Test

            long k = makeKey(curReq);

            if ( firstKey == 0 ) {
                firstKey = k;
            }

            if ( timeout > 0 ) {
                curResp.setExpiration(System.currentTimeMillis() + timeout);
            }
            else {
                curResp.setExpiration(null);
            }

            curResp.setMid(k);
            this.response_map.put(k, curResp);

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

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

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

        do {
            if ( this.dcListExpiration < now ) {
                Address[] list = getTransportContext().getNameServiceClient().getNbtAllByName(domain, 0x1C, null, null);

        log.debug("Read " + length + " took " + ( System.currentTimeMillis() - start ));
    }


    /**
     * @param bufSize
     * @param length
     * @param os
     * @throws IOException
     */
    static void writeRandom ( int bufSize, long length, DataOutput os ) throws IOException {
        long start = System.currentTimeMillis();
        byte buffer[] = new byte[bufSize];
        long p = 0;

        }
        log.debug("Read " + length + " took " + ( System.currentTimeMillis() - start ));
    }


    /**
     * @param bufSize
     * @param length
     * @param os
     * @throws IOException
     */
    static void writeRandom ( int bufSize, long length, OutputStream os ) throws IOException {
        long start = System.currentTimeMillis();
        byte buffer[] = new byte[bufSize];
        long p = 0;

        if( CACHE_POLICY == 0 ) {
            return;
        }
        long expiration = -1;
        if( CACHE_POLICY != FOREVER ) {
            expiration = System.currentTimeMillis() + CACHE_POLICY * 1000;
        }
        cacheAddress( hostName, addr, expiration );
    }
    static void cacheAddress( Name hostName, NbtAddress addr, long expiration ) {
        if( CACHE_POLICY == 0 ) {

                    byte[] clientChallenge) {
        if (type2 == null || responseKeyNT == null || clientChallenge == null) {
            return null;
        }
        long nanos1601 = (System.currentTimeMillis() + MILLISECONDS_BETWEEN_1970_AND_1601) * 10000L;
        return NtlmPasswordAuthentication.getNTLMv2Response(responseKeyNT,
                    type2.getChallenge(),
                    clientChallenge,