- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 923 for read1 (0.05 sec)
-
src/internal/zstd/bits.go
return br.r.makeError(int(br.off), msg) } // reverseBitReader reads a bit stream in reverse. type reverseBitReader struct { r *Reader // for error reporting data block // the bits to read off uint32 // current offset into data start uint32 // start in data; we read backward to start bits uint32 // bits ready to be returned cnt uint32 // number of valid bits in bits field }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 18 20:34:13 UTC 2023 - 3.3K bytes - Viewed (0) -
docs/bucket/replication/sio-error.sh
done sleep 10 ./mc alias set myminio1 http://localhost:9001 minioadmin minioadmin ./mc alias set myminio2 http://localhost:9101 minioadmin minioadmin ./mc ready myminio1 ./mc ready myminio2 sleep 1 ./mc mb myminio1/testbucket/ --with-lock ./mc mb myminio2/testbucket/ --with-lock ./mc encrypt set sse-s3 my-minio-key myminio1/testbucket/
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat May 18 18:19:01 UTC 2024 - 1.7K bytes - Viewed (0) -
docs/bucket/replication/test_del_marker_proxying.sh
chmod +x mc fi export MC_HOST_sitea=http://minio:minio123@127.0.0.1:9001 export MC_HOST_siteb=http://minio:minio123@127.0.0.1:9002 ./mc ready sitea ./mc ready siteb ./mc mb sitea/bucket ./mc version enable sitea/bucket ./mc mb siteb/bucket ./mc version enable siteb/bucket # Set bucket replication ./mc replicate add sitea/bucket --remote-bucket siteb/bucket
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 11:38:26 UTC 2024 - 1.8K bytes - Viewed (0) -
src/net/textproto/reader.go
} // closeDot drains the current DotReader if any, // making sure that it reads until the ending dot line. func (r *Reader) closeDot() { if r.dot == nil { return } buf := make([]byte, 128) for r.dot != nil { // When Read reaches EOF or an error, // it will set r.dot == nil. r.dot.Read(buf) } } // ReadDotBytes reads a dot-encoding and returns the decoded data. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 22.1K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/xml/ToolchainsXmlFactory.java
* under the License. */ package org.apache.maven.api.services.xml; import org.apache.maven.api.annotations.Experimental; import org.apache.maven.api.toolchain.PersistedToolchains; /** * Reads and writes a {@link PersistedToolchains} object to/from XML. * * @since 4.0.0 */ @Experimental
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Mar 23 05:29:39 UTC 2023 - 1.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go
return func(t *testing.T, pageSize, estimatedProcessedObjects uint64) { if reads := transformer.GetReadsAndReset(); reads != estimatedProcessedObjects { t.Errorf("unexpected reads: %d, expected: %d", reads, estimatedProcessedObjects) } estimatedGetCalls := uint64(1) if pageSize != 0 { // We expect that kube-apiserver will be increasing page sizes
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 26.5K bytes - Viewed (0) -
src/encoding/csv/reader.go
// Read returns the record along with the error [ErrFieldCount]. // If the record contains a field that cannot be parsed, // Read returns a partial record along with the parse error. // The partial record contains all fields read before the error. // If there is no data left to be read, Read returns nil, [io.EOF]. // If [Reader.ReuseRecord] is true, the returned slice may be shared // between multiple calls to Read.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 21:32:28 UTC 2024 - 14.2K bytes - Viewed (0) -
platforms/software/publish/src/main/java/org/gradle/api/publish/tasks/GenerateModuleMetadata.java
} @TaskAction void run() { InputState inputState = inputState(); if (!(inputState instanceof InputState.Ready)) { throw new IllegalStateException(inputState.toString()); } writeModuleMetadata( ((InputState.Ready) inputState).moduleMetadataSpec.get() ); } private void writeModuleMetadata(ModuleMetadataSpec moduleMetadataSpec) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Dec 21 07:21:42 UTC 2023 - 12.1K bytes - Viewed (0) -
src/vendor/golang.org/x/crypto/cryptobyte/string.go
func (s *String) ReadUint16(out *uint16) bool { v := s.read(2) if v == nil { return false } *out = uint16(v[0])<<8 | uint16(v[1]) return true } // ReadUint24 decodes a big-endian, 24-bit value into out and advances over it. // It reports whether the read was successful. func (s *String) ReadUint24(out *uint32) bool { v := s.read(3) if v == nil { return false }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 10 16:32:44 UTC 2023 - 5.2K bytes - Viewed (0) -
src/crypto/rand/rand_unix.go
r.used.Store(2) } r.mu.Unlock() } return io.ReadFull(r.f, b) } // hideAgainReader masks EAGAIN reads from /dev/urandom. // See golang.org/issue/9205 type hideAgainReader struct { r io.Reader } func (hr hideAgainReader) Read(p []byte) (n int, err error) { n, err = hr.r.Read(p) if errors.Is(err, syscall.EAGAIN) { err = nil } return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Oct 01 08:32:46 UTC 2022 - 1.8K bytes - Viewed (0)