Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 208 for newReader (0.13 sec)

  1. cmd/warm-backend.go

    // to perform all operations defined in the WarmBackend interface.
    func checkWarmBackend(ctx context.Context, w WarmBackend) error {
    	remoteVersionID, err := w.Put(ctx, probeObject, strings.NewReader("MinIO"), 5)
    	if err != nil {
    		if _, ok := err.(BackendDown); ok {
    			return err
    		}
    		return tierPermErr{
    			Op:  tierPut,
    			Err: err,
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. internal/dsync/dsync-client_test.go

    func (restClient *ReconnectRESTClient) Call(method string, args LockArgs) (status bool, err error) {
    	buf, err := args.MarshalMsg(nil)
    	if err != nil {
    		return false, err
    	}
    	body := bytes.NewReader(buf)
    	respBody, err := restClient.rest.Call(context.Background(), method,
    		url.Values{}, body, body.Size())
    	defer xhttp.DrainBody(respBody)
    
    	switch toLockError(err) {
    	case nil:
    		return true, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  3. 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},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  4. 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
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  5. internal/deadlineconn/deadlineconn_test.go

    		t.Fatalf("failed to write to server. %v", err)
    	}
    	_, err = io.WriteString(c, "message two\n")
    	if err != nil {
    		t.Fatalf("failed to write to server. %v", err)
    	}
    
    	received, err := bufio.NewReader(c).ReadString('\n')
    	if err != nil {
    		t.Fatalf("failed to read from server. %v", err)
    	}
    	if received != "messages received\n" {
    		t.Fatalf(`client: expected: "messages received\n", got: %v`, received)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Nov 05 18:09:21 UTC 2022
    - 3K bytes
    - Viewed (0)
  6. internal/bucket/versioning/versioning_test.go

    			excludeFolders:   true,
    		},
    	}
    
    	for i, tc := range testcases {
    		var v *Versioning
    		var err error
    		v, err = ParseConfig(strings.NewReader(tc.input))
    		if tc.err != err {
    			t.Fatalf("Test %d: expected %v but got %v", i+1, tc.err, err)
    		}
    		if err != nil {
    			if tc.err == nil {
    				t.Fatalf("Test %d: failed due to %v", i+1, err)
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 08 05:06:44 UTC 2022
    - 8.8K bytes
    - Viewed (0)
  7. 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/io/FilesTest.java

        File asciiFile = getTestFile("ascii.txt");
        assertThrows(NullPointerException.class, () -> Files.newReader(asciiFile, null));
    
        assertThrows(NullPointerException.class, () -> Files.newReader(null, UTF_8));
    
        BufferedReader r = Files.newReader(asciiFile, US_ASCII);
        try {
          assertEquals(ASCII, r.readLine());
        } finally {
          r.close();
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  9. internal/config/subnet/subnet.go

    	}
    	body, err := json.Marshal(payload)
    	if err != nil {
    		return "", err
    	}
    	r, err := http.NewRequest(http.MethodPost, reqURL, bytes.NewReader(body))
    	if err != nil {
    		return "", err
    	}
    
    	r.Header.Set("Content-Type", "application/json")
    
    	return c.submitPost(r)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 27 16:35:36 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  10. internal/config/identity/openid/provider/keycloak.go

    	values.Set("client_id", clientID)
    	values.Set("client_secret", clientSecret)
    	values.Set("grant_type", "client_credentials")
    
    	req, err := http.NewRequest(http.MethodPost, k.oeConfig.TokenEndpoint, strings.NewReader(values.Encode()))
    	if err != nil {
    		return err
    	}
    	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
    
    	resp, err := k.client.Do(req)
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jul 14 18:12:07 UTC 2024
    - 4.6K bytes
    - Viewed (0)
Back to top