Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewBuffer (0.21 sec)

  1. cmd/test-utils_test.go

    	if err != nil {
    		t.Fatal(failTestStr(anonTestStr, err.Error()))
    	}
    
    	// creating 2 read closer (to set as request body) from the body content.
    	readerOne := io.NopCloser(bytes.NewBuffer(buf))
    	readerTwo := io.NopCloser(bytes.NewBuffer(buf))
    
    	anonReq.Body = readerOne
    
    	// call the HTTP handler.
    	apiRouter.ServeHTTP(rec, anonReq)
    
    	// expected error response when the unsigned HTTP request is not permitted.
    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)
  2. cmd/peer-rest-server.go

    	})
    	if err != nil {
    		return grid.NewRemoteErr(err)
    	}
    
    	// Process until remote disconnects.
    	// Blocks on upstream (out) congestion.
    	// We have however a dynamic downstream buffer (ch).
    	buf := bytes.NewBuffer(grid.GetByteBuffer())
    	enc := json.NewEncoder(buf)
    	tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}}
    	for {
    		select {
    		case <-ctx.Done():
    			grid.PutByteBuffer(buf.Bytes())
    			return nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    	for i, disk := range onlineDisks {
    		if disk == nil {
    			continue
    		}
    		if disk.IsOnline() {
    			buf := grid.GetByteBufferCap(int(erasure.ShardFileSize(data.Size())) + 64)
    			inlineBuffers[i] = bytes.NewBuffer(buf[:0])
    			defer grid.PutByteBuffer(buf)
    			writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize())
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  4. src/bufio/bufio_test.go

    	srcBuf := bytes.NewBuffer(make([]byte, 8192))
    	src := NewReader(onlyReader{srcBuf})
    	dstBuf := new(bytes.Buffer)
    	dst := onlyWriter{dstBuf}
    	for i := 0; i < b.N; i++ {
    		srcBuf.Reset()
    		src.Reset(onlyReader{srcBuf})
    		dstBuf.Reset()
    		io.Copy(dst, src)
    	}
    }
    
    func BenchmarkReaderCopyNoWriteTo(b *testing.B) {
    	srcBuf := bytes.NewBuffer(make([]byte, 8192))
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Feb 10 18:56:01 GMT 2023
    - 51.5K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    					var r io.ReadCloser
    					if !si.Dir {
    						r, err = disk.ReadFileStream(ctx, volume, si.Name, 0, si.Size)
    						if err != nil {
    							continue
    						}
    					} else {
    						r = io.NopCloser(bytes.NewBuffer([]byte{}))
    					}
    					// Keep disk path instead of ID, to ensure that the downloaded zip file can be
    					// easily automated with `minio server hostname{1...n}/disk{1...m}`.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  6. src/archive/zip/reader_test.go

    	if err != ErrFormat {
    		t.Fatalf("unexpected error, got: %v, want: %v", err, ErrFormat)
    	}
    
    	// Also check that an archive containing a handful of empty
    	// files doesn't cause an issue
    	b := bytes.NewBuffer(nil)
    	w := NewWriter(b)
    	for i := 0; i < 5; i++ {
    		_, err := w.Create("")
    		if err != nil {
    			t.Fatalf("Writer.Create failed: %s", err)
    		}
    	}
    	if err := w.Close(); err != nil {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Mar 27 18:23:49 GMT 2024
    - 55.3K bytes
    - Viewed (0)
Back to top