}

// StartMetadataServer starts a mock GCE metadata server.
func StartMetadataServer() (*MetadataServer, error) {
	ms := &MetadataServer{}
	httpServer := httptest.NewServer(http.HandlerFunc(ms.getToken))
	ms.server = httpServer
	url, err := url.Parse(httpServer.URL)
	if err != nil {
		return nil, fmt.Errorf("parse URL failed: %v", err)
	}
	if err := os.Setenv("GCE_METADATA_HOST", url.Host); err != nil {

 */

package org.gradle.tooling.internal.consumer;

import org.gradle.initialization.BuildCancellationToken;

public interface CancellationTokenInternal {
    BuildCancellationToken getToken();

        private CancellationTokenImpl(DefaultBuildCancellationToken token) {
            this.token = token;
        }

        @Override
        public BuildCancellationToken getToken() {
            return token;
        }

        @Override
        public boolean isCancellationRequested() {
            return token.isCancellationRequested();
        }
    }

/**
 * Data to identify and connect to a daemon.
 */
public interface DaemonConnectDetails {
    String getUid();

    Long getPid();

    Address getAddress();

    byte[] getToken();

		instanceID:       getInstanceID(ipv6, headers),
	}
}

func requestHeaders(ipv6 bool) map[string]string {
	// try to get token first, if it fails, fallback to IMDSv1
	token := getToken(ipv6)
	if token == "" {
		log.Debugf("token is empty, will fallback to IMDSv1")
	}

	headers := make(map[string]string, 1)
	if token != "" {
		headers["X-aws-ec2-metadata-token"] = token
	}
	return headers

        this.identifier = identifier;
        this.token = token;
    }

    /**
     * Returns the authentication token for this command.
     */
    public byte[] getToken() {
        return token;
    }

    /**
     * @return an id that is guaranteed to be unique in the same process
     */
    public UUID getIdentifier() {
        return identifier;
    }

    public void test_new1() {
        final KuromojiItem kuromojiItem = new KuromojiItem(1, "t1", "s1", "r1", "p1");
        assertEquals(1, kuromojiItem.getId());
        assertEquals("t1", kuromojiItem.getToken());
        assertEquals("s1", kuromojiItem.getSegmentation());
        assertEquals("r1", kuromojiItem.getReading());
        assertEquals("p1", kuromojiItem.getPos());
        assertNull(kuromojiItem.getNewToken());

                if (connection == null) {
                    continue;
                }
                dispatch(connection, new InvalidateVirtualFileSystemAfterChange(changedPaths, idGenerator.generateId(), connection.getDaemon().getToken()));
            }
        }
    }

    private static void dispatch(Connection<Message> connection, Command command) {
        Throwable failure = null;
        try {
            connection.dispatch(command);

        DaemonClientConnection daemonConnection = getConnector().startSingleUseDaemon();
        Build build = new Build(getIdGenerator().generateId(), daemonConnection.getDaemon().getToken(), action, buildRequestContext.getClient(), buildRequestContext.getStartTime(), buildRequestContext.isInteractive(), parameters);

            if (connection != null) {
                try {
                    final ReportStatus statusCommand = new ReportStatus(idGenerator.generateId(), daemon.getToken());
                    final Status status = reportStatusDispatcher.dispatch(connection, statusCommand);
                    if (status != null) {
                        statuses.add(status);