Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 151 for NewReader (0.23 sec)

  1. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  2. cmd/auth-handler_test.go

    		// Short Content-Md5 header.
    		{mustNewSignedShortMD5Request(http.MethodPut, "http://127.0.0.1:9000/", 5, bytes.NewReader([]byte("hello")), t), ErrInvalidDigest},
    		// When request is properly signed, but has bad Content-MD5 header.
    		{mustNewSignedBadMD5Request(http.MethodPut, "http://127.0.0.1:9000/", 5, bytes.NewReader([]byte("hello")), t), ErrBadDigest},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  3. cmd/tier.go

    	b, err := config.Bytes()
    	if err != nil {
    		return nil, nil, err
    	}
    
    	payloadSize := int64(len(b))
    	br := bytes.NewReader(b)
    	hr, err := hash.NewReader(ctx, br, payloadSize, "", "", payloadSize)
    	if err != nil {
    		return nil, nil, err
    	}
    	if GlobalKMS == nil {
    		return NewPutObjReader(hr), &ObjectOptions{MaxParity: true}, nil
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  4. src/cmd/asm/internal/lex/lex_test.go

    			"A",
    			"B(THIS)",
    		),
    		"x.\n",
    	},
    	*/
    }
    
    func TestLex(t *testing.T) {
    	for _, test := range lexTests {
    		input := NewInput(test.name)
    		input.Push(NewTokenizer(test.name, strings.NewReader(test.input), nil))
    		result := drain(input)
    		if result != test.output {
    			t.Errorf("%s: got %q expected %q", test.name, result, test.output)
    		}
    	}
    }
    
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Aug 29 07:48:38 GMT 2023
    - 5.8K bytes
    - Viewed (0)
  5. cmd/test-utils_test.go

    	}
    	newReq := req
    	newReq.Body = io.NopCloser(
    		bytes.NewReader(bytes.Join([][]byte{newChunkHdr, newChunk[:len(newChunk)/2]},
    			[]byte(""))),
    	)
    	return newReq, nil
    }
    
    // Malform data given a request signed using streaming signature V4.
    func malformDataSigV4(req *http.Request, newByte byte) (*http.Request, error) {
    	bufReader := bufio.NewReader(req.Body)
    	hexChunkSize, chunkSignature, err := readChunkLine(bufReader)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  6. internal/mountinfo/mountinfo_linux_test.go

    		/dev/1    /path/to/1   type1	flags 1 1
    		/dev/2 /path/to/2 type2 flags,1,2=3 2 2
    		`
    	// Success case, verifies if parsing works properly.
    	{
    		mounts, err := parseMountFrom(strings.NewReader(successCase))
    		if err != nil {
    			t.Errorf("expected success")
    		}
    		if len(mounts) != 3 {
    			t.Fatalf("expected 3 mounts, got %d", len(mounts))
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.3K bytes
    - Viewed (0)
  7. cmd/object-api-putobject_test.go

    			inputDataSize: int64(len("abcd")),
    		},
    	}
    	for i, testCase := range testCases {
    		in := mustGetPutObjReader(t, bytes.NewReader(testCase.inputData), testCase.inputDataSize, testCase.inputMeta["etag"], testCase.inputSHA256)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  8. src/cmd/asm/internal/asm/line_test.go

    	})
    }
    
    func testBadInstParser(t *testing.T, goarch string, tests []badInstTest) {
    	for i, test := range tests {
    		arch, ctxt := setArch(goarch)
    		tokenizer := lex.NewTokenizer("", strings.NewReader(test.input+"\n"), nil)
    		parser := NewParser(ctxt, arch, tokenizer)
    
    		err := tryParse(t, func() {
    			parser.Parse()
    		})
    
    		switch {
    		case err == nil:
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Aug 29 07:48:38 GMT 2023
    - 1.9K bytes
    - Viewed (0)
  9. cmd/erasure-encode_test.go

    			}
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(int64(len(data[test.offset:]))), test.algorithm, erasure.ShardSize())
    		}
    		n, err := erasure.Encode(context.Background(), bytes.NewReader(data[test.offset:]), writers, buffer, erasure.dataBlocks+1)
    		closeBitrotWriters(writers)
    		if err != nil && !test.shouldFail {
    			t.Errorf("Test %d: should pass but failed with: %v", i, err)
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  10. src/archive/tar/writer_test.go

    	if !bytes.Contains(buf.Bytes(), []byte("PaxHeaders.0")) {
    		t.Fatal("Expected at least one PAX header to be written.")
    	}
    	// Test that we can get a long name back out of the archive.
    	reader := NewReader(&buf)
    	hdr, err = reader.Next()
    	if err != nil {
    		t.Fatal(err)
    	}
    	if hdr.Name != longName {
    		t.Fatal("Couldn't recover long file name")
    	}
    }
    
    func TestPaxSymlink(t *testing.T) {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Feb 27 16:39:23 GMT 2024
    - 38.7K bytes
    - Viewed (0)
Back to top