- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 87 for writerPCs (0.24 sec)
-
src/archive/tar/strconv.go
} // validPAXRecord reports whether the key-value pair is valid where each // record is formatted as: // // "%d %s=%s\n" % (size, key, value) // // Keys and values should be UTF-8, but the number of bad writers out there // forces us to be a more liberal. // Thus, we only reject all keys with NUL, and only reject NULs in values // for the PAX version of the USTAR string fields. // The key must not contain an '=' character.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 01 14:28:42 UTC 2023 - 9K bytes - Viewed (0) -
src/testing/iotest/reader.go
// Copyright 2009 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Package iotest implements Readers and Writers useful mainly for testing. package iotest import ( "bytes" "errors" "fmt" "io" ) // OneByteReader returns a Reader that implements // each non-empty Read by reading one byte from r.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 17:55:47 UTC 2023 - 8K bytes - Viewed (0) -
src/runtime/tracecpu.go
w.varint(stackID) trace.cpuBuf[gen%2] = w.traceBuf } return !eof } // traceCPUFlush flushes trace.cpuBuf[gen%2]. The caller must be certain that gen // has completed and that there are no more writers to it. func traceCPUFlush(gen uintptr) { // Flush any remaining trace buffers containing CPU samples. if buf := trace.cpuBuf[gen%2]; buf != nil { systemstack(func() { lock(&trace.lock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 8.7K bytes - Viewed (0) -
src/runtime/tracestack.go
return id } // dump writes all previously cached stacks to trace buffers, // releases all memory and resets state. It must only be called once the caller // can guarantee that there are no more writers to the table. func (t *traceStackTable) dump(gen uintptr) { stackBuf := make([]uintptr, traceStackSize) w := unsafeTraceWriter(gen, nil) if root := (*traceMapNode)(t.tab.root.Load()); root != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 14:38:56 UTC 2024 - 11K bytes - Viewed (0) -
cluster/gce/windows/common.psm1
# result into our powershell environment so we can make syscalls from this script. # We make syscalls directly, because whatever the powershell cmdlets do under the hood, # they can't seem to open the log files concurrently with writers. # See https://docs.microsoft.com/en-us/dotnet/framework/interop/marshaling-data-with-platform-invoke # for details on which unmanaged types map to managed types. $SyscallDefinitions = @'
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 19 14:47:38 UTC 2022 - 25.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler_test.go
} etag = response.Header.Get("ETag") } }() } waitGroup.Wait() } // Show the handler is capable of serving many concurrent readers and many // concurrent writers without tripping up. Good to run with go '-race' detector // since there are not many "correctness" checks func TestAbuse(t *testing.T) { manager := discoveryendpoint.NewResourceManager("apis") numReaders := 100
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 00:29:39 UTC 2024 - 28.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/json/json.go
return utilyaml.NewDocumentDecoder(r) } type yamlFrameWriter struct { w io.Writer } // Write separates each document with the YAML document separator (`---` followed by line // break). Writers must write well formed YAML documents (include a final line break). func (w yamlFrameWriter) Write(data []byte) (n int, err error) { if _, err := w.w.Write([]byte("---\n")); err != nil { return 0, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 25 16:08:07 UTC 2022 - 12K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/interfaces.go
// retrying the update until success if there is index conflict. // Note that object passed to tryUpdate may change across invocations of tryUpdate() if // other writers are simultaneously updating it, so tryUpdate() needs to take into account // the current contents of the object when deciding how the update object should look.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 07:53:48 UTC 2024 - 14.8K bytes - Viewed (0) -
src/go/doc/testdata/testing.go
import ( "flag" "fmt" "os" "runtime" "runtime/pprof" "strconv" "strings" "time" ) var ( // The short flag requests that tests run more quickly, but its functionality // is provided by test writers themselves. The testing package is just its // home. The all.bash installation script sets it to make installation more // efficient, but by default the flag is off so a plain "go test" will do a // full test of the package.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Oct 02 02:28:27 UTC 2022 - 11.8K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
} return meta.GetResourceVersion(), nil } // Patch applies only the modifications made in the PatchFunc rather than doing a full replace. Useful to avoid // read-modify-write conflicts when there are many concurrent-writers to the same resource. func (cl *Client) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) { modified, patchType := patchFn(orig.DeepCopy())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0)