- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 73 for writes (0.11 sec)
-
src/cmd/dist/build.go
if err := os.WriteFile(importcfg, buf.Bytes(), 0666); err != nil { fatalf("cannot write importcfg file: %v", err) } var archive string // The next loop will compile individual non-Go files. // Hand the Go files to the compiler en masse. // For packages containing assembly, this writes go_asm.h, which // the assembly files will need. pkgName := pkg
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 18:34:40 UTC 2024 - 54K bytes - Viewed (0) -
src/cmd/link/internal/ld/lib.go
} if ctxt.NeedCodeSign() { err := machoCodeSign(ctxt, *flagOutfile) if err != nil { Exitf("%s: code signing failed: %v", os.Args[0], err) } } } // passLongArgsInResponseFile writes the arguments into a file if they // are very long. func (ctxt *Link) passLongArgsInResponseFile(argv []string, altLinker string) []string { c := 0 for _, arg := range argv { c += len(arg) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 18:45:27 UTC 2024 - 88.6K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
bps int } func (c *slowConn) Write(p []byte) (int, error) { if c.bps == 0 { panic("too slow") } t0 := time.Now() wrote := 0 for wrote < len(p) { time.Sleep(100 * time.Microsecond) allowed := int(time.Since(t0).Seconds()*float64(c.bps)) / 8 if allowed > len(p) { allowed = len(p) } if wrote < allowed { n, err := c.Conn.Write(p[wrote:allowed]) wrote += n
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config_test.go
service: tt.service, } h.state.Store(&tt.state) err := h.rotateDEKOnKeyIDChange(ctx, tt.statusKeyID, "panda") klog.Flush() klog.SetOutput(io.Discard) // prevent further writes into buf if diff := cmp.Diff(tt.wantLogs, logLines(buf.String())); len(diff) > 0 { t.Errorf("log mismatch (-want +got):\n%s", diff) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 72.3K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
as.True(ok) as.Equal(int64(3), val.Value()) val, ok = allocatable[v1.ResourceName(resourceName2)] as.True(ok) as.Equal(int64(0), val.Value()) as.Empty(removed) // Writes and re-reads checkpoints. Verifies we create a stopped endpoint // for resourceName2, its capacity is set to zero, and we still consider // it as a DevicePlugin resource. This makes sure any pod that was scheduled
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
src/runtime/mprof.go
semrelease(&goroutineProfile.sema) return n, true } // tryRecordGoroutineProfileWB asserts that write barriers are allowed and calls // tryRecordGoroutineProfile. // //go:yeswritebarrierrec func tryRecordGoroutineProfileWB(gp1 *g) { if getg().m.p.ptr() == nil { throw("no P available, write barriers are forbidden") } tryRecordGoroutineProfile(gp1, nil, osyield) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 53.3K bytes - Viewed (0) -
src/cmd/go/internal/modload/buildlist.go
// rare cases (such as if a dependency splits out a nested module, or merges a // nested module back into a parent module). direct map[string]bool graphOnce sync.Once // guards writes to (but not reads from) graph graph atomic.Pointer[cachedGraph] } // A cachedGraph is a non-nil *ModuleGraph, together with any error discovered // while loading that graph. type cachedGraph struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 16:04:44 UTC 2024 - 53.8K bytes - Viewed (0) -
src/runtime/mgcscavenge.go
value atomic.Uint64 } // load loads and unpacks a scavChunkData. func (sc *atomicScavChunkData) load() scavChunkData { return unpackScavChunkData(sc.value.Load()) } // store packs and writes a new scavChunkData. store must be serialized // with other calls to store. func (sc *atomicScavChunkData) store(ssc scavChunkData) { sc.value.Store(ssc.pack()) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:48:45 UTC 2024 - 52.3K bytes - Viewed (0) -
src/cmd/go/internal/modget/get.go
for _, q := range queries { if q.matchesPackages { patterns = append(patterns, q.pattern) } } if len(patterns) == 0 { return nil } // mu guards concurrent writes to upgrades, which will be sorted // (to restore determinism) after loading. var mu sync.Mutex findPackage := func(ctx context.Context, path string, m module.Version) (versionOk bool) { version := "latest"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:26:32 UTC 2024 - 66.5K bytes - Viewed (0) -
src/runtime/asm_amd64.s
get_tls(R14) MOVQ g(R14), R14 #ifndef GOOS_plan9 XORPS X15, X15 #endif JMP ·sigpanic<ABIInternal>(SB) // gcWriteBarrier informs the GC about heap pointer writes. // // gcWriteBarrier returns space in a write barrier buffer which // should be filled in by the caller. // gcWriteBarrier does NOT follow the Go ABI. It accepts the // number of bytes of buffer needed in R11, and returns a pointer
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 11 20:38:24 UTC 2024 - 60.4K bytes - Viewed (0)