Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 208 for newHeader (0.1 sec)

  1. internal/s3select/simdj/reader_amd64_test.go

    	"github.com/minio/simdjson-go"
    )
    
    type tester interface {
    	Fatal(args ...interface{})
    }
    
    func loadCompressed(t tester, file string) (js []byte) {
    	dec, err := zstd.NewReader(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer dec.Close()
    	js, err = os.ReadFile(filepath.Join("testdata", file+".json.zst"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	js, err = dec.DecodeAll(js, nil)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  2. cmd/config-encrypted_test.go

    	}{
    		{edata1, cred1, true},
    		{edata2, cred2, true},
    		{data, cred1, false},
    	}
    
    	for _, test := range tests {
    		t.Run("", func(t *testing.T) {
    			ddata, err := madmin.DecryptData(test.cred.String(), bytes.NewReader(test.edata))
    			if err != nil && test.success {
    				t.Errorf("Expected success, saw failure %v", err)
    			}
    			if err == nil && !test.success {
    				t.Error("Expected failure, saw success")
    			}
    			if test.success {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  3. cmd/benchmark-utils_test.go

    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		// insert the object.
    		objInfo, err := obj.PutObject(context.Background(), bucket, "object"+strconv.Itoa(i),
    			mustGetPutObjReader(b, bytes.NewReader(textData), int64(len(textData)), md5hex, sha256hex), ObjectOptions{})
    		if err != nil {
    			b.Fatal(err)
    		}
    		if objInfo.ETag != md5hex {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Dec 23 15:46:00 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  4. cmd/storage-datatypes_test.go

    func BenchmarkDecodeVolInfoMsgp(b *testing.B) {
    	v := VolInfo{
    		Name:    "uuid",
    		Created: time.Now(),
    	}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.Log("Size:", buf.Len(), "bytes")
    	b.SetBytes(1)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 9.4K bytes
    - Viewed (0)
  5. docs/debugging/inspect/export.go

    		case 0:
    			_, e = msgp.CopyToJSON(buf, bytes.NewReader(b))
    			if e != nil {
    				return nil, e
    			}
    		case 1, 2:
    			v, b, e := msgp.ReadBytesZC(b)
    			if e != nil {
    				return nil, e
    			}
    			if _, nbuf, e := msgp.ReadUint32Bytes(b); e == nil {
    				// Read metadata CRC (added in v2, ignore if not found)
    				b = nbuf
    			}
    
    			_, e = msgp.CopyToJSON(buf, bytes.NewReader(v))
    			if e != nil {
    				return nil, e
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 08 15:58:02 UTC 2022
    - 9.1K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/CharSinkTest.java

          assertThrows(IOException.class, () -> failSource.copyTo(okSink));
          // ensure writer was closed IF it was opened (depends on implementation whether or not it's
          // opened at all if source.newReader() throws).
          assertTrue(
              "stream not closed when copying from source with option: " + option,
              !okSink.wasStreamOpened() || okSink.wasStreamClosed());
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  7. src/archive/zip/zip_test.go

    			t.Fatalf("creating file %d: %v", i, err)
    		}
    	}
    	if err := w.Close(); err != nil {
    		t.Fatalf("Writer.Close: %v", err)
    	}
    	s := buf.String()
    	zr, err := NewReader(strings.NewReader(s), int64(len(s)))
    	if err != nil {
    		t.Fatalf("NewReader: %v", err)
    	}
    	if got := len(zr.File); got != nFiles {
    		t.Fatalf("File contains %d files, want %d", got, nFiles)
    	}
    	for i := 0; i < nFiles; i++ {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  8. samples/guide/src/main/java/okhttp3/recipes/CurrentDateHeader.java

        @Override public Response intercept(Chain chain) throws IOException {
          Request request = chain.request();
          Headers newHeaders = request.headers()
              .newBuilder()
              .add("Date", new Date())
              .build();
          Request newRequest = request.newBuilder()
              .headers(newHeaders)
              .build();
          return chain.proceed(newRequest);
        }
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Oct 31 15:32:50 UTC 2018
    - 1.8K bytes
    - Viewed (0)
  9. cmd/object-api-utils_test.go

    	rec := httptest.NewRecorder()
    	// construct HTTP request for Get Object end point.
    	req, err := newTestSignedRequestV4(http.MethodPut, getPutObjectURL("", bucketName, objectName),
    		int64(5), bytes.NewReader([]byte("hello")), credentials.AccessKey, credentials.SecretKey, map[string]string{})
    	if err != nil {
    		t.Fatalf("failed to create HTTP request for Put Object: <ERROR> %v", err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  10. cmd/data-scanner_test.go

                           </LifecycleConfiguration>`
    	deleteAllLc, err := lifecycle.ParseLifecycleConfig(strings.NewReader(deleteAllILM))
    	if err != nil {
    		t.Fatalf("Failed to parse deleteAllILM test ILM policy %v", err)
    	}
    	delMarkerLc, err := lifecycle.ParseLifecycleConfig(strings.NewReader(delMarkerILM))
    	if err != nil {
    		t.Fatalf("Failed to parse delMarkerILM test ILM policy %v", err)
    	}
    	tests := []struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 03 11:18:58 UTC 2024
    - 6.9K bytes
    - Viewed (0)
Back to top