trace.cpuLogRead[1].close()
	trace.cpuSleep.wake()

	// Wait until the logger goroutine exits.
	<-trace.cpuLogDone

	// Clear state for the next trace.
	trace.cpuLogDone = nil
	trace.cpuLogRead[0] = nil
	trace.cpuLogRead[1] = nil
	trace.cpuSleep.close()
}

// traceReadCPU attempts to read from the provided profBuf[gen%2] and write
// into the trace. Returns true if there might be more to read or false

// shouldn't result in a doubling of memory usage, even if all converted events
// are kept alive, as we free batches once we're done with them.
//
// The conversion process is lossless.

package trace

import (
	"errors"
	"fmt"
	"internal/trace/event"
	"internal/trace/event/go122"
	"internal/trace/internal/oldtrace"
	"io"
)

        this.trackers = ImmutableList.copyOf(trackers);
    }

    private void collectTrackers(Set<BuildOperationTracker> dest, List<? extends BuildOperationTracker> trackers) {
        for (BuildOperationTracker tracker : trackers) {
            if (!dest.contains(tracker)) {
                collectTrackers(dest, tracker.getTrackers());
                dest.add(tracker);
            }
        }
    }

      {{- end }}
      {{- if not (eq .Values.global.proxy.tracer "none") }}
      tracing:
      {{- if eq .Values.global.proxy.tracer "lightstep" }}
        lightstep:
          # Address of the LightStep Satellite pool
          address: {{ .Values.global.tracer.lightstep.address }}
          # Access Token used to communicate with the Satellite pool
          accessToken: {{ .Values.global.tracer.lightstep.accessToken }}

files: "fake/user/code/file_y.py"
files: "fake/user/code/file_z.py"
traces {
  key: "MobilenetV1/Conv2d_0/BatchNorm/beta@"
  value {
    file_line_cols {
      file_index: 33
      line: 383
    }
  }
}
traces {
  key: "MobilenetV1/Conv2d_0/BatchNorm/beta/read@"
  value {
    file_line_cols {
      file_index: 49
      line: 886
    }
  }
}
traces {
  key: "MobilenetV1/Conv2d_0/BatchNorm/gamma@"
  value {

func (S Tracer) Warn(ctx context.Context, s string, i ...interface{}) {
	S.Logger.Warn(ctx, s, i...)
}

func (S Tracer) Error(ctx context.Context, s string, i ...interface{}) {
	S.Logger.Error(ctx, s, i...)
}

func (S Tracer) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) {
	S.Logger.Trace(ctx, begin, fc, err)
	S.Test(ctx, begin, fc, err)

files: "fake/user/code/file_y.py"
files: "fake/user/code/file_z.py"
traces {
  key: "MobilenetV1/Conv2d_0/BatchNorm/beta@"
  value {
    file_line_cols {
      file_index: 33
      line: 383
    }
  }
}
traces {
  key: "MobilenetV1/Conv2d_0/BatchNorm/beta/read@"
  value {
    file_line_cols {
      file_index: 49
      line: 886
    }
  }
}
traces {
  key: "MobilenetV1/Conv2d_0/BatchNorm/gamma@"
  value {

files : [ "org_tensorflow/tensorflow/compiler/mlir/tensorflow/tests/graphdef2mlir/error-message-with-source-info.pbtxt.fake_py.debug"]
traces: {
    key  : "x@"
    value: {
      file_line_cols: {
        line      : 1
        col       : 1
      }
    }
}
traces: {
    key  : "x_y_sum@"
    value: {
      file_line_cols: {
        line      : 3
        col       : 1
      }
      file_line_cols: {
        line      : 4

      {{- end }}
      {{- if not (eq .Values.global.proxy.tracer "none") }}
      tracing:
      {{- if eq .Values.global.proxy.tracer "lightstep" }}
        lightstep:
          # Address of the LightStep Satellite pool
          address: {{ .Values.global.tracer.lightstep.address }}
          # Access Token used to communicate with the Satellite pool
          accessToken: {{ .Values.global.tracer.lightstep.accessToken }}

        val tracer = ResolutionTracer(
            ExpressionResolverImpl(this, functionCallResolver),
            StatementResolverImpl(propertyAccessResolver, this, this),
            ErrorCollectorImpl()
        )
        statementResolver = tracer
        expressionResolver = tracer
        errorCollector = tracer