if (shutdown && runningTasks == 0) {
          return true;
        } else if (nanos <= 0) {
          return false;
        } else {
          long now = System.nanoTime();
          NANOSECONDS.timedWait(lock, nanos);
          nanos -= System.nanoTime() - now; // subtract the actual time we waited
        }
      }
    }
  }

  /**

    /** Time-to-live for cached authentication in milliseconds */
    private long authenticationTTL = 3600000L; // 1 hour default
    /** Timestamp when the authentication was created */
    private long authenticationTimestamp = System.currentTimeMillis();
    /** Flag to track if this authenticator has been closed */
    private volatile boolean closed = false;

    /**
     * Construct anonymous credentials
     */

        // all fixed inputs go into the suffix:
        // + label
        System.arraycopy(label, 0, suffix, 0, label.length);
        // + 1 byte 0x00
        // + context
        System.arraycopy(context, 0, suffix, label.length + 1, context.length);
        // + 4 byte (== r bits) big endian encoding of L
        suffix[suffix.length - 1] = (byte) 128;

 * <ul>
 *   <li>missing metadata</li>
 *   <li>version range violations</li>
 *   <li>version circular dependencies</li>
 *   <li>missing artifacts</li>
 *   <li>network/transfer errors</li>
 *   <li>file system errors: permissions</li>
 * </ul>
 *
 * TODO carlos: all these possible has*Exceptions and get*Exceptions methods make the clients too

********************************************************************************

## TensorFlow's Official CI and Build/Test Scripts

TensorFlow's official CI jobs run the scripts in this folder. Our internal CI
system, Kokoro, schedules our CI jobs by combining a build script with a file
from the `envs` directory that is filled with configuration options:

-   Nightly jobs (Run nightly on the `nightly` branch)

      val headers = response.headers
      for ((name, value) in headers) {
        println("$name: $value")
      }
      println()
    }

    // Stream the response to the System.out as it is returned from the server.
    val out = System.out.sink()
    val source = response.body.source()
    while (!source.exhausted()) {
      out.write(source.buffer, source.buffer.size)
      out.flush()
    }

        final TimestampConverter converter = new TimestampConverter("yyyy/MM/dd HH:mm:ss");
        final java.sql.Timestamp result = (java.sql.Timestamp) converter.getAsObject("2008/12/31 12:34:56");
        System.out.println(result);
        assertThat(converter.getAsString(result), is("2008/12/31 12:34:56"));
    }

    /**
     * @throws Exception
     */
    @Test
    public void testIsTarget() throws Exception {

                data[SIGNATURE_OFFSET + i] = 0;
            }

            mac.update(data, 0, data.length);
            byte[] signature = mac.doFinal();

            // Place signature in data
            System.arraycopy(signature, 0, data, SIGNATURE_OFFSET, SIGNATURE_LENGTH);

            boolean result = digest.verify(data, 0, data.length, 0, msg);

        byte[] buffer = new byte[512];
        int headerStart = 0;
        int bodyStart = Smb2Constants.SMB2_HEADER_LENGTH;

        // Write SMB2 header (64 bytes)
        // Protocol ID
        System.arraycopy(new byte[] { (byte) 0xFE, 'S', 'M', 'B' }, 0, buffer, headerStart, 4);
        // Structure size (64)
        SMBUtil.writeInt2(64, buffer, headerStart + 4);
        // Credit charge

        // Verify capabilities (4 bytes)
        assertEquals(DEFAULT_CAPABILITIES, SMBUtil.readInt4(buffer, 0));

        // Verify client GUID (16 bytes)
        byte[] extractedGuid = new byte[16];
        System.arraycopy(buffer, 4, extractedGuid, 0, 16);
        assertArrayEquals(defaultClientGuid, extractedGuid);

        // Verify security mode (2 bytes)
        assertEquals(DEFAULT_SECURITY_MODE, SMBUtil.readInt2(buffer, 20));