Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for sarete (6.95 sec)

  1. internal/crypto/key.go

    // system (crypto/rand) is used.
    func GenerateKey(extKey []byte, random io.Reader) (key ObjectKey) {
    	if random == nil {
    		random = rand.Reader
    	}
    	if len(extKey) != 32 { // safety check
    		logger.CriticalIf(context.Background(), errors.New("crypto: invalid key length"))
    	}
    	var nonce [32]byte
    	if _, err := io.ReadFull(random, nonce[:]); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 20:28:10 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/ztunnelserver.go

    			resp, err := conn.sendDataAndWaitForAck(update.Update, update.Fd)
    			if err != nil {
    				log.Errorf("ztunnel acked error: err %v ackErr %s", err, resp.GetAck().GetError())
    			}
    			log.Debugf("ztunnel acked")
    			// Safety: Resp is buffered, so this will not block
    			update.Resp <- updateResponse{
    				err:  err,
    				resp: resp,
    			}
    
    		case <-time.After(ztunnelKeepAliveCheckInterval):
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    		if opts.Expiration.Expire {
    			// Expire all versions expiration must still verify the state() on disk
    			// via a getObjectInfo() call as follows, any read quorum issues we
    			// must not proceed further for safety reasons. attempt a MRF heal
    			// while we see such quorum errors.
    			goi, _, gerr := er.getObjectInfoAndQuorum(ctx, bucket, object, opts)
    			if gerr != nil && goi.Name == "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  4. cmd/dynamic-timeouts.go

    		timeout := atomic.LoadInt64(&dt.timeout) * 125 / 100
    
    		// Set upper cap.
    		if timeout > int64(maxDynamicTimeout) {
    			timeout = int64(maxDynamicTimeout)
    		}
    		// Safety, shouldn't happen
    		if timeout < dt.minimum {
    			timeout = dt.minimum
    		}
    		atomic.StoreInt64(&dt.timeout, timeout)
    	} else if failPct < dynamicTimeoutDecreaseThresholdPct {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Aug 19 23:21:05 GMT 2022
    - 4.5K bytes
    - Viewed (0)
  5. cni/pkg/repair/repaircontroller.go

    	m.With(resultLabel.Value(resultSuccess)).Increment()
    	return nil
    }
    
    func (c *Controller) labelBrokenPod(pod *corev1.Pod) error {
    	// Added for safety, to make sure no healthy pods get labeled.
    	m := podsRepaired.With(typeLabel.Value(labelType))
    	repairLog.Infof("Pod detected as broken, adding label: %s/%s", pod.Namespace, pod.Name)
    
    	labels := pod.GetLabels()
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  6. cmd/object-api-utils_test.go

    		// passing invalid bucket names.
    		{"------", false},
    		{"my..bucket", false},
    		{"192.168.1.1", false},
    		{"$this-is-not-valid-too", false},
    		{"contains-$-dollar", false},
    		{"contains-^-caret", false},
    		{"contains-$-dollar", false},
    		{"contains-$-dollar", false},
    		{"......", false},
    		{"", false},
    		{"a", false},
    		{"ab", false},
    		{".starts-with-a-dot", false},
    		{"ends-with-a-dot.", false},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 23.4K bytes
    - Viewed (0)
Back to top