Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for newBuffer (0.05 seconds)

  1. cmd/admin-handlers-users_test.go

    	_, err := client.PutObject(ctx, bucket, "some-object", bytes.NewBuffer([]byte("stuff")), 5, minio.PutObjectOptions{})
    	if err != nil {
    		c.Fatalf("upload did not succeed got %#v", err)
    	}
    }
    
    func (c *check) mustNotUpload(ctx context.Context, client *minio.Client, bucket string) {
    	c.Helper()
    	_, err := client.PutObject(ctx, bucket, "some-object", bytes.NewBuffer([]byte("stuff")), 5, minio.PutObjectOptions{})
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 50.6K bytes
    - Click Count (0)
  2. 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.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (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())
    		}
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  4. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (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}`.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
Back to Top