Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for newHeader (0.19 sec)

  1. src/bufio/bufio_test.go

    		}
    	}
    	return string(b[0:nb])
    }
    
    func TestReaderSimple(t *testing.T) {
    	data := "hello world"
    	b := NewReader(strings.NewReader(data))
    	if s := readBytes(b); s != "hello world" {
    		t.Errorf("simple hello world test failed: got %q", s)
    	}
    
    	b = NewReader(newRot13Reader(strings.NewReader(data)))
    	if s := readBytes(b); s != "uryyb jbeyq" {
    		t.Errorf("rot13 hello world test failed: got %q", s)
    	}
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  2. cmd/storage-datatypes_gen_test.go

    	}
    
    	vn := BaseOptions{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeBaseOptions(b *testing.B) {
    	v := BaseOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 73.9K bytes
    - Viewed (0)
  3. src/archive/zip/reader_test.go

    	// zeroes
    	_, err := NewReader(bytes.NewReader(b), size)
    	if err != ErrFormat {
    		t.Errorf("zeroes: error=%v, want %v", err, ErrFormat)
    	}
    
    	// repeated directoryEndSignatures
    	sig := make([]byte, 4)
    	binary.LittleEndian.PutUint32(sig, directoryEndSignature)
    	for i := 0; i < size-4; i += 4 {
    		copy(b[i:i+4], sig)
    	}
    	_, err = NewReader(bytes.NewReader(b), size)
    	if err != ErrFormat {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 55.6K bytes
    - Viewed (0)
  4. internal/s3select/select_test.go

    			}
    			s3Select, err := NewS3Select(bytes.NewReader(testReq))
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			if err = s3Select.Open(newStringRSC(input)); err != nil {
    				t.Fatal(err)
    			}
    
    			w := &testResponseWriter{}
    			s3Select.Evaluate(w)
    			s3Select.Close()
    			resp := http.Response{
    				StatusCode:    http.StatusOK,
    				Body:          io.NopCloser(bytes.NewReader(w.response)),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 76.2K bytes
    - Viewed (0)
  5. cmd/erasure-healing_test.go

    		t.Fatal(err)
    	}
    
    	oi1, err := obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(data), length, "", ""), ObjectOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    	// 2nd version.
    	_, _ = rand.Read(data)
    	oi2, err := obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(data), length, "", ""), ObjectOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	disk := er.getDisks()[0]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  6. cmd/admin-handlers-users.go

    		return
    	}
    	data, err := io.ReadAll(r.Body)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL)
    		return
    	}
    	reader := bytes.NewReader(data)
    	zr, err := zip.NewReader(reader, int64(len(data)))
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL)
    		return
    	}
    
    	var skipped, removed, added madmin.IAMEntities
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 03 23:11:02 UTC 2024
    - 85.1K 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. internal/bucket/lifecycle/lifecycle_test.go

    		dec := xml.NewDecoder(strings.NewReader(tc.xml))
    		if err := dec.Decode(&got); err != nil || got != tc.expected {
    			if err != nil {
    				t.Fatalf("%d: Failed to unmarshal xml %v", i+1, err)
    			}
    			t.Fatalf("%d: Expected %v but got %v", i+1, tc.expected, got)
    		}
    	}
    }
    
    func TestParseLifecycleConfigWithID(t *testing.T) {
    	r := bytes.NewReader([]byte(`<LifecycleConfiguration>
    								  <Rule>
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  9. cmd/batch-handlers.go

    	if err != nil {
    		return err
    	}
    
    	ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
    	defer cancel()
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost, endpoint, bytes.NewReader(buf))
    	if err != nil {
    		return err
    	}
    
    	if token != "" {
    		req.Header.Set("Authorization", token)
    	}
    	req.Header.Set("Content-Type", "application/json")
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  10. cmd/bucket-handlers.go

    	}
    	if d != "multipart/form-data" {
    		return nil, http.ErrNotMultipart
    	}
    	boundary, ok := params["boundary"]
    	if !ok {
    		return nil, http.ErrMissingBoundary
    	}
    	return multipart.NewReader(r.Body, boundary), nil
    }
    
    // PostPolicyBucketHandler - POST policy
    // ----------
    // This implementation of the POST operation handles object creation with a specified
    // signature policy in multipart/form-data
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
Back to top