- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 87 for writerPCs (0.22 sec)
-
pilot/pkg/model/xds_cache.go
// If the cache has been updated to a newer push context, the write will be dropped silently. // This ensures stale data does not overwrite fresh data when dealing with concurrent // writers. Add(entry XdsCacheEntry, pushRequest *PushRequest, value *discovery.Resource) // Get retrieves the cached value if it exists. Get(entry XdsCacheEntry) *discovery.Resource
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 02 07:02:05 UTC 2023 - 6.1K bytes - Viewed (0) -
src/cmd/link/internal/ld/link.go
// Link holds the context for writing object code from a compiler // or for reading that input into the linker. type Link struct { Target ErrorReporter ArchSyms outSem chan int // limits the number of output writers Out *OutBuf version int // current version number for static/file-local symbols Debugvlog int Bso *bufio.Writer Loaded bool // set after all inputs have been loaded as symbols
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 19 15:59:22 UTC 2022 - 5.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/validator.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 14:00:05 UTC 2024 - 7.4K bytes - Viewed (0) -
src/encoding/gob/encoder.go
} // Make sure we're single-threaded through here, so multiple // goroutines can share an encoder. enc.mutex.Lock() defer enc.mutex.Unlock() // Remove any nested writers remaining due to previous errors. enc.w = enc.w[0:1] ut, err := validUserType(value.Type()) if err != nil { return err } enc.err = nil enc.byteBuf.Reset()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 7.8K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
func (r *RingBuffer) Reset() { r.mu.Lock() defer r.mu.Unlock() // Set error so any readers/writers will return immediately. r.setErr(errors.New("reset called"), true) if r.block { r.readCond.Broadcast() r.writeCond.Broadcast() } // Unlock the mutex so readers/writers can finish. r.mu.Unlock() r.wg.Wait() r.mu.Lock() r.r = 0 r.w = 0 r.err = nil r.isFull = false
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/bitrot.go
// Close all the readers. func closeBitrotReaders(rs []io.ReaderAt) { for _, r := range rs { if r != nil { if br, ok := r.(io.Closer); ok { br.Close() } } } } // Close all the writers. func closeBitrotWriters(ws []io.Writer) { for _, w := range ws { if w != nil { if bw, ok := w.(io.Closer); ok { bw.Close() } } } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 7.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
private val messageFrameBuffer = Buffer() /** Lazily initialized on first use. */ private var messageInflater: MessageInflater? = null // Masks are only a concern for server writers. private val maskKey: ByteArray? = if (isClient) null else ByteArray(4) private val maskCursor: Buffer.UnsafeCursor? = if (isClient) null else Buffer.UnsafeCursor() interface FrameCallback {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/CharStreamsTest.java
result = CharStreams.asWriter(secretlyAWriter); assertSame(secretlyAWriter, result); } // CharStreams.copy has type specific optimizations for Readers,StringBuilders and Writers public void testCopy() throws IOException { StringBuilder builder = new StringBuilder(); long copied = CharStreams.copy(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 11.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CharStreamsTest.java
result = CharStreams.asWriter(secretlyAWriter); assertSame(secretlyAWriter, result); } // CharStreams.copy has type specific optimizations for Readers,StringBuilders and Writers public void testCopy() throws IOException { StringBuilder builder = new StringBuilder(); long copied = CharStreams.copy(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 11.2K bytes - Viewed (0) -
src/go/doc/testdata/testing.1.golden
FILENAMES testdata/benchmark.go testdata/example.go testdata/testing.go VARIABLES // 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: Mon Dec 13 18:45:54 UTC 2021 - 8.4K bytes - Viewed (0)