- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 161 for race (0.19 sec)
-
pkg/kubelet/config/config_test.go
} func TestNewPodAddedSetReconciled(t *testing.T) { tCtx := ktesting.Init(t) // Create and touch new test pods, return the new pods and touched pod. We should create new pod list // before touching to avoid data race. newTestPods := func(touchStatus, touchSpec bool) ([]*v1.Pod, *v1.Pod) { pods := []*v1.Pod{ CreateValidPod("changeable-pod-0", "new"), CreateValidPod("constant-pod-1", "new"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 17.1K bytes - Viewed (0) -
src/cmd/compile/internal/types2/instantiate.go
res = sig default: // only types and functions can be generic panic(fmt.Sprintf("%v: cannot instantiate %v", pos, orig)) } // Update all contexts; it's possible that we've lost a race. return updateContexts(res) } // validateTArgLen checks that the number of type arguments (got) matches the // number of type parameters (want); if they don't match an error is reported.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:01:18 UTC 2024 - 12.7K bytes - Viewed (0) -
src/runtime/pprof/pprof.go
// and controls where the stack trace begins. Passing skip=0 begins the // trace in the function calling Add. For example, given this // execution stack: // // Add // called from rpc.NewClient // called from mypkg.Run // called from main.main // // Passing skip=0 begins the stack trace at the call to Add inside rpc.NewClient. // Passing skip=1 begins the stack trace at the call to NewClient inside mypkg.Run.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:52:17 UTC 2024 - 30.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
thread.join(); // It's possible to race and suspend the thread just before the park call actually takes effect, // causing the thread to be suspended for 3.5 seconds, and then park itself for 2 seconds after // being resumed. To avoid a flake in this scenario, calculate how long that thread actually // waited and assert based on that time. Empirically, the race where the thread ends up waiting
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
return err } // If there are no IPAddress depending on this ServiceCIDR is safe to remove it, // however, there can be a race when the allocators still consider the ServiceCIDR // ready and allocate a new IPAddress from them, to avoid that, we wait during a // a grace period to be sure the deletion change has been propagated to the allocators // and no new IPAddress is going to be allocated.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
src/os/exec/exec.go
// (It is safe and non-racy to do so on Unix platforms, and users might not // test with the race detector on all platforms; // see https://go.dev/issue/62596.) // // So we will pass the fully resolved path to os.StartProcess, but leave // c.Path as is: missing a bit of logging information seems less harmful // than triggering a surprising data race, and if the user really cares
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 41.4K bytes - Viewed (0) -
internal/logger/target/http/http.go
workers int64 maxWorkers int64 // workerStartMu sync.Mutex lastStarted time.Time 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 // If this webhook is being re-configured we will
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 14.9K bytes - Viewed (0) -
src/os/file_unix.go
if e != nil { return nil, &PathError{Op: "open", Path: name, Err: e} } // open(2) itself won't handle the sticky bit on *BSD and Solaris if setSticky { setStickyBit(name) } // There's a race here with fork/exec, which we are // content to live with. See ../syscall/exec_unix.go. if !supportsCloseOnExec { syscall.CloseOnExec(r) } f := newFile(r, name, kindOpenFile, unix.HasNonblockFlag(flag))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 13:52:34 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/xds/server.go
con := ctx.XdsConnection() // Do not call: defer close(con.pushChannel). The push channel will be garbage collected // when the connection is no longer used. Closing the channel can cause subtle race conditions // with push. According to the spec: "It's only necessary to close a channel when it is important // to tell the receiving goroutines that all data have been sent."
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
src/runtime/runtime2.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 47.9K bytes - Viewed (0)