- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 320 for race (0.04 sec)
-
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) -
src/database/sql/sql_test.go
// Test failure will happen with a panic or other race condition being // reported. rows, _ := tx.QueryContext(ctx, "WAIT|"+qwait+"|SELECT|people|name|") if rows != nil { var name string // Call Next to test Issue 21117 and check for races. for rows.Next() { // Scan the buffer so it is read and checked for races. rows.Scan(&name) } rows.Close() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
src/cmd/gofmt/gofmt.go
// (If that happens, we could, say, append to src to finish the read, or // proceed with a truncated buffer — but the fact that it changed at all // indicates a possible race with someone editing the file, so we prefer to // stop to avoid corrupting it.) src := make([]byte, size+1) n, err := io.ReadFull(in, src) switch err { case nil, io.EOF, io.ErrUnexpectedEOF:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 15.1K bytes - Viewed (0) -
src/time/tick_test.go
// the first drain1 has pulled the value out. // This is rare, but it does happen on overloaded builder machines. // It can also be reproduced on an M3 MacBook Pro using: // // go test -c strings // stress ./strings.test & # chew up CPU // go test -c -race time // stress -p 48 ./time.test -test.count=10 -test.run=TestChan/asynctimerchan=1/Ticker drain1() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller_test.go
informerFactory.WaitForCacheSync(ctx.Done()) // Add claims that only exist in the mutation cache. for _, claim := range tc.claimsInCache { ec.claimCache.Mutation(claim) } // Simulate race: stop informers, add more pods that the controller doesn't know about. stopInformers() for _, pod := range tc.podsLater { _, err := fakeKubeClient.CoreV1().Pods(pod.Namespace).Create(ctx, pod, metav1.CreateOptions{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 08:56:16 UTC 2024 - 28.2K bytes - Viewed (0) -
src/cmd/go/internal/load/pkg.go
} // On ARM with GOARM=5, it forces an import of math, for soft floating point. if cfg.Goarch == "arm" { deps = append(deps, "math") } // Using the race detector forces an import of runtime/race. if cfg.BuildRace { deps = append(deps, "runtime/race") } // Using memory sanitizer forces an import of runtime/msan. if cfg.BuildMSan { deps = append(deps, "runtime/msan") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 28 17:00:51 UTC 2024 - 120K bytes - Viewed (0) -
src/net/http/serve_test.go
// “[block] until all outstanding requests on this server have completed”, // causing the call to Logf below to race with the end of the test. // // Since the client doesn't cancel the request until we have copied half // the body, this call to add happens before the test is cleaned up, // preventing the race. wg.Add(1) defer wg.Done() n, err := io.CopyN(rw, req.Body, bodySize)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
return nil }, }) req, _ := http.NewRequestWithContext(ctx, "GET", "http://go.dev/", nil) proxyHandler.ServeHTTP(rw, req) }() // Trigger data race while iterating over response headers. // When run with -race, this causes the condition in https://go.dev/issue/65123 often // enough to detect reliably. for _ = range rw.Header() { } } func Test1xxResponses(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0)