Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 988 for readOp (0.1 sec)

  1. cmd/encryption-v1.go

    	reader, err := sio.DecryptReader(client, sio.Config{
    		Key:            objectEncryptionKey,
    		SequenceNumber: seqNumber,
    		CipherSuites:   fips.DARECiphers(),
    	})
    	if err != nil {
    		return nil, crypto.ErrInvalidCustomerKey
    	}
    	return reader, nil
    }
    
    // DecryptBlocksRequestR - same as DecryptBlocksRequest but with a
    // reader
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
  2. cmd/streaming-signature-v4.go

    	return nil
    }
    
    // readCRLF - check if reader only has '\r\n' CRLF character.
    // returns malformed encoding if it doesn't.
    func readCRLF(reader io.Reader) error {
    	buf := make([]byte, 2)
    	_, err := io.ReadFull(reader, buf[:2])
    	if err != nil {
    		return err
    	}
    	if buf[0] != '\r' || buf[1] != '\n' {
    		return errMalformedEncoding
    	}
    	return nil
    }
    
    // Read a line of bytes (up to \n) from b.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  3. internal/ringbuffer/ring_buffer.go

    		return r.err
    	}
    	return nil
    }
    
    // Read reads up to len(p) bytes into p. It returns the number of bytes read (0 <= n <= len(p)) and any error encountered.
    // Even if Read returns n < len(p), it may use all of p as scratch space during the call.
    // If some data is available but not len(p) bytes, Read conventionally returns what is available instead of waiting for more.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. internal/ringbuffer/ring_buffer_test.go

    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	if _, err := rb.TryRead([]byte{0}); err != (testError1{}) {
    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	rb.CloseWithError(testError2{})
    	if _, err := rb.Read(nil); err != (testError1{}) {
    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	if _, err := rb.Read([]byte{0}); err != (testError1{}) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  5. internal/crypto/sse.go

    	return
    }
    
    // EncryptSinglePart encrypts an io.Reader which must be the
    // body of a single-part PUT request.
    func EncryptSinglePart(r io.Reader, key ObjectKey) io.Reader {
    	r, err := sio.EncryptReader(r, sio.Config{MinVersion: sio.Version20, Key: key[:], CipherSuites: fips.DARECiphers()})
    	if err != nil {
    		logger.CriticalIf(context.Background(), errors.New("Unable to encrypt io.Reader using object key"))
    	}
    	return r
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  6. internal/http/headers.go

    	// Header indicates if the etag should be preserved by client
    	MinIOSourceETag = "x-minio-source-etag"
    
    	// Writes expected write quorum
    	MinIOWriteQuorum = "x-minio-write-quorum"
    
    	// Reads expected read quorum
    	MinIOReadQuorum = "x-minio-read-quorum"
    
    	// Indicates if we are using default storage class and there was problem loading config
    	// if this header is set to "true"
    	MinIOStorageClassDefaults = "x-minio-storage-class-defaults"
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 28 15:31:56 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  7. cmd/object-api-utils.go

    		ObjInfo:    oi,
    		Reader:     r,
    		cleanUpFns: cleanupFns,
    	}, nil
    }
    
    // ObjReaderFn is a function type that takes a reader and returns
    // GetObjectReader and an error. Request headers are passed to provide
    // encryption parameters. cleanupFns allow cleanup funcs to be
    // registered for calling after usage of the reader.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  8. cmd/postpolicyform.go

    }
    
    // parsePostPolicyForm - Parse JSON policy string into typed PostPolicyForm structure.
    func parsePostPolicyForm(r io.Reader) (PostPolicyForm, error) {
    	reader, err := sanitizePolicy(r)
    	if err != nil {
    		return PostPolicyForm{}, err
    	}
    
    	d := json.NewDecoder(reader)
    
    	// Convert po into interfaces and
    	// perform strict type conversion using reflection.
    	var rawPolicy struct {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  9. build-logic/documentation/src/main/groovy/gradlebuild/docs/ReleaseNotesTransformer.java

        private File releaseNotesJavascript;
        private Set<File> jqueryFiles;
    
        public ReleaseNotesTransformer(Reader original) {
            super(original);
            this.in = new Reader() {
                Reader delegate = null;
    
                @Override
                public int read(char[] cbuf, int off, int len) throws IOException {
                    if (delegate == null) {
                        delegate = transform(original);
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Thu Oct 03 05:02:20 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  10. build-logic/dependency-modules/src/main/kotlin/gradlebuild.dependency-modules.gradle.kts

            it.configure(dependencies.components, configurations)
        }
    }
    
    fun readCapabilities(source: File): List<CapabilitySpec> {
        JsonReader(source.reader(Charsets.UTF_8)).use { reader ->
            reader.isLenient = true
            return Gson().fromJson(reader)
        }
    }
    
    inline
    fun <reified T> Gson.fromJson(json: JsonReader): T = this.fromJson(json, object : TypeToken<T>() {}.type)
    
    
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Wed Jun 05 20:15:18 UTC 2024
    - 9.7K bytes
    - Viewed (0)
Back to top