Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for io (0.18 sec)

  1. cmd/metrics-v2.go

    				})
    		}
    
    		if io.SyscR > 0 {
    			metrics = append(metrics,
    				MetricV2{
    					Description: getMinIOProcessSysCallRMD(),
    					Value:       float64(io.SyscR),
    				})
    		}
    
    		if io.SyscW > 0 {
    			metrics = append(metrics,
    				MetricV2{
    					Description: getMinIOProcessSysCallWMD(),
    					Value:       float64(io.SyscW),
    				})
    		}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 11 21:22:15 GMT 2024
    - 132.1K bytes
    - Viewed (0)
  2. cmd/server_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"context"
    	"encoding/xml"
    	"fmt"
    	"io"
    	"math/rand"
    	"net/http"
    	"net/url"
    	"reflect"
    	"regexp"
    	"runtime"
    	"strings"
    	"sync"
    	"testing"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/minio-go/v7/pkg/set"
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  3. cmd/object-handlers.go

    	}
    
    	// Set Parts Count Header
    	if opts.PartNumber > 0 && len(objInfo.Parts) > 0 {
    		setPartsCountHeaders(w, objInfo)
    	}
    
    	setHeadGetRespHeaders(w, r.Form)
    
    	var iw io.Writer
    	iw = w
    	if buf != nil {
    		iw = io.MultiWriter(w, buf)
    	}
    
    	statusCodeWritten := false
    	httpWriter := xioutil.WriteOnClose(iw)
    	if rs != nil || opts.PartNumber > 0 {
    		statusCodeWritten = true
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 05 11:39:31 GMT 2024
    - 124.7K bytes
    - Viewed (0)
  4. cmd/object-handlers_test.go

    		}
    
    		readers := []io.Reader{}
    		cumulativeSum := int64(0)
    		for _, p := range oi.partLengths {
    			readers = append(readers, NewDummyDataGen(p, cumulativeSum))
    			cumulativeSum += p
    		}
    		refReader := io.LimitReader(ioutilx.NewSkipReader(io.MultiReader(readers...), off), length)
    		if ok, msg := cmpReaders(refReader, rec.Body); !ok {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 160K bytes
    - Viewed (0)
  5. cmd/bucket-replication.go

    	var objectSize int64
    	for _, partInfo := range objInfo.Parts {
    		if crypto.SSEC.IsEncrypted(objInfo.UserDefined) {
    			hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.Size), partInfo.Size, "", "", partInfo.ActualSize)
    		} else {
    			hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.ActualSize), partInfo.ActualSize, "", "", partInfo.ActualSize)
    		}
    		if err != nil {
    			return err
    		}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 112K bytes
    - Viewed (1)
Back to top