Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 167 for newLoader (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/erasure-object.go

    			return &GetObjectReader{
    				ObjInfo: objInfo,
    			}, err
    		}
    
    		// Zero byte objects don't even need to further initialize pipes etc.
    		return NewGetObjectReaderFromReader(bytes.NewReader(nil), objInfo, opts)
    	}
    
    	if objInfo.IsRemote() {
    		gr, err := getTransitionedObjectReader(ctx, bucket, object, rs, h, objInfo, opts)
    		if err != nil {
    			return nil, err
    		}
    		unlockOnDefer = false
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  2. cmd/site-replication.go

    		// do some validation.
    		newReplCfgBytes, err := xml.Marshal(replicationConfig)
    		if err != nil {
    			return err
    		}
    		newReplicationConfig, err := sreplication.ParseConfig(bytes.NewReader(newReplCfgBytes))
    		if err != nil {
    			return err
    		}
    		sameTarget, apiErr := validateReplicationDestination(ctx, bucket, newReplicationConfig, &validateReplicationDestinationOptions{CheckRemoteBucket: true})
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  3. cmd/sts-handlers.go

    	if len(form) == 0 {
    		return nil
    	}
    
    	sessionPolicyStr := form.Get(stsPolicy)
    	if len(sessionPolicyStr) == 0 {
    		return nil
    	}
    
    	sessionPolicy, err := policy.ParseConfig(bytes.NewReader([]byte(sessionPolicyStr)))
    	if err != nil {
    		return err
    	}
    
    	// Version in policy must not be empty
    	if sessionPolicy.Version == "" {
    		return errors.New("Version cannot be empty expecting '2012-10-17'")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.6K bytes
    - Click Count (0)
  4. doc/godebug.md

    ### Go 1.20
    
    Go 1.20 introduced support for rejecting insecure paths in tar and zip archives,
    controlled by the [`tarinsecurepath` setting](/pkg/archive/tar/#Reader.Next)
    and the [`zipinsecurepath` setting](/pkg/archive/zip/#NewReader).
    These default to `tarinsecurepath=1` and `zipinsecurepath=1`,
    preserving the behavior of earlier versions of Go.
    A future version of Go may change the defaults to
    `tarinsecurepath=0` and `zipinsecurepath=0`.
    
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Dec 03 00:18:09 GMT 2025
    - 24.7K bytes
    - Click Count (0)
  5. src/cmd/api/main_test.go

    			log.Fatalf("loading imports: %v\n%s", err, out)
    		}
    
    		var stdPackages []string
    		importMap := make(map[string]map[string]string)
    		importDir := make(map[string]string)
    		dec := json.NewDecoder(bytes.NewReader(out))
    		for {
    			var pkg struct {
    				ImportPath, Dir string
    				ImportMap       map[string]string
    				Standard        bool
    			}
    			err := dec.Decode(&pkg)
    			if err == io.EOF {
    				break
    			}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu Feb 20 03:25:33 GMT 2025
    - 31.4K bytes
    - Click Count (0)
  6. guava/src/com/google/common/io/Files.java

       * @param charset the charset used to decode the input stream; see {@link StandardCharsets} for
       *     helpful predefined constants
       * @return the buffered reader
       */
      public static BufferedReader newReader(File file, Charset charset) throws FileNotFoundException {
        checkNotNull(file);
        checkNotNull(charset);
        return new BufferedReader(new InputStreamReader(new FileInputStream(file), charset));
      }
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 25 20:24:13 GMT 2025
    - 32.8K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/io/Files.java

       * @param charset the charset used to decode the input stream; see {@link StandardCharsets} for
       *     helpful predefined constants
       * @return the buffered reader
       */
      public static BufferedReader newReader(File file, Charset charset) throws FileNotFoundException {
        checkNotNull(file);
        checkNotNull(charset);
        return new BufferedReader(new InputStreamReader(new FileInputStream(file), charset));
      }
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 25 20:24:13 GMT 2025
    - 32.8K bytes
    - Click Count (0)
  8. cmd/utils.go

    	formData := url.Values{}
    	formData.Set("login", username)
    	formData.Set("password", password)
    	req, err = http.NewRequestWithContext(ctx, http.MethodPost, lastReq.URL.String(), strings.NewReader(formData.Encode()))
    	if err != nil {
    		return "", fmt.Errorf("new request err (/login): %v", err)
    	}
    	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
    	_, err = dexClient.Do(req)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  9. cmd/storage-rest-server.go

    // waitForHTTPResponse will wait for responses where keepHTTPResponseAlive
    // has been used.
    // The returned reader contains the payload.
    func waitForHTTPResponse(respBody io.Reader) (io.Reader, error) {
    	reader := bufio.NewReader(respBody)
    	for {
    		b, err := reader.ReadByte()
    		if err != nil {
    			return nil, err
    		}
    		// Check if we have a response ready or a filler byte.
    		switch b {
    		case 0:
    			return reader, nil
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  10. cmd/notification.go

    	for idx, client := range sys.peerClients {
    		if client == nil {
    			continue
    		}
    		client := client
    		ng.Go(ctx, func() error {
    			return client.VerifyBinary(ctx, u, sha256Sum, releaseInfo, bytes.NewReader(bin))
    		}, idx, *client.host)
    	}
    	return ng.Wait()
    }
    
    // CommitBinary - asks remote peers to overwrite the old binary with the new one
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
Back to Top