- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 686 for read1 (0.04 sec)
-
cluster/gce/windows/smoke-test.sh
-o jsonpath='{.items[*].status.conditions[?(@.type=="Ready")].status}') for status in $statuses; do if [[ $status == "False" ]]; then echo "ERROR: some Windows node has status != Ready" echo "kubectl get nodes -l kubernetes.io/os=windows" ${kubectl} get nodes -l kubernetes.io/os=windows exit 1 fi done echo "Verified that all Windows nodes have status Ready" } function untaint_windows_nodes {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 20.6K bytes - Viewed (0) -
platforms/core-runtime/files/src/main/java/org/gradle/internal/file/RandomAccessFileInputStream.java
return n; } @Override public int read(byte[] bytes) throws IOException { return file.read(bytes); } @Override public int read() throws IOException { return file.read(); } @Override public int read(byte[] bytes, int offset, int length) throws IOException { return file.read(bytes, offset, length); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 1.6K bytes - Viewed (0) -
maven-settings-builder/src/main/java/org/apache/maven/settings/io/SettingsReader.java
* @throws IOException If the settings could not be deserialized. * @throws SettingsParseException If the input format could not be parsed. */ Settings read(File input, Map<String, ?> options) throws IOException, SettingsParseException; /** * Reads the settings from the specified character reader. The reader will be automatically closed before the method * returns. *
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 3.3K bytes - Viewed (0) -
src/net/http/responsecontroller.go
return nil, nil, errNotSupported() } } } // SetReadDeadline sets the deadline for reading the entire request, including the body. // Reads from the request body after the deadline has been exceeded will return an error. // A zero value means no deadline. // // Setting the read deadline after it has been exceeded will not extend it. func (c *ResponseController) SetReadDeadline(deadline time.Time) error { rw := c.rw for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4.2K bytes - Viewed (0) -
src/io/fs/readfile.go
} // ReadFile reads the named file from the file system fs and returns its contents. // A successful call returns a nil error, not [io.EOF]. // (Because ReadFile reads the whole file, the expected EOF // from the final Read is not treated as an error to be reported.) // // If fs implements [ReadFileFS], ReadFile calls fs.ReadFile. // Otherwise ReadFile calls fs.Open and uses Read and Close // on the returned [File].
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 11 20:25:50 UTC 2023 - 1.8K bytes - Viewed (0) -
internal/store/store.go
DelList(key []string) error Open() error Delete() error Extension() string } // Key denotes the key present in the store. type Key struct { Name string IsLast bool } // replayItems - Reads the items from the store and replays. func replayItems[I any](store Store[I], doneCh <-chan struct{}, log logger, id string) <-chan Key { keyCh := make(chan Key) go func() { defer xioutil.SafeClose(keyCh)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Mar 25 16:44:20 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/btree/BlockStore.java
* Removes the given block from this store. */ void remove(BlockPayload block); /** * Reads the first block from this store. */ <T extends BlockPayload> T readFirst(Class<T> payloadType); /** * Reads a block from this store. */ <T extends BlockPayload> T read(BlockPointer pos, Class<T> payloadType); /** * Writes a block to this store, adding the block if required.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.8K 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)