Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 213 for Int64 (1.12 sec)

  1. src/archive/zip/zip_test.go

    type suffixSaver struct {
    	keep  int
    	buf   []byte
    	start int
    	size  int64
    }
    
    func (ss *suffixSaver) Size() int64 { return ss.size }
    
    var errDiscardedBytes = errors.New("ReadAt of discarded bytes")
    
    func (ss *suffixSaver) ReadAt(p []byte, off int64) (n int, err error) {
    	back := ss.size - off
    	if back > int64(ss.keep) {
    		return 0, errDiscardedBytes
    	}
    	suf := ss.Suffix()
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Mar 27 18:23:49 GMT 2024
    - 19.5K bytes
    - Viewed (0)
  2. internal/grid/connection.go

    }
    
    // writeFrame writes frame binary representation into w.
    func (ww *wsWriter) writeFrame(w io.Writer, f ws.Frame) error {
    	const (
    		bit0  = 0x80
    		len7  = int64(125)
    		len16 = int64(^(uint16(0)))
    		len64 = int64(^(uint64(0)) >> 1)
    	)
    
    	bts := ww.tmp[:]
    	if f.Header.Fin {
    		bts[0] |= bit0
    	}
    	bts[0] |= f.Header.Rsv << 4
    	bts[0] |= byte(f.Header.OpCode)
    
    	var n int
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  3. cmd/encryption-v1.go

    	var sizes []int64
    	var decObjSize int64 // decrypted total object size
    	if o.isMultipart() {
    		sizes = make([]int64, len(o.Parts))
    		for i, part := range o.Parts {
    			var partSize uint64
    			partSize, err = sio.DecryptedSize(uint64(part.Size))
    			if err != nil {
    				err = errObjectTampered
    				return
    			}
    			sizes[i] = int64(partSize)
    			decObjSize += int64(partSize)
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 36.5K bytes
    - Viewed (0)
  4. cmd/handler-utils_test.go

    	}
    
    	// Corrupted XML
    	malformedReq := &http.Request{
    		Body:          io.NopCloser(bytes.NewReader([]byte("<>"))),
    		ContentLength: int64(len("<>")),
    	}
    
    	// Not an XML
    	badRequest := &http.Request{
    		Body:          io.NopCloser(bytes.NewReader([]byte("garbage"))),
    		ContentLength: int64(len("garbage")),
    	}
    
    	// generates the input request with XML bucket configuration set to the request body.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  5. internal/config/cache/cache.go

    	// Etag and ModTime of an object + version
    	Endpoint string `json:"endpoint"`
    
    	// BlockSize indicates the maximum object size below which
    	// data is cached and fetched remotely from DRAM.
    	BlockSize int64
    
    	// Is the HTTP client used for communicating with mcache server
    	clnt *http.Client
    }
    
    var configLock sync.RWMutex
    
    // Enabled - indicates if cache is enabled or not
    func (c *Config) Enabled() bool {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  6. cmd/bitrot-whole.go

    	return &wholeBitrotWriter{disk, volume, filePath, shardSize, algo.New()}
    }
    
    // Implementation to verify bitrot for the whole file.
    type wholeBitrotReader struct {
    	disk       StorageAPI
    	volume     string
    	filePath   string
    	verifier   *BitrotVerifier // Holds the bit-rot info
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  7. cmd/object-api-multipart_test.go

    		{bucketNames[0], objectNames[0], uploadIDs[0], 4, "mnop", "e132e96a5ddad6da8b07bba6f6131fef", int64(len("abcd"))},
    		// Part with size larger than 5Mb.
    		{bucketNames[0], objectNames[0], uploadIDs[0], 5, string(validPart), validPartMD5, int64(len(validPart))},
    		{bucketNames[0], objectNames[0], uploadIDs[0], 6, string(validPart), validPartMD5, int64(len(validPart))},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 77.1K bytes
    - Viewed (0)
  8. migrator/migrator.go

    	DB                          *gorm.DB
    	gorm.Dialector
    }
    
    type printSQLLogger struct {
    	logger.Interface
    }
    
    func (l *printSQLLogger) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) {
    	sql, _ := fc()
    	fmt.Println(sql + ";")
    	l.Interface.Trace(ctx, begin, fc, err)
    }
    
    // GormDataTypeInterface gorm data type interface
    type GormDataTypeInterface interface {
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Fri Apr 26 07:15:49 GMT 2024
    - 29K bytes
    - Viewed (0)
  9. cmd/bucket-quota.go

    		}
    		return quotaCfg, fmt.Errorf("Invalid quota config %#v", quotaCfg)
    	}
    	return
    }
    
    func (sys *BucketQuotaSys) enforceQuotaHard(ctx context.Context, bucket string, size int64) error {
    	if size < 0 {
    		return nil
    	}
    
    	q, err := sys.Get(ctx, bucket)
    	if err != nil {
    		return err
    	}
    
    	var quotaSize uint64
    	if q != nil && q.Type == madmin.HardQuota {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.3K bytes
    - Viewed (0)
  10. cmd/erasure-object_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	// Upload a good object
    	_, err = obj.DeleteObject(ctx, bucket, object, ObjectOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Create "obj" under "bucket".
    	_, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader([]byte("abcd")), int64(len("abcd")), "", ""), opts)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
Back to top