Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 100 for recycler (0.29 sec)

  1. pkg/api/persistentvolume/util_test.go

    				Spec: api.PersistentVolumeSpec{
    					PersistentVolumeReclaimPolicy: api.PersistentVolumeReclaimRecycle,
    				},
    			},
    			expected: []string{
    				`spec.persistentVolumeReclaimPolicy: The Recycle reclaim policy is deprecated. Instead, the recommended approach is to use dynamic provisioning.`,
    			},
    		},
    		{
    			name: "PV CephFS deprecation warning",
    			template: &api.PersistentVolume{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. cmd/bitrot-streaming.go

    	// Hence an immediate Read() on the file can return incorrect data.
    	if b.canClose != nil {
    		b.canClose.Wait()
    	}
    
    	// Recycle the buffer.
    	if b.byteBuf != nil {
    		globalBytePoolCap.Load().Put(b.byteBuf)
    		b.byteBuf = nil
    	}
    	return err
    }
    
    // newStreamingBitrotWriterBuffer returns streaming bitrot writer implementation.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  3. cmd/peer-s3-client.go

    	}
    	buckets := make([]BucketInfo, 0, len(bi.Value()))
    	for _, b := range bi.Value() {
    		if b != nil {
    			buckets = append(buckets, *b)
    		}
    	}
    	bi.Recycle() // BucketInfo has no internal pointers, so it's safe to recycle.
    	return buckets, nil
    }
    
    func (client *remotePeerS3Client) HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error) {
    	conn := client.gridConn()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  4. cmd/storage-datatypes.go

    	buf := grid.GetByteBufferCap(32 + 16<<10)
    	return &RenameDataInlineHandlerParams{RenameDataHandlerParams{FI: FileInfo{Data: buf[:0]}}}
    }
    
    // Recycle will reuse the memory allocated for the FileInfo data.
    func (r *RenameDataInlineHandlerParams) Recycle() {
    	if r == nil {
    		return
    	}
    	if cap(r.FI.Data) >= xioutil.SmallBlock {
    		grid.PutByteBuffer(r.FI.Data)
    		r.FI.Data = nil
    	}
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  5. pkg/kubelet/prober/scale_test.go

    // causing conntrack entries and ephemeral ports to be hold for 60 seconds
    // despite the probe may have finished in less than 1 second.
    // If the rate of probes is higher than the rate the OS recycles the ports used,
    // it can consume a considerable number of ephemeral ports or conntrack entries.
    // These tests verify that after certain period the probes keep working, if the probes
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 16 16:33:01 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  6. pkg/controller/namespace/namespace_controller.go

    	namespaceController.listerSynced = namespaceInformer.Informer().HasSynced
    
    	return namespaceController
    }
    
    // nsControllerRateLimiter is tuned for a faster than normal recycle time with default backoff speed and default overall
    // requeing speed.  We do this so that namespace cleanup is reliably faster and we know that the number of namespaces being
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  7. src/math/big/rat.go

    	}
    
    	// 2. Compute quotient and remainder (q, r).  NB: due to the
    	// extra shift, the low-order bit of q is logically the
    	// high-order bit of r.
    	var q nat
    	q, r := q.div(a2, a2, b2) // (recycle a2)
    	mantissa := low32(q)
    	haveRem := len(r) > 0 // mantissa&1 && !haveRem => remainder is exactly half
    
    	// 3. If quotient didn't fit in Msize2 bits, redo division by b2<<1
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 11:59:09 UTC 2023
    - 13.5K bytes
    - Viewed (0)
  8. cmd/peer-rest-client.go

    	if err != nil {
    		return
    	}
    	st.Results(func(b []byte) error {
    		select {
    		case traceCh <- b:
    		default:
    			// Do not block on slow receivers.
    			// Just recycle the buffer.
    			grid.PutByteBuffer(b)
    		}
    		return nil
    	})
    }
    
    func (client *peerRESTClient) doListen(ctx context.Context, listenCh chan<- []byte, v url.Values) {
    	conn := client.gridConn()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  9. pkg/controller/endpointslicemirroring/reconciler.go

    }
    
    // finalize creates, updates, and deletes slices as specified
    func (r *reconciler) finalize(endpoints *corev1.Endpoints, slices slicesByAction) error {
    	// If there are slices to create and delete, recycle the slices marked for
    	// deletion by replacing creates with updates of slices that would otherwise
    	// be deleted.
    	recycleSlices(&slices)
    
    	epsClient := r.client.DiscoveryV1().EndpointSlices(endpoints.Namespace)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  10. pkg/controller/volume/persistentvolume/pv_controller_base.go

    // The in-tree PV deletion protection finalizer is removed if the reclaimPolicy associated with the PV is `Retain` or
    // `Recycle`, removing the finalizer is necessary to reflect the recalimPolicy updates on the PV.
    // The method also removes any external PV Deletion Protection finalizers added on the PV, this represents CSI migration
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 29.5K bytes
    - Viewed (0)
Back to top