- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 923 for read1 (0.04 sec)
-
platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/Serializer.java
public interface Serializer<T> { /** * Reads the next object from the given stream. The implementation must not perform any buffering, so that it reads only those bytes from the input stream that are * required to deserialize the next object. * * @throws EOFException When the next object cannot be fully read due to reaching the end of stream. */ T read(Decoder decoder) throws EOFException, Exception; /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 1.3K bytes - Viewed (0) -
operator/pkg/util/util.go
s := make([]string, 0, len(m)) for k, v := range m { if v { s = append(s, k) } } return s } // ReadFilesWithFilter reads files from path, for a directory it recursively reads files and filters the results // for single file it directly reads the file. It returns a concatenated output of all matching files' content. func ReadFilesWithFilter(path string, filter FileFilter) (string, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 02 13:01:43 UTC 2023 - 3.9K bytes - Viewed (0) -
docs/distributed/SIZING.md
# Erasure code sizing guide ## Toy Setups Capacity constrained environments, MinIO will work but not recommended for production. | servers | drives (per node) | stripe_size | parity chosen (default) | tolerance for reads (servers) | tolerance for writes (servers) | |--------:|------------------:|------------:|------------------------:|------------------------------:|-------------------------------:|
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Aug 15 23:04:20 UTC 2023 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// Before accessing the cacher's cache, wait for the ready to be ok. // This is necessary to prevent users from accessing structures that are // uninitialized or are being repopulated right now. // ready needs to be set to false when the cacher is paused or stopped. // ready needs to be set to true when the cacher is ready to use after // initialization. ready *ready // Underlying storage.Interface.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
src/runtime/debug_test.go
ogcpercent := debug.SetGCPercent(-1) runtime.GC() // ready is a buffered channel so debugCallWorker won't block // on sending to it. This makes it less likely we'll catch // debugCallWorker while it's in the runtime. ready := make(chan *runtime.G, 1) var stop uint32 done := make(chan error) go debugCallWorker(ready, &stop, done) g = <-ready return g, func() { atomic.StoreUint32(&stop, 1) err := <-done
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 15:08:04 UTC 2023 - 8K bytes - Viewed (0) -
src/os/dir.go
// // If n <= 0, Readdir returns all the FileInfo from the directory in // a single slice. In this case, if Readdir succeeds (reads all // the way to the end of the directory), it returns the slice and a // nil error. If it encounters an error before the end of the // directory, Readdir returns the FileInfo read until that point // and a non-nil error. // // Most clients are better served by the more efficient ReadDir method.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 6.1K bytes - Viewed (0) -
platforms/native/language-native/src/test/groovy/org/gradle/language/nativeplatform/internal/incremental/sourceparser/PreprocessingReaderTest.groovy
line.setLength(0) } return result.toString() } def "reads from empty text"() { expect: def reader = new PreprocessingReader(new StringReader("")) !reader.readNextLine(new StringBuilder()) } def "reads single line"() { expect: def reader = new PreprocessingReader(new StringReader("abc(123)"))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 4.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/plan9/dir_plan9.go
func pstring(b []byte, s string) []byte { b = pbit16(b, uint16(len(s))) n := copy(b, s) return b[n:] } // gbit8 reads an 8-bit number from b and returns it with the remaining slice of b. func gbit8(b []byte) (uint8, []byte) { return uint8(b[0]), b[1:] } // gbit16 reads a 16-bit number in little-endian order from b and returns it with the remaining slice of b. func gbit16(b []byte) (uint16, []byte) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 15 19:02:39 UTC 2021 - 5.6K bytes - Viewed (0) -
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) -
tensorflow/compiler/mlir/tensorflow/utils/import_utils.h
#include "absl/strings/string_view.h" #include "tensorflow/core/lib/core/status.h" #include "tensorflow/core/platform/protobuf.h" namespace tensorflow { // Reads text (.pbtext) or binary (.pb) format of a proto message from the given // buffer. Returns error status of the file is not found or malformed proto. // Note that text protos can only be parsed when full protobuf::Message protos
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 06 09:43:41 UTC 2020 - 2K bytes - Viewed (0)