Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 258 for qint32 (0.08 sec)

  1. cmd/object-multipart-handlers.go

    		}
    		copy(objectEncryptionKey[:], key)
    
    		var nonce [12]byte
    		tmp := sha256.Sum256([]byte(fmt.Sprint(uploadID, partID)))
    		copy(nonce[:], tmp[:12])
    
    		partEncryptionKey := objectEncryptionKey.DerivePartKey(uint32(partID))
    		encReader, err := sio.EncryptReader(reader, sio.Config{
    			Key:          partEncryptionKey[:],
    			CipherSuites: fips.DARECiphers(),
    			Nonce:        &nonce,
    		})
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    type expiryStats struct {
    	missedExpiryTasks      atomic.Int64
    	missedFreeVersTasks    atomic.Int64
    	missedTierJournalTasks atomic.Int64
    	workers                atomic.Int32
    }
    
    // MissedTasks returns the number of ILM expiry tasks that were missed since
    // there were no available workers.
    func (e *expiryStats) MissedTasks() int64 {
    	return e.missedExpiryTasks.Load()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  3. cmd/object-api-interface.go

    	// Locking operations on object.
    	NewNSLock(bucket string, objects ...string) RWLocker
    
    	// Storage operations.
    	Shutdown(context.Context) error
    	NSScanner(ctx context.Context, updates chan<- DataUsageInfo, wantCycle uint32, scanMode madmin.HealScanMode) error
    	BackendInfo() madmin.BackendInfo
    	Legacy() bool // Only returns true for deployments which use CRCMOD as its object distribution algorithm.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  4. cmd/storage-rest-server.go

    				} else {
    					write([]byte{0})
    				}
    				xioutil.SafeClose(doneCh)
    				return
    			case block := <-blockCh:
    				var tmp [5]byte
    				tmp[0] = 2
    				binary.LittleEndian.PutUint32(tmp[1:], uint32(len(block)))
    				write(tmp[:])
    				write(block)
    				if canWrite {
    					w.(http.Flusher).Flush()
    				}
    			}
    		}
    	}()
    	return &h
    }
    
    var poolBuf8k = sync.Pool{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  5. cmd/update.go

    			Code:       AdminUpdateUnexpectedFailure,
    			Message:    err.Error(),
    			StatusCode: http.StatusInternalServerError,
    		}
    	}
    	return resp.Body, nil
    }
    
    var updateInProgress atomic.Uint32
    
    // Function to get the reader from an architecture
    func downloadBinary(u *url.URL, mode string) (binCompressed []byte, bin []byte, err error) {
    	transport := getUpdateTransport(30 * time.Second)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    	formatLegacy    bool
    	formatLastCheck time.Time
    
    	diskInfoCache *cachevalue.Cache[DiskInfo]
    	sync.RWMutex
    	formatData []byte
    
    	nrRequests   uint64
    	major, minor uint32
    	fsType       string
    
    	immediatePurge       chan string
    	immediatePurgeCancel context.CancelFunc
    
    	// mutex to prevent concurrent read operations overloading walks.
    	rotational bool
    	walkMu     *sync.Mutex
    	walkReadMu *sync.Mutex
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  7. cmd/test-utils_test.go

    // chance the file doesn't exist yet.
    var (
    	randN  uint32
    	randmu sync.Mutex
    )
    
    // Temp files created in default Tmp dir
    var globalTestTmpDir = os.TempDir()
    
    // reseed - returns a new seed every time the function is called.
    func reseed() uint32 {
    	return uint32(time.Now().UnixNano() + int64(os.Getpid()))
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  8. internal/grid/handlers.go

    	peerPrefix      = "peer"
    	peerPrefixS3    = "peerS3"
    	healPrefix      = "heal"
    )
    
    func init() {
    	// Static check if we exceed 255 handler ids.
    	// Extend the type to uint16 when hit.
    	if uint32(handlerLast) > 255 {
    		panic(fmt.Sprintf("out of handler IDs. %d > %d", handlerLast, 255))
    	}
    }
    
    func (h HandlerID) valid() bool {
    	return h != handlerInvalid && h < handlerLast
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  9. cmd/peer-rest-client.go

    	sent := time.Now()
    	resp, err := getSysConfigRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	info = resp.ValueOrZero()
    	if ti, ok := info.Config["time-info"].(madmin.TimeInfo); ok {
    		rt := int32(time.Since(sent).Milliseconds())
    		ti.RoundtripDuration = rt
    		info.Config["time-info"] = ti
    	}
    	return info, err
    }
    
    // GetSysErrors - fetch sys errors for a remote node.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  10. common-protos/k8s.io/api/storage/v1beta1/generated.proto

      // The same rule applies for a unique volume that is shared among multiple pods on the same node.
      // If this field is nil, then the supported number of volumes on this node is unbounded.
      // +optional
      optional int32 count = 1;
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 24.9K bytes
    - Viewed (0)
Back to top