}

        if (event instanceof LogEvent) {
            loggingProtocol.sendOutputEvent((LogEvent) event);
        } else if (event instanceof StyledTextOutputEvent) {
            loggingProtocol.sendOutputEvent((StyledTextOutputEvent) event);
        }
    }

        this.listener = listener;
    }

    @Override
    public void onOutput(OutputEvent event) {
        if (event instanceof StyledTextOutputEvent) {
            onTextEvent((StyledTextOutputEvent) event);
        } else if (event instanceof LogLevelChangeEvent) {
            onLogLevelChange((LogLevelChangeEvent) event);
        } else {
            throw new IllegalArgumentException();

        // Log events
        registry.register(LogEvent.class, new LogEventSerializer(logLevelSerializer, throwableSerializer));
        registry.register(StyledTextOutputEvent.class, new StyledTextOutputEventSerializer(logLevelSerializer, new ListSerializer<StyledTextOutputEvent.Span>(new SpanSerializer(factory.getSerializerFor(StyledTextOutput.Style.class)))));

import org.gradle.integtests.fixtures.AbstractIntegrationSpec
import org.gradle.integtests.fixtures.BuildOperationsFixture
import org.gradle.internal.logging.events.StyledTextOutputEvent

class JavaCompilerDaemonFailureIntegrationTest extends AbstractIntegrationSpec {

    def "startup failure messages from a compiler daemon are associated with the task that starts it"() {

            formatted = Lists.newArrayList(
                new StyledTextOutputEvent.Span(StyledTextOutput.Style.Header, statusPrefix),
                new StyledTextOutputEvent.Span(failing ? StyledTextOutput.Style.FailureHeader : StyledTextOutput.Style.SuccessHeader, coloredProgress),
                new StyledTextOutputEvent.Span(StyledTextOutput.Style.Header, statusSuffix));
        }
        return formatted;
    }

package org.gradle.workers.internal

import org.gradle.api.internal.tasks.execution.ExecuteTaskActionBuildOperationType
import org.gradle.integtests.fixtures.BuildOperationsFixture
import org.gradle.internal.logging.events.StyledTextOutputEvent

class WorkerDaemonFailureLoggingIntegrationTest extends AbstractDaemonWorkerExecutorIntegrationSpec {
    def setup() {
        def workAction = fixture.getWorkActionThatCreatesFiles("NormalWorkAction")

 * limitations under the License.
 */

package org.gradle.process.internal.worker.child;

import org.gradle.internal.logging.events.LogEvent;
import org.gradle.internal.logging.events.StyledTextOutputEvent;

/**
 * Protocol for sending logging information back from a worker process to the daemon.
 */
public interface WorkerLoggingProtocol {
    /**
     * Sends a log event to the daemon to be logged.
     */

 * limitations under the License.
 */

package org.gradle.internal.logging.console

import org.fusesource.jansi.Ansi
import org.gradle.internal.logging.events.StyledTextOutputEvent
import org.gradle.internal.logging.text.StyledTextOutput
import org.gradle.internal.nativeintegration.console.ConsoleMetaData
import spock.lang.Specification

class DefaultRedrawableLabelTest extends Specification{

package org.gradle.internal.logging.format;

import org.gradle.internal.logging.events.StyledTextOutputEvent;

import java.util.List;

public interface LogHeaderFormatter {
    /**
     * Given a message, return possibly-styled output for displaying message meant to categorize
     * other messages "below" it, if any.
     */
    List<StyledTextOutputEvent.Span> format(String description, String status, boolean failed);

import org.gradle.internal.logging.events.OutputEventListener;
import org.gradle.internal.logging.events.ProgressStartEvent;
import org.gradle.internal.logging.events.RenderableOutputEvent;
import org.gradle.internal.logging.events.StyledTextOutputEvent;
import org.gradle.internal.logging.sink.OutputEventListenerManager;
import org.gradle.internal.operations.BuildOperationProgressEventEmitter;
import org.gradle.internal.operations.CurrentBuildOperationRef;