Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for traceapi (0.12 sec)

  1. pkg/tracing/tracing.go

    	"go.opentelemetry.io/otel/propagation"
    	"go.opentelemetry.io/otel/sdk/resource"
    	"go.opentelemetry.io/otel/sdk/trace"
    	semconv "go.opentelemetry.io/otel/semconv/v1.17.0"
    	traceapi "go.opentelemetry.io/otel/trace"
    
    	"istio.io/istio/pkg/log"
    )
    
    // Inspired by https://github.com/moby/buildkit/blob/d9a6afdf089a7c4b97cac704a60ad70c21086f12/util/tracing/detect/otlp.go#L18
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jul 26 01:07:39 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  2. src/runtime/tracemap.go

    // appear in the table anymore.
    func (tab *traceMap) stealID() uint64 {
    	return tab.seq.Add(1)
    }
    
    // put inserts the data into the table.
    //
    // It's always safe for callers to noescape data because put copies its bytes.
    //
    // Returns a unique ID for the data and whether this is the first time
    // the data has been added to the map.
    func (tab *traceMap) put(data unsafe.Pointer, size uintptr) (uint64, bool) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 17:03:35 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  3. src/runtime/tracecpu.go

    Carlos Amedee <******@****.***> 1712158572 -0400
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 17:03:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  4. src/runtime/traceevent.go

    	return traceArg(trace.stringTab[tl.gen%2].put(tl.gen, s))
    }
    
    // uniqueString returns a traceArg representing s which may be passed to write.
    // The string is assumed to be unique or long, so it will be written out to
    // the trace eagerly.
    func (tl traceLocker) uniqueString(s string) traceArg {
    	return traceArg(trace.stringTab[tl.gen%2].emit(tl.gen, s))
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:47:01 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  5. src/runtime/traceallocfree.go

    	traceRelease(trace)
    }
    
    func traceSpanTypeAndClass(s *mspan) traceArg {
    	if s.state.get() == mSpanInUse {
    		return traceArg(s.spanclass) << 1
    	}
    	return traceArg(1)
    }
    
    // SpanExists records an event indicating that the span exists.
    func (tl traceLocker) SpanExists(s *mspan) {
    	tl.eventWriter(traceGoRunning, traceProcRunning).commit(traceEvSpan, traceSpanID(s), traceArg(s.npages), traceSpanTypeAndClass(s))
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 20:32:51 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  6. src/runtime/tracestatus.go

    	// Trace the status.
    	if stackID == 0 {
    		w = w.event(traceEvGoStatus, traceArg(goid), traceArg(uint64(mid)), traceArg(status))
    	} else {
    		w = w.event(traceEvGoStatusStack, traceArg(goid), traceArg(uint64(mid)), traceArg(status), traceArg(stackID))
    	}
    
    	// Trace any special ranges that are in-progress.
    	if markAssist {
    		w = w.event(traceEvGCMarkAssistActive, traceArg(goid))
    	}
    	return w
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 17:03:35 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  7. pkg/test/framework/components/zipkin/kube.go

    	// Get 100 most recent traces
    	client := http.Client{
    		Timeout: 5 * time.Second,
    	}
    	scopes.Framework.Debugf("make get call to zipkin api %v", c.address+fmt.Sprintf(tracesAPI, limit, spanName, annotationQuery))
    	resp, err := client.Get(c.address + fmt.Sprintf(tracesAPI, limit, spanName, annotationQuery))
    	if err != nil {
    		scopes.Framework.Debugf("zipking err %v", err)
    		return nil, err
    	}
    	if resp.StatusCode != http.StatusOK {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 14 19:29:38 UTC 2023
    - 8K bytes
    - Viewed (0)
  8. src/runtime/trace2map_test.go

    // license that can be found in the LICENSE file.
    
    package runtime_test
    
    import (
    	. "runtime"
    	"strconv"
    	"sync"
    	"testing"
    )
    
    func TestTraceMap(t *testing.T) {
    	var m TraceMap
    
    	// Try all these operations multiple times between resets, to make sure
    	// we're resetting properly.
    	for range 3 {
    		var d = [...]string{
    			"a",
    			"b",
    			"aa",
    			"ab",
    			"ba",
    			"bb",
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Apr 10 18:52:49 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  9. src/runtime/tracestring.go

    // writing strings out into the trace.
    type traceStringTable struct {
    	// lock protects buf.
    	lock mutex
    	buf  *traceBuf // string batches to write out to the trace.
    
    	// tab is a mapping of string -> unique ID.
    	tab traceMap
    }
    
    // put adds a string to the table, emits it, and returns a unique ID for it.
    func (t *traceStringTable) put(gen uintptr, s string) uint64 {
    	// Put the string in the table.
    	ss := stringStructOf(&s)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 17:03:35 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  10. src/runtime/tracetype.go

    import (
    	"internal/abi"
    	"internal/goarch"
    	"unsafe"
    )
    
    // traceTypeTable maps stack traces (arrays of PC's) to unique uint32 ids.
    // It is lock-free for reading.
    type traceTypeTable struct {
    	tab traceMap
    }
    
    // put returns a unique id for the type typ and caches it in the table,
    // if it's seeing it for the first time.
    //
    // N.B. typ must be kept alive forever for this to work correctly.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 20:31:27 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top