Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 208 for newHeader (0.11 sec)

  1. 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})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  2. 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'")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  3. cmd/iam-object-store.go

    }
    
    func decryptData(data []byte, objPath string) ([]byte, error) {
    	if utf8.Valid(data) {
    		return data, nil
    	}
    
    	pdata, err := madmin.DecryptData(globalActiveCred.String(), bytes.NewReader(data))
    	if err == nil {
    		return pdata, nil
    	}
    	if GlobalKMS != nil {
    		pdata, err = config.DecryptBytes(GlobalKMS, data, kms.Context{
    			minioMetaBucket: path.Join(minioMetaBucket, objPath),
    		})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  4. 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));
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jul 22 19:03:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  5. cmd/sts-handlers_test.go

    			iamFile := pathJoin(iamAssetsDir, f)
    
    			fileContent, ok := exportContent[f]
    			if !ok {
    				t.Fatalf("missing content for %s", f)
    			}
    
    			if err := rawDataFn(bytes.NewReader(fileContent), iamFile, len(fileContent)); err != nil {
    				t.Fatalf("failed to write %s: %v", iamFile, err)
    			}
    		}
    		zipWriter.Close()
    		importContent = b.Bytes()
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 97.1K bytes
    - Viewed (0)
  6. 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (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));
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jul 22 19:03:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  8. cmd/server-main.go

    	}
    }
    
    func mergeServerCtxtFromConfigFile(configFile string, ctxt *serverCtxt) error {
    	rd, err := xioutil.ReadFile(configFile)
    	if err != nil {
    		return err
    	}
    
    	cfReader := bytes.NewReader(rd)
    
    	cv := config.ServerConfigVersion{}
    	if err = yaml.Unmarshal(rd, &cv); err != nil {
    		return err
    	}
    
    	switch cv.Version {
    	case "v1", "v2":
    	default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  9. 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
    			}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 31.4K bytes
    - Viewed (0)
  10. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
Back to top