- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 923 for read1 (0.06 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/factory_test.go
}, } for _, tc := range tests { t.Run(tc.name, func(t *testing.T) { ready := make(chan struct{}) tc.cfg.Transport.ServerList = client.Endpoints() newETCD3Client = func(c storagebackend.TransportConfig) (*clientv3.Client, error) { defer close(ready) dummyKV := mockKV{ get: func(ctx context.Context) (*clientv3.GetResponse, error) { select {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 29 15:58:10 UTC 2022 - 12.1K bytes - Viewed (0) -
src/runtime/export_unix_test.go
} type M = m var waitForSigusr1 struct { rdpipe int32 wrpipe int32 mID int64 } // WaitForSigusr1 blocks until a SIGUSR1 is received. It calls ready // when it is set up to receive SIGUSR1. The ready function should // cause a SIGUSR1 to be sent. The r and w arguments are a pipe that // the signal handler can use to report when the signal is received. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 20 21:27:51 UTC 2023 - 2.3K bytes - Viewed (0) -
src/cmd/go/internal/modindex/build_read.go
r.syntaxError() } } // readIdent reads an identifier from the input. // If an identifier is not present, readIdent records a syntax error. func (r *importReader) readIdent() { c := r.peekByte(true) if !isIdent(c) { r.syntaxError() return } for isIdent(r.peekByte(false)) { r.peek = 0 } } // readString reads a quoted string literal from the input.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 23 10:10:21 UTC 2023 - 13K bytes - Viewed (0) -
src/io/pipe.go
// with code expecting an [io.Writer]. // // Reads and Writes on the pipe are matched one to one // except when multiple Reads are needed to consume a single Write. // That is, each Write to the [PipeWriter] blocks until it has satisfied // one or more Reads from the [PipeReader] that fully consume // the written data. // The data is copied directly from the Write to the corresponding // Read (or Reads); there is no internal buffering. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 18 19:34:35 UTC 2023 - 5.1K bytes - Viewed (0) -
platforms/core-execution/execution/src/test/groovy/org/gradle/internal/execution/history/impl/FileCollectionFingerprintSerializerTest.groovy
def serializer = new FileCollectionFingerprintSerializer(stringInterner) def "reads and writes empty fingerprints"() { when: def out = serialize(FileCollectionFingerprint.EMPTY, serializer) then: out == FileCollectionFingerprint.EMPTY } def "reads and writes fingerprints"() { def hash = TestHashCodes.hashCodeFrom(1234)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:46:15 UTC 2023 - 4.1K bytes - Viewed (0) -
src/encoding/gob/decoder.go
err error } // NewDecoder returns a new decoder that reads from the [io.Reader]. // If r does not also implement [io.ByteReader], it will be wrapped in a // [bufio.Reader]. func NewDecoder(r io.Reader) *Decoder { dec := new(Decoder) // We use the ability to read bytes as a plausible surrogate for buffering. if _, ok := r.(io.ByteReader); !ok { r = bufio.NewReader(r) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 7.2K bytes - Viewed (0) -
docs/contribute/concurrency.md
Framing rules make it impractical to implement http/2 correctly on a single blocking thread. The flow-control features introduce feedback between reads and writes, requiring writes to acknowledge reads and reads to throttle writes. In OkHttp we expose a blocking API over a framed protocol. This document explains the code and policy that makes that work. ### Threads #### Application's calling thread
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/filelock/LockFileAccess.java
lockInfoAccess.writeLockInfo(lockFileAccess, lockInfo); } public LockInfo readLockInfo() throws IOException { return lockInfoAccess.readLockInfo(lockFileAccess); } /** * Reads the lock state from the lock file, possibly writing out a new lock file if not present or empty. */ public LockState ensureLockState() throws IOException { return lockStateAccess.ensureLockState(lockFileAccess);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 3.1K bytes - Viewed (0) -
platforms/software/maven/src/integTest/groovy/org/gradle/api/publish/maven/MavenPublishBuildOperationIntegrationTest.groovy
writes1.size() == 20 writes1[0].details.location == m1.artifact.uri.toString() writes1[0].result.bytesWritten == m1.artifact.file.length() def reads1 = buildOperations.all(ExternalResourceReadBuildOperationType) reads1.size() == 1 when: // Publish again buildFile << """ version = '1.3' """ def m2 = repo.module("org.test", "test", "1.3")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 14:02:46 UTC 2023 - 3.3K bytes - Viewed (0) -
internal/ioutil/hardlimitreader.go
// A HardLimitedReader reads from R but limits the amount of // data returned to just N bytes. Each call to Read // updates N to reflect the new amount remaining. // Read returns EOF when N <= 0 or when the underlying R returns EOF. type HardLimitedReader struct { R io.Reader // underlying reader N int64 // max bytes remaining } func (l *HardLimitedReader) Read(p []byte) (n int, err error) { if l.N < 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat May 06 02:53:12 UTC 2023 - 2K bytes - Viewed (0)