Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 187 for reader_r (0.11 sec)

  1. cmd/post-policy-fan-out.go

    				if err != nil {
    					errs[idx] = err
    					return
    				}
    
    				reader, err = reader.WithEncryption(hr, &objectEncryptionKey)
    				if err != nil {
    					errs[idx] = err
    					return
    				}
    			}
    
    			objInfo, err := objectAPI.PutObject(ctx, bucket, req.Key, reader, ObjectOptions{
    				Versioned:        globalBucketVersioningSys.PrefixEnabled(bucket, req.Key),
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  2. internal/crypto/key_test.go

    package crypto
    
    import (
    	"bytes"
    	"crypto/rand"
    	"encoding/hex"
    	"io"
    	"testing"
    
    	"github.com/minio/minio/internal/logger"
    )
    
    var shortRandom = func(limit int64) io.Reader { return io.LimitReader(rand.Reader, limit) }
    
    func recoverTest(i int, shouldPass bool, t *testing.T) {
    	if err := recover(); err == nil && !shouldPass {
    		t.Errorf("Test %d should fail but passed successfully", i)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  3. src/archive/zip/zip_test.go

    	}
    }
    
    type repeatedByte struct {
    	off int64
    	b   byte
    	n   int64
    }
    
    // rleBuffer is a run-length-encoded byte buffer.
    // It's an io.Writer (like a bytes.Buffer) and also an io.ReaderAt,
    // allowing random-access reads.
    type rleBuffer struct {
    	buf []repeatedByte
    }
    
    func (r *rleBuffer) Size() int64 {
    	if len(r.buf) == 0 {
    		return 0
    	}
    	last := &r.buf[len(r.buf)-1]
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  4. build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/classanalysis/AnalyzeAndShade.kt

                    fun visitClassFile(file: Path) {
                        try {
                            val reader = ClassReader(Files.newInputStream(file))
                            val details = classes[reader.className]
                            details.visited = true
                            val classWriter = ClassWriter(0)
                            reader.accept(
                                ClassRemapper(
                                    classWriter,
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Mon Oct 28 12:55:30 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  5. internal/http/request-recorder.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"bytes"
    	"io"
    )
    
    // RequestRecorder - records the
    // of a given io.Reader
    type RequestRecorder struct {
    	// Data source to record
    	io.Reader
    	// Response body should be logged
    	LogBody bool
    
    	// internal recording buffer
    	buf bytes.Buffer
    	// total bytes read including header size
    	bytesRead int
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Apr 12 21:37:19 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  6. tensorflow/c/eager/c_api_experimental_reader.h

    // streamz->GetCell("label-value")->IncrementBy(1);
    //
    // The test code can then read and test the value of that counter:
    //
    // auto* reader = TFE_MonitoringNewCounterReader("name");
    // test();
    // int64_t value = TFE_MonitoringReadCounter1(reader, "label-value");
    
    // Opaque handle to a reader.
    typedef struct TFE_MonitoringCounterReader TFE_MonitoringCounterReader;
    
    // Returns a handle to be used for reading values from streamz counter. The
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Thu Apr 20 03:14:47 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  7. internal/hash/reader_test.go

    	}
    }
    
    // Tests hash reader checksum verification.
    func TestHashReaderVerification(t *testing.T) {
    	testCases := []struct {
    		desc              string
    		src               io.Reader
    		size              int64
    		actualSize        int64
    		md5hex, sha256hex string
    		err               error
    	}{
    		0: {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 10.3K bytes
    - Viewed (0)
  8. internal/auth/credentials.go

    	accessKey, err = GenerateAccessKey(accessKeyMaxLen, rand.Reader)
    	if err != nil {
    		return "", "", err
    	}
    	secretKey, err = GenerateSecretKey(secretKeyMaxLen, rand.Reader)
    	if err != nil {
    		return "", "", err
    	}
    	return accessKey, secretKey, nil
    }
    
    // GenerateAccessKey returns a new access key generated randomly using
    // the given io.Reader. If random is nil, crypto/rand.Reader is used.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 28 17:14:16 UTC 2024
    - 12K bytes
    - Viewed (0)
  9. cmd/object-multipart-handlers.go

    	if isCompressed {
    		wantEncryption := crypto.Requested(r.Header) || isEncrypted
    		s2c, cb := newS2CompressReader(reader, actualPartSize, wantEncryption)
    		idxCb = cb
    		defer s2c.Close()
    		reader = etag.Wrap(s2c, reader)
    		length = -1
    	}
    
    	srcInfo.Reader, err = hash.NewReader(ctx, reader, length, "", "", actualPartSize)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/api/admin/badword/ApiAdminBadwordAction.java

            validateApi(body, messages -> {});
            CommonPoolUtil.execute(() -> {
                try (Reader reader = new BufferedReader(new InputStreamReader(body.badWordFile.getInputStream(), getCsvEncoding()))) {
                    badWordService.importCsv(reader);
                    suggestHelper.storeAllBadWords(false);
                } catch (final Exception e) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top