Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 320 for race (0.04 sec)

  1. 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)
  2. 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)
  3. src/runtime/runtime2.go

    	waitReasonFlushProcCaches                         // "flushing proc caches"
    	waitReasonTraceGoroutineStatus                    // "trace goroutine status"
    	waitReasonTraceProcStatus                         // "trace proc status"
    	waitReasonPageTraceFlush                          // "page trace flush"
    	waitReasonCoroutine                               // "coroutine"
    )
    
    var waitReasonStrings = [...]string{
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top