private final Collection<Artifact> artifacts = new ArrayList<>();

    LocalSnapshotMetadata(Artifact artifact, Date timestamp) {
        super(createMetadata(artifact), (Path) null, timestamp);
    }

    LocalSnapshotMetadata(Metadata metadata, Path path, Date timestamp) {
        super(metadata, path, timestamp);
    }

    private static Metadata createMetadata(Artifact artifact) {
        Snapshot snapshot = new Snapshot();

        protected String propertiesPath;

        /**
         * Number of threads to use for thumbnail generation.
         */
        @Option(name = "-t", aliases = "--numOfThreads", metaVar = "numOfThreads", usage = "The number of threads")
        protected int numOfThreads = 1;

        /**
         * Whether to run in cleanup mode to remove old thumbnails.

     * @param pipeName the name of the pipe to peek
     * @param fid the file identifier for the pipe
     */
    public TransPeekNamedPipe(final Configuration config, final String pipeName, final int fid) {
        super(config, SMB_COM_TRANSACTION, TRANS_PEEK_NAMED_PIPE);
        this.name = pipeName;
        this.fid = fid;
        this.timeout = 0xFFFFFFFF;
        this.maxParameterCount = 6;
        this.maxDataCount = 1;

        // Enable ALPN.
        val names = alpnProtocolNames(protocols)
        sslParameters.applicationProtocols = names.toTypedArray()

        sslSocket.sslParameters = sslParameters
      }
    } else {
      super.configureTlsExtensions(sslSocket, hostname, protocols)
    }
  }

  override fun getSelectedProtocol(sslSocket: SSLSocket): String? =
    if (sslSocket is org.openjsse.javax.net.ssl.SSLSocket) {

     */
    public static void writeUTime(final long t, final byte[] dst, final int dstIndex) {
        writeInt4(t / 1000, dst, dstIndex);
    }

    /**
     * SMB1 protocol header template with magic number 0xFF 'SMB'
     */
    public static final byte[] SMB_HEADER = { (byte) 0xFF, (byte) 'S', (byte) 'M', (byte) 'B', (byte) 0x00, (byte) 0x00, (byte) 0x00,

	go func() {
		defer xioutil.SafeClose(ch)

		concurrency := opts.concurrencyStart

		if opts.autotune {
			// if we have less drives than concurrency then choose
			// only the concurrency to be number of drives to start
			// with - since default '32' might be big and may not
			// complete in total time of 10s.
			if globalEndpoints.NEndpoints() < concurrency {
				concurrency = globalEndpoints.NEndpoints()
			}

    implements MutableNetwork<N, E> {

  /** Constructs a mutable graph with the properties specified in {@code builder}. */
  StandardMutableNetwork(NetworkBuilder<? super N, ? super E> builder) {
    super(builder);
  }

  @Override
  @CanIgnoreReturnValue
  public boolean addNode(N node) {
    checkNotNull(node, "node");

    if (containsNode(node)) {
      return false;
    }

    protected void lookup(MavenContext context) throws Exception {
        if (context.maven == null) {
            super.lookup(context);
            context.maven = context.lookup.lookup(Maven.class);
        }
    }

    @Override
    protected void postCommands(MavenContext context) throws Exception {
        super.postCommands(context);

        Logger logger = context.logger;

    NO_ENTRY_SET;

    @Override
    public Set<Feature<? super Void>> getImpliedFeatures() {
      return emptySet();
    }
  }

  @SuppressWarnings("rawtypes") // class literals
  @Override
  protected List<Class<? extends AbstractTester>> getTesters() {
    List<Class<? extends AbstractTester>> testers = copyToList(super.getTesters());
    testers.add(CollectionSerializationEqualTester.class);

     * @param informationLevel the information level to query
     */
    public Trans2QueryPathInformation(final Configuration config, final String filename, final int informationLevel) {
        super(config, SMB_COM_TRANSACTION2, TRANS2_QUERY_PATH_INFORMATION);
        this.path = filename;
        this.informationLevel = informationLevel;
        this.totalDataCount = 0;
        this.maxParameterCount = 2;