}

    /**
     * Gets the share name.
     *
     * @return the share name
     */
    public String getShareName() {
        return shareName;
    }

    /**
     * Gets the server address.
     *
     * @return the server address
     */
    public InetAddress getServerAddress() {
        return serverAddress;
    }

    /**
     * Gets the service type.
     *

 */

package com.google.common.collect.testing.google;

import static com.google.common.base.Preconditions.checkNotNull;
import static com.google.common.collect.Sets.newHashSet;
import static com.google.common.collect.Sets.newTreeSet;
import static com.google.common.collect.testing.SampleElements.Strings.AFTER_LAST;
import static com.google.common.collect.testing.SampleElements.Strings.AFTER_LAST_2;

    }

    private String registrationId;
    private byte[] contextHandle;

    /**
     * Gets the registration ID to unregister.
     *
     * @return the registration ID
     */
    public String getRegistrationId() {
        return registrationId;
    }

    /**
     * Sets the registration ID to unregister.
     *
     * @param registrationId the registration ID
     */

        return server;
    }

    /**
     * Sets the server address.
     * @param server The server address.
     */
    public void setServer(final String server) {
        this.server = server;
    }

    /**
     * Returns the port number.
     * @return The port number.
     */
    public int getPort() {
        return port;
    }

    /**
     * Sets the port number.
     * @param port The port number.

     */
    @Override
    MetadataResolutionRequest setOffline(boolean offline);

    /**
     * Gets the artifact to resolve metadata for.
     *
     * @return The artifact to resolve metadata for or {@code null} if not set.
     */
    Artifact getArtifact();

    /**
     * Sets the artifact for which to resolve metadata.
     *
     * @param artifact The artifact for which to resolve metadata.

     * Forces all crawlers to stop immediately.
     * Sets the force stop flag and stops all active crawler instances.
     */
    private void forceStop() {
        systemHelper.setForceStop(true);
        if (crawlerList != null) {
            for (final Crawler crawler : crawlerList) {
                crawler.stop();
            }
        }
    }

    /**
     * Gets the total execution time for index updates.
     *

    }

    /**
     * Sets the file information class for the directory query
     *
     * @param fileInformationClass
     *            the fileInformationClass to set
     */
    public void setFileInformationClass(final byte fileInformationClass) {
        this.fileInformationClass = fileInformationClass;
    }

    /**
     * Sets the query flags for the directory enumeration
     *

        this.dataLength = length;
    }

    /**
     * Sets the number of bytes remaining to be written in a sequence of write operations.
     *
     * @param remainingBytes the remainingBytes to set
     */
    public void setRemainingBytes(final int remainingBytes) {
        this.remainingBytes = remainingBytes;
    }

    /**
     * Sets the write operation flags.
     *

    protected String getCharSet(final File file) {
        return charset;
    }

    /**
     * Gets the character encoding used for FTP operations.
     *
     * @return The character encoding
     */
    public String getCharset() {
        return charset;
    }

    /**
     * Sets the character encoding used for FTP operations.
     *
     * @param charset The character encoding to set
     */

			if err == nil || err == io.EOF {
				return entries, err
			}
			entries.truncate(0)
		} else {
			if o.pool < len(z.serverPools) && o.set < len(z.serverPools[o.pool].sets) {
				o.debugln("Resuming", o)
				entries, err = z.serverPools[o.pool].sets[o.set].streamMetadataParts(ctx, *o)
				entries.reuse = true // We read from stream and are not sharing results.
				if err == nil {
					return entries, nil
				}
			} else {