Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 162 for newLoader (0.07 sec)

  1. src/archive/zip/zip_test.go

    			t.Fatalf("creating file %d: %v", i, err)
    		}
    	}
    	if err := w.Close(); err != nil {
    		t.Fatalf("Writer.Close: %v", err)
    	}
    	s := buf.String()
    	zr, err := NewReader(strings.NewReader(s), int64(len(s)))
    	if err != nil {
    		t.Fatalf("NewReader: %v", err)
    	}
    	if got := len(zr.File); got != nFiles {
    		t.Fatalf("File contains %d files, want %d", got, nFiles)
    	}
    	for i := 0; i < nFiles; i++ {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  2. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  3. cmd/erasure-encode_test.go

    			}
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(int64(len(data[test.offset:]))), test.algorithm, erasure.ShardSize())
    		}
    		n, err := erasure.Encode(t.Context(), bytes.NewReader(data[test.offset:]), writers, buffer, erasure.dataBlocks+1)
    		closeBitrotWriters(writers)
    		if err != nil && !test.shouldFail {
    			t.Errorf("Test %d: should pass but failed with: %v", i, err)
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  4. cmd/admin-handlers-site-replication.go

    	case madmin.SRIAMItemPolicy:
    		if item.Policy == nil {
    			err = globalSiteReplicationSys.PeerAddPolicyHandler(ctx, item.Name, nil, item.UpdatedAt)
    		} else {
    			policy, perr := policy.ParseConfig(bytes.NewReader(item.Policy))
    			if perr != nil {
    				writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, perr), r.URL)
    				return
    			}
    			if policy.IsEmpty() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 19.3K bytes
    - Viewed (0)
  5. cmd/object-multipart-handlers.go

    		encodedSuccessResponse := encodeResponse(response)
    
    		// Write success response.
    		writeSuccessResponseXML(w, encodedSuccessResponse)
    		return
    	}
    
    	actualPartSize = length
    	var reader io.Reader = etag.NewReader(ctx, gr, nil, nil)
    
    	mi, err := objectAPI.GetMultipartInfo(ctx, dstBucket, dstObject, uploadID, dstOpts)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 90.6K bytes
    - Viewed (0)
  7. cmd/object-api-deleteobject_test.go

    		}
    
    		for _, object := range testCase.objectToUploads {
    			md5Bytes := md5.Sum([]byte(object.content))
    			oi, err := obj.PutObject(context.Background(), testCase.bucketName, object.name, mustGetPutObjReader(t, strings.NewReader(object.content),
    				int64(len(object.content)), hex.EncodeToString(md5Bytes[:]), ""), ObjectOptions{})
    			if err != nil {
    				t.Log(oi)
    				t.Fatalf("%s : %s", instanceType, err.Error())
    			}
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-rebalance.go

    		parts := make([]CompletePart, len(oi.Parts))
    		for i, part := range oi.Parts {
    			hr, err := hash.NewReader(ctx, io.LimitReader(gr, part.Size), part.Size, "", "", part.ActualSize)
    			if err != nil {
    				return fmt.Errorf("rebalanceObject: hash.NewReader() %w", err)
    			}
    			pi, err := z.PutObjectPart(ctx, bucket, oi.Name, res.UploadID,
    				part.Number,
    				NewPutObjReader(hr),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  9. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  10. src/cmd/asm/internal/asm/line_test.go

    	})
    }
    
    func testBadInstParser(t *testing.T, goarch string, tests []badInstTest) {
    	for i, test := range tests {
    		arch, ctxt := setArch(goarch)
    		tokenizer := lex.NewTokenizer("", strings.NewReader(test.input+"\n"), nil)
    		parser := NewParser(ctxt, arch, tokenizer)
    
    		err := tryParse(t, func() {
    			parser.Parse()
    		})
    
    		switch {
    		case err == nil:
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 1.9K bytes
    - Viewed (0)
Back to top