</mxCell>
                <mxCell id="90" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;dashed=1;startArrow=none;startFill=0;endArrow=classic;endFill=1;strokeWidth=3;" parent="1" source="101" target="32" edge="1">
                    <mxGeometry relative="1" as="geometry">
                        <mxPoint x="390" y="-190" as="sourcePoint"/>

	var startStack, endStack trace.Stack
	var startG, endG trace.GoID
	startTime, endTime := ctx.startTime, ctx.endTime
	if task.Start != nil {
		startStack = task.Start.Stack()
		startG = task.Start.Goroutine()
		startTime = task.Start.Time()
	}
	if task.End != nil {
		endStack = task.End.Stack()
		endG = task.End.Goroutine()
		endTime = task.End.Time()
	}
	arg := struct {
		ID     uint64 `json:"id"`

        long endTime = finishEvent.getEndTime();
        Throwable failure = finishEvent.getFailure();
        if (failure != null) {
            return new DefaultProjectConfigurationFailureResult(startTime, endTime, singletonList(DefaultFailure.fromThrowable(failure)), pluginApplicationResults);
        }
        return new DefaultProjectConfigurationSuccessResult(startTime, endTime, pluginApplicationResults);
    }

                </mxCell>
                <mxCell id="90" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;dashed=1;startArrow=none;startFill=0;endArrow=classic;endFill=1;strokeWidth=3;" parent="1" source="101" target="32" edge="1">
                    <mxGeometry relative="1" as="geometry">
                        <mxPoint x="390" y="-190" as="sourcePoint"/>

        event
    }

    private InternalSuccessResult buildSuccess(long startTime, long endTime) {
        InternalSuccessResult result = Mock(InternalSuccessResult)
        result.startTime >> startTime
        result.endTime >> endTime

        result
    }

    private InternalFailureResult buildFailure(long startTime, long endTime, InternalFailure failure) {
        InternalFailureResult result = Mock(InternalFailureResult)

public class DefaultTaskSkippedResult extends AbstractTaskResult implements InternalTaskSkippedResult {
    private final String skipMessage;

    public DefaultTaskSkippedResult(long startTime, long endTime, String skipMessage, boolean incremental) {
        super(startTime, endTime, "skipped", incremental, null);
        this.skipMessage = skipMessage;
    }

    @Override
    public String getSkipMessage() {
        return skipMessage;
    }

public class DefaultWorkItemFailureResult extends DefaultOperationFailureResult implements WorkItemFailureResult {

    public DefaultWorkItemFailureResult(long startTime, long endTime, List<? extends Failure> failures) {
        super(startTime, endTime, failures);
    }

        long startTime = finishEvent.getStartTime();
        long endTime = finishEvent.getEndTime();
        ExecuteTaskBuildOperationType.Result result = (ExecuteTaskBuildOperationType.Result) finishEvent.getResult();
        boolean incremental = result != null && result.isIncremental();

        if (state.getUpToDate()) {

func (m *bucketMeasurement) updateExponentialMovingAverage(endTime time.Time) {
	// Calculate aggregate avg bandwidth and exp window avg
	m.lock.Lock()
	defer func() {
		m.startTime = endTime
		m.lock.Unlock()
	}()

	if m.startTime.IsZero() {
		return
	}

	if endTime.Before(m.startTime) {
		return
	}

	duration := endTime.Sub(m.startTime)

    def "downloads distribution with valid user-agent information"() {
        given:
        server.expect(server.get("/custom-dist.zip").expectUserAgent(matchesNameAndVersion("Gradle Tooling API", GradleVersion.current().getVersion())).sendFile(distribution.binDistribution))

        and:
        toolingApi.withConnector {
            it.useDistribution(URI.create("http://localhost:${server.port}/custom-dist.zip"))
        }

        when: