Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 162 for newLoader (0.05 sec)

  1. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  2. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  3. cmd/encryption-v1.go

    		if len(data) == 0 {
    			return data
    		}
    		var buffer bytes.Buffer
    		mac := hmac.New(sha256.New, key[:])
    		mac.Write([]byte(baseKey))
    		if _, err := sio.Encrypt(&buffer, bytes.NewReader(data), sio.Config{Key: mac.Sum(nil)}); err != nil {
    			logger.CriticalIf(context.Background(), errors.New("unable to encrypt using object key"))
    		}
    		return buffer.Bytes()
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  4. cmd/admin-handlers-users_test.go

    	}
    
    	req.ContentLength = int64(len(buf))
    	sum := sha256.Sum256(buf)
    	req.Header.Set("X-Amz-Content-Sha256", hex.EncodeToString(sum[:]))
    	req.Body = io.NopCloser(bytes.NewReader(buf))
    	req = signer.SignV4(*req, accessKey, secretKey, "", "")
    
    	// 3.1 Execute the request.
    	resp, err := s.TestSuiteCommon.client.Do(req)
    	if err != nil {
    		c.Fatalf("unexpected request err: %v", err)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 47.4K bytes
    - Viewed (0)
  5. 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
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  6. cmd/peer-rest-server.go

    		return
    	}
    
    	if lrTime.Sub(currentReleaseTime) <= 0 {
    		s.writeErrorResponse(w, fmt.Errorf("server is running the latest version: %s", Version))
    		return
    	}
    
    	zr, err := zstd.NewReader(r.Body)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    	defer zr.Close()
    
    	if err = verifyBinary(u, sha256Sum, releaseInfo, getMinioMode(), zr); err != nil {
    		s.writeErrorResponse(w, err)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  7. api/go1.5.txt

    pkg mime, type WordDecoder struct
    pkg mime, type WordDecoder struct, CharsetReader func(string, io.Reader) (io.Reader, error)
    pkg mime, type WordEncoder uint8
    pkg mime/quotedprintable, func NewReader(io.Reader) *Reader
    pkg mime/quotedprintable, func NewWriter(io.Writer) *Writer
    pkg mime/quotedprintable, method (*Reader) Read([]uint8) (int, error)
    pkg mime/quotedprintable, method (*Writer) Close() error
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu Jul 30 21:14:09 UTC 2015
    - 46.6K bytes
    - Viewed (0)
  8. cmd/xl-storage_test.go

    	algo = HighwayHash256S
    	shardSize := int64(1024 * 1024)
    	shard := make([]byte, shardSize)
    	w := newStreamingBitrotWriter(storage, "", volName, fileName, size, algo, shardSize)
    	reader := bytes.NewReader(data)
    	for {
    		// Using io.Copy instead of this loop will not work for us as io.Copy
    		// will use bytes.Reader.WriteTo() which will not do shardSize'ed writes
    		// causing error.
    		n, err := reader.Read(shard)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 66K bytes
    - Viewed (0)
  9. cmd/object-api-listobjects_test.go

    	<Rule>
    		<Status>Enabled</Status>
    		<Expiration>
    			<Days>1</Days>
    		</Expiration>
    	</Rule>
    </LifecycleConfiguration>
    `)
    
    	lifecycleConfig, err := lifecycle.ParseLifecycleConfig(bytes.NewReader(lifecycleBytes))
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	for i, upload := range uploads {
    		err := obj.MakeBucket(context.Background(), upload.bucket, MakeBucketOptions{})
    		if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 76.1K bytes
    - Viewed (0)
  10. cmd/xl-storage.go

    		// fdatasync() at the end instead of opening the file with O_DSYNC.
    		//
    		// This is an optimization mainly to ensure faster I/O.
    		if len(b) > xioutil.DirectioAlignSize {
    			r := bytes.NewReader(b)
    			return s.writeAllDirect(ctx, filePath, r.Size(), r, flags, skipParent, true)
    		}
    		w, err = s.openFileSync(filePath, flags, skipParent)
    	} else {
    		w, err = s.openFile(filePath, flags, skipParent)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
Back to top