Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 481 for race (0.06 sec)

  1. doc/next/9-todo.md

    CL 561935 - crypto CL that used purego tag and mentioned accepted-but-not-implemented proposal https://go.dev/issue/23172 to document purego tag; doesn't need a release note
    CL 568340 - fixed a spurious race in time.Ticker.Reset (added via accepted proposal https://go.dev/issue/33184), doesn't seem to need a release note
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 17:18:52 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. pkg/controller/storageversionmigrator/storageversionmigrator.go

    	svm, err := svmc.svmListers.Get(name)
    	if apierrors.IsNotFound(err) {
    		// no work to do, don't fail and requeue
    		return nil
    	}
    	if err != nil {
    		return err
    	}
    	// working with a copy to avoid race condition between this and resource version controller
    	toBeProcessedSVM := svm.DeepCopy()
    
    	if IsConditionTrue(toBeProcessedSVM, svmv1alpha1.MigrationSucceeded) || IsConditionTrue(toBeProcessedSVM, svmv1alpha1.MigrationFailed) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  3. src/sort/sort_test.go

    func TestCountSortOps(t *testing.T)   { countOps(t, Sort, "Sort  ") }
    
    func bench(b *testing.B, size int, algo func(Interface), name string) {
    	if stringspkg.HasSuffix(testenv.Builder(), "-race") && size > 1e4 {
    		b.Skip("skipping slow benchmark on race builder")
    	}
    	b.StopTimer()
    	data := make(intPairs, size)
    	x := ^uint32(0)
    	for i := 0; i < b.N; i++ {
    		for n := size - 3; n <= size+3; n++ {
    			for i := 0; i < len(data); i++ {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 07 19:41:04 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  4. src/cmd/link/internal/ld/lib.go

    var internalpkg = []string{
    	"crypto/internal/boring",
    	"crypto/internal/boring/syso",
    	"crypto/x509",
    	"net",
    	"os/user",
    	"runtime/cgo",
    	"runtime/race",
    	"runtime/race/internal/amd64v1",
    	"runtime/race/internal/amd64v3",
    	"runtime/msan",
    	"runtime/asan",
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 21 18:45:27 UTC 2024
    - 88.6K bytes
    - Viewed (0)
  5. src/runtime/netpoll_windows.go

    		// and the timer expired just while calling NtCancelWaitCompletionPacket, in which case
    		// this call fails to cancel the association to avoid a race condition.
    		// This is a rare case, so we can just avoid using the high resolution timer this time.
    	default:
    		println("runtime: NtCancelWaitCompletionPacket failed; errno=", errno)
    		throw("runtime: netpoll failed")
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 26 19:58:28 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go

    	// to avoid race condition when accessing/modifying request (e.g. headers)
    	rCopy := r.Clone(r.Context())
    	go func() {
    		defer func() {
    			err := recover()
    			// do not wrap the sentinel ErrAbortHandler panic value
    			if err != nil && err != http.ErrAbortHandler {
    				// Same as stdlib http server code. Manually allocate stack
    				// trace buffer size to prevent excessively large logs
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  7. src/internal/poll/fd_unix.go

    	if err := fd.incref(); err != nil {
    		return err
    	}
    	defer fd.decref()
    	// Atomic store so that concurrent calls to SetBlocking
    	// do not cause a race condition. isBlocking only ever goes
    	// from 0 to 1 so there is no real race here.
    	atomic.StoreUint32(&fd.isBlocking, 1)
    	return syscall.SetNonblock(fd.Sysfd, false)
    }
    
    // Darwin and FreeBSD can't read or write 2GB+ files at a time,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 04:09:44 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  8. pkg/istio-agent/xds_proxy_delta.go

    					con.sendDeltaRequest(&discovery.DeltaDiscoveryRequest{
    						TypeUrl: model.ProxyConfigType,
    					})
    				}
    				// set flag before sending the initial request to prevent race.
    				initialRequestsSent.Store(true)
    				// Fire of a configured initial request, if there is one
    				p.connectedMutex.RLock()
    				initialRequest := p.initialDeltaHealthRequest
    				if initialRequest != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 04 20:29:08 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  9. internal/logger/target/kafka/kafka.go

    type Target struct {
    	status int32
    
    	totalMessages  int64
    	failedMessages int64
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan interface{}
    	logChMu sync.RWMutex
    
    	// store to persist and replay the logs to the target
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun Jun 02 03:03:39 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  10. testing/performance/src/templates/native-dependents-resources/googleTest/libs/googleTest/1.7.0/include/gtest/internal/gtest-filepath.h

      // already exists. The number will be incremented until a pathname is found
      // that does not already exist.
      // Examples: 'dir/foo_test.xml' or 'dir/foo_test_1.xml'.
      // There could be a race condition if two or more processes are calling this
      // function at the same time -- they could both pick the same filename.
      static FilePath GenerateUniqueFileName(const FilePath& directory,
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 9.4K bytes
    - Viewed (0)
Back to top