- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 241 for uint32 (0.39 sec)
-
cmd/xl-storage-disk-id-check.go
totalWrites atomic.Uint64 totalDeletes atomic.Uint64 totalErrsAvailability atomic.Uint64 // Captures all data availability errors such as faulty disk, timeout errors. totalErrsTimeout atomic.Uint64 // Captures all timeout only errors // apiCalls should be placed first so alignment is guaranteed for atomic operations. apiCalls [storageMetricLast]uint64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
internal/s3select/message.go
headerLength := len(header) payloadLength := len(payload) totalLength := totalByteLength(headerLength, payloadLength) buf := new(bytes.Buffer) binary.Write(buf, binary.BigEndian, uint32(totalLength)) binary.Write(buf, binary.BigEndian, uint32(headerLength)) prelude := buf.Bytes() binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(prelude)) buf.Write(header) if payload != nil { buf.Write(payload) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
internal/grid/connection.go
// We may have reads that aren't locked, so update atomically. gotState := atomic.LoadUint32((*uint32)(&c.state)) if gotState == StateShutdown || State(gotState) == s { return } if s == StateConnected { atomic.StoreInt64(&c.LastPong, time.Now().UnixNano()) } atomic.StoreUint32((*uint32)(&c.state), uint32(s)) if debugPrint { fmt.Println(c.Local, "updateState:", gotState, "->", s) }
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) -
internal/s3select/genmessage.go
headerLength := len(header) payloadLength := 0 totalLength := totalByteLength(headerLength, payloadLength) buf = new(bytes.Buffer) binary.Write(buf, binary.BigEndian, uint32(totalLength)) binary.Write(buf, binary.BigEndian, uint32(headerLength)) prelude := buf.Bytes() binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(prelude)) buf.Write(header) message := buf.Bytes()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 4.4K bytes - Viewed (0) -
cmd/encryption-v1.go
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) } } else { var partSize uint64 partSize, err = sio.DecryptedSize(uint64(o.Size)) if err != nil { err = errObjectTampered return }
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) -
internal/bucket/bandwidth/monitor_gen.go
import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *BucketBandwidthReport) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 5.4K bytes - Viewed (0) -
internal/store/batch.go
var ErrBatchFull = errors.New("batch is full") type key interface { string | int | int64 } // Batch represents an ordered batch type Batch[K key, T any] struct { keys []K items map[K]T limit uint32 sync.Mutex } // Add adds the item to the batch func (b *Batch[K, T]) Add(key K, item T) error { b.Lock() defer b.Unlock() if b.isFull() { return ErrBatchFull }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 2.5K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops_gen.go
o = msgp.AppendArrayHeader(o, uint32(len(z.QueuedBuckets))) for za0001 := range z.QueuedBuckets { o = msgp.AppendString(o, z.QueuedBuckets[za0001]) } // string "HealedBuckets" o = append(o, 0xad, 0x48, 0x65, 0x61, 0x6c, 0x65, 0x64, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x73) o = msgp.AppendArrayHeader(o, uint32(len(z.HealedBuckets))) for za0002 := range z.HealedBuckets {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 17:05:40 GMT 2024 - 21.5K bytes - Viewed (0) -
internal/hash/checksum.go
// MinIOMultipartChecksum is as metadata on multipart uploads to indicate checksum type. const MinIOMultipartChecksum = "x-minio-multipart-checksum" // ChecksumType contains information about the checksum type. type ChecksumType uint32 const ( // ChecksumTrailing indicates the checksum will be sent in the trailing header. // Another checksum type will be set. ChecksumTrailing ChecksumType = 1 << iota
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.9K bytes - Viewed (0) -
cmd/storage-datatypes.go
// // The above means that any added/deleted fields are incompatible. // //msgp:tuple DiskInfo type DiskInfo struct { Total uint64 Free uint64 Used uint64 UsedInodes uint64 FreeInodes uint64 Major uint32 Minor uint32 NRRequests uint64 FSType string RootDisk bool Healing bool Scanning bool Endpoint string MountPath string ID string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0)