Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for pr (0.16 sec)

  1. cmd/sftp-server-driver.go

    		return nil, err
    	}
    	if !ok {
    		return nil, os.ErrNotExist
    	}
    
    	pr, pw := io.Pipe()
    
    	wa := &writerAt{
    		buffer: make(map[int64][]byte),
    		w:      pw,
    		r:      pr,
    		wg:     &sync.WaitGroup{},
    	}
    	wa.wg.Add(1)
    	go func() {
    		_, err := clnt.PutObject(r.Context(), bucket, object, pr, -1, minio.PutObjectOptions{
    			ContentType:          mimedb.TypeByExtension(path.Ext(object)),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    		return err
    	}
    	defer xhttp.DrainBody(respBody)
    
    	pr, pw := io.Pipe()
    	go func() {
    		pw.CloseWithError(waitForHTTPStream(respBody, pw))
    	}()
    	mr := msgp.NewReader(pr)
    	defer readMsgpReaderPoolPut(mr)
    	for {
    		var file ReadMultipleResp
    		if err := file.DecodeMsg(mr); err != nil {
    			if errors.Is(err, io.EOF) {
    				err = nil
    			}
    			pr.CloseWithError(err)
    			return toStorageErr(err)
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  3. CONTRIBUTING.md

    `git push --force origin test-branch`
    
    ### Fixing sanity check failures after public API changes
    
    If your PR includes any changes to the Gradle Public API, it will cause the binary compatibility check to fail.
    The binary compatibility check runs as a part of the broader sanity check.
    The latter runs on every PR and is a prerequisite for merging.
    
    Plain Text
    - Registered: Wed May 08 11:36:15 GMT 2024
    - Last Modified: Sat May 04 07:43:02 GMT 2024
    - 15.6K bytes
    - Viewed (0)
  4. cmd/metacache-set.go

    						return entries, io.EOF
    					}
    				}
    			}
    
    			pr, pw := io.Pipe()
    			go func() {
    				werr := er.getObjectWithFileInfo(ctx, minioMetaBucket, o.objectPath(partN), 0,
    					fi.Size, pw, fi, metaArr, onlineDisks)
    				pw.CloseWithError(werr)
    			}()
    
    			tmp := newMetacacheReader(pr)
    			e, err := tmp.filter(o)
    			pr.CloseWithError(err)
    			tmp.Close()
    			entries.o = append(entries.o, e.o...)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  5. Makefile.core.mk

    # If pre-commit script is not used, please run this manually.
    precommit: format lint
    
    format: fmt ## Auto formats all code. This should be run before sending a PR.
    
    fmt: format-go format-python tidy-go
    
    ifeq ($(DEBUG),1)
    # gobuild script uses custom linker flag to set the variables.
    RELEASE_LDFLAGS=''
    else
    RELEASE_LDFLAGS='-extldflags -static -s -w'
    endif
    
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 20:25:15 GMT 2024
    - 22.5K bytes
    - Viewed (0)
  6. cmd/post-policy_test.go

    // Wrapper
    func TestPostPolicyReservedBucketExploit(t *testing.T) {
    	ExecObjectLayerTestWithDirs(t, testPostPolicyReservedBucketExploit)
    }
    
    // testPostPolicyReservedBucketExploit is a test for the exploit fixed in PR
    // #16849
    func testPostPolicyReservedBucketExploit(obj ObjectLayer, instanceType string, dirs []string, t TestErrHandler) {
    	if err := newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 29.6K bytes
    - Viewed (0)
Back to top